Compare commits
3 Commits
56b939d385
...
5d2c9e249c
Author | SHA1 | Date |
---|---|---|
|
5d2c9e249c | |
|
289ef5440e | |
|
dfa7d25559 |
|
@ -8,6 +8,7 @@ import net.md_5.bungee.api.CommandSender;
|
||||||
import net.md_5.bungee.api.chat.TextComponent;
|
import net.md_5.bungee.api.chat.TextComponent;
|
||||||
import net.md_5.bungee.api.connection.ProxiedPlayer;
|
import net.md_5.bungee.api.connection.ProxiedPlayer;
|
||||||
import net.md_5.bungee.api.plugin.Command;
|
import net.md_5.bungee.api.plugin.Command;
|
||||||
|
import org.redisson.api.RMap;
|
||||||
|
|
||||||
public class KrakatoapCommand extends Command {
|
public class KrakatoapCommand extends Command {
|
||||||
|
|
||||||
|
@ -31,6 +32,20 @@ public class KrakatoapCommand extends Command {
|
||||||
.getSendQueueMessages().size(), ProxySystem.getInstance()
|
.getSendQueueMessages().size(), ProxySystem.getInstance()
|
||||||
.getKraSocketClientProtocol()
|
.getKraSocketClientProtocol()
|
||||||
.getReceivedQueueMessages().size())));
|
.getReceivedQueueMessages().size())));
|
||||||
|
|
||||||
|
String uuid = ProxySystem.getInstance().getFormatter()
|
||||||
|
.formatUuid(player.getUniqueId().toString());
|
||||||
|
|
||||||
|
RMap<String, String> map = ProxySystem.getInstance().getRedisManager()
|
||||||
|
.getRedissonClient()
|
||||||
|
.getMap("player:" + uuid);
|
||||||
|
|
||||||
|
if (!map.isEmpty()) {
|
||||||
|
player.sendMessage(new TextComponent("\n§7Redis player data:"));
|
||||||
|
map.forEach((key, value) -> {
|
||||||
|
player.sendMessage(new TextComponent("§7key: §e" + key + " §7value: §e" + value));
|
||||||
|
});
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -1,9 +1,11 @@
|
||||||
package net.krakatoa.proxy.listener;
|
package net.krakatoa.proxy.listener;
|
||||||
|
|
||||||
|
import net.krakatoa.proxy.ProxySystem;
|
||||||
import net.md_5.bungee.api.connection.ProxiedPlayer;
|
import net.md_5.bungee.api.connection.ProxiedPlayer;
|
||||||
import net.md_5.bungee.api.event.PlayerDisconnectEvent;
|
import net.md_5.bungee.api.event.PlayerDisconnectEvent;
|
||||||
import net.md_5.bungee.api.plugin.Listener;
|
import net.md_5.bungee.api.plugin.Listener;
|
||||||
import net.md_5.bungee.event.EventHandler;
|
import net.md_5.bungee.event.EventHandler;
|
||||||
|
import org.redisson.api.RMap;
|
||||||
|
|
||||||
public class PlayerDisconnectListener implements Listener {
|
public class PlayerDisconnectListener implements Listener {
|
||||||
|
|
||||||
|
@ -11,6 +13,18 @@ public class PlayerDisconnectListener implements Listener {
|
||||||
public void onDisconnect(PlayerDisconnectEvent event) {
|
public void onDisconnect(PlayerDisconnectEvent event) {
|
||||||
ProxiedPlayer proxiedPlayer = event.getPlayer();
|
ProxiedPlayer proxiedPlayer = event.getPlayer();
|
||||||
|
|
||||||
|
String uuid = ProxySystem.getInstance().getFormatter()
|
||||||
|
.formatUuid(proxiedPlayer.getUniqueId().toString());
|
||||||
|
|
||||||
|
// redis
|
||||||
|
RMap<String, String> map = ProxySystem.getInstance().getRedisManager()
|
||||||
|
.getRedissonClient()
|
||||||
|
.getMap("player:" + uuid);
|
||||||
|
|
||||||
|
if (!map.isEmpty()) {
|
||||||
|
map.delete();
|
||||||
|
}
|
||||||
|
|
||||||
/*Long res = ProxySystem.getInstance().getRedisManager().getRedisKeyCommands()
|
/*Long res = ProxySystem.getInstance().getRedisManager().getRedisKeyCommands()
|
||||||
.del("player:" + proxiedPlayer.getUniqueId().toString());
|
.del("player:" + proxiedPlayer.getUniqueId().toString());
|
||||||
|
|
||||||
|
|
|
@ -8,6 +8,7 @@ import earth.krakatao.protocol.KraSocketClientProtocolMessage;
|
||||||
import earth.krakatao.protocol.KraSocketClientProtocolStatus;
|
import earth.krakatao.protocol.KraSocketClientProtocolStatus;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.security.SecureRandom;
|
import java.security.SecureRandom;
|
||||||
|
import java.util.Objects;
|
||||||
import java.util.concurrent.TimeUnit;
|
import java.util.concurrent.TimeUnit;
|
||||||
import java.util.function.Consumer;
|
import java.util.function.Consumer;
|
||||||
import net.krakatoa.proxy.ProxySystem;
|
import net.krakatoa.proxy.ProxySystem;
|
||||||
|
@ -80,9 +81,11 @@ public class PostLoginListener implements Listener {
|
||||||
map.put("voiceWebCode", "voiceWebCode");
|
map.put("voiceWebCode", "voiceWebCode");
|
||||||
|
|
||||||
document.forEach((key, value) -> {
|
document.forEach((key, value) -> {
|
||||||
ProxySystem.getInstance().getLogger()
|
if (!Objects.equals(key, "_id")) {
|
||||||
.info("key " + key + " value " + value.toString());
|
ProxySystem.getInstance().getLogger()
|
||||||
map.put(key, value.toString());
|
.info("key " + key + " value " + value.toString());
|
||||||
|
map.put(key, value.toString());
|
||||||
|
}
|
||||||
});
|
});
|
||||||
ProxySystem.getInstance().getLogger().info("PUT !");
|
ProxySystem.getInstance().getLogger().info("PUT !");
|
||||||
} else {
|
} else {
|
||||||
|
|
Loading…
Reference in New Issue