-交换器（Exchange），它是发送消息的实体。-队列（Queue），这是接收消息的实体。-绑定器（Bind），将交换器和队列连接起来，并且封装消息的路由信息。交换器也有一些性质：-持久性：如果启用，交换器将会在协商器重启前都有效。-自动删除：如果启用，那么交换器将会在其绑定的队列都被删除掉之后自... « 阅读全文

　　问题环境：1、iphone的safari浏览器，有个特点，在屏保或者最小化浏览器后，会自己暂停所有浏览器进程。2、通过js接入rabbitmq进行长轮询，原理是保持一个永不间断的http请求，因为上面的问题，导致在最小化浏览器时候这个http请求会被暂停，导致服务端超时，造成了长轮询被迫中断。解决方... « 阅读全文

　　1.Erlang 安装wget http://www.erlang.org/download/otp_src_R14B.tar.gz   tar -zxf otp_src_R14B01.tar.gz   cd otp_src_R14B01   ./configure   make    make install  注意在make install 时使用root权限   2. xmlto （rabbitmq 编译安装时需要使用）wget  https... « 阅读全文

　　http://www.rabbitmq.com/clustering.html#auto-config Clustering overview A RabbitMQ broker is a logical grouping of one or several Erlang nodes, each running the RabbitMQ application and sharing users, virtual hosts, queues, exchanges, etc. Sometimes ... « 阅读全文

　　安装Windows：安装erlang，直接运行rabbitmq即可。Linux：1.****jdk6.bin  [设置/etc/profile，尾部添加]  #jdk  export JAVA_HOME=/opt/SDK/jdk  export CLASSPATH=.:$JAVA_HOME/jre/lib/rt.jar:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar  export PATH=$PATH:$JAVA_HOME/bin... « 阅读全文

　　   童鞋们在看python写的rabbitmq扩展的时候应该注意到我们的Connection类的构造函数(Connection是连接rabbitmq的一个类)   def __init__(self,        host='localhost',        userid='guest',        password='guest',        login_method='AMQPLAIN',        login_response=None,        v... « 阅读全文

　　String queue =channel.queueDeclare("test.queue").getQueue();Rabbitmq Server 会有以下操作：定义了一个queue，名称为test.queue把queue的名称(test.queue)作为routingKey，将当前这个queuebinding到一个默认的exchange(名称为空，服务器自动创建的)上如果我们binding的话channel.queueBind("test.queue","t... « 阅读全文

　　客户端，获得接口代理对象，进行远程调用/** * 包装RpcClient，进行远程调用后，需要同步等待结果 */package com.sun.study.spring.rabbitmq;import java.io.ByteArrayInputStream;import java.io.ByteArrayOutputStream;import java.io.DataInputStream;import java.io.DataOutputStream;import java.io.EOFEx... « 阅读全文

　　rabbitmq java api 关于消息处理的一个重要的类是channelchannel 主要进行相关定义，发送消息，获取消息，事务处理等。channel可以在多线程中使用，但是在任何时候保证只有一个线程执行命令是很重要的，这在前面 已经说的很清楚了。public interface Channel extends ShutdownNotifier {// 重新得到channel numberint getChannelNumber();//得到当前channel的connectionCon... « 阅读全文

　　前面两步后，进行Spring的配置<?xml version="1.0" encoding="UTF-8"?><beans xmlns="http://www.springframework.org/schema/beans"    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"    xmlns... « 阅读全文