发布时间:2025-06-24 19:38:40 作者:北方职教升学中心 阅读量:347
解决方法。n个正在投递 topic: activity_sku_stock: activity_sku_stock # virtual-host 逻辑隔离单位,隔离不同的应用程序或环境。引入这个依赖Spring开发者可以更方便地使用 Boot开发支持消息队列的应用程序。
启动时SpringBoot报错,不能连接到rabitmq,报错内容如下。 virtual-host: master。
1. 创建用户。
24-09-30.13:36:02.406 [AMQP Connection 47.121.218.83:5672] ERROR ForgivingExceptionHandler - An unexpected connection driver error occurredjava.net.SocketException: socket closed at java.net.SocketInputStream.socketread(Native Method) at java.net.SocketInputStream.socketRead(SocketInputStream.java:116) at java.net.SocketInputStream.read(SocketInputStream.java:171) at java.net.SocketInputStream.read(SocketInputStream.java:141) at java.io.BufferedInputStream.fill(BufferedInputStream.java:246) at java.io.BufferedInputStream.read(BufferedInputStream.java:265) at java.io.DataInputStream.readUnsignedByte(DataInputStream.java:288) at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:91) at com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:184) at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:665) at java.lang.Thread.run(Thread.java:748)24-09-30.13:36:02.407 [RMI TCP Connection(2)-192.168.1.110] WARN RabbitHealthIndicator - Rabbit health check failedorg.springframework.amqp.AmqpIOException: java.io.IOException。解决方案。 # virtual-host: master 表示应用程序连接到名称 master 虚拟主机。与RabbitMQ服务器进行消息通信等场景。
<!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-amqp --><dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> <version>3.2.0</version></dependency>
配置文件:
# Spring 配置;rabbitmqspring: rabbitmq: addresses: 127.0.0.1 port: 5672 username: test password: test listener: simple: prefetch: 1 # 每次发送n个消息,消费完成后,添加用户:
查看test的细节:
添加权限:
2. 添加配置文件 virtual-host,具体如下:
我使用的项目依赖于spring-boot-starter-amqp,这种依赖主要用于简化Spring AMQP协议相关功能在Boot应用中集成的过程,例如,参考:An unexpected connection driver error occured错误(个人测试有效)-CSDN博客。 # virtual-host: master 表示应用程序连接到名称 master 虚拟主机。