论坛
潜水/灌水快乐,沉淀知识,认识更多同行。
ToB圈子
加入IT圈,遇到更多同好之人。
朋友圈
看朋友圈动态,了解ToB世界。
ToB门户
了解全球最新的ToB事件
博客
Blog
排行榜
Ranklist
文库
业界最专业的IT文库,上传资料也可以赚钱
下载
分享
Share
导读
Guide
相册
Album
记录
Doing
搜索
本版
文章
帖子
ToB圈子
用户
免费入驻
产品入驻
解决方案入驻
公司入驻
案例入驻
登录
·
注册
只需一步,快速开始
账号登录
立即注册
找回密码
用户名
Email
自动登录
找回密码
密码
登录
立即注册
首页
找靠谱产品
找解决方案
找靠谱公司
找案例
找对的人
专家智库
悬赏任务
圈子
SAAS
IT评测·应用市场-qidao123.com
»
论坛
›
大数据
›
数据仓库与分析
›
SpringBoot毗连rabbitmq 报错 An unexpected connection ...
SpringBoot毗连rabbitmq 报错 An unexpected connection driver error occu ...
傲渊山岳
论坛元老
|
2025-3-20 13:22:20
|
显示全部楼层
|
阅读模式
楼主
主题
1004
|
帖子
1004
|
积分
3012
SpringBoot在启动时报错,毗连不上rabbitmq,报错内容如下
24-09-30.13:36:02.406 [AMQP Connection 47.121.218.83:5672] ERROR ForgivingExceptionHandler - An unexpected connection driver error occurred
java.net.SocketException: socket closed
at java.net.SocketInputStream.socketRead0(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 failed
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来开辟支持消息队列的应用程序。
<!-- 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 配置;rabbitmq
spring:
rabbitmq:
addresses: 127.0.0.1
port: 5672
username: test
password: test
listener:
simple:
prefetch: 1 # 每次投递n个消息,消费完在投递n个
topic:
activity_sku_stock: activity_sku_stock
# virtual-host 是一个逻辑隔离单位,用于将不同的应用程序或环境隔离开来。
# virtual-host: master 表示应用程序将连接到名为 master 的虚拟主机。
virtual-host: master
复制代码
[code][/code]
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。
本帖子中包含更多资源
您需要
登录
才可以下载或查看,没有账号?
立即注册
x
回复
使用道具
举报
0 个回复
正序浏览
返回列表
快速回复
高级模式
B
Color
Image
Link
Quote
Code
Smilies
您需要登录后才可以回帖
登录
or
立即注册
本版积分规则
发表回复
回帖并转播
发新帖
回复
傲渊山岳
论坛元老
这个人很懒什么都没写!
楼主热帖
2022你不容错过的软件测试项目实战(we ...
SQL Server创建表
Swift之Codable自定义解析将任意数据类 ...
MySQL max() min() 函数取值错误
K8S 性能优化 - K8S APIServer 调优 ...
【微服务专题之】.Net6下集成微服务网 ...
ThinkPHP5 远程命令执行漏洞
kubernetes top查看内存CPU使用情况 ...
变量的定义和使用
2022年春节后这波疫情对于国内SAP咨询 ...
标签云
运维
CIO
存储
服务器
浏览过的版块
向量数据库
快速回复
返回顶部
返回列表