SpringBoot毗连rabbitmq 报错 An unexpected connection driver error occu ...

打印 上一主题 下一主题

主题 1004|帖子 1004|积分 3012

SpringBoot在启动时报错,毗连不上rabbitmq,报错内容如下
  1. 24-09-30.13:36:02.406 [AMQP Connection 47.121.218.83:5672] ERROR ForgivingExceptionHandler - An unexpected connection driver error occurred
  2. java.net.SocketException: socket closed
  3.     at java.net.SocketInputStream.socketRead0(Native Method)
  4.     at java.net.SocketInputStream.socketRead(SocketInputStream.java:116)
  5.     at java.net.SocketInputStream.read(SocketInputStream.java:171)
  6.     at java.net.SocketInputStream.read(SocketInputStream.java:141)
  7.     at java.io.BufferedInputStream.fill(BufferedInputStream.java:246)
  8.     at java.io.BufferedInputStream.read(BufferedInputStream.java:265)
  9.     at java.io.DataInputStream.readUnsignedByte(DataInputStream.java:288)
  10.     at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:91)
  11.     at com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:184)
  12.     at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:665)
  13.     at java.lang.Thread.run(Thread.java:748)
  14. 24-09-30.13:36:02.407 [RMI TCP Connection(2)-192.168.1.110] WARN  RabbitHealthIndicator  - Rabbit health check failed
  15. org.springframework.amqp.AmqpIOException: java.io.IOException
复制代码
办理方法
1. 创建一个用户
参考:An unexpected connection driver error occured错误(亲测有效)-CSDN博客
添加一个用户:
 查看test的详情:

 添加权限:

2. 设置文件添加 virtual-host,具体如下:
我使用的项目依赖是spring-boot-starter-amqp,这个依赖紧张用于简化在Spring Boot应用中集成AMQP协议相关功能的过程,比如与RabbitMQ服务器进行消息通信等场景。通过引入这个依赖,开辟者可以更方便地使用Spring Boot来开辟支持消息队列的应用程序。
  1. <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-amqp -->
  2. <dependency>
  3.    <groupId>org.springframework.boot</groupId>
  4.    <artifactId>spring-boot-starter-amqp</artifactId>
  5.    <version>3.2.0</version>
  6. </dependency>
复制代码
设置文件:
  1. # Spring 配置;rabbitmq
  2. spring:
  3.   rabbitmq:
  4.     addresses: 127.0.0.1
  5.     port: 5672
  6.     username: test
  7.     password: test
  8.     listener:
  9.       simple:
  10.         prefetch: 1 # 每次投递n个消息,消费完在投递n个
  11.     topic:
  12.       activity_sku_stock: activity_sku_stock
  13.     # virtual-host 是一个逻辑隔离单位,用于将不同的应用程序或环境隔离开来。
  14.     # virtual-host: master 表示应用程序将连接到名为 master 的虚拟主机。
  15.     virtual-host: master
复制代码
[code][/code]


免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。

本帖子中包含更多资源

您需要 登录 才可以下载或查看,没有账号?立即注册

x
回复

使用道具 举报

0 个回复

倒序浏览

快速回复

您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

傲渊山岳

论坛元老
这个人很懒什么都没写!
快速回复 返回顶部 返回列表