快捷導(dǎo)航

異常排查記錄amqp協(xié)議鏈接陷阱

更新時(shí)間：2022年02月24日 14:35:34 作者：kl

這篇文章主要介紹了一次關(guān)于amqp協(xié)議鏈接陷阱-An?unexpected?connection?driver?error?occured的異常排查記錄，有需要的朋友可以借鑒參考下，希望能夠有所幫助

前言

amqp是一種通用的消息隊(duì)列數(shù)據(jù)傳輸協(xié)議，典型的MQ應(yīng)用RabbitMQ就實(shí)現(xiàn)了amqp協(xié)議，所以，我們?cè)谑褂胊mqp-client鏈接rabbitmq時(shí)，可以使用amqp的鏈接協(xié)議連接rabbitmq。但是博主在嘗試使用amqp協(xié)議鏈接時(shí)，碰到了一個(gè)隱藏的連接協(xié)議規(guī)范問(wèn)題，故記錄在此。

amqp協(xié)議文檔：https://www.rabbitmq.com/uri-spec.html

問(wèn)題背景

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)

原因分析

異常一分析：

首先拋出上面異常，是因?yàn)閞abbitmq服務(wù)器拒絕了你的操作，中斷了你的連接，所以一般應(yīng)用在剛啟動(dòng)建立連接時(shí)并不會(huì)報(bào)錯(cuò)，而是在發(fā)送數(shù)據(jù)時(shí)報(bào)鏈接的錯(cuò)誤。拒絕操作的原因是當(dāng)前鏈接的賬號(hào)沒(méi)有vhost的操作權(quán)限。那么基于這個(gè)原因，很可能是如下的問(wèn)題：

1、當(dāng)前賬號(hào)沒(méi)有權(quán)限

2、當(dāng)前賬號(hào)沒(méi)有操作具體的vhost的權(quán)限

網(wǎng)上很多人的問(wèn)題都是第一個(gè)，忘記給賬號(hào)賦值權(quán)限了，博主的問(wèn)題是因?yàn)閍mqp的連接串有問(wèn)題，導(dǎo)致鏈接了錯(cuò)誤的vhost，所以表象就是沒(méi)有權(quán)限。rabbitmq默認(rèn)的vhost是“/”,amqp://keking:kk123456@192.168.1.226:5672/連接串代表的vhost并不是“/”，而是“”。