示例

    Api 详情，请查看总览

    2.             String netTag, String dataProxyGroup, boolean isLocalVisit, boolean isReadProxyIPFromLocal,
    3.             String configBasePath, int msgType) {
    4.         ProxyClientConfig dataProxyConfig = null;
    5.         DefaultMessageSender messageSender = null;
    6.         try {
    7.             dataProxyConfig = new ProxyClientConfig(localIP, isLocalVisit, inLongManagerAddr,
    8.                     Integer.valueOf(inLongManagerPort), dataProxyGroup, netTag);
    9.             if (StringUtils.isNotEmpty(configBasePath)) {
    10.                 dataProxyConfig.setConfStoreBasePath(configBasePath);
    11.             }
    12.             dataProxyConfig.setReadProxyIPFromLocal(isReadProxyIPFromLocal);
    13.             messageSender = DefaultMessageSender.generateSenderByClusterId(dataProxyConfig);
    14.             messageSender.setMsgtype(msgType);
    15.             logger.error("getMessageSender has exception e = {}", e);
    16.         }
    17.         return messageSender;
    18.     }

    参数说明如下：

    当 isReadProxyIPFromLocal 为 true 的时候, 会从本地配置文件中获取 Dataproxy 的配置信息。

    本地文件的路径为：

    1.     ${configBasePath}

    文件名称为：

    1.     ${dataProxyGroup}.local
    2.     dataProxyGroup = inlong_test

    则本地文件的全路径名称为：

    文件配置内容为( json 格式),其中 host 为 DataProxy 服务器地址，port为对应的端口，这需要至少配置两个（可以配置为相同的两项）：

    1.     {"isInterVisit":1,"clusterId":"1","size":1,"switch":1,"address":[{"host":"127.0.0.1","port":"46802"},{"host":"127.0.0.1","port":"46802"}]}
    1.     public void sendTcpMessage(DefaultMessageSender sender, String inlongGroupId,
    2.             String inlongStreamId, String messageBody, long dt) throws Exception {
    3.      SendResult result = sender.sendMessage(messageBody.getBytes("utf8"),inlongGroupId, inlongStreamId,
    4.              0, String.valueOf(dt), 20,TimeUnit.SECONDS);
    5.      logger.info("messageSender {} ", result);
    6.     }

    参数说明如下：

    1.     public HttpProxySender getMessageSender(String localIP, String inLongManagerAddr, String inLongManagerPort,
    2.             String netTag, String dataProxyGroup, boolean isLocalVisit, boolean isReadProxyIPFromLocal,
    3.             String configBasePath) {
    4.          ProxyClientConfig proxyConfig = null;
    5.          HttpProxySender sender = null;
    6.          try {
    7.              proxyConfig = new ProxyClientConfig(localIP, isLocalVisit, inLongManagerAddr,
    8.                         Integer.valueOf(inLongManagerPort),
    9.              proxyConfig.setGroupId(dataProxyGroup);
    10.              proxyConfig.setConfStoreBasePath(configBasePath);
    11.              proxyConfig.setReadProxyIPFromLocal(isReadProxyIPFromLocal);
    13.              sender = new HttpProxySender(proxyConfig);
    14.          } catch (ProxysdkException e) {
    15.              e.printStackTrace();
    16.          } catch (Exception e) {
    17.              e.printStackTrace();
    18.          }
    19.          return sender;
    20.     }

    参数说明如下：

    当 isReadProxyIPFromLocal 为 true 的时候, 会从本地配置文件中获取 Dataproxy 的配置信息。

    1.     ${configBasePath}

    文件名称为：

    例如：

    1.     configBasePath = /data/inlong
    2.     dataProxyGroup = inlong_test

    则本地文件的全路径名称为：

    1.     /data/inlong/inlong_test.local

    文件配置内容为( json 格式),其中 host 为 DataProxy 服务器地址，port 为对应的端口，这需要至少配置两个（可以配置为相同的两项）：

    1.     {"isInterVisit":1,"clusterId":"1","size":1,"switch":1,"address":[{"host":"127.0.0.1","port":"46802"},{"host":"127.0.0.1","port":"46802"}]}
    1.     public void sendHttpMessage(HttpProxySender sender, String inlongGroupId,
    2.             String inlongStreamId, String messageBody) throws Exception {
    3.         List<String> bodyList = new ArrayList<>();
    4.         bodyList.add(messageBody);
    5.         sender.asyncSendMessage(bodyList, inlongGroupId, inlongStreamId, System.currentTimeMillis(),
    6.              20, TimeUnit.SECONDS, new MyMessageCallBack());

    参数说明如下：