private boolean rmvMsgStubInfo(int messageId) {
        TcpCallFuture curFuture = reqObjects.remove(messageId);
        if (curFuture == null) {
            return false;
        }
        ConcurrentHashMap<Integer, Boolean> msgIdMap =
                channelMsgIdMap.get(curFuture.getChanStr());
        if (msgIdMap != null) {
            msgIdMap.remove(curFuture.getMessageId());
        }
        return true;
    }
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