yimeng528
- 浏览: 188771 次
- 性别:
- 来自: 北京
-
最新评论
-
ZZX19880809：
没看到有[x] Received 'hello word!0' ...
rabbitmq学习3:Publish/Subscribe -
ZZX19880809：
根本就没有. 应该输入first message.
rabbitmq学习2:Work Queues -
jiaofuyou：
独孤日日也 写道我亲自试验了并没有实现啊，第一个worker输 ...
rabbitmq学习2:Work Queues -
独孤日日也：
我亲自试验了并没有实现啊，第一个worker输出： Wait ...
rabbitmq学习2:Work Queues -
jiaofuyou：
想问个问题，象这种任务分发的工作队列，你举的例子是一个队列被多 ...
rabbitmq学习2:Work Queues
文章列表
看了 http://my249645546.iteye.com/blog/1716629 上的这篇文章感觉挺好的，所以决定转过来，谢谢这位博主。
很多人觉得jquery、ext等一些开源js源代码 十分的晦涩，读不懂，遇到问题需要调试也很费劲。其实我个人感觉主要是有几个方面的原因：
1、对一些js不常用的语法、操作符不熟悉
2、某个function中又嵌套了一些内部的function，使得整个代码的层次结构不像java代码那么清晰。
3、js中允许变量先使用后定义，会造成我们看代码时候忽然冒出来一个变量、function，却找不到是在哪里定义的。
那么今天给大家分享一下 ...
前面我们已经学习了发送消息及同步接收消息的例子了。下面我们来看看如何通过Spring配置来实现异步接收消息。
现在我们建立两个WEB项目。发送消息的项目命名为”rabbitmq-demo-producer“ ，异步接受的消息项目名称”rabbitmq-demo-consumer“。
下面来看看rabbitmq-demo-producer项目中发送信息的程序及配置。
MessageProducer类是用于发送消息的类。实现如下
Java代码
package com.abin.rabbitmq;
通过对spring-amqp看重要类的认识，下面来通过spring-amqp的发送消息及同步接收消息是如何实现的。有兴趣的朋友 可以去spring-amqp官网下载例子。
先来看看HelloWorldConfiguration类
Java代码
package org.springframework.amqp.helloworld;
import org.springframework.amqp.core.Queue;
对于大多数应用来说都做了与spring整合，对于rabbitmq来说。也有与spring的整合。可能通过spring的官网找到spring-amqp项目下载。spring-amqp项目包括三个子项目：spring-amqp、spring-erlang、spring-rabbit.
下面来认识一下spring-amqp中的几个重要类；以spring-amqp-1.0.0.M3版本为例
1、Message : Spring AMQP定义的Message类是AMQP域模型中代表之一。Message类封装了body(消息BODY)和properties（消息属性） 。使得这个API ...
从前面几小节的学习，我们可能知道在发送和接收消息重要的类ConnectionFactory， Connection，Channel和QueueingConsumer。
ConntectionFactory类是方便创建与AMQP代理相关联的Connection；下面来看看ConntectionFactory是如何创建一个Contention.
首先通过new ConnectionFactory()创建一个ConnectionFactory；并设置此连接工厂的主机设置为localhost。通过ConnectionFactory的newConnection()方法 创建一个Connec ...
在《rabbitmq学习2:Work Queues 》中我们已经知道了在多个worker如何分配耗时的任务。如果我现在要在远程的机器上运行然后得到结果，那应当怎么做呢？那就要用到RPC（Remote Procedure Call or RPC ）了！
关于RPC的介绍请参考百度百科里的关于RPC的介绍：http://baike.baidu.com/view/32726.htm#sub32726
现在来看看来看看Rabbitmq中RPC吧！RPC的工作示意图如下：
上图中的C代表客户端，S表示服务器端；Rabbitmq中的RPC流程如下：
1、首先客户端发送一 ...
在前面的《rabbitmq学习4:Routing 》中使用一般的名字的路由，现在想通过一些路由规则让消费者来接受符合规则的消息？那应当怎么样呢？那就要用到类型为topic的Exchange了。
Topics的工作示意图如下：
我们可能从图中看到有*和#两个通配符。*表示通配一个词；#表示通配0个或多个词。
下面让我们来看看Topics的程序如何实现的吧!
P端的程序如下 ：
Java代码
package com.abin.rabbitmq;
在《rabbitmq学习3:Publish/Subscribe 》中已经学习了发送一个消息，所有消费者端都能收到。那现在这节准备介绍通过路由规则来接受生产者端所发送的消费。Routing的工作示意图如下：
对于Routing的示意图与Publish/Subscribe中的示意图区别：
第一：Publish/Subscribe的Exchange的类型为“fanout”,而Routing的类型为“direct”
第二：Publish/Subscribe的路由为默认的，而Routing的路由是自定义的。
可能从上图的示意图如可以发现可以把Routing的模式也可以转化Publi ...
在前面的Work Queue中的消息是均匀分配消息给消费者；如果我想把消息分发给所有的消费者呢？那应当怎么操作呢？这就是要下面提到的Publish/Subscribe（分布/订阅）。让我们开始Publish/Subscribe之旅吧!
Publish/Subscribe的工作示意图 ...
在前面的已经提到了一对一的情况;现在一个生产者与多个消费者的情况（Work Queues）。Work Queues的示意图如下：
对于上图的模型中对于c端的worker来说。RabbitMQ服务器可能一直发送多个消息给一个worker，而另一个可能几乎不做任何事情。这样就会导致一个worker很忙，而另一个却很空闲。这种情况可能都不想出现。如何解决这个问题呢。当然最理想的情况是均匀分配消息给每个worker。我们可能通过channel . basicQos(1)方法（prefetchCount = 1 ）来设置同一时间每次发给一个消息给一个worker。示意图如下：
P ...
rabbitMQ是一个在AMQP基础上完整的，可服用的企业消息系统。他遵循Mozilla Public License 开源协议。
关于amqp可参考http://www.oschina.net/p/rabbitmq/
rabbitmq是一个消费的代理；通过生产者客户端生产一个信息，转送给消费者客户端;在这个传输过程中，根据你的需要可以经过路由、缓冲、持久化来得到这个消息。
先通过一个例子开始：通过rabbitmq输出"Hello World!"
其中P代表生产者、C表示消费者、中间红色部分代表消息队列
生产者客户端的发送消息程序如 ...
目录
构建项目
服务端实现
客户端测试
嵌入式HTTP服务发布服务
[一]、构建项目
创建项目 xfire-jsr181-demo：
mvn archetype:create -DgroupId=com.micmiu.xfire.demo -DartifactId=xfire-jsr181-demo -DarchetypeArti
目录
构建项目
创建服务端API
嵌入式HTTP服务器发布服务
创建客户端
[一]、构建项目
maven构建项目：
目录：
概述
根据默认配置实现代理客户端
根据JSR 181注解实现代理客户端
根据WSDL自动生成客户端代码
动态客户端的实现
[一]、概述
以 XFire webservice入门
目录：
前言概述
环境配置
构建项目
服务端的实现
客户端的实现
[一]、前言概述
在2010年3月曾经写过一篇