RabbitMQ心得技术问题

（1）应用场景
MQ全称为Message Queue，即消息队列， RabbitMQ是由erlang语言开发，基于AMQP（Advanced Message Queue 高级消息队列协议）协议实现的消息队列，它是一种应用程序之间的通信方法，消息队列在分布式系统开发中应用非常广泛。RabbitMQ官方地址：http://www.rabbitmq.com/
开发中消息队列通常有如下应用场景：
1、任务异步处理。
将不需要同步处理的并且耗时长的操作由消息队列通知消息接收方进行异步处理。提高了应用程序的响应时间。
2、应用程序解耦合
MQ相当于一个中介，生产方通过MQ与消费方交互，它将应用程序进行解耦合。
为什么使用RabbitMQ呢？
1、使得简单，功能强大。
2、基于AMQP协议。
3、社区活跃，文档完善。
4、高并发性能好，这主要得益于Erlang语言。
5、Spring Boot默认已集成RabbitMQ
（2）其它相关术语
AMQP
AMQP是一套公开的消息队列协议，最早在2003年被提出，它旨在从协议层定义消息通信数据的标准格式，为的就是解决MQ市场上协议不统一的问题。RabbitMQ就是遵循AMQP标准协议开发的MQ服务。
官方：http://www.amqp.org/
JMS
JMS是java提供的一套消息服务API标准，其目的是为所有的java应用程序提供统一的消息通信的标准，类似java的jdbc，只要遵循jms标准的应用程序之间都可以进行消息通信。它和AMQP有什么不同，jms是java语言专属的消息服务标准，它是在api层定义标准，并且只能用于java应用；而AMQP是在协议层定义的标准，是跨语言的。
（3）RabbitMQ工作原理

文章图片

组成部分说明如下：

Broker：消息队列服务进程，此进程包括两个部分：Exchange和Queue。
Exchange：消息队列交换机，按一定的规则将消息路由转发到某个队列，对消息进行过虑。
Queue：消息队列，存储消息的队列，消息到达队列并转发给指定的消费方。
Producer：消息生产者，即生产方客户端，生产方客户端将消息发送到MQ。
Consumer：消息消费者，即消费方客户端，接收MQ转发的消息。

消息发布接收流程：
-----发送消息-----
1、生产者和Broker建立TCP连接。
2、生产者和Broker建立通道。
3、生产者通过通道消息发送给Broker，由Exchange将消息进行转发。
4、Exchange将消息转发到指定的Queue（队列）
----接收消息-----
1、消费者和Broker建立TCP连接
2、消费者和Broker建立通道
3、消费者监听指定的Queue（队列）
4、当有消息到达Queue时Broker默认将消息推送给消费者。
5、消费者接收到消息。
（4）搭建环境
【RabbitMQ心得】1）java client
生产者和消费者都属于客户端
用 rabbitMQ官方提供的java client测试
2）创建maven工程
创建生产者工程和消费者工程，分别加入RabbitMQ java client的依赖。
test-rabbitmq-producer：生产者工程
test-rabbitmq-consumer：消费者工程

com.rabbitmq

amqp-client

4.0.3

org.springframework.boot

spring-boot-starter-logging

生产者
生产者操作流程如下：
1）创建连接
2）创建通道
3）声明队列
4）发送消息
在生产者工程下的test包中创建测试类如下：

public class Producer01 {

//队列名称

private static final String QUEUE = "helloworld";

public static void main(String[] args) throws IOException, TimeoutException {

Connection connection = null;

Channel channel = null;

try

{

ConnectionFactory factory = new ConnectionFactory();

factory.setHost("localhost");

factory.setPort(5672);

factory.setUsername("guest");

factory.setPassword("guest");

factory.setVirtualHost("/"); //rabbitmq默认虚拟机名称为“/”，虚拟机相当于一个独立的mq服务器

//创建与RabbitMQ服务的TCP连接

connection= factory.newConnection();

//创建与Exchange的通道，每个连接可以创建多个通道，每个通道代表一个会话任务

channel = connection.createChannel();

/**

* 声明队列，如果Rabbit中没有此队列将自动创建

* param1:队列名称

* param2:是否持久化

* param3:队列是否独占此连接

* param4:队列不再使用时是否自动删除此队列

* param5:队列参数

*/

channel.queueDeclare(QUEUE, true, false, false, null);

String message = "helloworld小明"+System.currentTimeMillis();

/**

* 消息发布方法

* param1：Exchange的名称，如果没有指定，则使用Default Exchange

* param2:routingKey,消息的路由Key，是用于Exchange（交换机）将消息转发到指定的消息队列

* param3:消息包含的属性

* param4：消息体

*/

/**

* 这里没有指定交换机，消息将发送给默认交换机，每个队列也会绑定那个默认的交换机，但是不能显示绑定或解除绑定

*　默认的交换机，routingKey等于队列名称

*/

channel.basicPublish("", QUEUE, null, message.getBytes());

System.out.println("Send Message is:'" + message + "'");

}

catch(Exception ex)

{

ex.printStackTrace();

}

finally

{

if(channel != null)

{

channel.close();

}

if(connection != null)

{

connection.close();

}

消费者
消费者操作流程如下：
1）创建连接
2）创建通道
3）声明队列
4）监听队列
5）接收消息
6）ack回复
在消费者工程下的test包中创建测试类如下：

public class Consumer01 {

private static final String QUEUE = "helloworld";

public static void main(String[] args) throws IOException, TimeoutException {

ConnectionFactory factory = new ConnectionFactory();

//设置MabbitMQ所在服务器的ip和端口

factory.setHost("127.0.0.1");

factory.setPort(5672);

Connection connection = factory.newConnection();

Channel channel = connection.createChannel();

//声明队列

channel.queueDeclare(QUEUE, true, false, false, null);

//定义消费方法

DefaultConsumer consumer = new DefaultConsumer(channel) {

/**

* 消费者接收消息调用此方法

* @param consumerTag 消费者的标签，在channel.basicConsume()去指定

* @param envelope 消息包的内容，可从中获取消息id，消息routingkey，交换机，消息和重传标志(收到消息失败后是否需要重新发送)

* @param properties

* @param body

* @throws IOException

*/

@Override

public void handleDelivery(String consumerTag,

Envelope envelope,

AMQP.BasicProperties properties,

byte[] body)

throws IOException {

//交换机

String exchange = envelope.getExchange();

//路由key

String routingKey = envelope.getRoutingKey();

//消息id

long deliveryTag = envelope.getDeliveryTag();

//消息内容

String msg = new String(body,"utf-8");

System.out.println("receive message.." + msg);

}

};

/**

* 监听队列String queue, boolean autoAck,Consumer callback

* 参数明细

* 1、队列名称

* 2、是否自动回复，设置为true为表示消息接收到自动向mq回复接收到了，mq接收到回复会删除消息，设置为false则需要手动回复

* 3、消费消息的方法，消费者接收到消息后调用此方法

*/

channel.basicConsume(QUEUE, true, consumer);

?

}

RabbitMQ心得

推荐阅读

不要用 mongodb

能率热水器11 闪烁,主要考虑这几个方面

Java|Java 代码检查工具之PMD入门使用详细教程

请答全名今天是哪位忍者的生日？？火影忍者手游7.3答案

Win10系统Adobe Flash Player失效如何解决?解决Adobe Flash Player失效方法分享

熊童子多肉掉下来的叶子能插活吗图片熊童子多肉掉下来的叶子能插活吗

西游记水帘洞景区在哪里水帘洞在哪里

北京中山公园游览路线北京中山公园银杏几月份可以看2021

在华为系列当中,从高端机到低端机是怎样排列的？

20万启动资金可以做的项目投资20万元做什么生意好

眼睛小怎么整容变大如何让眼睛变大微整，眼睛怎么微整

全文山东省2023年退休养老金调整最新消息山东养老金上调最新方案预算

金枪鱼三明治——镇静安神开胃健脾

大米冬天放外面怕冻，大米白面冬天放在外面怕冻不

南昌八一起义纪念馆要身份证吗现在南昌八一起义纪念馆要身份证吗?

丈母爹打女婿犯法吗

海南月入10000元抚养费标准是什么

五味子配什么补肾效果好

c与mysql数据库连接 c连接mysql代码

印刷报价网站_印刷报价网站程序