mirror of
https://github.com/tiennm99/zfoo.git
synced 2026-10-15 14:16:45 +00:00
doc[net]: 更新文档
This commit is contained in:
1 parent
cd37302c27
commit
fa4babdcb4
3 files changed
+3
-3
No files matched your search
@@ -94,7 +94,7 @@ public class Consumer implements IConsumer {
|
|||||||
loadBalancer.afterLoadBalancer(session, packet, clientSignalAttachment);
|
loadBalancer.afterLoadBalancer(session, packet, clientSignalAttachment);
|
||||||
return syncAnswer;
|
return syncAnswer;
|
||||||
} catch (TimeoutException e) {
|
} catch (TimeoutException e) {
|
||||||
throw new NetTimeOutException(StringUtils.format("syncRequest timeout exception, ask:[{}], attachment:[{}]"
|
throw new NetTimeOutException(StringUtils.format("syncAsk timeout exception, ask:[{}], attachment:[{}]"
|
||||||
, JsonUtils.object2String(packet), JsonUtils.object2String(clientSignalAttachment)));
|
, JsonUtils.object2String(packet), JsonUtils.object2String(clientSignalAttachment)));
|
||||||
} finally {
|
} finally {
|
||||||
SignalBridge.removeSignalAttachment(clientSignalAttachment);
|
SignalBridge.removeSignalAttachment(clientSignalAttachment);
|
||||||
|
|||||||
@@ -39,7 +39,7 @@ public interface IRouter {
|
|||||||
void atReceiver(Session session, IPacket packet, @Nullable IAttachment attachment);
|
void atReceiver(Session session, IPacket packet, @Nullable IAttachment attachment);
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* attention:syncRequest和asyncRequest只能客户端调用
|
* attention:syncAsk和asyncAsk只能客户端调用
|
||||||
* 同一个客户端可以同时发送多条同步或者异步消息。
|
* 同一个客户端可以同时发送多条同步或者异步消息。
|
||||||
* 服务器对每个请求消息也只能回复一条消息,不能在处理一条不同或者异步消息的时候回复多条消息。
|
* 服务器对每个请求消息也只能回复一条消息,不能在处理一条不同或者异步消息的时候回复多条消息。
|
||||||
*
|
*
|
||||||
|
|||||||
@@ -199,7 +199,7 @@ public class Router implements IRouter {
|
|||||||
|
|
||||||
return new SyncAnswer<>((T) responsePacket, clientSignalAttachment);
|
return new SyncAnswer<>((T) responsePacket, clientSignalAttachment);
|
||||||
} catch (TimeoutException e) {
|
} catch (TimeoutException e) {
|
||||||
throw new NetTimeOutException(StringUtils.format("syncRequest timeout exception, ask:[{}], attachment:[{}]"
|
throw new NetTimeOutException(StringUtils.format("syncAsk timeout exception, ask:[{}], attachment:[{}]"
|
||||||
, JsonUtils.object2String(packet), JsonUtils.object2String(clientSignalAttachment)));
|
, JsonUtils.object2String(packet), JsonUtils.object2String(clientSignalAttachment)));
|
||||||
} finally {
|
} finally {
|
||||||
SignalBridge.removeSignalAttachment(clientSignalAttachment);
|
SignalBridge.removeSignalAttachment(clientSignalAttachment);
|
||||||
|
|||||||
Reference in new issue
Block a user