Add logger
This commit is contained in:
parent
dd467673c7
commit
856b07de37
@ -10,6 +10,9 @@ repositories {
|
||||
}
|
||||
|
||||
dependencies {
|
||||
implementation 'org.slf4j:slf4j-api:2.0.7'
|
||||
implementation 'ch.qos.logback:logback-core:1.3.6'
|
||||
implementation 'ch.qos.logback:logback-classic:1.3.6'
|
||||
implementation 'com.google.protobuf:protobuf-java:3.22.2'
|
||||
implementation 'net.java.dev.jna:jna:5.6.0'
|
||||
implementation fileTree(dir: 'libs', include: ['*.jar'])
|
||||
|
@ -5,6 +5,8 @@ import com.iamteer.Wcf.Request;
|
||||
import com.iamteer.Wcf.Response;
|
||||
import io.sisu.nng.Socket;
|
||||
import io.sisu.nng.pair.Pair1Socket;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import java.nio.ByteBuffer;
|
||||
import java.util.Arrays;
|
||||
@ -12,6 +14,7 @@ import java.util.Arrays;
|
||||
public class Client {
|
||||
private final int BUFFER_SIZE = 16 * 1024 * 1024; // 16M
|
||||
private Socket socket = null;
|
||||
private static Logger logger = LoggerFactory.getLogger(Client.class);
|
||||
|
||||
public Client(String hostPort) {
|
||||
connectRPC(hostPort);
|
||||
@ -21,11 +24,12 @@ public class Client {
|
||||
try {
|
||||
socket = new Pair1Socket();
|
||||
socket.dial(url);
|
||||
logger.info("请点击登录微信");
|
||||
while (!isLogin()) { // 直到登录成功
|
||||
waitMs(1000);
|
||||
}
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
logger.error("连接 RPC 失败: ", e);
|
||||
System.exit(-1);
|
||||
}
|
||||
}
|
||||
@ -55,7 +59,7 @@ public class Client {
|
||||
long size = socket.receive(ret, true);
|
||||
return Response.parseFrom(Arrays.copyOfRange(ret.array(), 0, (int) size));
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
logger.error("命令调用失败: ", e);
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
@ -1,10 +1,15 @@
|
||||
package com.iamteer;
|
||||
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
public class Main {
|
||||
private static Logger logger = LoggerFactory.getLogger(Main.class);
|
||||
|
||||
public static void main(String[] args) {
|
||||
final String url = "tcp://192.168.1.104:10086";
|
||||
Client client = new Client(url);
|
||||
|
||||
System.out.println("IsLogin: " + client.isLogin());
|
||||
logger.info("isLogin: {}", client.isLogin());
|
||||
}
|
||||
}
|
||||
|
15
java/wcferry/src/main/resources/logback.xml
Normal file
15
java/wcferry/src/main/resources/logback.xml
Normal file
@ -0,0 +1,15 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<configuration>
|
||||
<!-- appender 的配置表示打印到控制台。 -->
|
||||
<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
|
||||
<!-- encoder 默认配置为 PatternLayoutEncoder -->
|
||||
<encoder>
|
||||
<pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
|
||||
</encoder>
|
||||
</appender>
|
||||
|
||||
<root level="debug">
|
||||
<appender-ref ref="STDOUT" />
|
||||
</root>
|
||||
|
||||
</configuration>
|
Loading…
Reference in New Issue
Block a user