优化协议

vince

2024-01-27 facc0ea3fa37091a98aa1e0a0d1081fd32fba28e

 src/main/java/com/fzzy/protocol/youxian0/client/ClientEngine.java

@@ -30,7 +30,7 @@

    private String host;
    private int port;
    public  static  Channel defaultChannel;
    public static Channel defaultChannel;


    public ClientEngine(String host, int port) {
@@ -103,6 +103,7 @@
            return InvokeResult.SOCKET_NOT_CREATE;
        }
        if (!defaultChannel.isActive()) {
            defaultChannel = null;
            return InvokeResult.CHANNEL_CLOSED;
        }

@@ -116,7 +117,7 @@
        return defaultChannel;
    }

    public static void add2ChannelMap(String key, Channel channel) {
    public  void add2ChannelMap(String key, Channel channel) {
        clientChannelMap.put(key, channel);
    }

@@ -133,6 +134,7 @@
            return channel;
        } else {
            channel.close();
            defaultChannel = null;
        }
        return null;
    }
@@ -142,6 +144,7 @@
            return InvokeResult.SOCKET_NOT_CREATE;
        }
        if (!channel.isActive()) {
            defaultChannel = null;
            return InvokeResult.CHANNEL_CLOSED;
        }
        channel.writeAndFlush(Unpooled.copiedBuffer(BytesUtil.hexStrToBytes(hex))).sync();