一、消息发送原理

应用与Mq Server之间会创建一个TCP连接，一旦TCP打开，并通过了认证，认证就是你试图连接Rabbit之前发送的Rabbit服务器连接信息和用户名和密码，一旦认证通过你的应用程序和Rabbit就创建了一条AMQP信道（Channel）。

信道是创建在“真实”TCP上的虚拟连接，AMQP命令都是通过信道发送出去的，每个信道都会有一个唯一的ID，不论是发布消息，订阅队列或者介绍消息都是通过信道完成的。

为什么不通过TCP直接发送命令？
对于操作系统来说创建和销毁TCP会话是非常昂贵的开销，假设高峰期每秒有成千上万条连接，每个连接都要创建一条TCP会话，这就造成了TCP连接的巨大浪费，而且操作系统每秒能创建的TCP也是有限的，因此很快就会遇到系统瓶颈。

如果我们每个请求都使用一条TCP连接，既满足了性能的需要，又能确保每个连接的私密性，这就是引入信道概念的原因。

二、引入

pom：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

yml：

spring：
    rabbitmq:
      host: 127.0.0.1
      port: 5672
      username: guest
      password: guest

docker安装

docker run -d -p 5672:5672 -p 15672:15672 --name rabbitmq rabbitmq:management

web界面
http://localhost:15672/#/queues
默认账户密码:guest

三、作用

1：消峰 类似秒杀的场景大量请求进入放入队列，消费方恒定的速度消费，避免瞬间并发拖垮系统 时间空间双重消峰
2：解耦 后续的业务逻辑放到队列中处理，例如跨系统的调用
3：异步 异步执行，处理请求

四、消息模式

1.点对点简单模式

2.work模式:同一队列内一个消费者消费

根据routingKey寻找所有队列中相符的队列

3.订阅模式:发送到交换器，根据不同交换器发送到对应规则队列 队列内单一消费者消费

3.1 fanout广播模式
适用场景：
创建订单后发送消息，日志服务与订单服务都接到消息处理
投放到交换器所有绑定的队列都会收到消息
消息由队列内其一消费者消费
3.2 direct路由模式
默认的交换机模式（不写exchange参数时，直接使用routingKey对匹配的队列名匹配）
交换机内相同routingKey的队列接收到消息
3.3 topic主题模式
与direct模式对比支持模糊绑定
交换机内匹配的routingKey的队列接收到消息
"*"匹配一个分段(用“.”分割)的内容（替代表示某个字符串）；
"#"匹配0和多个字符（通配符替代内容）

广播模式拓展
需求场景：通过消息服务对集群中每台实例发送消息，可通过fanout交换机实现
fanout交换机绑定AnonymousQueue 生成一个随机队列 每台实例生成一个队列 一个交换机对所有实例的队列发送消息，每台实例接收处理

五、消息丢失

发送方设置confirm回调
yml:

spring:
  rabbitmq:
    publisher-confirms: true

注入回调接口ConfirmCallback

@Configuration
public class MqConfig {

    @Bean
    public AmqpTemplate amqpTemplate(RabbitTemplate rabbitTemplate){
        //设置消息发送回调
        rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> {
            if(ack){
                System.out.println("消息: "+correlationData+"，已经被ack成功");
            }else{
                System.out.println("消息: "+correlationData+"，nack，失败原因是："+cause);
            }
        });
       return rabbitTemplate;
    }
}

接收方开启ack 手动确认消息接收
yml：

spring:
  rabbitmq:
    listener:
      simple
        acknowledge-mode: MANUAL

手动确认：
deliveryTag：channel中唯一代表了一次投递
multiple：是否批处理

void channel.basicAck(message.getMessageProperties().getDeliveryTag(), false)

拒绝返回队列：
deliveryTag：
multiple：是否批处理
requeue：是否将消息返回队列

void channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true);

丢弃消息：
deliveryTag：
requeue:是否将返回队列 丢弃时为false

void channel.basicReject(message.getMessageProperties().getDeliveryTag(), false);

六、重复消费

业务保证接口幂等性
通过对Tagid上锁，维护一个map