@Override
  public void req(
      @NonNull final AbstractTcpClientParamsETO reqData,
      @NonNull final Class<T> toClazz,
      @NonNull final ServiceInfo serviceInfo,
      @NonNull final TcpRespListenerI<T> respListener) {
    // step1
    reqData.validate();
    try {
      // step2
      // 启动客户端
      final MessageProcessor<String> clientProcessor =
          (session, res) -> {
            // step5
            // TODO zhaojun 三方返回数据报文记录
            SystemRuntimeLogUtils.info(
                "external online send tcp req, The response data received is {}", res);
            // step6
            final T respData = respListener.parseRespData(res, toClazz);
            // 在这里可以对外部服务的一些状态码进行校验，如果校验失败直接抛出异常即可
            // step7
            respListener.bizCodeValidate(respData);
            final AbstractRespETO respPojo = (AbstractRespETO) respData;
            // step8
            respPojo.validate();
            // step9
            // 会在自定义响应对象 T 自身的validate 方法调用后执行，即如果第三方返回的数据本身有问题在 validate进行字段校验的时候就会 fast fail
            respPojo.desensitized();
            // step10
            respListener.success(respData);
          };
      final AioQuickClient aioQuickClient =
          new AioQuickClient(
              clientProps.getHost(), clientProps.getPort(), new StringProtocol(), clientProcessor);
      final AioSession session = aioQuickClient.start();
      // 请求参数对象ETO 自行判断如何转换提交参数数据报文格式类型
      // step3
      final String reqParams = reqData.toParams();
      final byte[] bytes = reqParams.getBytes();
      // encode
      session.writeBuffer().writeInt(bytes.length);
      session.writeBuffer().write(bytes);
      // step4
      // flush data
      session.writeBuffer().flush();
    } catch (final IOException e) {
      SystemRuntimeLogUtils.error("发送 tcp 请求出现 IO 错误", e);
      throw new TcpInvokeException(serviceInfo, TcpInvokeExceptionDesc.TCP_IO_ERR, e);
    } finally {
    }
  }