You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2020/11/17 09:40:51 UTC
[GitHub] [rocketmq] leyan95 opened a new issue #2435: 调用 DefaultMQProducer 的 Message request(final Message msg, final long timeout) 方法后管道注销导致响应数据失败
leyan95 opened a new issue #2435:
URL: https://github.com/apache/rocketmq/issues/2435
调用 DefaultMQProducer 的 Message request(final Message msg, final long timeout) 方法后管道注销导致响应数据失败
生产端报错如下：
```java
17:13:52.753 [pool-9-thread-2] ERROR o.h.b.c.session.ActiveSessionCenter CODE: 10006 DESC: send request message to
<SETTING> OK, but wait reply message timeout, 10000 ms.; nested exception is
org.apache.rocketmq.client.exception.RequestTimeoutException: CODE: 10006 DESC: send request message to <SETTING> OK,
but wait reply message timeout, 10000 ms.; nested exception is org.springframework.messaging.MessagingException: CODE:
10006 DESC: send request message to <SETTING> OK, but wait reply message timeout, 10000 ms.; nested exception is
org.apache.rocketmq.client.exception.RequestTimeoutException: CODE: 10006 DESC: send request message to <SETTING> OK,
but wait reply message timeout, 10000 ms.
```
消费端报错如下：
```java
21:14:17.347 ERROR [NettyClientPublicExecutor_4] o.a.r.s.s.DefaultRocketMQListenerContainer -- Consumer replies message
failed. error: CODE: 1 DESC: push reply message to 172.17.0.1@bisRocketMqTemplatefail.,
For more information, please visit the url, http://rocketmq.apache.org/docs/faq/,
```
broker.log 报错如下：
```java
2020-11-17 17:13:10 INFO brokerOutApi_thread_2 - register broker[0]to name server 192.168.5.71:9876 OK
2020-11-17 17:13:23 INFO ClientManageThread_11 - unregister a consumer[T-BisPersistence-Group] from consumerGroupInfo ClientChannelInfo [channel=[id: 0x243c28ed, L:/172.17.0.4:10911 - R:/192.168.5.71:57852], clientId=172.17.0.1@DEFAULT, language=JAVA, version=333, lastUpdateTimestamp=1605604395817]
2020-11-17 17:13:23 INFO ClientManageThread_12 - unregister a producer[CLIENT_INNER_PRODUCER] from groupChannelTable ClientChannelInfo [channel=[id: 0x243c28ed, L:/172.17.0.4:10911 - R:/192.168.5.71:57852], clientId=172.17.0.1@DEFAULT, language=JAVA, version=333, lastUpdateTimestamp=1605604403420]
2020-11-17 17:13:23 INFO ClientManageThread_13 - unregister a producer[my-group] from groupChannelTable ClientChannelInfo [channel=[id: 0x5c09b98f, L:/172.17.0.4:10911 - R:/192.168.5.71:57854], clientId=172.17.0.1@1, language=JAVA, version=333, lastUpdateTimestamp=1605604403468]
2020-11-17 17:13:23 INFO ClientManageThread_14 - unregister a producer[CLIENT_INNER_PRODUCER] from groupChannelTable ClientChannelInfo [channel=[id: 0x5c09b98f, L:/172.17.0.4:10911 - R:/192.168.5.71:57854], clientId=172.17.0.1@1, language=JAVA, version=333, lastUpdateTimestamp=1605604403473]
2020-11-17 17:13:23 INFO ClientManageThread_15 - unregister a producer[_INNER_TRACE_PRODUCER] from groupChannelTable ClientChannelInfo [channel=[id: 0x0fc43360, L:/172.17.0.4:10911 - R:/192.168.5.71:57858], clientId=172.17.0.1@PID_CLIENT_INNER_TRACE_PRODUCER_192.168.5.71:9876, language=JAVA, version=333, lastUpdateTimestamp=1605604403483]
2020-11-17 17:13:23 INFO ClientManageThread_16 - unregister a producer[CLIENT_INNER_PRODUCER] from groupChannelTable ClientChannelInfo [channel=[id: 0x0fc43360, L:/172.17.0.4:10911 - R:/192.168.5.71:57858], clientId=172.17.0.1@PID_CLIENT_INNER_TRACE_PRODUCER_192.168.5.71:9876, language=JAVA, version=333, lastUpdateTimestamp=1605604403486]
2020-11-17 17:13:23 INFO ClientManageThread_17 - unregister a producer[my-group] from groupChannelTable ClientChannelInfo [channel=[id: 0x36ae7d5e, L:/172.17.0.4:10911 - R:/192.168.5.71:57880], clientId=172.17.0.1@bisRocketMqTemplate, language=JAVA, version=333, lastUpdateTimestamp=1605604403510]
2020-11-17 17:13:23 INFO ClientManageThread_18 - unregister a producer[CLIENT_INNER_PRODUCER] from groupChannelTable ClientChannelInfo [channel=[id: 0x36ae7d5e, L:/172.17.0.4:10911 - R:/192.168.5.71:57880], clientId=172.17.0.1@bisRocketMqTemplate, language=JAVA, version=333, lastUpdateTimestamp=1605604403513]
2020-11-17 17:13:40 INFO brokerOutApi_thread_3 - register broker[0]to name server 192.168.5.71:9876 OK
2020-11-17 17:13:41 INFO HeartbeatThread_11 - new consumer connected, group: T-BisPersistence-Group CONSUME_PASSIVELY BROADCASTING channel: ClientChannelInfo [channel=[id: 0x51fe3854, L:/172.17.0.4:10911 - R:/192.168.5.71:37102], clientId=172.17.0.1@DEFAULT, language=JAVA, version=333, lastUpdateTimestamp=1605604421064]
2020-11-17 17:13:41 INFO HeartbeatThread_11 - registerConsumer info changed ConsumerData [groupName=T-BisPersistence-Group, consumeType=CONSUME_PASSIVELY, messageModel=BROADCASTING, consumeFromWhere=CONSUME_FROM_LAST_OFFSET, unitMode=false, subscriptionDataSet=[SubscriptionData [classFilterMode=false, topic=T-BisPersistence, subString=*, tagsSet=[], codeSet=[], subVersion=1605604421013, expressionType=TAG]]] 192.168.5.71:37102
2020-11-17 17:13:41 INFO HeartbeatThread_11 - new producer connected, group: CLIENT_INNER_PRODUCER channel: ClientChannelInfo [channel=[id: 0x51fe3854, L:/172.17.0.4:10911 - R:/192.168.5.71:37102], clientId=172.17.0.1@DEFAULT, language=JAVA, version=333, lastUpdateTimestamp=1605604421065]
2020-11-17 17:13:41 INFO HeartbeatThread_15 - new producer connected, group: my-group channel: ClientChannelInfo [channel=[id: 0xddaaa777, L:/172.17.0.4:10911 - R:/192.168.5.71:37112], clientId=172.17.0.1@1, language=JAVA, version=333, lastUpdateTimestamp=1605604421235]
2020-11-17 17:13:41 INFO HeartbeatThread_15 - new producer connected, group: CLIENT_INNER_PRODUCER channel: ClientChannelInfo [channel=[id: 0xddaaa777, L:/172.17.0.4:10911 - R:/192.168.5.71:37112], clientId=172.17.0.1@1, language=JAVA, version=333, lastUpdateTimestamp=1605604421235]
2020-11-17 17:13:41 INFO HeartbeatThread_2 - new producer connected, group: _INNER_TRACE_PRODUCER channel: ClientChannelInfo [channel=[id: 0x8b7c6af5, L:/172.17.0.4:10911 - R:/192.168.5.71:37114], clientId=172.17.0.1@PID_CLIENT_INNER_TRACE_PRODUCER_192.168.5.71:9876, language=JAVA, version=333, lastUpdateTimestamp=1605604421247]
2020-11-17 17:13:41 INFO HeartbeatThread_2 - new producer connected, group: CLIENT_INNER_PRODUCER channel: ClientChannelInfo [channel=[id: 0x8b7c6af5, L:/172.17.0.4:10911 - R:/192.168.5.71:37114], clientId=172.17.0.1@PID_CLIENT_INNER_TRACE_PRODUCER_192.168.5.71:9876, language=JAVA, version=333, lastUpdateTimestamp=1605604421247]
2020-11-17 17:13:42 INFO HeartbeatThread_6 - new producer connected, group: my-group channel: ClientChannelInfo [channel=[id: 0x86466d0f, L:/172.17.0.4:10911 - R:/192.168.5.71:37130], clientId=172.17.0.1@bisRocketMqTemplate, language=JAVA, version=333, lastUpdateTimestamp=1605604422092]
2020-11-17 17:13:42 INFO HeartbeatThread_6 - new producer connected, group: CLIENT_INNER_PRODUCER channel: ClientChannelInfo [channel=[id: 0x86466d0f, L:/172.17.0.4:10911 - R:/192.168.5.71:37130], clientId=172.17.0.1@bisRocketMqTemplate, language=JAVA, version=333, lastUpdateTimestamp=1605604422092]
2020-11-17 17:13:42 ERROR NettyServerNIOSelector_3_3 - processRequestWrapper response to /192.168.5.71:57852 failed
java.nio.channels.ClosedChannelException: null
at io.netty.channel.AbstractChannel$AbstractUnsafe.write(...)(Unknown Source) ~[netty-all-4.0.42.Final.jar:4.0.42.Final]
2020-11-17 17:13:42 ERROR NettyServerNIOSelector_3_3 - RemotingCommand [code=11, language=JAVA, version=333, opaque=519, flag(B)=0, remark=null, extFields={queueId=0, maxMsgNums=32, sysFlag=2, suspendTimeoutMillis=15000, commitOffset=0, topic=T-BisPersistence, queueOffset=21, expressionType=TAG, subVersion=1605603944871, consumerGroup=T-BisPersistence-Group}, serializeTypeCurrentRPC=JSON]
2020-11-17 17:13:42 ERROR NettyServerNIOSelector_3_3 - RemotingCommand [code=19, language=JAVA, version=355, opaque=519, flag(B)=1, remark=OFFSET_OVERFLOW_ONE, extFields=null, serializeTypeCurrentRPC=JSON]
2020-11-17 17:13:42 ERROR NettyServerNIOSelector_3_3 - processRequestWrapper response to /192.168.5.71:57852 failed
```
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org