gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

feat(sj_1.0.0): 优化代码

Browse Source
This commit is contained in:
opensnail 2024-04-30 18:38:25 +08:00
parent d9118cd041
commit cc499696f2
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/rpc/client/NettyHttpClientHandler.java
View File

@ -35,7 +35,7 @@ public class NettyHttpClientHandler extends SimpleChannelInboundHandler<FullHttp
client = RequestBuilder.<NettyClient, NettyResult>newBuilder() client = RequestBuilder.<NettyClient, NettyResult>newBuilder()
.client(NettyClient.class) .client(NettyClient.class)
.callback( .callback(
nettyResult -> SnailJobLog.LOCAL.info("heartbeat check requestId:[{}]", nettyResult.getRequestId())) nettyResult -> SnailJobLog.LOCAL.debug("heartbeat check requestId:[{}]", nettyResult.getRequestId()))
.build(); .build();
this.nettyHttpConnectClient = nettyHttpConnectClient; this.nettyHttpConnectClient = nettyHttpConnectClient;
@ -48,7 +48,7 @@ public class NettyHttpClientHandler extends SimpleChannelInboundHandler<FullHttp
String content = response.content().toString(CharsetUtil.UTF_8); String content = response.content().toString(CharsetUtil.UTF_8);
HttpHeaders headers = response.headers(); HttpHeaders headers = response.headers();
SnailJobLog.LOCAL.info("Receive server data content:[{}], headers:[{}]", content, headers); SnailJobLog.LOCAL.debug("Receive server data content:[{}], headers:[{}]", content, headers);
NettyResult nettyResult = JsonUtil.parseObject(content, NettyResult.class); NettyResult nettyResult = JsonUtil.parseObject(content, NettyResult.class);
RpcContext.invoke(nettyResult.getRequestId(), nettyResult); RpcContext.invoke(nettyResult.getRequestId(), nettyResult);