MQ

MQ

优势

劣势

1.系统可用性降低

2.系统的复杂度提高

3.一致性

常见的MQ的产品：RabbitMQ,RocketMQ(阿里)，kafka

简介

RabbitMQ是由erlang语言开发，基于AMQP（Advanced Message Queue 高级消息队列协议）协议实现的消息队列，它是一种应用程序之间的通信方法，消息队列在分布式系统开发中应用非常广泛。

子主题 3

快速入门

需求：完成消息的传递

子主题 2

高级特性

消息可靠性投递（提供者发送消息，消费者消费消息包含两种模式）

confirm：确认模式

return：腿回模式

Consumer ACK（消费端收到消息后的确认方式）

自动确认;acknowledge="**none**"

手动确认：acknowledge="**manual**"

消费端限流

TTL（TTL 全称 Time To Live（存活时间/过期时间））

1配置文件

<!--ttl-->

<rabbit:queue name="test_queue_ttl" id="test_queue_ttl">

    <!--设置queue的参数-->

    <rabbit:queue-arguments>

        <!--x-message-ttl指队列的过期时间-->

        <entry key="x-message-ttl" value="100000" value-type="java.lang.Integer"/>

    </rabbit:queue-arguments>

</rabbit:queue>

<rabbit:topic-exchange name="test_exchange_ttl" >

    <rabbit:bindings>

        <rabbit:binding pattern="ttl.#" queue="test_queue_ttl"></rabbit:binding>

    </rabbit:bindings>

</rabbit:topic-exchange>

2测试类

@Test

public void testTtl() {

    for (int i = 0; i < 10; i++) {

        // 发送消息

        rabbitTemplate.convertAndSend("test_exchange_ttl",

                                      "ttl.hehe", "message ttl....");

    }

}

3.设置单个消息的过期时间

@Test

public void testTtl() {

  // 消息后处理对象，设置一些消息的参数信息

    MessagePostProcessor messagePostProcessor = new MessagePostProcessor() {

        @Override

        public Message postProcessMessage(Message message) throws AmqpException {

            //1.设置message的信息

            message.getMessageProperties().setExpiration("5000");//消息的过期时间

            //2.返回该消息

            return message;

        }

    };

    //消息单独过期

    rabbitTemplate.convertAndSend("test_exchange_ttl",

                                  "ttl.hehe", "message ttl....",messagePostProcessor);

    for (int i = 0; i < 10; i++) {

        if(i == 5){

            //消息单独过期

            rabbitTemplate.convertAndSend("test_exchange_ttl", "ttl.hehe", "message ttl....",messagePostProcessor);

        }else{

            //不过期的消息

            rabbitTemplate.convertAndSend("test_exchange_ttl", "ttl.hehe", "message ttl....");

        }

    }

}

死信队列

消息成为死信的三种情况：**

1. 队列消息长度到达限制；

2. 消费者拒接消费消息，basicNack/basicReject,并且不把消息重新放入原目标队列,requeue=false；

3. 原队列存在消息过期设置，消息到达超时时间未被消费；

延迟队列

TTL+死信队列

日志与监控

消息可靠性分析与追踪

管理

应用问题

消息可靠信保障

消息幂等性处理（一个消息多次处理结果是一样的）

集群搭建

RabbitMQ高可用集群

镜像集群配置

负载均衡-HAProxy