qq27800734/taoyao
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[*] 日常优化

Browse Source
This commit is contained in:
acgist
2023-09-02 09:13:22 +08:00
parent d354cb30b5
commit df41c28d6c
2 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/Protocol.java
View File

@@ -14,6 +14,7 @@ import com.acgist.taoyao.signal.event.ApplicationEventAdapter;
* client:: 终端信令 * client:: 终端信令
* system:: 系统信令 * system:: 系统信令
* control:: 控制信令 * control:: 控制信令
* session:: 会话信令
* platform:: 平台信令 * platform:: 平台信令
* *
* @author acgist * @author acgist

14
taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/ProtocolManager.java
View File

@@ -58,10 +58,10 @@ public class ProtocolManager {
this.applicationContext.getBeansOfType(Protocol.class).entrySet().stream() this.applicationContext.getBeansOfType(Protocol.class).entrySet().stream()
.sorted((a, z) -> a.getValue().signal().compareTo(z.getValue().signal())) .sorted((a, z) -> a.getValue().signal().compareTo(z.getValue().signal()))
.forEach(e -> { .forEach(e -> {
final String key = e.getKey(); final String key = e.getKey();
final Protocol value = e.getValue(); final Protocol value = e.getValue();
final String name = value.name(); final String name = value.name();
final String signal = value.signal(); final String signal = value.signal();
if(this.protocolMapping.containsKey(signal)) { if(this.protocolMapping.containsKey(signal)) {
throw MessageCodeException.of("存在重复信令协议：" + signal); throw MessageCodeException.of("存在重复信令协议：" + signal);
} }
@@ -91,7 +91,7 @@ public class ProtocolManager {
public void execute(String content, AutoCloseable instance) { public void execute(String content, AutoCloseable instance) {
final Client client = this.clientManager.getClients(instance); final Client client = this.clientManager.getClients(instance);
if(client == null) { if(client == null) {
log.warn("信令终端无效：{}-{}", instance, content); log.warn("信令终端无效：{} - {}", instance, content);
return; return;
} }
// 验证请求 // 验证请求
@@ -107,8 +107,8 @@ public class ProtocolManager {
client.push(this.platformErrorProtocol.build(MessageCode.CODE_1002, "信令消息格式错误（没有头部）")); client.push(this.platformErrorProtocol.build(MessageCode.CODE_1002, "信令消息格式错误（没有头部）"));
return; return;
} }
final String v = header.getV(); final String v = header.getV();
final Long id = header.getId(); final Long id = header.getId();
final String signal = header.getSignal(); final String signal = header.getSignal();
// 设置缓存ID // 设置缓存ID
this.platformErrorProtocol.set(id); this.platformErrorProtocol.set(id);