热门标签
热门文章
- 1怎样才能从Java初级程序员成长为一名合格的架构师？
- 2Mysql的ROW_NUMBER()的使用
- 3python的工具包有哪些,python工具包有哪些
- 4【投稿优惠-EI稳定检索】2024年先进机械电子、电气工程与自动化国际学术会议(ICAMEEA 2024)
- 5a == 1 && a== 2 && a== 3 返回 true ？
- 6Java汉语言处理工具：HanLP初体验_java hanlp
- 7第十八届全国大学智能汽车竞赛报名信息统计_智能车大赛参赛队伍csdn
- 8今日arXiv最热大模型论文：清华大学发布，ChatGML又添新功能，集成“自我批评”，提升数学能力
- 9使用Kimi大语言模型实现知识图谱抽取_kim大模型
- 10Git submodule 命令简介_git sumodule update 意思
当前位置: article > 正文
【原创】RabbitMQ 之 mandatory
作者：小蓝xlanll | 2024-04-25 04:23:54
赞
踩
rabbitmq mandatory
1.什么情况会导致 blackholed？
两种情况：
- 声明 exchange 后未绑定任何 queue ，此时发送到该 exchange 上的 message 均被 blackholed ；
- 声明 exchange 后绑定了 queue ，但发送到该 exchange 上的 message 所使用的 routing_key 不匹配任何 binding_key ，则 blackholed 。
决定 message 将被如何处理，是被 exchange 直接丢弃还是由其发回给 producer （Basic.Return+Content-Header+Content-Body）。
3.mandatory 和 Publisher confirm 机制的区别？
Publisher confirm 机制是用来确认 message 的可靠投递，mandatory 参数是用来确保在 queue 不存在的情况下，message 不会被 blackholed 。
queue 存在时，开启 mandatory 的情况：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
|
[warn] evsignal_init: socketpair: No error
drive_machine: [conn_init] ---
in
TCP 3-way connecting!
drive_machine: [conn_connecting] --- connection timeout 1
time
on socket(6040)
drive_machine: [conn_connected] --- connected on socket(6040)
6040: conn_state change connected ==> snd_protocol_header
--> Send Protocol.Header!
6040: conn_state change snd_protocol_header ==> rcv_connection_start_method
<-- Recv Connection.Start Method frame!
6040: conn_state change rcv_connection_start_method ==> snd_connection_start_rsp_method
--> Send Connection.Start-Ok Method frame!
6040: conn_state change snd_connection_start_rsp_method ==> rcv_connection_tune_method
drive_machine: wait
for
Connection.Tune method another 10 seconds!!
<-- Recv Connection.Tune Method frame!
6040: conn_state change rcv_connection_tune_method ==> snd_connection_tune_rsp_method
--> Send Connection.Tune-Ok Method frame!
6040: conn_state change snd_connection_tune_rsp_method ==> snd_connection_open_method
--> Send Connection.Open Method frame!
6040: conn_state change snd_connection_open_method ==> rcv_connection_open_rsp_method
<-- Recv Connection.Open-Ok Method frame!
6040: conn_state change rcv_connection_open_rsp_method ==> snd_channel_open_method
--> Send Channel.Open Method frame!
6040: conn_state change snd_channel_open_method ==> rcv_channel_open_rsp_method
drive_machine: wait
for
Channel.Open-Ok method another 10 seconds!!
<-- Recv Channel.Open-Ok Method frame!
6040: conn_state change rcv_channel_open_rsp_method ==> idle
drive_machine: [conn_idle] --- [PRODUCER]: Find something to send!
6040: conn_state change idle ==> snd_basic_publish_method
--> Send Basic.Publish Method frame!
6040: conn_state change snd_basic_publish_method ==> snd_basic_content_header
--> Send Content-Header frame!
6040: conn_state change snd_basic_content_header ==> snd_basic_content_body
--> Send Content-Body frame!
6040: conn_state change snd_basic_content_body ==> idle
drive_machine: [conn_idle] --- [PRODUCER]: Find nothing to send! wait
for
another 10 seconds
drive_machine: [conn_idle] --- [PRODUCER]: Find nothing to send! wait
for
another 10 seconds
|
queue 不存在时，开启 mandatory 的情况：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
|
[warn] evsignal_init: socketpair: No error
drive_machine: [conn_init] ---
in
TCP 3-way connecting!
drive_machine: [conn_connecting] --- connection timeout 1
time
on socket(8088)
drive_machine: [conn_connected] --- connected on socket(8088)
8088: conn_state change connected ==> snd_protocol_header
--> Send Protocol.Header!
8088: conn_state change snd_protocol_header ==> rcv_connection_start_method
drive_machine: wait
for
Connection.Start method another 10 seconds!!
<-- Recv Connection.Start Method frame!
8088: conn_state change rcv_connection_start_method ==> snd_connection_start_rsp_method
--> Send Connection.Start-Ok Method frame!
8088: conn_state change snd_connection_start_rsp_method ==> rcv_connection_tune_method
<-- Recv Connection.Tune Method frame!
8088: conn_state change rcv_connection_tune_method ==> snd_connection_tune_rsp_method
--> Send Connection.Tune-Ok Method frame!
8088: conn_state change snd_connection_tune_rsp_method ==> snd_connection_open_method
--> Send Connection.Open Method frame!
8088: conn_state change snd_connection_open_method ==> rcv_connection_open_rsp_method
<-- Recv Connection.Open-Ok Method frame!
need to code something!
8088: conn_state change rcv_connection_open_rsp_method ==> snd_channel_open_method
--> Send Channel.Open Method frame!
8088: conn_state change snd_channel_open_method ==> rcv_channel_open_rsp_method
drive_machine: wait
for
Channel.Open-Ok method another 10 seconds!!
<-- Recv Channel.Open-Ok Method frame!
need to code something!
8088: conn_state change rcv_channel_open_rsp_method ==> idle
drive_machine: [conn_idle] --- [PRODUCER]: Find something to send!
8088: conn_state change idle ==> snd_basic_publish_method
--> Send Basic.Publish Method frame!
8088: conn_state change snd_basic_publish_method ==> snd_basic_content_header
--> Send Content-Header frame!
8088: conn_state change snd_basic_content_header ==> snd_basic_content_body
--> Send Content-Body frame!
8088: conn_state change snd_basic_content_body ==> rcv_basic_return_method
<-- Recv Basic.Return Method frame!
### reply_code: 312, reply_text: NO_ROUTE, exchange=amq.direct, routing_key=test1
8088: conn_state change rcv_basic_return_method ==> idle
drive_machine: [conn_idle] --- [PRODUCER]: Find nothing to send! wait
for
another 10 seconds
drive_machine: [conn_idle] --- [PRODUCER]: Find nothing to send! wait
for
another 10 seconds
|
该图显示了在 Basic.Publish 中设置 mandatory 为 true 。
该图中显示了当 queue 不存在时，服务器返回 Basic.Return + Content.Header + Content.Body 的内容。
下图为正常情况和异常情况。
声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/小蓝xlanll/article/detail/483235
推荐阅读
相关标签
