前言
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/
异常信息
异常一:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
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' |
异常二:
1
2
3
4
5
|
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协议链接异常的资料请关注服务器之家其它相关文章!
原文链接:http://www.kailing.pub/article/index/arcid/272.html