[GitHub] [rocketmq] zd46319 commented on issue #6810: [Bug] with the same clientId, the groupChannelTable in ProducerManager has data, but the clientChannelTable does not

Sun, 23 Jul 2023 20:34:22 -0700 


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: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to