-
消息記錄表中消息的狀態(tài):0消息發(fā)送中,1發(fā)送成功,2發(fā)送失敗
把業(yè)務(wù)數(shù)據(jù)、消息記錄分別插入相應(yīng)的數(shù)據(jù)表
發(fā)送消息
監(jiān)聽消息確認(rèn)(收到確認(rèn),消息狀態(tài)從0改為1)
定時任務(wù):定時獲取消息狀態(tài)為0的消息,重新發(fā)送
重新發(fā)送三次后如果還是發(fā)送不了,狀態(tài)改為2,人工發(fā)送
查看全部 -
保障消息100%投遞成功
查看全部 -
AMQP協(xié)議模型
查看全部 -
RoutingKey模糊匹配:
order.*匹配一切以"order."開頭的、后面不帶點的路由名稱(order.123,order.abc等)
order.#匹配一個或多個詞(order.123.123,order.aaa.bbb等)
查看全部 -
實體對象一般都要implements Serializable
查看全部 -
rabbitMq安裝
查看全部 -
RabbitMQ消息是如何流轉(zhuǎn)的: Message與Exchange之間實際上有virtual host這一環(huán)節(jié)
查看全部 -
AMQP協(xié)議模型
查看全部 -
RabbitMQ的整體架構(gòu)
查看全部 -
保存學(xué)習(xí)查看全部
-
MQ可靠性投遞查看全部
-
Routing key規(guī)則:1、order.*(僅僅匹配一個單詞,如:order.adc 、order.wer。不能匹配:order.adf.sdf)
2、order.#(可以匹配多個單詞)
查看全部 -
AMQP核心概念:1、Server:又稱Broker,接受客戶端的連接,實現(xiàn)AMQP實體服務(wù)
2、Connection:連接,應(yīng)用程序與Broker的網(wǎng)絡(luò)連接
3、Channel:網(wǎng)絡(luò)信道,幾乎所有的操作都在Channel中進(jìn)行,Channel是進(jìn)行消息讀寫的通道??蛻舳丝山⒍鄠€Channel,每個Channel代表一個回話任務(wù)。
4、消息,服務(wù)器和應(yīng)用程序之間傳送的數(shù)據(jù),RabbitMQ的消息分為Properties和Body組成。Properties可以對消息進(jìn)行修飾,比如消息的優(yōu)先 級、延遲等高級特性;Body則是消息體內(nèi)容。
5、Virtual host:虛擬主機(jī),用于進(jìn)行邏輯隔離,最上層的消息路由。一個Virtual Host里面可以有若干個Exchange和Queue,同一個Virtual Host里面不能有相同名稱的Exchange或Queue。
6、Exchange:交換機(jī),接收消息,根據(jù)路由建轉(zhuǎn)發(fā)消息到綁定的隊列。
7、Binding:Exchange和Queue之間的虛擬連接,bingding中可以包含routing key。
8、Routing key;一個路由規(guī)則,虛擬機(jī)可以用它來確定如何路由一個特定消息。
9、Queue;也稱Message Queue,消息隊列,保存消息并將它們轉(zhuǎn)發(fā)給消費者。
查看全部 -
RabbitMQ:1、 啟動命令:rabbitmq-server start &
????內(nèi)存方式存儲:rabbitmq-server start --ram
2、是否啟動:lsof -i:5672
3、管理插件:rabbitmq-plugins enable rabbitmq_management
????插件列表:rabbitmq-plugins list
4、訪問地址:http://192.168.11.76:15672/
查看全部 -
查看未正常關(guān)閉掉RabbitMQ的相關(guān)進(jìn)程:ps -ef | grep rabbit
查看全部
舉報