diff --git a/src/org/redkale/net/sncp/SncpClient.java b/src/org/redkale/net/sncp/SncpClient.java index 3a917c3c1..a08d13fb8 100644 --- a/src/org/redkale/net/sncp/SncpClient.java +++ b/src/org/redkale/net/sncp/SncpClient.java @@ -248,6 +248,7 @@ public final class SncpClient { } public void remoteSameGroup(final BsonConvert bsonConvert, final JsonConvert jsonConvert, Transport transport, final int index, final Object... params) { + if (transport == null) return; final SncpAction action = actions[index]; if (action.handlerFuncParamIndex >= 0) params[action.handlerFuncParamIndex] = null; //不能让远程调用handler,因为之前本地方法已经调用过了 for (InetSocketAddress addr : transport.getRemoteAddresses()) { @@ -256,6 +257,7 @@ public final class SncpClient { } public void asyncRemoteSameGroup(final BsonConvert bsonConvert, final JsonConvert jsonConvert, Transport transport, final int index, final Object... params) { + if (transport == null) return; if (executor != null) { executor.accept(() -> { remoteSameGroup(bsonConvert, jsonConvert, transport, index, params);