-
1、RabbitMQ官網(wǎng):http://www.rabbitmq.com/
查看全部 -
RabbitMQ優(yōu)點:1、底層采用Erlang語言編寫,服務(wù)器間數(shù)據(jù)交互延遲低,吞吐量大。2、開源、性能優(yōu)秀、穩(wěn)定性保障。3、與SpringAMQP完美的整合、API豐富。4、集群模式豐富,表達(dá)式配置,HA模式、鏡像隊列模式(主流)5、保證數(shù)據(jù)不丟失的前提做到高可靠性、可用性。6、AMQP全稱:Advanced Message Queuing Protocol(高級消息隊列協(xié)議)
查看全部 -
RabbitMQ是一個開源的消息代理和隊列服務(wù)器,用來通過普通協(xié)議在完全不同的應(yīng)用之間共享數(shù)據(jù)。只是多語言。RabbitMQ是使用Erlang語言編寫,基于AMQP協(xié)議的。
查看全部 -
很好 太實用? 謝謝老師
查看全部 -
一直連接超時,后面才想起來防火墻只開放了15672端口,忘記開放5672端口了(?_?)查看全部
-
Server:又稱Broker,接受客戶端連接,實現(xiàn)AMQP實體服務(wù)
Connection:應(yīng)用程序與Broker的網(wǎng)絡(luò)連接
Channel:網(wǎng)絡(luò)信道,幾乎所有的操作都在Channel中進行,Channel是進行消息讀寫的通道??蛻舳丝梢越⒍鄠€Channel,每個Channel代表一個會話任務(wù)。
Message:消息,服務(wù)器和應(yīng)用程序間傳送的數(shù)據(jù),由Body(消息內(nèi)容)和Properties(優(yōu)先級、延遲等高級特性)組成
查看全部 -
RabbitMQ整體架構(gòu)
查看全部 -
@EnableScheduling 啟動定時任務(wù)
線程池的創(chuàng)建 taskScheduler 創(chuàng)建線程池的方法
查看全部 -
publisher-confirms 消息確認(rèn)模式 監(jiān)聽相應(yīng)結(jié)果
查看全部 -
BIZ DB 業(yè)務(wù)的數(shù)據(jù)
MSG DB ?發(fā)送消息的日志
?第一步 發(fā)送消息之前,先落地業(yè)務(wù)數(shù)據(jù)庫和消息數(shù)據(jù)庫
第二步 發(fā)送消息 發(fā)送給mq broker(mq服務(wù)上)
第三步?mq broker收到消息會給 生產(chǎn)端一個應(yīng)答
如果沒有 收到消息 我們采用定時任務(wù)
定時拉取狀態(tài)等于0的消息。?
定時任務(wù)重發(fā)
查看全部 -
rabbitmq的配置
concurrency:連接數(shù)
prefetch限流 ?//prefetch=1 同一時間 只能有一條消息過來?
ackonwledge-mode=AUTO //manual手動簽收,auto自動簽收
查看全部 -
routingKey 路由鍵
correlationData 消息的唯一id
Routing key : ?order. * ?order.# 區(qū)別
order.* 只支持 order.abc
order.# 支持 order.abc.1234
查看全部 -
Server:又稱Broker(實體服務(wù)) 接收客戶端的連接。實現(xiàn)AMQP實體服務(wù)
Connection:連接,應(yīng)用程序與Broker的網(wǎng)絡(luò)連接
Channel :網(wǎng)絡(luò)信道,幾乎所有的操作都在Chanel中進行,Channel是進行消息讀寫的通道。客戶端可建立多個Channel,每個Channel代表一個
會話任務(wù)
Message:消息,服務(wù)器和應(yīng)用程序之間傳送的數(shù)據(jù),由Properties和Body組成。Properties可以對消息進行修飾,比如消息的優(yōu)先級,延遲等高級特性;Body則就是消息體內(nèi)容。
Virtual host:虛擬地址,用于進行邏輯隔離,最上層的消息路由。一個
Virtual host里面可以有若干個Exchange和Queue,同一個Virtual host里面不能有相同名稱的Exchange或Queue(用于隔離不同的項目和應(yīng)用的)
Exchange:交換機,接收消息,根據(jù)路由鍵轉(zhuǎn)發(fā)消息到綁定的隊列
Binding:Exchange和Queue之間的虛擬連接,binding中可以包含routing key
Routing key:一個路由規(guī)則,虛擬機可用它來確定如何路由一個特定消息
Queue:也稱為Message Queue,消息隊列,保存消息并將它們轉(zhuǎn)發(fā)給消費者,消費者直接監(jiān)聽隊列就能收到消息了
查看全部 -
RabbitMQ?簡Q
目前很多互聯(lián)網(wǎng)大廠都在使用RabbitMQ
RabbitMQ底層是采用Erlang語言進行編寫的
Erlang語言在交換機領(lǐng)域非常受歡迎的,低延遲,復(fù)制數(shù)據(jù)延遲低不低。低的話說明性能好
開源?性能優(yōu)秀?穩(wěn)定性保障
與SpringAMOP完美的整合,API豐富
集群模式豐富?表達(dá)式配置 HA模式?鏡像隊列模型
保證數(shù)據(jù)不丟失的前提做到高可靠性?可用性
集群構(gòu)建模型:主從 、鏡像隊列、遠(yuǎn)程模式
普遍用鏡像隊列?前端用haproxy做到負(fù)載均衡?上一層加keepalived達(dá)到高可用
AMQP:Advanced Message Queuing Protocol
AMQP翻譯:高級消息隊列協(xié)議
是一套規(guī)范
通過路由關(guān)聯(lián)?
Virtual?host?虛擬主機
查看全部 -
rabbitMq基于erlang編寫,所以要搭建erlang環(huán)境。
rabbitMq是amqp協(xié)議????
查看全部
舉報