首页 运维干货RabbitMQ简介以及应用

RabbitMQ简介以及应用

运维派隶属马哥教育旗下专业运维社区,是国内成立最早的IT运维技术社区,欢迎关注公众号:yunweipai
领取学习更多免费Linux云计算、Python、Docker、K8s教程关注公众号:马哥linux运维

RabbitMQ简介以及应用插图

一、简要介绍

  • 开源AMQP实现,Erlang语言编写,支持多种客户端
  • 分布式、高可用、持久化、可靠、安全
  • 支持多种协议:AMQP、STOMP、MQTT、HTTP
  • 适用于多系统之间的业务解耦的消息中间件

二、基本概念

1、exchange:交换器,负责接收消息,转发消息至绑定的队列,有四种类型:

  • direct:完全匹配的路由
  • topic:模式匹配的路由
  • fanout:广播模式
  • headers:键值对匹配路由

Exchange属性:

  • 持久化:如果启用,那么rabbit服务重启之后仍然存在
  • 自动删除:如果启用,那么交换器将会在其绑定的队列都被删除掉之后自动删除掉自身

2、Queue:队列,rabbitmq的内部对象,用于存储消息,其属性类似于Exchange,同样可以设置是否持久化、自动删除等

消费者从Queue中获取消息并消费。多个消费者可以订阅同一个Queue,这时Queue中的消息会被平均分摊给多个消费者进行处理,而不是每个消费者都收到所有的消息并处理。

3、Binding:绑定,根据路由规则绑定交换器与队列

4、Routing:路由键,路由的关键字

三、消息的可靠性

  • Message acknowledgment:消息确认,在消息确认机制下,收到回执才会删除消息,未收到回执而断开了连接,消息会转发给其他消费者,如果忘记回执,会导致消息堆积,消费者重启后会重复消费这些消息并重复执行业务逻辑。
  • Message durability:消息持久化,设置消息持久化可以避免绝大部分消息丢失,比如rabbitmq服务重启,但是采用非持久化可以提升队列的处理效率。如果要确保消息的持久化,那么消息对应的Exchange和Queue同样要设置为持久化。
  • Prefetch count,每次发送给消费者消息的数量,默认为1

另外,如果需要可靠性业务,需要设置持久化和ack机制,如果系统高吞吐,可以设置为非持久化、noack、自动删除机制。

四、简单应用

模拟这样一个业务场景,用户下单成功后,需要给用户增加积分,同时还需要给用户发送下单成功的消息,这是在电商业务中很常见的一个业务场景。

如果系统是微服务架构,可能用户下单功能在订单服务,给用户增加积分的功能在积分服务,给用户发送通知消息的功能在通知服务,各个服务之间解耦,互不影响。那么要实现上述的业务场景,消息中间件rabbitmq是一个很好的选择。

原因如下:

  • 高性能,它的实现语言是天生具备高并发高可用的erlang 语言
  • 支持消息的持久化,即使服务器挂了,也不会丢失消息
  • 消息应答(ack)机制,消费者消费完消息后发送一个消息应答,rabbitmq才会删除消息,确保消息的可靠性
  • 支持高可用集群
  • 灵活的路由

实现思路:

用户下单成功后,rabbitmq发送一条消息至EXCHANGE.ORDER_CREATE交换器,该交换器绑定了两个队列,QUEUE.ORDER_INCREASESCORE、QUEUE.ORDER_NOTIFY,消费者订阅这两个队列分别用来处理增加积分、发送用户通知。如果后续日志系统还需要记录下单的相关日志,那么我们只需要再定义一个队列并将其绑定到EXCHANGE.ORDER_CREATE即可。

下单发rabbitmq消息

积分系统订阅消息

通知系统订阅消息

测试

输出:

原文转载:https://www.jianshu.com/p/2f55cd7a3e1c
作者:会跳舞的机器人

本文链接:http://www.yunweipai.com/36914.html

网友评论comments

发表评论

电子邮件地址不会被公开。

暂无评论

Copyright © 2012-2020 YUNWEIPAI.COM - 运维派
扫二维码
扫二维码
返回顶部