Hello friends,
Another query on some charateristics of Ignite beheviour which I'm not sure
if it's my usage or the intention of the product. We are using the messaging
sub-system to distribute streams of data between interested processes.
The server is sending data as follows:
ignite.message().sendOrdered("my-topic", objectToSend, 1);
The client subscribing:
ignite.message().localListen("my-topic", (UUID uuid, Object o) -> {
log.info(o);
return true;
});
This works well for our use case apart from one behaviour. When a topic
subscriber process exits the sender detects the TCP failure and blocks the
sending thread for a prolonged period of time. Reporting the exception
below.
We really don't care that a subcriber has gone away. We're more of a
multicast use case but don't want to introduce the overhead of a specialist
messaging product for what is quite a narrow use case. Ignite messaging
seems to do the trick apart from this one disconnection behaviour.
Thanks for the great product and keep up the good work!
Kevin
[WARN ] 2017-03-16 11:06:32.951 [grid-nio-worker-0-#9%null%]
TcpCommunicationSpi - Failed to process selector key (will close):
GridSelectorNioSessionImpl [selectorIdx=0, queueSize=0,
writeBuf=java.nio.DirectByteBuffer[pos=0 lim=32768 cap=32768],
readBuf=java.nio.DirectByteBuffer[pos=0 lim=32768 cap=32768],
recovery=GridNioRecoveryDescriptor [acked=4624, resendCnt=0, rcvCnt=478,
sentCnt=4632, reserved=true, lastAck=478, nodeLeft=false,
node=TcpDiscoveryNode [id=613517f0-9534-46e3-bbe7-eb5ed1515b27,
addrs=[0:0:0:0:0:0:0:1, 10.1.1.15, 127.0.0.1, 172.27.236.2,
2001:0:9d38:6abd:18fe:1bb0:f5fe:fef0], sockAddrs=[/172.27.236.2:47501,
/2001:0:9d38:6abd:18fe:1bb0:f5fe:fef0:47501, A0004.lan/10.1.1.15:47501,
/0:0:0:0:0:0:0:1:47501, /127.0.0.1:47501], discPort=47501, order=2,
intOrder=2, lastExchangeTime=1489622741577, loc=false,
ver=1.8.0#20161205-sha1:9ca40dbe, isClient=false], connected=true,
connectCnt=1, queueLimit=5120, reserveCnt=1], super=GridNioSessionImpl
[locAddr=/0:0:0:0:0:0:0:1:59801, rmtAddr=/0:0:0:0:0:0:0:1:47101,
createTime=1489622741736, closeTime=0, bytesSent=13680979, bytesRcvd=158379,
sndSchedTime=1489622792923, lastSndTime=1489622792923,
lastRcvTime=1489622792813, readsPaused=false,
filterChain=FilterChain[filters=[GridNioCodecFilter
[parser=o.a.i.i.util.nio.GridDirectParser@69ad4e89, directMode=true],
GridConnectionBytesVerifyFilter], accepted=false]]
[WARN ] 2017-03-16 11:06:32.952 [grid-nio-worker-0-#9%null%]
TcpCommunicationSpi - Closing NIO session because of unhandled exception
[cls=class o.a.i.i.util.nio.GridNioException, msg=An existing connection was
forcibly closed by the remote host]
[INFO ] 2017-03-16 11:06:32.957 [market-data-worker] MarketDataPublisher -
ABC{bestBid=5.73, bestAsk=5.39, bidVol=575, askVol=2261, IAP=5.53}
[WARN ] 2017-03-16 11:06:33.980 [market-data-worker] TcpCommunicationSpi -
Connect timed out (consider increasing 'failureDetectionTimeout'
configuration property) [addr=/0:0:0:0:0:0:0:1:47101,
failureDetectionTimeout=10000]
[WARN ] 2017-03-16 11:06:34.977 [market-data-worker] TcpCommunicationSpi -
Connect timed out (consider increasing 'failureDetectionTimeout'
configuration property) [addr=/127.0.0.1:47101,
failureDetectionTimeout=10000]
[WARN ] 2017-03-16 11:06:35.982 [market-data-worker] TcpCommunicationSpi -
Connect timed out (consider increasing 'failureDetectionTimeout'
configuration property) [addr=/172.27.236.2:47101,
failureDetectionTimeout=10000]
[WARN ] 2017-03-16 11:06:36.983 [market-data-worker] TcpCommunicationSpi -
Connect timed out (consider increasing 'failureDetectionTimeout'
configuration property) [addr=/2001:0:9d38:6abd:18fe:1bb0:f5fe:fef0:47101,
failureDetectionTimeout=10000]
[WARN ] 2017-03-16 11:06:37.981 [market-data-worker] TcpCommunicationSpi -
Connect timed out (consider increasing 'failureDetectionTimeout'
configuration property) [addr=A0004.lan/10.1.1.15:47101,
failureDetectionTimeout=10000]
[WARN ] 2017-03-16 11:06:37.981 [market-data-worker] TcpCommunicationSpi -
Failed to connect to a remote node (make sure that destination node is alive
and operating system firewall is disabled on local and remote hosts)
[addrs=[/0:0:0:0:0:0:0:1:47101, /127.0.0.1:47101, /172.27.236.2:47101,
/2001:0:9d38:6abd:18fe:1bb0:f5fe:fef0:47101, A0004.lan/10.1.1.15:47101]]
[ERROR] 2017-03-16 11:06:37.987 [market-data-worker] MarketDataPublisher -
Failed to send message to remote node: TcpDiscoveryNode
[id=613517f0-9534-46e3-bbe7-eb5ed1515b27, addrs=[0:0:0:0:0:0:0:1, 10.1.1.15,
127.0.0.1, 172.27.236.2, 2001:0:9d38:6abd:18fe:1bb0:f5fe:fef0],
sockAddrs=[/172.27.236.2:47501, /2001:0:9d38:6abd:18fe:1bb0:f5fe:fef0:47501,
A0004.lan/10.1.1.15:47501, /0:0:0:0:0:0:0:1:47501, /127.0.0.1:47501],
discPort=47501, order=2, intOrder=2, lastExchangeTime=1489622741577,
loc=false, ver=1.8.0#20161205-sha1:9ca40dbe, isClient=false]
org.apache.ignite.spi.IgniteSpiException: Failed to send message to remote
node: TcpDiscoveryNode [id=613517f0-9534-46e3-bbe7-eb5ed1515b27,
addrs=[0:0:0:0:0:0:0:1, 10.1.1.15, 127.0.0.1, 172.27.236.2,
2001:0:9d38:6abd:18fe:1bb0:f5fe:fef0], sockAddrs=[/172.27.236.2:47501,
/2001:0:9d38:6abd:18fe:1bb0:f5fe:fef0:47501, A0004.lan/10.1.1.15:47501,
/0:0:0:0:0:0:0:1:47501, /127.0.0.1:47501], discPort=47501, order=2,
intOrder=2, lastExchangeTime=1489622741577, loc=false,
ver=1.8.0#20161205-sha1:9ca40dbe, isClient=false]
at
org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.sendMessage0(TcpCommunicationSpi.java:2017)
~[ignite-core-1.8.0.jar:1.8.0]
at
org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.sendMessage(TcpCommunicationSpi.java:1955)
~[ignite-core-1.8.0.jar:1.8.0]
at
org.apache.ignite.internal.managers.communication.GridIoManager.send(GridIoManager.java:1148)
~[ignite-core-1.8.0.jar:1.8.0]
at
org.apache.ignite.internal.managers.communication.GridIoManager.send(GridIoManager.java:1571)
~[ignite-core-1.8.0.jar:1.8.0]
at
org.apache.ignite.internal.managers.communication.GridIoManager.sendOrderedMessage(GridIoManager.java:1315)
~[ignite-core-1.8.0.jar:1.8.0]
at
org.apache.ignite.internal.managers.communication.GridIoManager.sendUserMessage(GridIoManager.java:1453)
~[ignite-core-1.8.0.jar:1.8.0]
at
org.apache.ignite.internal.IgniteMessagingImpl.sendOrdered(IgniteMessagingImpl.java:140)
~[ignite-core-1.8.0.jar:1.8.0]
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/ignite-messaging-disconnection-behaviour-tp11218.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.
