新增:zhub 服务 ping 回应

This commit is contained in:
lxy 2021-08-05 10:00:24 +08:00
parent 9be0721de0
commit 074e5a0685

View File

@ -95,6 +95,13 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
}
String type = "";
// +ping
if ("+ping".equals(readLine)) {
send("+pong");
continue;
}
// 主题订阅消息
if ("*3".equals(readLine)) {
readLine = reader.readLine(); // $7 len()