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