-
消費不了,兩個可能:
一是 rabbitmq配置錯誤,
二是 發送端和消費端的實體類的路徑不一致;
查看全部 -
保障100%消息投遞成功方案: sender 發送消息后,等待 broker 返回確認,超時未收到返回時通知 (用定時任務掃描狀態未成功,且超過時間跨度的消息),則通知 sender 再次發送。
(這步解決了消息發送時丟失的問題,但是產生了重復發送的問題:消息確實發送成功了,但是丟失了返回確認通知,要解決這個問題需要在消費端服務進行冪等)
查看全部 -
演示配置: /etc/hostname (配置主機) /etc/hosts (搭建集群配置)
安裝軟件:erlang , socat (秘鑰工具) , rabbitmq-server? (按這個順序依次安裝)
修改控制臺的用戶名密碼: /ebin/rabbit.app 文件編輯 loopback_users
改為 [guest] (去掉雙尖括號和雙引號,當做常量)
--------------------------------------------------------
rabbitmqctl 集群相關的各種操作
rabbitmq-server 啟動服務
驗證是否啟動成功:# lsof -i:5672(端口)?
--------------------------------------------------------
rabbitmq-plugins 安裝插件(比如控制臺)
#rabbitmq-plugins list? ?( 打印列表,找到?rabbitmq_management )
#rabbitmq-plugins? enable rabbitmq_management? (把它 enable )
在瀏覽器打開管控臺(默認 15672)
查看全部 -
基于 AMQP 協議 ,用 erlang 語言編寫,延遲度低
特點:集群模式豐富(主要采用鏡像隊列,保證消息不丟失),表達式配置,ha模式,
--------------------------------------------------------
AMQP 模型: publisher -> [ exchange -> queue] ( 這里就是 broker 或 server )? -> consumer
exchange 與 queue 之間建立了路由關系
查看全部 -
下載rabbitMQ的步驟
如果沒刪干凈的話,會報錯,在9:58的位置會有解決方法
查看全部 -
RabbitMQ是一個開源的消息代理和隊列服務器,用來通過普通協議在完全不同的應用之間共享數據,RabbitMQ是使用Erlang語言來編寫的,并且RabbitMQ是基于AMQP協議的。
開源、性能優秀,穩定性保障
與SpringAMQP完美的整合、API豐富
集群模式豐富,表達式配置,HA模式,鏡像隊列模型
保證數據不丟失的前提做到可靠性、可用性
AMQP全稱:Advanced Message Queuing Protocal(高級消息隊列)
查看全部 -
滴滴頭條,美團都在用這個
可靠性投遞
通過confirm模式
消息入庫
ack
查看全部 -
2
查看全部 -
8
查看全部 -
ack手工簽收
查看全部 -
手工簽收必須依賴通道
分為消息體和消息頭
手工簽收有一個basicAck的響應
查看全部 -
1
查看全部 -
1
?
查看全部 -
路由規則
broker就是服務
查看全部 -
publisher-confirms 異步等待消息結果
查看全部
舉報