You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by hunan <na...@xa.vixtel.com> on 2011/06/23 03:32:35 UTC
our program reconnect repeatly due to java.net.SocketException:
Connection reset
we use activemq 5.3.0 , our client program reconnect repeatly due to "
java.net.SocketException: Connection reset" on that computer , but normal on
other computers , the concrete logs is:
[DEBUG] 2011-06-17 21:11:39,343 []
org.apache.activemq.transport.ResponseCor
relator.onCommand(ResponseCorrelator.java:105) Received unexpected
resp
onse: {Response {commandId = 0, responseRequired = false, correlationId =
1}}for
command id: 1
[DEBUG] 2011-06-17 21:11:39,359 []
org.apache.activemq.transport.ResponseCor
relator.onCommand(ResponseCorrelator.java:105) Received unexpected
resp
onse: {Response {commandId = 0, responseRequired = false, correlationId =
28}}fo
r command id: 28
[DEBUG] 2011-06-17 21:11:39,359 []
org.apache.activemq.transport.ResponseCor
relator.onCommand(ResponseCorrelator.java:105) Received unexpected
resp
onse: {Response {commandId = 0, responseRequired = false, correlationId =
70}}fo
r command id: 70
[DEBUG] 2011-06-17 21:11:39,375 []
org.apache.activemq.transport.ResponseCor
relator.onCommand(ResponseCorrelator.java:105) Received unexpected
resp
onse: {Response {commandId = 0, responseRequired = false, correlationId =
2}}for
command id: 2
[DEBUG] 2011-06-17 21:13:39,281 []
org.apache.activemq.transport.tcp.TcpTran
sport.doStop(TcpTransport.java:458) Stopping transport
tcp:///222.12
7.223.137:61616
[WARN ] 2011-06-17 21:13:39,281 []
org.apache.activemq.transport.failover.Fa
iloverTransport.handleTransportFailure(FailoverTransport.java:206)
Transport failed to
tcp://222.127.223.137:61616?wireFormat.maxInactivityDuration
=0 , attempting to automatically reconnect due to: java.net.SocketException:
Con
nection reset
[DEBUG] 2011-06-17 21:13:39,281 []
org.apache.activemq.transport.failover.Fa
iloverTransport.handleTransportFailure(FailoverTransport.java:207)
Transport failed with the following exception:
java.net.SocketException: Connection reset
at java.net.SocketInputStream.read(Unknown Source)
at
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBuff
eredInputStream.java:50)
at
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBuff
eredInputStream.java:58)
at java.io.DataInputStream.readInt(Unknown Source)
at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.
java:272)
at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTranspo
rt.java:210)
at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.jav
a:202)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:
185)
at java.lang.Thread.run(Unknown Source)
[DEBUG] 2011-06-17 21:13:39,296 []
org.apache.activemq.transport.failover.Fa
iloverTransport.getConnectList(FailoverTransport.java:593)
urlList
connectionList:[tcp://222.127.223.137:61616?wireFormat.maxInactivityDuration=0]
[DEBUG] 2011-06-17 21:13:39,312 []
org.apache.activemq.transport.failover.Fa
iloverTransport.doReconnect(FailoverTransport.java:712) Attempting
conne
ct to: tcp://222.127.223.137:61616?wireFormat.maxInactivityDuration=0
[DEBUG] 2011-06-17 21:13:39,328 []
org.apache.activemq.transport.WireFormatN
egotiator.sendWireFormat(WireFormatNegotiator.java:82) Sending:
WireFor
matInfo { version=5, properties={TightEncodingEnabled=true, CacheSize=1024,
TcpN
oDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true,
MaxInactiv
ityDurationInitalDelay=10000, MaxInactivityDuration=0, CacheEnabled=true},
magic
=[A,c,t,i,v,e,M,Q]}
[DEBUG] 2011-06-17 21:13:39,343 []
org.apache.activemq.transport.tcp.TcpTran
sport.run(TcpTransport.java:181) TCP consumer thread for
tcp:///2
22.127.223.137:61616 starting
[DEBUG] 2011-06-17 21:13:39,375 []
org.apache.activemq.transport.WireFormatN
egotiator.negociate(WireFormatNegotiator.java:118) Received
WireFor
mat: WireFormatInfo { version=5, properties={TightEncodingEnabled=true,
CacheSiz
e=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false,
StackTraceEnabled=true
, MaxInactivityDurationInitalDelay=10000, MaxInactivityDuration=0,
CacheEnabled=
true}, magic=[A,c,t,i,v,e,M,Q]}
[DEBUG] 2011-06-17 21:13:39,375 []
org.apache.activemq.transport.WireFormatN
egotiator.negociate(WireFormatNegotiator.java:125)
tcp:///222.127.2
23.137:61616 before negotiation: OpenWireFormat{version=5,
cacheEnabled=false, s
tackTraceEnabled=false, tightEncodingEnabled=false,
sizePrefixDisabled=false}
[DEBUG] 2011-06-17 21:13:39,375 []
org.apache.activemq.transport.WireFormatN
egotiator.negociate(WireFormatNegotiator.java:140)
tcp:///222.127.2
23.137:61616 after negotiation: OpenWireFormat{version=5, cacheEnabled=true,
sta
ckTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false}
[DEBUG] 2011-06-17 21:13:39,390 []
org.apache.activemq.transport.failover.Fa
iloverTransport.restoreTransport(FailoverTransport.java:635)
restore,
replay: ActiveMQObjectMessage {commandId = 343, responseRequired = true,
messag
eId = ID:gdi030006-1660-1308315269437-0:0:18:1:1, originalDestination =
null, or
iginalTransactionId = null, producerId =
ID:gdi030006-1660-1308315269437-0:0:18:
1, destination = queue://NETVISTA.GUI.REPLY.63224970514165, transactionId =
null
, expiration = 1308315795218, timestamp = 1308315495218, arrival = 0,
brokerInTi
me = 0, brokerOutTime = 0, correlationId = null, replyTo =
queue://NETVISTA.GUI.
SYNC63224970514165, persistent = true, type = null, priority = 4, groupID =
null
, groupSequence = 0, targetConsumerId = null, compressed = false, userID =
null,
content = org.apache.activemq.util.ByteSequence@16ea3c2,
marshalledProperties =
org.apache.activemq.util.ByteSequence@1e34309, dataStructure = null,
redelivery
Counter = 0, size = 0, properties = {MESSAGE_SELECTOR=1308315495203,
COMMOND_TYP
E=0}, readOnlyProperties = true, readOnlyBody = true, droppable = false}
[DEBUG] 2011-06-17 21:13:39,406 []
org.apache.activemq.transport.failover.Fa
iloverTransport.restoreTransport(FailoverTransport.java:635)
restore,
replay: ActiveMQObjectMessage {commandId = 349, responseRequired = true,
messag
eId = ID:gdi030006-1660-1308315269437-0:0:19:1:1, originalDestination =
null, or
iginalTransactionId = null, producerId =
ID:gdi030006-1660-1308315269437-0:0:19:
1, destination = queue://NETVISTA.GUI.REPLY.63224970514165, transactionId =
null
, expiration = 1308315811390, timestamp = 1308315511390, arrival = 0,
brokerInTi
me = 0, brokerOutTime = 0, correlationId = null, replyTo = null, persistent
= tr
ue, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumer
Id = null, compressed = false, userID = null, content =
org.apache.activemq.util
.ByteSequence@e64834, marshalledProperties =
org.apache.activemq.util.ByteSequen
ce@146101f, dataStructure = null, redeliveryCounter = 0, size = 0,
properties =
{SESSION_ID=63224970514165}, readOnlyProperties = true, readOnlyBody = true,
dro
ppable = false}
[DEBUG] 2011-06-17 21:13:39,421 []
org.apache.activemq.transport.failover.Fa
iloverTransport.doReconnect(FailoverTransport.java:721) Connection
estab
lished
[INFO ] 2011-06-17 21:13:39,421 []
org.apache.activemq.transport.failover.Fa
iloverTransport.doReconnect(FailoverTransport.java:747) Successfully
rec
onnected to tcp://222.127.223.137:61616?wireFormat.maxInactivityDuration=0
[DEBUG] 2011-06-17 21:13:39,437 []
org.apache.activemq.transport.ResponseCor
relator.onCommand(ResponseCorrelator.java:105) Received unexpected
resp
onse: {Response {commandId = 0, responseRequired = false, correlationId =
1}}for
command id: 1
[DEBUG] 2011-06-17 21:13:39,437 []
org.apache.activemq.transport.ResponseCor
relator.onCommand(ResponseCorrelator.java:105) Received unexpected
resp
onse: {Response {commandId = 0, responseRequired = false, correlationId =
28}}fo
r command id: 28
[DEBUG] 2011-06-17 21:13:39,453 []
org.apache.activemq.transport.ResponseCor
relator.onCommand(ResponseCorrelator.java:105) Received unexpected
resp
onse: {Response {commandId = 0, responseRequired = false, correlationId =
70}}fo
r command id: 70
[DEBUG] 2011-06-17 21:13:39,453 []
org.apache.activemq.transport.ResponseCor
relator.onCommand(ResponseCorrelator.java:105) Received unexpected
resp
onse: {Response {commandId = 0, responseRequired = false, correlationId =
2}}for
command id: 2
[DEBUG] 2011-06-17 21:15:39,046 []
org.apache.activemq.transport.tcp.TcpTran
sport.doStop(TcpTransport.java:458) Stopping transport
tcp:///222.12
7.223.137:61616
[WARN ] 2011-06-17 21:15:39,046 []
org.apache.activemq.transport.failover.Fa
iloverTransport.handleTransportFailure(FailoverTransport.java:206)
Transport failed to
tcp://222.127.223.137:61616?wireFormat.maxInactivityDuration
=0 , attempting to automatically reconnect due to: java.net.SocketException:
Con
nection reset
[DEBUG] 2011-06-17 21:15:39,062 []
org.apache.activemq.transport.failover.Fa
iloverTransport.handleTransportFailure(FailoverTransport.java:207)
Transport failed with the following exception:
java.net.SocketException: Connection reset
at java.net.SocketInputStream.read(Unknown Source)
at
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBuff
eredInputStream.java:50)
at
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBuff
eredInputStream.java:58)
at java.io.DataInputStream.readInt(Unknown Source)
at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.
java:272)
at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTranspo
rt.java:210)
at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.jav
a:202)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:
185)
at java.lang.Thread.run(Unknown Source)
[DEBUG] 2011-06-17 21:15:39,078 []
org.apache.activemq.transport.failover.Fa
iloverTransport.getConnectList(FailoverTransport.java:593)
urlList
connectionList:[tcp://222.127.223.137:61616?wireFormat.maxInactivityDuration=0]
[DEBUG] 2011-06-17 21:15:39,078 []
org.apache.activemq.transport.failover.Fa
iloverTransport.doReconnect(FailoverTransport.java:712) Attempting
conne
ct to: tcp://222.127.223.137:61616?wireFormat.maxInactivityDuration=0
[DEBUG] 2011-06-17 21:15:39,109 []
org.apache.activemq.transport.WireFormatN
egotiator.sendWireFormat(WireFormatNegotiator.java:82) Sending:
WireFor
matInfo { version=5, properties={TightEncodingEnabled=true, CacheSize=1024,
TcpN
oDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true,
MaxInactiv
ityDurationInitalDelay=10000, MaxInactivityDuration=0, CacheEnabled=true},
magic
=[A,c,t,i,v,e,M,Q]}
[DEBUG] 2011-06-17 21:15:39,109 []
org.apache.activemq.transport.tcp.TcpTran
sport.run(TcpTransport.java:181) TCP consumer thread for
tcp:///2
22.127.223.137:61616 starting
[DEBUG] 2011-06-17 21:15:39,125 []
org.apache.activemq.transport.WireFormatN
egotiator.negociate(WireFormatNegotiator.java:118) Received
WireFor
mat: WireFormatInfo { version=5, properties={TightEncodingEnabled=true,
CacheSiz
e=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false,
StackTraceEnabled=true
, MaxInactivityDurationInitalDelay=10000, MaxInactivityDuration=0,
CacheEnabled=
true}, magic=[A,c,t,i,v,e,M,Q]}
[DEBUG] 2011-06-17 21:15:39,140 []
org.apache.activemq.transport.WireFormatN
egotiator.negociate(WireFormatNegotiator.java:125)
tcp:///222.127.2
23.137:61616 before negotiation: OpenWireFormat{version=5,
cacheEnabled=false, s
tackTraceEnabled=false, tightEncodingEnabled=false,
sizePrefixDisabled=false}
[DEBUG] 2011-06-17 21:15:39,140 []
org.apache.activemq.transport.WireFormatN
egotiator.negociate(WireFormatNegotiator.java:140)
tcp:///222.127.2
23.137:61616 after negotiation: OpenWireFormat{version=5, cacheEnabled=true,
sta
ckTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false}
[DEBUG] 2011-06-17 21:15:39,140 []
org.apache.activemq.transport.failover.Fa
iloverTransport.restoreTransport(FailoverTransport.java:635)
restore,
replay: ActiveMQObjectMessage {commandId = 343, responseRequired = true,
messag
eId = ID:gdi030006-1660-1308315269437-0:0:18:1:1, originalDestination =
null, or
iginalTransactionId = null, producerId =
ID:gdi030006-1660-1308315269437-0:0:18:
1, destination = queue://NETVISTA.GUI.REPLY.63224970514165, transactionId =
null
, expiration = 1308315795218, timestamp = 1308315495218, arrival = 0,
brokerInTi
me = 0, brokerOutTime = 0, correlationId = null, replyTo =
queue://NETVISTA.GUI.
SYNC63224970514165, persistent = true, type = null, priority = 4, groupID =
null
, groupSequence = 0, targetConsumerId = null, compressed = false, userID =
null,
content = org.apache.activemq.util.ByteSequence@16ea3c2,
marshalledProperties =
org.apache.activemq.util.ByteSequence@1e34309, dataStructure = null,
redelivery
Counter = 0, size = 0, properties = {MESSAGE_SELECTOR=1308315495203,
COMMOND_TYP
E=0}, readOnlyProperties = true, readOnlyBody = true, droppable = false}
[DEBUG] 2011-06-17 21:15:39,156 []
org.apache.activemq.transport.failover.Fa
iloverTransport.restoreTransport(FailoverTransport.java:635)
restore,
replay: ActiveMQObjectMessage {commandId = 349, responseRequired = true,
messag
eId = ID:gdi030006-1660-1308315269437-0:0:19:1:1, originalDestination =
null, or
iginalTransactionId = null, producerId =
ID:gdi030006-1660-1308315269437-0:0:19:
1, destination = queue://NETVISTA.GUI.REPLY.63224970514165, transactionId =
null
, expiration = 1308315811390, timestamp = 1308315511390, arrival = 0,
brokerInTi
me = 0, brokerOutTime = 0, correlationId = null, replyTo = null, persistent
= tr
ue, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumer
Id = null, compressed = false, userID = null, content =
org.apache.activemq.util
.ByteSequence@e64834, marshalledProperties =
org.apache.activemq.util.ByteSequen
ce@146101f, dataStructure = null, redeliveryCounter = 0, size = 0,
properties =
{SESSION_ID=63224970514165}, readOnlyProperties = true, readOnlyBody = true,
dro
ppable = false}
[DEBUG] 2011-06-17 21:15:39,171 []
org.apache.activemq.transport.failover.Fa
iloverTransport.doReconnect(FailoverTransport.java:721) Connection
estab
lished
[INFO ] 2011-06-17 21:15:39,187 []
org.apache.activemq.transport.failover.Fa
iloverTransport.doReconnect(FailoverTransport.java:747) Successfully
rec
onnected to tcp://222.127.223.137:61616?wireFormat.maxInactivityDuration=0
[DEBUG] 2011-06-17 21:15:39,187 []
org.apache.activemq.transport.ResponseCor
relator.onCommand(ResponseCorrelator.java:105) Received unexpected
resp
onse: {Response {commandId = 0, responseRequired = false, correlationId =
1}}for
command id: 1
[DEBUG] 2011-06-17 21:15:39,203 []
org.apache.activemq.transport.ResponseCor
relator.onCommand(ResponseCorrelator.java:105) Received unexpected
resp
onse: {Response {commandId = 0, responseRequired = false, correlationId =
28}}fo
r command id: 28
[DEBUG] 2011-06-17 21:15:39,203 []
org.apache.activemq.transport.ResponseCor
relator.onCommand(ResponseCorrelator.java:105) Received unexpected
resp
onse: {Response {commandId = 0, responseRequired = false, correlationId =
70}}fo
r command id: 70
[DEBUG] 2011-06-17 21:15:39,218 []
org.apache.activemq.transport.ResponseCor
relator.onCommand(ResponseCorrelator.java:105) Received unexpected
resp
onse: {Response {commandId = 0, responseRequired = false, correlationId =
2}}for
command id: 2
--
View this message in context: http://activemq.2283324.n4.nabble.com/our-program-reconnect-repeatly-due-to-java-net-SocketException-Connection-reset-tp3618719p3618719.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.