RpcException不做处理

core/src/main/java/com/wecloud/im/ws/sender/ChannelSender.java

@@ -13,6 +13,7 @@ import java.util.stream.Collectors;
 
 
 import org.apache.dubbo.config.annotation.DubboReference;
 import org.apache.dubbo.config.annotation.DubboReference;
 import org.apache.dubbo.rpc.RpcContext;
 import org.apache.dubbo.rpc.RpcContext;
+import org.apache.dubbo.rpc.RpcException;
 import org.apache.dubbo.rpc.cluster.router.address.Address;
 import org.apache.dubbo.rpc.cluster.router.address.Address;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import org.springframework.stereotype.Component;
@@ -159,7 +160,12 @@ public class ChannelSender {
                 Address address = new Address(clientChannelInfo.getLanIp(), 20882);
                 Address address = new Address(clientChannelInfo.getLanIp(), 20882);
                 RpcContext.getContext().setObjectAttachment("address", address);
                 RpcContext.getContext().setObjectAttachment("address", address);
                 log.info("dubbo指定ip调用 {}", JSON.toJSONString(address));
                 log.info("dubbo指定ip调用 {}", JSON.toJSONString(address));
-                routerSendService.sendMsgRemote(toClientId, clientChannelInfo.getPlatform(), msgJson);
+                try {
+                    routerSendService.sendMsgRemote(toClientId, clientChannelInfo.getPlatform(), msgJson);
+                } catch (RpcException exception) {
+                    // do nothing is ok
+                    log.info("rpc 调用异常 {} ", JSON.toJSONString(clientChannelInfo));
+                }
             }
             }
         }
         }