添加注释
parent
55a240bb45
commit
6025eb29fd
|
@ -79,6 +79,7 @@ public class RedisRpcConfig implements MessageListener {
|
||||||
if (userSetting.getServerId().equals(response.getToId())) {
|
if (userSetting.getServerId().equals(response.getToId())) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
logger.info("[redis-rpc] << {}", response);
|
||||||
response(response);
|
response(response);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -87,6 +88,7 @@ public class RedisRpcConfig implements MessageListener {
|
||||||
if (userSetting.getServerId().equals(request.getFromId())) {
|
if (userSetting.getServerId().equals(request.getFromId())) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
logger.info("[redis-rpc] >> {}", request);
|
||||||
Method method = getMethod(request.getUri());
|
Method method = getMethod(request.getUri());
|
||||||
// 没有携带目标ID的可以理解为哪个wvp有结果就哪个回复,携带目标ID,但是如果是不存在的uri则直接回复404
|
// 没有携带目标ID的可以理解为哪个wvp有结果就哪个回复,携带目标ID,但是如果是不存在的uri则直接回复404
|
||||||
if (userSetting.getServerId().equals(request.getToId())) {
|
if (userSetting.getServerId().equals(request.getToId())) {
|
||||||
|
|
|
@ -76,7 +76,7 @@ public class RedisRpcRequest {
|
||||||
return "RedisRpcRequest{" +
|
return "RedisRpcRequest{" +
|
||||||
"fromId='" + fromId + '\'' +
|
"fromId='" + fromId + '\'' +
|
||||||
", toId='" + toId + '\'' +
|
", toId='" + toId + '\'' +
|
||||||
", sn='" + sn + '\'' +
|
", sn=" + sn +
|
||||||
", uri='" + uri + '\'' +
|
", uri='" + uri + '\'' +
|
||||||
", param=" + param +
|
", param=" + param +
|
||||||
'}';
|
'}';
|
||||||
|
|
|
@ -2,4 +2,4 @@ spring:
|
||||||
application:
|
application:
|
||||||
name: wvp
|
name: wvp
|
||||||
profiles:
|
profiles:
|
||||||
active: local2
|
active: local
|
Loading…
Reference in New Issue