add message timeout

This commit is contained in:
okx-code
2024-11-15 23:06:53 +00:00
parent e88488664b
commit c76428fc56
2 changed files with 5 additions and 0 deletions

View File

@@ -29,6 +29,7 @@ public class BungeeServerBroadcaster implements ServerBroadcaster {
DataOutputStream msgout = new DataOutputStream(msgbytes);
try {
msgout.writeUTF("group");
msgout.writeLong(System.currentTimeMillis());
msgout.writeUTF(senderId.toString());
msgout.writeUTF(senderName);
msgout.writeUTF(senderDisplayName);

View File

@@ -36,6 +36,10 @@ public class BungeeServerListener implements PluginMessageListener {
String type = msgIn.readUTF();
CivChat2Manager manager = CivChat2.getInstance().getCivChat2Manager();
if (type.equals("group")) {
long timestamp = msgIn.readLong();
if (System.currentTimeMillis() - timestamp > 5000) {
return;
}
manager.sendRemoteGroupMsg(UUID.fromString(msgIn.readUTF()), msgIn.readUTF(), msgIn.readUTF(), msgIn.readUTF(), msgIn.readUTF());
} else {
CivChat2.getInstance().getLogger().log(Level.WARNING, "Unknown type '" + type + "' in CivChat2 plugin message");