0091-每特教育每特學(xué)院螞蟻課堂-4期-消息中間件-rabbitmq解決消息冪等性問(wèn)題rabbitmq

1、每特教育/螞蟻教育-上海每特教育科技有限公司課題課程內(nèi)容高性能RabbitMQ每特教育|螞蟻課堂Java高端分布式、微服務(wù)IT培訓(xùn)。培訓(xùn)內(nèi)容:分布式、微服務(wù)、高可用、高并發(fā)、并發(fā)編程、JVM、性能調(diào)優(yōu)、真實(shí)企業(yè)實(shí)際項(xiàng)目等。主講老師:97后Java架構(gòu)師-螞蟻課堂創(chuàng)始人-余勝軍余老師微信號(hào):yushengjun644官方粉絲群: 193086273QQ:644064779或者 1051546329品牌模版內(nèi)容頁(yè)1.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。2.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文

2、本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。3.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。每特教育/螞蟻教育-上海每特教育科技有限公司品牌模版內(nèi)容頁(yè)1.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。2.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。3.提煉小標(biāo)題點(diǎn)擊此處輸入文本

3、內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。每特教育/螞蟻教育-上海每特教育科技有限公司個(gè)人簡(jiǎn)介余勝軍，男，1997年出生，螞蟻課堂創(chuàng)始人&97后互聯(lián)網(wǎng)創(chuàng)業(yè)者，創(chuàng)辦了上海每特教育科技有限公司，其公司產(chǎn)品是主要培訓(xùn)Java架構(gòu)師培訓(xùn)。18歲的時(shí)候擔(dān)任主力Java研發(fā)、項(xiàng)目Leader、年薪稅后高達(dá)22萬(wàn)左右，同年18歲創(chuàng)辦了螞蟻課堂-在線教育平臺(tái)。18歲的時(shí)候通過(guò)自己第一桶金，給自己父母在武漢市買了一套數(shù)百萬(wàn)的房子。19歲的時(shí)候創(chuàng)辦了-上海每特教育科技有限公司 定位軟件行業(yè)分布式微服務(wù)培訓(xùn)。20歲的時(shí)候在線直播Java分布式和微服

4、務(wù)培訓(xùn)課程，年收入300萬(wàn)元。20歲的時(shí)候創(chuàng)辦了人生第二家公司-蘇州特每信息科技有限公司，其注冊(cè)資本1000萬(wàn)元。余老師聯(lián)系方式:QQ:644064779微信:yushengjun644內(nèi)容頁(yè)1.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。2.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。3.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸

5、入文本內(nèi)容。每特教育/螞蟻教育-上海每特教育科技有限公司課程內(nèi)容1. RabbitMQ課程介紹2. RabbitMQ與其他MQ有什么不同3.Windows 環(huán) 境 搭 建 4.RabbitMQ管理平臺(tái)介紹5.VirtualHost與權(quán)限管理6.RabbitMQ簡(jiǎn)單與工作隊(duì)列7.RabbitMQ消息Ack應(yīng)答模式8.RabbitMQ持久化機(jī)制9. RabbitMQ訂閱模式10. RabbitMQ路由模式11.SpringBoot整合RabbitMQ 12.RabbitMQ冪等性解決方案內(nèi)容頁(yè)1.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處

6、輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。2.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。3.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。每特教育/螞蟻教育-上海每特教育科技有限公司課程內(nèi)容1、RabbitMQ消費(fèi)者補(bǔ)償機(jī)制2、如何合適選擇重試機(jī)制3、消費(fèi)者如果保證消息冪等性，不被重復(fù)消費(fèi)3、RabbitMQ手動(dòng)應(yīng)答與自動(dòng)應(yīng)答模式4、基于RabbitMQ實(shí)現(xiàn)分布式事務(wù)最終一致性5、RabbitMQ死信隊(duì)列，保證消息的高可

7、用內(nèi)容頁(yè)1.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。2.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。3.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。每特教育/螞蟻教育-上海每特教育科技有限公司課程內(nèi)容1、RabbitMQ六種隊(duì)列模式2、AMQP（高級(jí)消息隊(duì)列協(xié)議）原理3、RabbitMQ交換機(jī)的作用4、RabbitMQ

8、四種交換機(jī)類型5、采用發(fā)布訂閱異步實(shí)現(xiàn)發(fā)送郵件 6、Routing路由與通配符Topics模式7、SpringBoot整合RabbitMQ內(nèi)容頁(yè)1.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。2.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。3.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。每特教育/螞蟻教育-上海每特教育科技

9、有限公司RabbitMQ簡(jiǎn)介RabbitMQ是一個(gè)由erlang開(kāi)發(fā)的AMQP（Advanced Message Queue ）的開(kāi)源實(shí)現(xiàn)。AMQP 的出現(xiàn)其實(shí)也是應(yīng)了廣大人民群眾的需求，雖然在同步消息通訊的世界里有很多公開(kāi)標(biāo)準(zhǔn)（如 COBAR的 IIOP ，或者是 SOAP 等），但是在異步消息處理中卻不是這樣， 只有大企業(yè)有一些商業(yè)實(shí)現(xiàn)（如微軟的 MSMQ ，IBM 的 Websphere MQ 等），因此，在2006 年的 6 月，Cisco 、Redhat、iMatix 等聯(lián)合制定了 AMQP 的公開(kāi)標(biāo)準(zhǔn)。RabbitMQ是由RabbitMQ Technologies Ltd開(kāi)發(fā)并且提

10、供商業(yè)支持的。該公司在2010 年4月被SpringSource（VMWare的一個(gè)部門）收購(gòu)。在2013年5月被并入Pivotal。其實(shí)VMWare，Pivotal和EMC本質(zhì)上是一家的。不同的是VMWare是獨(dú)立上市子公司，而Pivotal是整合了EMC的某些資源，現(xiàn)在并沒(méi)有上市。RabbitMQ的官網(wǎng)是百度百科amqp協(xié)議介紹/item/AMQP/8354716?fr=aladdin 注意:RabbitMQ是采用erlang語(yǔ)言開(kāi)發(fā)的，所以必須有erlang環(huán)境才可以運(yùn)行內(nèi)容頁(yè)1.提煉小標(biāo)題點(diǎn)擊此處輸

11、入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。2.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。3.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。每特教育/螞蟻教育-上海每特教育科技有限公司RabbitMQ與其他MQ有什么不同RabbitMQ是一個(gè)由erlang開(kāi)發(fā)的AMQP（Advanced Message Queue ）的開(kāi)源實(shí)現(xiàn)。AMQP 的

12、出現(xiàn)其實(shí)也是應(yīng)了廣大人民群眾的需求，雖然在同步消息通訊的世界里有很多公開(kāi)標(biāo)準(zhǔn)（如 COBAR的 IIOP ，或者是 SOAP 等），但是在異步消息處理中卻不是這樣， 只有大企業(yè)有一些商業(yè)實(shí)現(xiàn)（如微軟的 MSMQ ，IBM 的 Websphere MQ 等），因此，在2006 年的 6 月，Cisco 、Redhat、iMatix 等聯(lián)合制定了 AMQP 的公開(kāi)標(biāo)準(zhǔn)。RabbitMQ是由RabbitMQ Technologies Ltd開(kāi)發(fā)并且提供商業(yè)支持的。該公司在2010 年4月被SpringSource（VMWare的一個(gè)部門）收購(gòu)。在2013年5月被并入Pivotal。其實(shí)VMWare，

13、Pivotal和EMC本質(zhì)上是一家的。不同的是VMWare是獨(dú)立上市子公司，而Pivotal是整合了EMC的某些資源，現(xiàn)在并沒(méi)有上市。RabbitMQ的官網(wǎng)是注意:RabbitMQ是采用erlang語(yǔ)言開(kāi)發(fā)的，所以必須有erlang環(huán)境才可以運(yùn)行內(nèi)容頁(yè)1.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。2.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。3.提煉小標(biāo)題點(diǎn)擊此處輸

14、入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。每特教育/螞蟻教育-上海每特教育科技有限公司erlang語(yǔ)言簡(jiǎn)介Erlang編程語(yǔ)言最初目的是進(jìn)行大型電信交換設(shè)備的軟件開(kāi)發(fā)，是一種適用于大規(guī)模并行處理環(huán)境的高可靠性編程語(yǔ)言。隨著多核處理器技術(shù)的日漸普及，以及互聯(lián)網(wǎng)、云計(jì)算等技術(shù)的發(fā)展，該語(yǔ)言的應(yīng)用范圍也有逐漸擴(kuò)大之勢(shì)。百度百科介紹:/item/Erlang%E8%AF%AD%E8%A8%80/20864044?fr=aladdin初衷理念實(shí)現(xiàn)抗高并發(fā)語(yǔ)言內(nèi)容頁(yè)1.提煉小標(biāo)題點(diǎn)擊此處輸

15、入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。2.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。3.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。每特教育/螞蟻教育-上海每特教育科技有限公司RabbitMQ環(huán)境安裝1. 下載并安裝erlang,下載地址：/download2. 配置erlang環(huán)境變量信息新增

16、環(huán)境變量ERLANG_HOME=erlang的安裝地址 將%ERLANG_HOME%bin加入到path中3. 下載并安裝RabbitMQ，下載地址：/download.html注意: RabbitMQ 它依賴于Erlang,需要先安裝Erlang。內(nèi)容頁(yè)1.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。2.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。3.提煉小標(biāo)題點(diǎn)擊此

17、處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。每特教育/螞蟻教育-上海每特教育科技有限公司RabbitMQ環(huán)境安裝1. 下載并安裝erlang,下載地址：/download2. 配置erlang環(huán)境變量信息新增環(huán)境變量ERLANG_HOME=erlang的安裝地址 將%ERLANG_HOME%bin加入到path中3. 下載并安裝RabbitMQ，下載地址：/download.html注意: RabbitMQ 它依賴于Erlang,需要先

18、安裝Erlang。內(nèi)容頁(yè)1.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。2.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。3.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。每特教育/螞蟻教育-上海每特教育科技有限公司RabbitMQ管理平臺(tái)RabbitMQ 管理平臺(tái)地址 :15672默認(rèn)賬號(hào):gu

19、est/guest用戶可以自己創(chuàng)建新的賬號(hào)Virtual Hosts:像mysql有數(shù)據(jù)庫(kù)的概念并且可以指定用戶對(duì)庫(kù)和表等操作的權(quán)限。那RabbitMQ呢？ RabbitMQ也有類似的權(quán)限管理。在RabbitMQ中可以虛擬消息服務(wù)器VirtualHost，每個(gè)VirtualHost相當(dāng)月一個(gè)相對(duì)獨(dú)立的RabbitMQ服務(wù)器，每個(gè)VirtualHost之間是相互隔離的。exchange、queue、message不能互通。內(nèi)容頁(yè)1.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。2.提煉小標(biāo)題點(diǎn)擊此處輸入文本

20、內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。3.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。每特教育/螞蟻教育-上海每特教育科技有限公司消息隊(duì)列RabbitMQ的五種形式隊(duì)列1. 點(diǎn)對(duì)點(diǎn)(簡(jiǎn)單)的隊(duì)列2. 工作(公平性)隊(duì)列模式3.發(fā)布訂閱模式(fanout) 4.路由模式Routing5.通配符模式Topics詳細(xì)網(wǎng)址:/getstarted.html內(nèi)容頁(yè)1.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。

21、擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。2.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。3.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。每特教育/螞蟻教育-上海每特教育科技有限公司RabbitMQ關(guān)鍵名詞AMQP（高級(jí)消息隊(duì)列協(xié)議）是一個(gè)異步消息傳遞所使用應(yīng)用層協(xié)議規(guī)范，為面向消息中間件設(shè)計(jì)，基于此協(xié)議的客戶端與消息中間件可以無(wú)視消息來(lái)源傳遞消息，不

22、受客戶端、消息中間件、不同的開(kāi)發(fā)語(yǔ)言環(huán)境等條件的限制；涉及概念解釋：Server(Broker):接收客戶端連接，實(shí)現(xiàn)AMQP協(xié)議的消息隊(duì)列和路由功能的進(jìn)程；Virtual Host：虛擬主機(jī)的概念，類似權(quán)限控制組，一個(gè)Virtual Host里可以有多個(gè)Exchange和Queue。Exchange:交換機(jī)，接收生產(chǎn)者發(fā)送的消息，并根據(jù)Routing Key將消息路由到服務(wù)器中的隊(duì)列Queue。ExchangeType:交換機(jī)類型決定了路由消息行為，RabbitMQ中有三種類型Exchange，分別是fanout、direct、topic；Message Queue：消息隊(duì)列，用于存儲(chǔ)還未被

23、消費(fèi)者消費(fèi)的消息；Message：由Header和body組成，Header是由生產(chǎn)者添加的各種屬性的集合，包括Message是否被持久化、優(yōu)先級(jí)是多少、由哪個(gè)Message Queue接收等；body是真正需要發(fā)送的數(shù)據(jù)內(nèi)容； BindingKey：綁定關(guān)鍵字，將一個(gè)特定的Exchange和一個(gè)特定的Queue綁定起來(lái)。內(nèi)容頁(yè)1.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。2.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入

24、文本內(nèi)容。3.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。每特教育/螞蟻教育-上海每特教育科技有限公司RabbitMQ交換機(jī)的作用生產(chǎn)者發(fā)送消息不會(huì)向傳統(tǒng)方式直接將消息投遞到隊(duì)列中，而是先將消息投遞到交換機(jī)中，在由交換機(jī)轉(zhuǎn)發(fā)到具體的隊(duì)列，隊(duì)列在將消息以推送或者拉取方式給消費(fèi)者進(jìn)行消費(fèi)，這和我們之前學(xué)習(xí)Nginx有點(diǎn)類似。交換機(jī)的作用根據(jù)具體的路由策略分發(fā)到不同的隊(duì)列中，交換機(jī)有四種類型。Direct exchange（直連交換機(jī)）是根據(jù)消息攜帶的路由鍵（routing key）將消息投遞給對(duì)應(yīng)隊(duì)列的Fa

25、nout exchange（扇型交換機(jī)）將消息路由給綁定到它身上的所有隊(duì)列Topic exchange（主題交換機(jī)）隊(duì)列通過(guò)路由鍵綁定到交換機(jī)上，然后，交換機(jī)根據(jù)消息里的路由值，將消息路由給一個(gè)或多個(gè)綁定隊(duì)列Headers exchange（頭交換機(jī)）類似主題交換機(jī)，但是頭交換機(jī)使用多個(gè)消息屬性來(lái)代替路由鍵建立路由規(guī)則。通過(guò)判斷消息頭的值能否與指定的綁定相匹配來(lái)確立路由規(guī)則。消息隊(duì)列RabbitMQ應(yīng)答模式為了確保消息不會(huì)丟失，RabbitMQ支持消息應(yīng)內(nèi)答容。頁(yè)消費(fèi)者發(fā)送一個(gè)消息應(yīng)答，告訴RabbitMQ這個(gè)消息已經(jīng)接收并且處理完畢了。RabbitMQ就可以刪除它了。1.提煉小標(biāo)題如果一個(gè)消

26、費(fèi)者掛掉卻沒(méi)有發(fā)送應(yīng)答，RabbitMQ會(huì)理解為這個(gè)消息沒(méi)有處理完全，然后交給另一個(gè)點(diǎn)消擊費(fèi)此者處去輸重入文新本處內(nèi)理容。這擊樣此，處你輸入就文可本以內(nèi)確容認(rèn)。即點(diǎn)使擊此消處費(fèi)輸者入偶文爾本掛內(nèi)掉容也。擊不此會(huì)處丟輸失入任文本內(nèi)容。 何消息點(diǎn)了擊。此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。沒(méi)有任何消息超時(shí)限制；只有當(dāng)消費(fèi)者掛掉時(shí)，RabbitMQ才會(huì)重新投遞。即使處理一條消息會(huì)花費(fèi)很長(zhǎng)的時(shí)間。消息應(yīng)答是點(diǎn)默擊認(rèn)此打處開(kāi)輸?shù)娜胛?。本我?nèi)們?nèi)萃?。過(guò)擊顯此示處的輸入設(shè)文置本au內(nèi)t容oA。sk點(diǎn)=t擊r此ue處關(guān)輸閉入這文種本機(jī)內(nèi)制容。擊現(xiàn)此即處自輸動(dòng)入應(yīng)文本內(nèi)容。2.提煉小標(biāo)題答開(kāi)，點(diǎn)一擊旦此我處們輸

27、完入文成本任內(nèi)務(wù)容，。消擊費(fèi)此者處會(huì)輸入自文動(dòng)本發(fā)內(nèi)送容應(yīng)。答。RabbitMQ消息已被處理，可以從內(nèi)存刪除。如果消費(fèi)者因宕機(jī)或鏈接失敗等原因沒(méi)有發(fā)送ACK（不同于ActiveMQ，在Rabbit3M.提Q里煉，小消標(biāo)題息沒(méi)有過(guò)期的概念），則RabbitMQ會(huì)將消息重新發(fā)送給其他在隊(duì)列的下一個(gè)消點(diǎn)費(fèi)擊者此。處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。每特教育/螞蟻教育-上海每特教育科技有限公司內(nèi)容頁(yè)1.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊

28、此處輸入文本內(nèi)容。2.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。3.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。每特教育/螞蟻教育-上海每特教育科技有限公司RabbitMQ的公平轉(zhuǎn)發(fā)目前消息轉(zhuǎn)發(fā)機(jī)制是平均分配，這樣就會(huì)出現(xiàn)倆個(gè)消費(fèi)者，奇數(shù)的任務(wù)很耗時(shí)，偶數(shù)的任何工作量很小，造成的原因就是近當(dāng)消息到達(dá)隊(duì)列進(jìn)行轉(zhuǎn)發(fā)消息。并不在乎有多少任務(wù)消費(fèi)者并未傳遞一個(gè)應(yīng)答給RabbitMQ。僅僅盲目轉(zhuǎn)發(fā)所有的奇數(shù)給一個(gè)消費(fèi)者，

29、 偶數(shù)給另一個(gè)消費(fèi)者。為了解決這樣的問(wèn)題，我們可以使用basicQos方法，傳遞參數(shù)為prefetchCount= 1。這樣告訴RabbitMQ不要在同一時(shí)間給一個(gè)消費(fèi)者超過(guò)一條消息。換句話說(shuō)，只有在消費(fèi)者空閑的時(shí)候會(huì)發(fā)送下一條信息。調(diào)度分發(fā)消息的方式，也就是告訴RabbitMQ每次只給消費(fèi)者處理一條消息，也就是等待消費(fèi)者處理完畢并自己對(duì)剛剛處理的消息進(jìn)行確認(rèn)之后，才發(fā)送下一條消息，防止消費(fèi)者太過(guò)于忙碌，也防止它太過(guò)去清閑。通過(guò) 設(shè)置channel.basicQos(1);內(nèi)容頁(yè)1.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)

30、容。擊此處輸入文本內(nèi)容。2.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。3.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。每特教育/螞蟻教育-上海每特教育科技有限公司消息隊(duì)列RabbitMQ應(yīng)答模式案例:生產(chǎn)者端代碼不變，消費(fèi)者端代碼這部分就是用于開(kāi)啟手動(dòng)應(yīng)答模式的。channel.basicConsume(QUEUE_NAME, false, defaultConsumer);注：第二個(gè)參數(shù)值為false代表關(guān)閉

31、RabbitMQ的自動(dòng)應(yīng)答機(jī)制，改為手動(dòng)應(yīng)答。在處理完消息時(shí)，返回應(yīng)答狀態(tài)，true表示為自動(dòng)應(yīng)答模式。channel.basicAck(envelope.getDeliveryTag(), false);內(nèi)容頁(yè)1.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。2.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。3.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸

32、入文本內(nèi)容。擊此處輸入文本內(nèi)容。每特教育/螞蟻教育-上海每特教育科技有限公司發(fā)布/訂閱模式Publish/Subscribe這個(gè)可能是消息隊(duì)列中最重要的隊(duì)列了，其他的都是在它的基礎(chǔ)上進(jìn)行了擴(kuò)展。功能實(shí)現(xiàn)：一個(gè)生產(chǎn)者發(fā)送消息，多個(gè)消費(fèi)者獲取消息（同樣的消息），包括一個(gè)生產(chǎn)者，一個(gè)交換機(jī)，多個(gè)隊(duì)列，多個(gè)消費(fèi)者。思路解讀（重點(diǎn)理解）：（1） 一個(gè)生產(chǎn)者，多個(gè)消費(fèi)者（2） 每一個(gè)消費(fèi)者都有自己的一個(gè)隊(duì)列（3） 生產(chǎn)者沒(méi)有直接發(fā)消息到隊(duì)列中，而是發(fā)送到交換機(jī)（4） 每個(gè)消費(fèi)者的隊(duì)列都綁定到交換機(jī)上（5） 消息通過(guò)交換機(jī)到達(dá)每個(gè)消費(fèi)者的隊(duì)列該模式就是Fanout Exchange（扇型交換機(jī)）將消息路由給

33、綁定到它身上的所有隊(duì)列以用戶發(fā)郵件案例講解注意：交換機(jī)沒(méi)有存儲(chǔ)消息功能，如果消息發(fā)送到?jīng)]有綁定消費(fèi)隊(duì)列的交換機(jī)，消息則丟失。內(nèi)容頁(yè)1.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。2.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。3.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。每特教育/螞蟻教育-上海每特教育科技有限公司路由模

34、式RoutingKey生產(chǎn)者發(fā)送消息到交換機(jī)并指定一個(gè)路由key，消費(fèi)者隊(duì)列綁定到交換機(jī)時(shí)要制定路由key（key匹配就能接受消息，key不匹配就不能接受消息）例如：我們可以把路由key設(shè)置為insert，那么消費(fèi)者隊(duì)列key指定包含insert才可以接收消息，消費(fèi)者隊(duì)列key定義為update或者delete就不能接收消息。很好的控制了更新，插入和刪除的操作。采用交換機(jī)direct模式內(nèi)容頁(yè)1.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。2.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處

35、輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。3.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。每特教育/螞蟻教育-上海每特教育科技有限公司通配符模式Topics說(shuō)明：此模式實(shí)在路由key模式的基礎(chǔ)上，使用了通配符來(lái)管理消費(fèi)者接收消息。生產(chǎn)者P發(fā)送消息到交換機(jī)X，type=topic，交換機(jī)根據(jù)綁定隊(duì)列的routing key的值進(jìn)行通配符匹配；符號(hào)#：匹配一個(gè)或者多個(gè)詞lazy.# 可以匹配lazy.irs或者lazy.irs.cor符號(hào)*：只能匹配一個(gè)詞lazy.* 可以

36、匹配lazy.irs或者lazy.cor內(nèi)容頁(yè)1.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。2.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。3.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。每特教育/螞蟻教育-上海每特教育科技有限公司通配符模式Topics說(shuō)明：此模式實(shí)在路由key模式的基礎(chǔ)上，使用了通配符來(lái)管理消費(fèi)者接收

37、消息。生產(chǎn)者P發(fā)送消息到交換機(jī)X，type=topic，交換機(jī)根據(jù)綁定隊(duì)列的routing key的值進(jìn)行通配符匹配；符號(hào)#：匹配一個(gè)或者多個(gè)詞lazy.# 可以匹配lazy.irs或者lazy.irs.cor符號(hào)*：只能匹配一個(gè)詞lazy.* 可以匹配lazy.irs或者lazy.cor內(nèi)容頁(yè)1.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。2.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。3.提煉小標(biāo)題點(diǎn)擊此處輸

38、入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。每特教育/螞蟻教育-上海每特教育科技有限公司RabbitMQ消息確認(rèn)機(jī)制問(wèn)題產(chǎn)生背景:生產(chǎn)者發(fā)送消息出去之后，不知道到底有沒(méi)有發(fā)送到RabbitMQ服務(wù)器， 默認(rèn)是不知道的。而且有的時(shí)候我們?cè)诎l(fā)送消息之后，后面的邏輯出問(wèn)題了，我們不想要發(fā)送之前的消息了，需要撤回該怎么做。解 決 方 案 : 1.AMQP 事務(wù)機(jī)制2.Confirm 模式事務(wù)模式:txSelecttxCommit txRollback將當(dāng)前channel設(shè)置為transaction模式提交當(dāng)前事務(wù)事務(wù)回滾內(nèi)容頁(yè)1.

39、提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。2.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。3.提煉小標(biāo)題點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。點(diǎn)擊此處輸入文本內(nèi)容。擊此處輸入文本內(nèi)容。每特教育/螞蟻教育-上海每特教育科技有限公司RabbitMQ消息重試機(jī)制消費(fèi)者在消費(fèi)消息的時(shí)候，如果消費(fèi)者業(yè)務(wù)邏輯出現(xiàn)程序異常，這時(shí)候應(yīng)該如何處理？答案：使用消息重試機(jī)制。（演示重試機(jī)制）如何合適選擇重試機(jī)制:情況1:情況2:消費(fèi)者獲取到消息后，調(diào)用第三方接口，但接口暫時(shí)無(wú)法訪問(wèn)，是否需要重試?（需要重試機(jī)制）消費(fèi)者獲取到消