RabbitMQ系列笔记介绍篇

陌无崖 · · 190 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

导语

rabbitMQ是市面上应用很广的一种应用间传送数据的通信方式,是由erlang语言开发,主要特点就是异步通信,实现服务与服务之间的解耦。

特点

可靠性:提供了持久化、传输时确认、发布时确认、跟踪机制

灵活的路由:有四种交换器负责分发路由

集群:支持集群

多种协议:支持STOMP、和MQTT协议

多语言:支持大部分流行语言

友好的界面:提供了直观的管理界面

可扩展:提供了许多插件。

应用场景

高并发排队机制:比如在秒杀场景,提示用户正在等待,在队列里存放了有序的待处理的消息,而不是所有的消息杂乱无章

服务之间的解耦:服务之间可通过发布订阅的模式,让Rabbitmq队列通知订阅了该消息的服务执行相关代码。

工作机制

在其通信的过程中,有两个重要的角色,分别是生产者和消费者,需要强调的是RabbitMQ服务器并不产生任何消息,它只负责传递数据,由生产者创建消息,发布到RabbitMQ服务器,而消费者订阅了消息,并从RabbitMQ服务器获取消息。如下图所示

分配生产者的消息

在RabbitMQ服务器中,存在一个交换器,可以理解成交换机拿了很多队列的钥匙,并把相应的消息放在队列中,在服务器中有四种交换器。下面我们逐个来进行介绍:

direct:直连交换机,一个交换机对应了不同的队列,队列需要绑定routeing_key,消息需要指定一个binding_key,当消息被发送到交换机时,就能准确的送到指定的队列去了。

Fanout:扇形交换机,见名知意可知,这是一个广播类型的交换机,属于最简单的交换机类型,它收到消息后会将消息分发到所有绑定在自己身上的队列。

Topic:主题交换机,该交换机时对直连交换机的扩展,可以将消息发送到多个队列,实现的方法是为我们的routing_key指定规则,同样binding_key也需要指定规则,类似于模糊匹配,*代表一个单词,#代表任意数量的单词。

Headers:首部交换机,是通过headers的信息进行路由,绑定到队列的时候需要定义Hash的数据结。

五种工作模式

简单队列

一个生产者对应一个消费者

work模式

一个生产者对应了多个消费者,但只有一个消费者可以获得消息,可用于负载均衡,让效率高的消费者负责多个消息

发布订阅模式

一个消费者将消息首先发送到交换器,交换器绑定到多个队列,然后被监听该队列的消费者所接收并消费。图中的X代表交换器

路由模式

可以用于消费者选择性的接收消息

主题模式

即我们的topix交换机进行模糊绑定。

以上的工作模式只需了解工作流程,具体的代码,后面的博客中会陆续讲到。

推荐阅读

开发环境搭建(持续更新中)

RabbitMQ系列笔记介绍篇

Golang中Modle包的使用

goriila context深入学习笔记

Go Context深入学习笔记

基于Nginx和Consul构建高可用及自动发现的Docker服务架构

关于log日志的深入学习笔记

本文欢迎转载,转载请联系作者,谢谢!

公众号【常更新】:无崖子天下无敌

GitHub:https://github.com/yuwe1

CSDN【看心情更新】:https://blog.csdn.net/weixin_40051278

博客地址【定期更新】:https://mowuya.cn/

                                                                                        打开微信扫一扫,关注微信公众号

本文来自:简书

感谢作者:陌无崖

查看原文:RabbitMQ系列笔记介绍篇

入群交流(和以上内容无关):加入Go大咖交流群,免费领全套学习资料或添加微信:muxilin131420 备注:入群;或加QQ群:729884609

190 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传