@Override
    protected InvokeFuture createInvokeFuture(Connection conn, RemotingCommand request,
                                              InvokeContext invokeContext,
                                              InvokeCallback invokeCallback) {
        return new DefaultInvokeFuture(request.getId(), new RpcInvokeCallbackListener(
            RemotingUtil.parseRemoteAddress(conn.getChannel())), invokeCallback, request
            .getProtocolCode().getFirstByte(), this.getCommandFactory(conn), invokeContext);
    }
@see com.alipay.remoting.BaseRemoting#createInvokeFuture(Connection, RemotingCommand, InvokeContext, InvokeCallback)
src/main/java/com/alipay/remoting/rpc/RpcRemoting.java