1.日志信息：

2019-09-26 15:27:03.415 ERROR 13580 --- [ 127.0.0.1:5672] o.s.a.r.c.CachingConnectionFactory?????? : Channel shutdown: connection error; protocol method: #method<connection.close>(reply-code=503, reply-text=COMMAND_INVALID - unknown exchange type 'x-delayed-message', class-id=40, method-id=10)

2.原因分析

延時(shí)隊(duì)列報(bào)錯(cuò)

ShutdownSignalException: connection error; protocol method:#method<connection.close>(reply-code=503, reply-text=COMMAND_INVALID - unknown exchange type 'x-delayed-message', class-id=40, method-id=10)

代表沒(méi)有找到對(duì)應(yīng)x-delayed-message的exchange type

RabbitMQ默認(rèn)的交換機(jī)類(lèi)型為：

headers、direct、fanout、topic

??????

3.解決方法：

1、下載rabbitMQ插件

插件下載地址：https://www.rabbitmq.com/community-plugins.html

選擇rabbitmq_delayed_message_exchange插件。

根據(jù)安裝的RabbitMQ版本選擇相對(duì)應(yīng)版本的插件。

這里我本機(jī) RabbitMQ安裝的是3.7.18版本的，所以選擇下載3.7.x版本的插件。

在下載好之后，解壓得到 .ez 結(jié)尾的插件包，將其復(fù)制到RabbitMQ安裝目錄下的 plugins 文件夾。

下面是我解壓出來(lái)的.ez文件：

復(fù)制粘貼到plugins文件夾下：

然后通過(guò)命令行啟用該插件：

rabbitmq-plugins enable rabbitmq_delayed_message_exchange

至此，就添加了x-delayed-message類(lèi)型的交換機(jī)

4.注意問(wèn)題

RabbitMQ版本為3.7.17時(shí)插件能成功安裝，但是不能正常使用，依然會(huì)報(bào)錯(cuò)！！！！

我這里是升級(jí)了一個(gè)版本，到3.7.18。

或者使用3.6低版本也可以避免此問(wèn)題。

總結(jié)

以上是生活随笔為你收集整理的reply-code=503, reply-text=COMMAND_INVALID - unknown exchange type 'x-delayed-message'的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。