dubbo在listener调用时对异常的处理

使用场景：使用dubbo Callback回调消费kafka数据 使用目的：1、防止kafka账户信息泄露

2、Topic授权校验

3、对kafka数据进行过滤

服务发布：

<dubbo:service interface="com.xx.xx.xx.xxService" ref="dataSubscriptionService" timeout="200000" callbacks="1000" connections="100" protocol="dubbo" group="routing"> <dubbo:method name="addListener"> <dubbo:argument index="2" callback="true" /> </dubbo:method> </dubbo:service>

服务消费： <dubbo:reference id="dataSubscriptionService" interface="com.xx.xx.xx.xxService" group="XX"/>

出现问题：

1、服务端稳定，客户端重启【客户端停止后，服务端未监听客户端停止，回调报错】 服务端报错： client disconnected com.alibaba.dubbo.rpc.RpcException: Failed to send message Request Caused by: java.nio.channels.ClosedChannelException: null 会丢失数据条数不定或延迟

2、服务端重启，客户端稳定【服务端停止后，客户端未监听服务端停止重连，永久卡死】

客户端永久卡死，重启后正常消费数据

1、服务端正在发送数据过程中重启，丢失同批不定条数数据

2、静置状态重启，客户端重启后数据正常消费，不会丢失数据

3、客户端启动之后非阻塞状态，服务端故障后客户端不再重试

原提问者GitHub用户my12us