RabbitMq相关

1、简介

RabbitMQ 是由Erlang开发的 AMQP(Advanved Message Queue)的开源实现;消息投送时使用 “至少一次交付”模式,来保证消息的投送成功率。

AMQP:是一种进程间传递异步消息的网络协议


几个概念说明:

Broker:它提供一种传输服务,它的角色就是维护一条从生产者到消费者的路线,保证数据能按照指定的方式进行传输,

Exchange:消息交换机,它指定消息按什么规则,路由到哪个队列。

Queue:消息的载体,每个消息都会被投到一个或多个队列。

Binding:绑定,它的作用就是把exchange和queue按照路由规则绑定起来.

Routing Key:路由关键字,exchange根据这个关键字进行消息投递。

vhost:虚拟主机,一个broker里可以有多个vhost,用作不同用户的权限分离。

Producer:消息生产者,就是投递消息的程序.

Consumer:消息消费者,就是接受消息的程序.

Channel:消息通道,在客户端的每个连接里,可建立多个channel.

2、RabbitMq工作模式

2.1 simple 模式


simple

消息生产者将消息放入队列

消息消费者监听,消息队列中有消息就消费,自动从队列中删除(隐患:消息可能没有被消费者正确处理,已经从队列中消失了,造成消息的丢失,这里可以设置成手动的ack,但如果设置成手动ack,处理完后要及时发送ack消息给队列,否则会造成内存溢出)

2.2 work工作模式(资源的竞争)


work工作模式

消息生产者将消息放入队列

但是会有多个消费者,同时监听同一个队列,来消费消息。C1,C2同时抢队列的消息内容,谁先抢到谁负责处理(隐患:高并发情况下,默认会出现一个消息被多个消费者共同使用情况,可以设置一个开关(syncronize) 保证一条消息只能被一个消费者使用)

2.3 publish/subscribe发布订阅(共享资源)


发布订阅

每个消费者监听自己的队列

x是broker内的交换机,消息生产者将消息发送给交换机,由交换机来转发消息到绑定的队列

2.4 routing路由模式


路由模式

消息生产者将消息发送给交换机,交换机根据路由匹配对应的消息队列,然后对应的消费者才能消费消息;

2.5 topic 主题模式(路由模式的一种)


topic主题模式

* # 都是通配符,* 是匹配单个字符,#匹配字符

2.6 rpc模式


rpc模式


RPC就是远程调用方式,Rabbitmq来实现的异步调用,流程如下:

1、客户端(消费生产者)向 RPC队列发送rpc调用消息,同时监听rpc响应队列

2、服务端监听RPC请求队列,收到消息后执行自身逻辑,得到方法结果并发送到响应队列中

3、客户端(消费生产者)监听响应队列,接收rpc调用结果

队列交互 根据 replyTo(为请求创建匿名互斥队列) 和 correlationId (请求的唯一值,客户端收到响应结果时 校验使用)来实现

3、Exchange 类型

3.1 Direct

直连模式,要求消息与指定的路由键完全匹配


Direct

3.2 Topic

模糊匹配,路由键模糊匹配某种规则 ;符号“#”匹配一个或多个词,符号“*”只能匹配一个词。



Topic

3.3 Fanout

不处理路由键,队列与交换机绑定即可。广播式发送消息


Fanout

3.4 Headers

不处理路由键,发送消息中 headers属性进行匹配;队列与交换机绑定是指定一组键值对,消息的headers与键值对匹配,完全匹配则路由到该队列,否则不处理


Headers

4、相关作用和使用场景

解耦:服务间调用 由直接调用改为mq中发起调用,如发短信,或者 还款信息更改

异步:一个业务场景完成后,可以同时触发其他场景并行执行;用户下单时,发起三方数据检查或发起审核

削峰:请求量增大时,来平缓处理消息;如果 埋点处理或者 抢购活动处理 ,或者延迟队列处理

5、其他

怎么保证消息不丢失

ack确认,开启持久化

重复消费问题


参考:

消息中间件MQ与RabbitMQ面试题(2020最新版)

RabbitMQ四种Exchange类型

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 203,456评论 5 477
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,370评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 150,337评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,583评论 1 273
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,596评论 5 365
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,572评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,936评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,595评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,850评论 1 297
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,601评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,685评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,371评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,951评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,934评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,167评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 43,636评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,411评论 2 342