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