You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by "zd46319 (via GitHub)" <gi...@apache.org> on 2023/07/24 03:34:17 UTC
[GitHub] [rocketmq] zd46319 commented on issue #6810: [Bug] with the same clientId, the groupChannelTable in ProducerManager has data, but the clientChannelTable does not
zd46319 commented on issue #6810:
URL: https://github.com/apache/rocketmq/issues/6810#issuecomment-1647147948
我这边遇到了同样的问题，版本也是4.9.3，broker的日志显示是这样的：
```
2023-07-20 02:14:49 INFO NettyEventExecutor - NETTY EVENT: remove channel[ClientChannelInfo [channel=[id: 0x1d2ea18e, L:/192.168.0.100:10911 ! R:/192.168.0.102:41678], clientId=192.168.0.102@18699#35262262388230038, language=JAVA, version=399, lastUpdateTimestamp=1689790452184]][192.168.0.102:41678] from ProducerManager groupChannelTable, producer group: group-1
2023-07-20 02:14:49 INFO NettyEventExecutor - NETTY EVENT: remove channel[ClientChannelInfo [channel=[id: 0x1d2ea18e, L:/192.168.0.100:10911 ! R:/192.168.0.102:41678], clientId=192.168.0.102@18699#35262262388230038, language=JAVA, version=399, lastUpdateTimestamp=1689790452184]][192.168.0.102:41678] from ProducerManager groupChannelTable, producer group: CLIENT_INNER_PRODUCER
2023-07-20 02:14:49 INFO HeartbeatThread_3 - new producer connected, group: CLIENT_INNER_PRODUCER channel: ClientChannelInfo [channel=[id: 0x1d2ea18e, L:/192.168.0.100:10911 ! R:/192.168.0.102:41678], clientId=192.168.0.102@18699#35262262388230038, language=JAVA, version=399, lastUpdateTimestamp=1689790489779]
2023-07-20 02:14:49 INFO HeartbeatThread_3 - new producer connected, group: group-1 channel: ClientChannelInfo [channel=[id: 0x1d2ea18e, L:/192.168.0.100:10911 ! R:/192.168.0.102:41678], clientId=192.168.0.102@18699#35262262388230038, language=JAVA, version=399, lastUpdateTimestamp=1689790489779]
2023-07-20 02:15:12 INFO HeartbeatThread_5 - new producer connected, group: CLIENT_INNER_PRODUCER channel: ClientChannelInfo [channel=[id: 0xad11f188, L:/192.168.0.100:10911 - R:/192.168.0.102:47453], clientId=192.168.0.102@18699#35262262388230038, language=JAVA, version=399, lastUpdateTimestamp=1689790512232]
2023-07-20 02:15:12 INFO HeartbeatThread_5 - new producer connected, group: group-1 channel: ClientChannelInfo [channel=[id: 0xad11f188, L:/192.168.0.100:10911 - R:/192.168.0.102:47453], clientId=192.168.0.102@18699#35262262388230038, language=JAVA, version=399, lastUpdateTimestamp=1689790512232]
2023-07-20 02:16:59 WARN ClientHousekeepingScheduledThread1 - SCAN: remove expired channel[192.168.0.102:41678] from ProducerManager groupChannelTable, producer group name: group-1
2023-07-20 02:16:59 WARN ClientHousekeepingScheduledThread1 - SCAN: remove expired channel[192.168.0.102:41678] from ProducerManager groupChannelTable, producer group name: CLIENT_INNER_PRODUCER
```
02:14:49有一次网络抖动，导致“192.168.0.102@18699#35262262388230038”这个**clientId有两个channel连到了broker上**，端口41678和端口47453。导致registerProducer的时候，groupChannelTable有两条数据，clientChannelTable 只有一条。
之后ProducerManager.scanNotActiveChannel()扫描的时候，扫到了41678端口这个channel，remove的时候顺便把clientChannelTable给清了。之后再通过clientId从clientChannelTable获取的时候就“channel not found”了。
--
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.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org