日志采集 Java SDK 使用指南


public DefaultMessageSender getMessageSender(String localIP, String inLongManagerAddr, String inLongManagerPort, String netTag, String dataProxyGroup, boolean isLocalVisit, boolean isReadProxyIPFromLocal, String configBasePath, int msgType) {

    ProxyClientConfig dataProxyConfig = null;
    DefaultMessageSender messageSender = null;
    try {   
      // 初始化客户端配置，其中“test”，“123456”是需要认证的用户名和密码，实际使用时需要根据环境配置进行更替
      dataProxyConfig = new ProxyClientConfig(localIP, isLocalVisit, inLongManagerAddr,         Integer.valueOf(inLongManagerPort), dataProxyGroup, netTag, "test", "123456");
      // 设置配置信息的本地保存路径，该设置可选，缺省情况下 SDK 会在当前用户工作目录下构造一个"/.inlong/"目录存储配置数据
      if (StringUtils.isNotEmpty(configBasePath)) {     
          dataProxyConfig.setConfStoreBasePath(configBasePath);     
      }
      // 设置是否允许使用本地保存的配置信息，该设置可选，缺省不启用
      dataProxyConfig.setReadProxyIPFromLocal(isReadProxyIPFromLocal);
      // 初始化MessageSender对象，异常将抛异常
      messageSender = DefaultMessageSender.generateSenderByClusterId(dataProxyConfig);
      // 设置 SDK 与DataProxy间消息发送的消息类型，该设置可选，缺省默认为7以二进制形式进行数据发送
      messageSender.setMsgtype(msgType);
   } catch (Exception e) {
      logger.error("getMessageSender has exception e = {}", e);
   }
   // 返回初始化结果
   return messageSender;
   }

public void sendTcpMessage(DefaultMessageSender sender, String inlongGroupId, String inlongStreamId, String messageBody, long dt) {
    SendResult result = null;
    try {
        // 以同步模式发送单条消息，不携带属性信息
        result = sender.sendMessage(messageBody.getBytes("utf8"), inlongGroupId, inlongStreamId,
                                    0, String.valueOf(dt), 20, TimeUnit.SECONDS);
    } catch (UnsupportedEncodingException e) {
      e.printStackTrace();
    }
    logger.info("messageSender {}", result);
    }