private void descInflightMsgCnt(TcpCallFuture callFuture) {
        TcpNettyClient nettyTcpClient = usingClientMaps.get(callFuture.getClientAddr());
        if (nettyTcpClient != null
                && nettyTcpClient.getChanTermId() == callFuture.getChanTerm()) {
            nettyTcpClient.decInFlightMsgCnt(callFuture.getChanTerm());
            return;
        }
        nettyTcpClient = deletingClientMaps.get(callFuture.getClientAddr());
        if (nettyTcpClient != null
                && nettyTcpClient.getChanTermId() == callFuture.getChanTerm()) {
            nettyTcpClient.decInFlightMsgCnt(callFuture.getChanTerm());
        }
    }
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