rabbitmq学习资料资源-CSDN文库

需积分: 9 111 浏览量 2017-12-20 19:57:53 上传评论 1 收藏 1004KB PDF 举报

资源推荐

资源详情

资源评论

RabbitMQ 学习文档

消息队列 AMQP

1. RabbitMQ的简介

RabbitMQ作为一个中间件，本质上是一个消息的代理，在这个领域还有ActiveMQ、RocketMQ、

ZeroMQ、Joram、Kafka等等。其中ActiveMQ是Apache公司开源的消息系统，使用Java语言开发，功能

较为完善，被大量开源项目所使用。而RocketMQ是阿里开源的消息中间件，他也是纯Java开发，具有高吞

吐量、高可用性、适合大规模分布式系统应用的特点。接下来的Kafka是LinkedIn开源的分布式发布-订阅消

息系统，目前这个项目已经属于Apache顶级项目。Kafka的主要特点是基于Pull的模式来处理消息消息，追

求高吞吐量，后面的Kafka学习文档中会详细讲解，这里就不一一展开了。

认识一个东西我们首先从怎么使用它开始。

首先从 [Github上下载RabbitMQ的源码]

下载后好源码,按照指示进行编译安装。下面先对Rabbit里面会用到的术语进行一个说明。

名称解释

Producer(生产者) 发送消息的程序

Consumer(消费者) 消息的接收处理程序

Queue(队列) 放置消息的仓库

2. RabbitMQ的使用

2.1 初识RabbitMQ

首先我们使用一个“Hello World”走进RabbitMQ的世界

在这个demo中我们首先有两个Java程序，一个扮演生产者的角色，一个扮演消费者的角色。使用

RabbitMQ的一个消息队列来作为消息的仓库。基本的流程如下。

4. /**

5. * 消息消费者

6. *

7. * @author hzwangqing2

8. * @create 2016-08-27-16:31

9. */

10. public class C {

11.

12. private final static String QUEUE_NAME = "netease";

13.

14. public static void main(String[] argv) throws Exception {

15. // 创建连接工厂

16. ConnectionFactory factory = new ConnectionFactory();

17. // 设置RabbitMQ地址

18. factory.setHost("localhost");

19. // 创建一个新的连接

20. Connection connection = factory.newConnection();

21. // 创建一个频道

22. Channel channel = connection.createChannel();

23. // 声明要关注的队列 -- 在RabbitMQ中，队列声明是幂等性的（一个幂等操作的特

点是其任意多次执行所产生的影响均与一次执行的影响相同），也就是说，如果不存在，就创建

，如果存在，不会对已经存在的队列产生任何影响。

24. channel.queueDeclare(QUEUE_NAME, false, false, false, null);

25. System.out.println("C [*] Waiting for messages. To exit press C

TRL+C");

26. // DefaultConsumer类实现了Consumer接口，通过传入一个频道，告诉服务器我

们需要那个频道的消息，如果频道中有消息，就会执行回调函数handleDelivery

27. Consumer consumer = new DefaultConsumer(channel) {

28. @Override

29. public void handleDelivery(String consumerTag, Envelope env

elope, AMQP.BasicProperties properties, byte[] body) throws

IOException {

30. String message = new String(body, "UTF-8");

31. System.out.println("C [x] Received '" + message + "'");

32. }

33. };

34. // 自动回复队列应答 -- RabbitMQ中的消息确认机制，后面章节会详细讲解

35. channel.basicConsume(QUEUE_NAME, true, consumer);

36. }

37. }

demo写好了后，我们来运行一下这两个程序，我们首先运行消费者程序。

1. C [*] Waiting for messages. To exit press CTRL+C

剩余48页未读，继续阅读

内容反馈

ykm77777

粉丝: 0
资源: 4

最新资源

资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！点击此处反馈

feedback-tip