消息中间件 RabbitMQ (一)
简述
RabbitMQ 是一个消息中间件,类似于传统的邮局,不过RabbitMQ充当了邮箱,邮局,邮递员的角色。和邮局不同的是,它使用消息接受,存储,发送二进制数据。
RabbitMQ 的一些术语
Producing
: 生产者,发送消息方,只发送消息。
queue
: 消息队列,允许消息从RabbitMQ传送到应用程序,消息只能被存储在队列中。队列仅仅被宿主机的内存和磁盘空间限制,本质上它是一个大的缓存块。生产者可以往队列发消息,消费者也可以从队列中接受消息。
Consuming
:消费者,类似于收信人,消费者程序通常是在等待接收消息。
ps:生产者,消费者和中间件不应该在同一台宿主机上面,实际中大多数应用都不会这样做。
“Hello World”
Send.java,发布者发送消息
1 | package me.chenzhijun; |
Receiver.java,先要声明确定建立连接,因为需要等待接收消息
1 | package me.chenzhijun; |
maven仓库包:
1 | <dependencies> |
使用Demo的时候需要先下载安装RabbitMQ,可能还需要安装erlang,安装完成后打开网站localhost:15672
,就可以看到rabbitMQ的管理后台了。
参考文档: