lyf666 2017-03-26 22:30:22 +08:00
parent c32ab53c7e
commit dc56248320
3 changed files with 5 additions and 6 deletions

View File

@ -6,7 +6,7 @@
<groupId>cn.cloudowr</groupId> <groupId>cn.cloudowr</groupId>
<artifactId>sdk</artifactId> <artifactId>sdk</artifactId>
<version>1.4.13</version> <version>1.4.14</version>
<build> <build>
<plugins> <plugins>
<plugin> <plugin>

View File

@ -27,7 +27,7 @@ public class Logger {
//用来自动连接的不想自动连接请设为null //用来自动连接的不想自动连接请设为null
private static ReconnConf<Object, Message, Object> reconnConf = new ReconnConf<Object, Message, Object>(5000L); private static ReconnConf<Object, Message, Object> reconnConf = new ReconnConf<Object, Message, Object>(5000L);
private static ClientChannelContext<Object, Message, Object> clientChannelContext;
public static void initLogger() throws Exception { public static void initLogger() throws Exception {
String serverIp = "log.cloudowr.cn"; String serverIp = "log.cloudowr.cn";
@ -38,15 +38,14 @@ public class Logger {
clientGroupContext = new ClientGroupContext<>(aioClientHandler, aioListener, reconnConf); clientGroupContext = new ClientGroupContext<>(aioClientHandler, aioListener, reconnConf);
aioClient = new AioClient<>(clientGroupContext); aioClient = new AioClient<>(clientGroupContext);
clientChannelContext = aioClient.connect(serverNode);
} }
public static void log(String msg) { public static void log(String msg) {
try { try {
ClientChannelContext<Object, Message, Object> clientChannelContext= aioClient.connect(serverNode);
Message packet = new JSONStringMessage(msg.getBytes(Message.CHARSET)); Message packet = new JSONStringMessage(msg.getBytes(Message.CHARSET));
Aio.send(clientChannelContext, packet); Aio.send(clientChannelContext, packet);
} catch (UnsupportedEncodingException e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }
} }

View File

@ -7,7 +7,7 @@ public class HeartBeatMessage extends Message {
public static final HeartBeatMessage PACKET = new HeartBeatMessage(); public static final HeartBeatMessage PACKET = new HeartBeatMessage();
private HeartBeatMessage() {} private HeartBeatMessage() {}
public byte[] getBody() { public byte[] getBody() {
return new byte[]{0}; return null;
} }
@Override @Override