MQ笔记

作者: SithCait | 来源:发表于2018-09-28 13:50 被阅读0次

    1.大多应用中,可通过消息服务中间件来提升系统异步通信、扩展解耦能力

    2.消息服务中两个重要概念:
    消息代理(message broker)和目的地(destination)
    当消息发送者发送消息以后,将由消息代理接管,消息代理保证消息传递到指定目的地。

    3.消息队列主要有两种形式的目的地
    队列(queue):点对点消息通信(point-to-point)
    主题(topic):发布(publish)/订阅(subscribe)消息通信

    4.点对点式:
    消息发送者发送消息,消息代理将其放入一个队列中,消息接收者从队列中获取消息内容,消息读取后被移出队列
    消息只有唯一的发送者和接受者,但并不是说只能有一个接收者

    5.发布订阅式:
    发送者(发布者)发送消息到主题,多个接收者(订阅者)监听(订阅)这个主题,那么就会在消息到达时同时收到消息

    6.JMS(Java Message Service)JAVA消息服务:
    基于JVM消息代理的规范。ActiveMQ、HornetMQ是JMS实现

    7.AMQP(Advanced Message Queuing Protocol)
    高级消息队列协议,也是一个消息代理的规范,兼容JMS
    RabbitMQ是AMQP的实现


    image.png

    8.Spring支持
    spring-jms提供了对JMS的支持
    spring-rabbit提供了对AMQP的支持
    需要ConnectionFactory的实现来连接消息代理
    提供JmsTemplate、RabbitTemplate来发送消息
    @JmsListener(JMS)、@RabbitListener(AMQP)注解在方法上监听消息代理发布的消息
    @EnableJms、@EnableRabbit开启支持

    9.Spring Boot自动配置
    JmsAutoConfiguration
    RabbitAutoConfiguration

    10.RabbitMQ运行机制
    生产者把消息发布到 Exchange 上,消息最终到达队列并被消费者接收,而 Binding 决定交换器的消息应该发送到那个队列。

    image.png

    11.场景
    应用解耦
    订单——>库存
    流量削峰
    请求——>秒杀业务处理

    相关文章

      网友评论

          本文标题:MQ笔记

          本文链接:https://www.haomeiwen.com/subject/wofpoftx.html