lyf
/
cowr_sdk
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

.

master
lyf666 2017-03-26 22:35:20 +08:00
parent dc56248320
commit e6f4bf340c
2 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pom.xml
View File

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

9
src/main/java/cn/cloudowr/sdk/log/Logger.java
View File

@ -27,10 +27,10 @@ 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 = "127.0.0.1";
int serverPort = Const.PORT; int serverPort = Const.PORT;
serverNode = new Node(serverIp, serverPort); serverNode = new Node(serverIp, serverPort);
aioClientHandler = new BaseClientAioHandler(); aioClientHandler = new BaseClientAioHandler();
@ -38,14 +38,15 @@ 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 (Exception e) { } catch (UnsupportedEncodingException e) {
e.printStackTrace(); e.printStackTrace();
} }
} }