消息中间件-RabbitMQ,ActiveMQ

末蓝、 2022-05-14 07:58 463阅读 0赞

# MQ简介及AMQP协议 #

**什么是MQ？**

Message Queue, 消息队列（MQ）是一种应用程序对应用程序的通信方法。  
MQ是消费-生产者模型的一个典型的代表，一端往消息队列中不断写入消息，而另一端则可以读取队列中的消息。  
老牌:ActiveMQ、RabbitMQ 新热:Kafka ，还有 ZeroMQ

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzYyNjc3_size_16_color_FFFFFF_t_70][]

**RabbitMQ**

*  性能优秀,稳定性保障,支持分布式
 *  RabbitMQ是使用Erlang语言来编写,
 *  并且RabbitMQ是基于AMQP协议的
 *  开源的消息代理和队列服务器,用来通过普通协议在完全不同的应用之间共享数据
 *  与SpringAMQP完美整合、API丰富

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzYyNjc3_size_16_color_FFFFFF_t_70 1][] ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzYyNjc3_size_16_color_FFFFFF_t_70 2][]

常见应用场景:**最终一致性、广播、错峰流控**  
以常见的订单系统为例，用户点击【下单】按钮之后的业务逻辑可能包括：扣减库存、生成相应单据、发红包、发短信通知。在业务发展初期这些逻辑可能放在一起同步执行，随着业务的发展订单量增长，需要提升系统服务的性能，这时可以将一些不需要立即生效的操作拆分出来异步执行，比如发放红包、发短信通知等。这种场景下就可以用 MQ  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzYyNjc3_size_16_color_FFFFFF_t_70 3]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzYyNjc3_size_16_color_FFFFFF_t_70 4][]

JMS两种模式:

1.  主题  
    发布者和订阅者,主题中的消息被所有订阅者消费,消费者不能消费订阅之前的消息  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzYyNjc3_size_16_color_FFFFFF_t_70 5]
2.  队列  
    客户端包括生产者和消费者,队列中的消息只能被一个消费者消费,消费者可以随时消费队列中的消息  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzYyNjc3_size_16_color_FFFFFF_t_70 6]

**AMQP协议**  
它是应用层协议的一个开放标准，为面向消息的中间件设计，基于此协议的客户端与消息中间件可传递消息，并不受产品、开发语言等条件的限制。  
![70][]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzYyNjc3_size_16_color_FFFFFF_t_70 7]

--------------------

# RabbitMQ安装与使用 #

**官网地址**:[http://www.rabbitmq.com][http_www.rabbitmq.com]

1.安装gcc等环境  
2.下载rpm包  
流程:秘钥----erlang—RabbitMQ  
![这里写图片描述][70 1]

> 安装 `rpm -ivh your-package.rpm`  
> \-i：显示套件的相关信息；  
> \-v：显示指令执行过程；  
> \-h或–hash：套件安装时列出标记；

> 卸载  
> `rpm -e包名`

3配置  
/etc/hosts /etc/hostname(linux防火墙)  
修改rabbit.app,启用用户guest  
4启用管控台

默认端口号:**5672**

# RabbitMQ核心概念 #

\#\#\#架构模型  
![模型][70 2]

### 核心概念 ###

\*\*Server:\*\*又称Broker,接受客户端连接,实现AMQP实体服务,表示消息队列服务器实体。  
Connection网络连接，应用-----broker  
**Channel信道**，多路复用连接中的一条独立的双向数据流通道。信道是建立在真实的TCP连接内地虚拟连接，AMQP 命令都是通过信道发出去的，不管是发布消息、订阅队列还是接收消息，这些动作都是通过信道完成。因为对于操作系统来说建立和销毁 TCP 都是非常昂贵的开销，所以引入了信道的概念，以复用一条 TCP 连接。  
**Message消息**，消息是不具名的，它由消息头properties和消息体body组成。消息体是不透明的，而消息头则由一系列的可选属性组成，这些属性包括routing-key（路由键）、priority（相对于其他消息的优先权）、delivery-mode（指出该消息可能需要持久性存储）等。  
**Virtual Host虚拟主机**，表示一批交换器、消息队列和相关对象。虚拟主机是共享相同的身份认证和加密环境的独立服务器域。每个 vhost 本质上就是一个 mini 版的 RabbitMQ 服务器，拥有自己的队列、交换器、绑定和权限机制。vhost 是 AMQP 概念的基础，必须在连接时指定，RabbitMQ 默认的 vhost 是 / 。  
![这里写图片描述][70 3]  
**Exchange交换器**用来接收生产者发送的消息并将这些消息路由给服务器中的队列。  
**Queue消息队列**用来保存消息直到发送给消费者。它是消息的容器，也是消息的终点。一个消息可投入一个或多个队列。消息一直在队列里面，等待消费者连接到这个队列将其取走。

**Binding绑定**用于消息队列和交换器之间的关联。一个绑定就是基于路由键将交换器和消息队列连接起来的路由规则，所以可以将交换器理解成一个由绑定构成的路由表。

**Routing key**一个路由规则,虚拟机可用它来确定如何路由一个特定消息

**Publisher**  
消息的生产者，也是一个向交换器发布消息的客户端应用程序。  
**Consumer**  
消息的消费者，表示一个从消息队列中取得消息的客户端应用程序。

### 消息如何流转的? ###

Publisher生产者发送消息(指定Exchange名称,指定routing key)

找到exchange  
找到queue1

消费者监听并获取message

![这里写图片描述][70 4]

# springboot2.0.4整合RabbitMQ #

### ONE: ###

**项目 producer:**  
引入依赖

spring-boot-start-amqp

修改application.properties

spring.rabbit.address=192.168.11.81:5672
    spring.rabbitmq.username=guest
    spring.rabbitmq.password=guest
    # 可以更改默认/
    spring.rabbitmq.virtual-host=/
    # 超时时间 ms
    spring.rabbitmq.connection-timeout=15000

通过网络进行传输,实体要实现序列化  
 `class MyMessage implements Serializable`

**发送消息类OrderSender\[生产者\]**

@Component
    public class OrderSender{ 
    	@Autowired
    	private RabbitTemplate rabbitTemplate
    	/** * 功能描述: * 发送order给rabbitmq * @param: [exchange,routingKey,消息体内容,消息唯一ID] * @return: void * @auther: * @date: 2018/10/4 */
        public void setObject(Object obj){ 
            CorrelationData correlationData = new CorrelationData();
            correlationData.setId("weiyiID");
            rabbitTemplate.convertAndSend("exchange",
                    "myMessage.abcd",
                    obj,
                    correlationData);
        }
    }

**项目 consumer\[消费者\] :**

import java.io.IOException;
    import java.util.Map;
    
    /** * 描述: * 消费者获取消息队列信息 * * @author zhaojianyu * @create 2018-10-04 下午8:41 */
    @Component
    public class MessageReceiver { 
    	//构建监听,绑定关系,路由key等等
        @RabbitListener(
                bindings = @QueueBinding(
                        value = @Queue(value = "myMessage-q",durable="true"),
                        exchange = @Exchange(value="myMessage-exchange",durable="true",type = "topic"),
                        key = "myMessage.*"
                )
        )
        @RabbitHandler
        public void messageReceiver(@Payload MqMessage mqMessage, @Headers Map<String, Object> headers, Channel channel){ 
            //收到消息开始消费, 手工签收 false不批量签收
            Long deliverTag = (Long) headers.get(AmqpHeaders.DELIVERY_TAG);
            try { 
            //手工返回结果,通知消费成功
                channel.basicAck(deliverTag,false);
            } catch (IOException e) { 
                e.printStackTrace();
            }
        }
    }

--------------------

## ActiveMQ ##

1.  win安装  
    win 官网下载,打开bin/win64  
    ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzYyNjc3_size_16_color_FFFFFF_t_70 8][]  
    登录 localhost:8161  
    默认账号密码 admin
2.  linux安装

tar -zxvf aaa.tar.gz
    cd ./activeMQ/bin
    ./activemq start # 开启服务
    ps -ef |grep activemq
    ./activemq stop # 关闭服务

依赖  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzYyNjc3_size_16_color_FFFFFF_t_70 9]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzYyNjc3_size_16_color_FFFFFF_t_70]: /images/20220514/2d182b3b40504f4487a03aa4688660e4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzYyNjc3_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20181231135424861.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzYyNjc3,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzYyNjc3_size_16_color_FFFFFF_t_70 2]: /images/20220514/f72a6ab25395445da167646e58505f1f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzYyNjc3_size_16_color_FFFFFF_t_70 3]: /images/20220514/825717f16aab4128a37a24dcd75fcb49.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzYyNjc3_size_16_color_FFFFFF_t_70 4]: /images/20220514/7785b9dd5bbf4d47bfd690f822216114.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzYyNjc3_size_16_color_FFFFFF_t_70 5]: /images/20220514/83ae2b42d9f64b8a9439ea4d42cafe87.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzYyNjc3_size_16_color_FFFFFF_t_70 6]: /images/20220514/b738f5e70b244d15a26fa24f2f2e075b.png
[70]: /images/20220514/24c26917942c49209493f8b8e0ef6a8d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzYyNjc3_size_16_color_FFFFFF_t_70 7]: /images/20220514/6d2be8dc24204c26a1289c1aafb83f40.png
[http_www.rabbitmq.com]: http://www.rabbitmq.com
[70 1]: /images/20220514/f92c4e837eb44575bacb43b2ad60665c.png
[70 2]: /images/20220514/ef543b11cf1a4bb59eea49a2ee43f76d.png
[70 3]: /images/20220514/c401936288e34190bf27a362cfe86963.png
[70 4]: /images/20220514/6587caff1b6e494fb8539aaaee410f45.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzYyNjc3_size_16_color_FFFFFF_t_70 8]: /images/20220514/e8f9b37fc89e40219110a8f1d017b8a6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NzYyNjc3_size_16_color_FFFFFF_t_70 9]: /images/20220514/2e716c2be21d4abfb1096399f996784c.png