MQ 介绍
MQ是消息中间件，常见的有RabbitMQ,Kafka,RocketMQ,activeMQ 等，用于分布式系统中。作用有三点
- 解耦
- 异步
- 削峰
RabbitMQ 整体上是一个生产者，消费者模型，主要负责接收，存储和转发消息。
模型架构
生产者生产消息将消息发送给路由，路由根据路由规则匹配将消息写入到队列中，然后消费者订阅并进行消息的消费。
概念介绍
- Producer 生产者
- Exchange 交换器
生产者将数据包装好后将消息发送给交换器，再由交换器将消息路由给符合路由规则的消息队列中 - Routingkey
路由键，生产者在将消息发送给Exchange时会指定一个RoutingKey，RoutingKey和交换器，BindingKey 关联才能具体的将消息路由到相应的消息队列中。
Binding：RabbitMQ将通过将BindingKey和交换器的绑定将队列关联起来，在绑定的时候会指定BindingKey
发送消息的过程是生成者生成消息，绑定Routingkey 发送给Exchange，Exchange接受到消息和Routingkey，然后将RoutingKey拿出来和bindingKey进行匹配，最后根据这个匹配将消息路由到正确的队列（可能是多个匹配的队列）当中。
Exchange 类型
fanout会将所有发送到该交换器中的消息路由到所有与该交换器绑定的队列中。
Direct
将消息路由到那些BindingKey和RoutingKey完全匹配的队列中。
Topic
用*和# 来进行模式匹配单词，单词间用 . 来隔开， * 代表一个单词，#代表多个单词。
Headers
它不依赖路由键，而是根据消息内容中headers的属性匹配。
Connection & Channel
无论是生产者还是消费者都会和RabbitMQ Broker建立一个TCP连接，就是一个Connection，然后客户端就可以创建一个AMQP信道（Channel）
因为建立TCP连接性能开销大，所以复用后能够提升性能，但如果单个Channel连接流量大时就需要单独开辟Connection连接。
Channel不能在线程之间共享
消息确认与拒绝机制
消息队列提供了Ack机制来提供的消息确认机制，当autoAck=false时RabbitMQ会等待消费者显示地回复确认信号才从内存或者磁盘中删除（实质上是先打上删除标记，然后再删除），当autoAck = true时，RabbitMQ会将已经发送出去的消息重内存和磁盘中删除，而不管消费者是否真正地消费了该消息。当autoAck为false时，RabbitMQ会一直等待客户端回应，如果客户端连接断开，则该消息会重新进入队列，等待投递给消费者。
当客户端想要拒绝该消息可以使用
void basicReject(long deliveryTag, boolean requeue) throws IOException;
deliveryTag 可以看做是消息的编号，requeue = true 时，消息会重新进入队列。
mandatory & immediate 他们有当消息 传递过程中不可达目的地时将消息返回给生成者的功能
消息中间件常见问题
1.如何保证高可用
2.如何保证消息不丢失
3.如何保证消息不被重复消费
网友评论