spring cloud stream开发遇到的问题（一）：连接

在使用消息队列开发Spring cloud stream项目时，连接rabbitmq遇到一个问题：

问题1：连接报错信息

com.rabbitmq.client.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)

解决方法：安装x-delayed-message插件

下面介绍一下安装过程：

下载插件
我下载的是3.7.xand 3.8.x版本的

延迟插件版本.png

• 下载完成后是一个zip / ez 包,解压缩 将ez文件拷贝到rabbitmq安装目录下的plugins目录中

安装

cmd 进入F:\Program Files\RabbitMQ Server\rabbitmq_server-3.8.16\sbin
执行：rabbitmq-plugins enable rabbitmq_delayed_message_exchange
启动 rabbitmq-service.bat start
关闭 rabbitmq-service.bat stop

执行安装过程如下图：

安装过程.png

验证

进入mqweb地址，查看如下图表示安装成功：

安装结果验证.png