public void setChannelFrozen(String channelStr) {
        Map<Integer, Boolean> inflightMsgIds = channelMsgIdMap.get(channelStr);
        if (inflightMsgIds == null) {
            return;
        }
        TcpCallFuture callFuture;
        TcpNettyClient nettyTcpClient;
        for (Integer messageId : inflightMsgIds.keySet()) {
            if (messageId == null) {
                continue;
            }
            callFuture = this.reqObjects.get(messageId);
            if (callFuture == null) {
                continue;
            }
            // find and process in using clients
            nettyTcpClient = usingClientMaps.get(callFuture.getClientAddr());
            if (nettyTcpClient != null
                    && nettyTcpClient.getChanTermId() == callFuture.getChanTerm()) {
                nettyTcpClient.setFrozen(callFuture.getChanTerm());
                return;
            }
            // find and process in deleting clients
            nettyTcpClient = deletingClientMaps.get(callFuture.getClientAddr());
            if (nettyTcpClient != null
                    && nettyTcpClient.getChanTermId() == callFuture.getChanTerm()) {
                nettyTcpClient.setFrozen(callFuture.getChanTerm());
                return;
            }
            break;
        }
    }
Build up the connection between the server and client.
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/tcp/TcpClientMgr.java