tiennm99/zfoo
1
0
Fork 0
mirror of https://github.com/tiennm99/zfoo.git synced 2026-08-20 06:24:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

perf[net]: 异步请求增加没有调用成功的日志

Browse Source
This commit is contained in:
jaysunxiao
2021-09-06 15:20:15 +08:00
parent 9f51347734
commit 47be79785e
2 changed files with 15 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
net/src/main/java/com/zfoo/net/dispatcher/manager/PacketDispatcher.java
+3
View File
@@ -34,6 +34,7 @@ import com.zfoo.net.session.model.Session;
import com.zfoo.net.task.TaskManager;
import com.zfoo.net.task.model.ReceiveTask;
import com.zfoo.protocol.IPacket;
import com.zfoo.protocol.exception.ExceptionUtils;
import com.zfoo.protocol.util.JsonUtils;
import com.zfoo.protocol.util.StringUtils;
import com.zfoo.util.math.HashUtils;
@@ -247,6 +248,8 @@ public class PacketDispatcher implements IPacketDispatcher {
var notCompleteCallback = asyncAnswer.getNotCompleteCallback();
if (notCompleteCallback != null) {
notCompleteCallback.run();
} else {
logger.error(ExceptionUtils.getMessage(throwable));
}
return;
}
net/src/test/java/com/zfoo/net/core/tcp/client/TcpClientTest.java
+12 -5
View File
@@ -17,6 +17,7 @@ import com.zfoo.net.NetContext;
import com.zfoo.net.core.tcp.TcpClient;
import com.zfoo.net.packet.tcp.*;
import com.zfoo.net.session.SessionUtils;
import com.zfoo.net.task.model.SafeRunnable;
import com.zfoo.protocol.exception.ExceptionUtils;
import com.zfoo.protocol.util.JsonUtils;
import com.zfoo.util.ThreadUtils;
@@ -105,11 +106,17 @@ public class TcpClientTest {
var ask = new AsyncMess0Ask();
ask.setMessage("Hello, client0 -> server0!");
var answer = NetContext.getDispatcher().asyncAsk(session1, ask, AsyncMess0Answer.class, null);
answer.whenComplete(sm -> {
logger.info("异步请求[{}]收到结果[{}]", atomicInteger.incrementAndGet(), JsonUtils.object2String(answer));
}
);
NetContext.getDispatcher().asyncAsk(null, ask, AsyncMess0Answer.class, null)
.notComplete(new SafeRunnable() {
@Override
public void doRun() {
logger.info("异步请求没有完成");
}
})
.whenComplete(answer -> {
logger.info("异步请求[{}]收到结果[{}]", atomicInteger.incrementAndGet(), JsonUtils.object2String(answer));
}
);
}
});
executor.execute(thread);