异常排查记录amqp协议链接陷阱
前言
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协议链接异常的资料请关注编程网其它相关文章！
免责声明：
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的，并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据，供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
