diff --git a/pom.xml b/pom.xml index a78daa6..4956503 100644 --- a/pom.xml +++ b/pom.xml @@ -6,7 +6,7 @@ cn.cloudowr sdk - 1.4.13 + 1.4.14 diff --git a/src/main/java/cn/cloudowr/sdk/log/Logger.java b/src/main/java/cn/cloudowr/sdk/log/Logger.java index ec489ed..fc4e250 100644 --- a/src/main/java/cn/cloudowr/sdk/log/Logger.java +++ b/src/main/java/cn/cloudowr/sdk/log/Logger.java @@ -27,7 +27,7 @@ public class Logger { //用来自动连接的,不想自动连接请设为null private static ReconnConf reconnConf = new ReconnConf(5000L); - private static ClientChannelContext clientChannelContext; + public static void initLogger() throws Exception { String serverIp = "log.cloudowr.cn"; @@ -38,15 +38,14 @@ public class Logger { clientGroupContext = new ClientGroupContext<>(aioClientHandler, aioListener, reconnConf); aioClient = new AioClient<>(clientGroupContext); - - clientChannelContext = aioClient.connect(serverNode); } public static void log(String msg) { try { + ClientChannelContext clientChannelContext= aioClient.connect(serverNode); Message packet = new JSONStringMessage(msg.getBytes(Message.CHARSET)); Aio.send(clientChannelContext, packet); - } catch (UnsupportedEncodingException e) { + } catch (Exception e) { e.printStackTrace(); } } diff --git a/src/main/java/cn/cloudowr/sdk/log/entity/HeartBeatMessage.java b/src/main/java/cn/cloudowr/sdk/log/entity/HeartBeatMessage.java index a37866b..e737470 100644 --- a/src/main/java/cn/cloudowr/sdk/log/entity/HeartBeatMessage.java +++ b/src/main/java/cn/cloudowr/sdk/log/entity/HeartBeatMessage.java @@ -7,7 +7,7 @@ public class HeartBeatMessage extends Message { public static final HeartBeatMessage PACKET = new HeartBeatMessage(); private HeartBeatMessage() {} public byte[] getBody() { - return new byte[]{0}; + return null; } @Override