异常排查记录amqp协议链接陷阱

更新时间：2022年02月24日 14:35:34 作者：kl

这篇文章主要介绍了一次关于amqp协议链接陷阱-An unexpected connection driver error occured的异常排查记录，有需要的朋友可以借鉴参考下，希望能够有所帮助

前言

amqp是一种通用的消息队列数据传输协议，典型的MQ应用RabbitMQ就实现了amqp协议，所以，我们在使用amqp-client链接rabbitmq时，可以使用amqp的链接协议连接rabbitmq。但是博主在尝试使用amqp协议链接时，碰到了一个隐藏的连接协议规范问题，故记录在此。

amqp协议文档：https://www.rabbitmq.com/uri-spec.html

问题背景

amqp-client版本：5.4.x
amqp-url：amqp://keking:kk123456@192.168.1.226:5672/

异常信息

异常一：

11:49:12.329 [AMQP Connection 192.168.1.226:5672] ERROR com.rabbitmq.client.impl.ForgivingExceptionHandler - An unexpected connection driver error occured
java.net.SocketException: socket closed
	at java.net.SocketInputStream.socketRead0(Native Method) ~[?:1.8.0_77]
	at java.net.SocketInputStream.socketRead(SocketInputStream.java:116) ~[?:1.8.0_77]
	at java.net.SocketInputStream.read(SocketInputStream.java:170) ~[?:1.8.0_77]
	at java.net.SocketInputStream.read(SocketInputStream.java:141) ~[?:1.8.0_77]
	at java.io.BufferedInputStream.fill(BufferedInputStream.java:246) ~[?:1.8.0_77]
	at java.io.BufferedInputStream.read(BufferedInputStream.java:265) ~[?:1.8.0_77]
	at java.io.DataInputStream.readUnsignedByte(DataInputStream.java:288) ~[?:1.8.0_77]
	at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:91) ~[amqp-client-5.4.3.jar:5.4.3]
	at com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:164) ~[amqp-client-5.4.3.jar:5.4.3]
	at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:596) [amqp-client-5.4.3.jar:5.4.3]
	at java.lang.Thread.run(Thread.java:745) [?:1.8.0_77]
Disconnected from the target VM, address: '127.0.0.1:0', transport: 'socket'

异常二：

java.lang.IllegalArgumentException: Multiple segments in path of AMQP URI: /%2Fapp/kl
	at com.rabbitmq.client.ConnectionFactory.setUri(ConnectionFactory.java:348)
	at com.rabbitmq.client.ConnectionFactory.setUri(ConnectionFactory.java:370)
	at com.jd.blockchain.consensus.mq.factory.RabbitFactory.initConnectionFactory(RabbitFactory.java:42)
	at com.jd.blockchain.consensus.mq.factory.RabbitFactory.main(RabbitFactory.java:52)

原因分析

异常一分析：

首先抛出上面异常，是因为rabbitmq服务器拒绝了你的操作，中断了你的连接，所以一般应用在刚启动建立连接时并不会报错，而是在发送数据时报链接的错误。拒绝操作的原因是当前链接的账号没有vhost的操作权限。那么基于这个原因，很可能是如下的问题：

1、当前账号没有权限

2、当前账号没有操作具体的vhost的权限

网上很多人的问题都是第一个，忘记给账号赋值权限了，博主的问题是因为amqp的连接串有问题，导致链接了错误的vhost，所以表象就是没有权限。rabbitmq默认的vhost是“/”,amqp://keking:kk123456@192.168.1.226:5672/连接串代表的vhost并不是“/”，而是“”。

异常二分析：

针对异常二的问题，在amqp链接协议中，vhost部分的斜杆目录需要使用%2f代替，不然客户端在解析URI的时候，分割链接时就会抛出协议不正确的异常

解决问题

amqp链接协议详情如下：

所以，要链接到“/”的vhost，正确的链接应该要在尾部加上“%2f”，如

“amqp://keking:kk123456@192.168.1.226:5672/%2f”

以上就是异常排查记录amqp协议链接陷阱的详细内容，更多关于amqp协议链接异常的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

java web实现自动登录功能
这篇文章主要为大家详细介绍了java web实现自动登录功能，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2017-10-10
java线程并发semaphore类示例
Java 5.0里新加了4个协调线程间进程的同步装置，它们分别是Semaphore, CountDownLatch, CyclicBarrier和Exchanger,本例主要介绍Semaphore,Semaphore是用来管理一个资源池的工具，可以看成是个通行证
2014-01-01
Java中this，static，final，const用法详解
这篇文章主要介绍了Java中this，static，final，const用法详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2019-07-07
Java NIO 中 Selector 解析
这篇文章主要介绍了Java NIO 中 Selector，Selector即选择器，选择器提供选择执行已经就绪的任务的能力即为翻译为多路复用，下面文章对Selector详细介绍内容，需要的小伙伴可以参考一下
2022-02-02
JAVA日常开发中读写XML的方法详解
这篇文章主要介绍了JAVA日常开发中读写XML的相关资料,详细讲解了在Java中如何使用DOM（文档对象模型）和SAX（简单API for XML）两种方式读取XML文件,以及如何使用DOM和JAXB（Java Architecture for XML Binding）两种方式写入XML文件,需要的朋友可以参考下
2024-12-12
SpringBoot 表单提交全局日期格式转换器实现方式
这篇文章主要介绍了SpringBoot 表单提交全局日期格式转换器,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2023-04-04
Java正则表达式Pattern和Matcher原理详解
这篇文章主要介绍了Java正则表达式Pattern和Matcher原理详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2020-02-02
Java通过值查找对应的枚举的实现
本文主要介绍了Java通过值查找对应的枚举的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2022-02-02
Springboot maven项目配置文件覆盖问题的处理
这篇文章主要介绍了Springboot maven项目配置文件覆盖问题的处理方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
2024-05-05
java高并发的用户线程和守护线程详解
本篇文章主要介绍了浅谈java中守护线程与用户线程，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2021-10-10