RabbitMQ开发中文文档_rabbitmq中文文档,rabbitmq开发文档资源-CSDN下载

RabbitMQ

GetStarted

5星 · 超过95%的资源需积分: 49 12 浏览量 2013-07-25 16:36:18 上传评论 1 收藏 637KB DOC 举报

资源推荐

资源详情

资源评论

1 发送"Hello World"消息

简介

 是一个消息服务器。从本质上讲，它接收生产者生产的消息，并发送给消费者。期间，

它可以根据用户给定的规则来路由、缓存、持久化这些消息。

以下是  用到的一些专业术语：

1.生产的意思就是发送。发送消息的程序就是生产者，如下图所示：

队列就是接受消息的邮箱，由

 提供。尽管消息在 

和应用之间传递，但只能被封装在一个队列中。队列没有限制，可以储存任意多的消息它本质是

是一个无限的缓存。一个队列可以接收多个生产者发送来的消息，并可以把消息分发给多个消费者。

队列可以用下图表示：

3.消费类似于接收。等待接收消息的

程序就是消费者，如下图所示：

注意生产者、消费者和  服

务器不必位于同一台机器上，事实上大部

分都是如此。

"Hello World"示例

(使用 Java 版客户端)

此处有  个  程序：发送一个消息的生产者和一个接收消息并打印的消费者。为了上手方便，我

们将忽略程序的细节，只专注于核心部分。发送的消息的内容是“。

在下图中，“代表生产者，“代表消费者。中间的方块代表队列 的消息缓存器，储

存向消费者发送的消息。

Java 依赖

库

 使用  协议，它是一个开放的、通用的消息协议。许多编程语言都实现了 

协议。这里我们使用  版。

下载客户端依赖包，并核对一下它的签名。将其解压到你的工作目录中，并从此目录中获取  文

件：

 !"

! !"#"#

$ 中央仓库也提供此依赖包%&' 是 ! ，(!' 是  !)

有了  依赖包，就可以编码了。

发送消息

我们将调用消息生产者 *

和消息消费者 !。生产者

和  连接并发送一

个消息，然后退出。

在 * 中导入依赖类：

import! !!+!,;

import! !!;

import! !-;

创建 * 类并给队列命名.

publicclassSend{

privatenalstatic*&/0/0120=3-3;

publicstaticvoidmain(*&[]&)

throws..'405!{

...

}

}

然后和服务器之间建立一个连接.

!+!,(!,=new!+!,();

(!,.66(3!-63);

!!!=(!,.7!();

-!-=!!.!-();

! 对象将 6!8 连接抽象化，封装了协议的版本和身份验证等。使用“!-6连接

本地的  服务器。如果想连接到其它机器，只需要修改机器名或 ' 地址即可。

下一步创建一个消息通道$!-)，通过它来完成大部分的工作。发送消息之前，必须先创建一

个队列；然后将消息发送给它：

!-. 9!(/0/0120,false,false,false,null);

*&66&=3:3;

!-.6!6-(33,/0/0120,null,66&.&;,6());

*,6..(3<5=*>3+66&+3>3);

创建队列代码如上，当且仅当该队列不存在时，才会被创建。消息是字节数组，这样你就可以任意

地对消息的内容进行编码。

最后，我们关闭消息通道和连接?

!-.!6();

!!.!6();

这就是完整的 Send.java 类。

发送消息失败!

如果这是你第一次使用  而且没有看到发送的消息，那么你可能正在挠头中并很想知道哪

儿错了。也许服务器启动时没有足够的磁盘空间$默认情况下它至少需要 @A; 的磁盘空间)，因此它

拒绝接收消息。检查一下服务器的 &B 配置文件并减小将该限制的属性值。可以查看配置文件文

档怎么设置 681(1 属性。

接收消息

上面就是消息生产者。消费者从  获取消息，和只发送一次消息的生产者不同，消费者会

一直等待接收消息并将接收的消息打印出来。

! 和 * 基

本需要引用同样的类：

import

! !!+!,;

import! !!;

import! !-;

import! !&6;

新引用的类 &6 是用来接收从服务器发送来的消息。

和 * 一样，要打开连接、创建消息通道、声明队列，从声明的队列中接收消息。请注意，生产

者的队列必须和消费者的队列一致。

publicclassRecv{

privatenalstatic*&/0/0120=3-3;

publicstaticvoidmain(*&[]&)

throws..'405!,

.&.'05!{

!+!,(!,=new!+!,();

(!,.66(3!-63);

!!!=(!,.7!();

-!-=!!.!-();

!-. 9!(/0/0120,false,false,false,null);

*,6..(3<"=&(66&6C566CDE3);

...

}

}

注意在这里也声明了队列。因为消费者可能在生产者之前启动，但必须确保消费者在尝试接收消息

时队列就存在。

通知服务器把队列中的消息发送给我们。由于服务器以异步的方式发送消息，所以我们需要提供一

个回调对象，当消息发送过来它就会通知我们。&6 就是这个回调。

&6!6=new&6(!-);

!-.6!6(/0/0120,true,!6);

while(true){

&6.9,,=!6.59,();

*&66&=new*&(,.&;,());

*,6..(3<5=!>3+66&+3>3);

}

&659,$)方法会阻塞直到下一条消息从服务器发送过来。

以上就是完整的 Recv.java 代码。

组合代码

同时编译这  个类，需要将  ! 放到类路径下：

!! !*!

运行上面两个程序需要将  ! 等依赖拷贝到类路径下。在终端上运行生产者：

!.!6@.!6!@@. !*

再运行消费者：

!.!6@.!6!@@. !!

在 776 环境下，使用冒号而不是分号来分隔类路径下的  包。

消费者打印从  接收的消息。消费者将一直运行，等待接收消息$使用  停止)，所以

请从另一个终端上运行生产者。

剩余29页未读，继续阅读

评论收藏

内容反馈

yuyezitong

2013-12-06

虽然没有找到我想要的信息，不过很适合初学者~详细~丰富~~
zjj911

2016-08-04

很全面,很好用,谢谢分享.
wuzen007007

2014-07-04

还不错，适合初学者
wizards14

2016-06-28

官网文档的翻译版本，凑合看吧
tianshanjian

2015-12-30

不错的，下载看看

前往

页

小凡致心

粉丝: 286

RabbitMQ开发中文文档

RabbitMQ中文文档.pdf

RabbitMQ 文档

RabbitMQ说明文档

rabbitMQ技术文档

RabbitMQ技术帮助文档

rabbitMQ使用手册

RabbitMQ API文档

rabbitmq.pptx（官方文档）

rabbitMQ的api及规范说明书.doc

RabbitMQ 开发文档(翻译)

RabbitMQ开发演示文档

RabbitMQ API中文文档（英文HTML版）

Spring Cloud 中文文档 参考手册 中文版2018

Spring Cloud 2018最新_官网文档_中文参考手册_pdf

ecstore、ecos核心框架中文文档

celery-v4.3.0中文.pdf

spring cloud 中文文档

rabbitmq开发规范

RabbitMQ服务使用手册.doc

《深入RabbitMQ》.pdf.zip

RabbitMq使用手册

RabbitMQ用户手册

spring-cloud-starter-stream-rabbit MQ使用规范

rabbitmq实战指南

乐优商城使用的RabbitMQ附安装手册

RabbitMQ服务开发指南（修订版-1）

rabbitmq整合项目.rtf

springboot说明文档中文版

Spring Cloud 中文文档.pdf

最新资源

Spring Cloud 中文文档参考手册中文版2018