274 lines
9.9 KiB
Java
274 lines
9.9 KiB
Java
/**
|
|
* Copyright © 2013 tuxed <write@imaginarycode.com>
|
|
* This work is free. You can redistribute it and/or modify it under the
|
|
* terms of the Do What The Fuck You Want To Public License, Version 2,
|
|
* as published by Sam Hocevar. See http://www.wtfpl.net/ for more details.
|
|
*/
|
|
package com.imaginarycode.minecraft.redisbungee;
|
|
|
|
import com.google.common.base.Joiner;
|
|
import com.google.common.collect.ImmutableSet;
|
|
import com.google.common.collect.Lists;
|
|
import com.google.common.collect.Sets;
|
|
import net.md_5.bungee.api.ChatColor;
|
|
import net.md_5.bungee.api.CommandSender;
|
|
import net.md_5.bungee.api.ServerPing;
|
|
import net.md_5.bungee.api.config.ServerInfo;
|
|
import net.md_5.bungee.api.connection.ProxiedPlayer;
|
|
import net.md_5.bungee.api.event.PlayerDisconnectEvent;
|
|
import net.md_5.bungee.api.event.PostLoginEvent;
|
|
import net.md_5.bungee.api.event.ProxyPingEvent;
|
|
import net.md_5.bungee.api.event.ServerConnectedEvent;
|
|
import net.md_5.bungee.api.plugin.Command;
|
|
import net.md_5.bungee.api.plugin.Listener;
|
|
import net.md_5.bungee.api.plugin.Plugin;
|
|
import net.md_5.bungee.event.EventHandler;
|
|
import org.yaml.snakeyaml.Yaml;
|
|
import redis.clients.jedis.Jedis;
|
|
import redis.clients.jedis.JedisPool;
|
|
import redis.clients.jedis.JedisPoolConfig;
|
|
|
|
import java.io.*;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
import java.util.Set;
|
|
import java.util.concurrent.TimeUnit;
|
|
|
|
public class RedisBungee extends Plugin implements Listener {
|
|
private static JedisPool pool;
|
|
private static String serverId;
|
|
private static List<String> servers = Lists.newArrayList();
|
|
private static RedisBungee plugin;
|
|
|
|
public static int getCount() {
|
|
int count = 0;
|
|
count += plugin.getProxy().getOnlineCount();
|
|
if (pool != null) {
|
|
Jedis rsc = pool.getResource();
|
|
try {
|
|
for (String i : servers) {
|
|
if (i.equals(serverId)) continue;
|
|
if (rsc.exists("server:" + i + ":playerCount"))
|
|
count += Integer.valueOf(rsc.get("server:" + i + ":playerCount"));
|
|
}
|
|
} finally {
|
|
pool.returnResource(rsc);
|
|
}
|
|
}
|
|
return count;
|
|
}
|
|
|
|
public static Set<String> getPlayers() {
|
|
Set<String> players = Sets.newHashSet();
|
|
for (ProxiedPlayer pp : plugin.getProxy().getPlayers()) {
|
|
players.add(pp.getName());
|
|
}
|
|
if (pool != null) {
|
|
Jedis rsc = pool.getResource();
|
|
try {
|
|
for (String i : servers) {
|
|
if (i.equals(serverId)) continue;
|
|
for (String p : rsc.smembers("server:" + i + ":usersOnline")) {
|
|
if (!players.contains(p)) {
|
|
players.add(p);
|
|
}
|
|
}
|
|
}
|
|
} finally {
|
|
pool.returnResource(rsc);
|
|
}
|
|
}
|
|
return ImmutableSet.copyOf(players);
|
|
}
|
|
|
|
public static ServerInfo getServerFor(ProxiedPlayer pp) {
|
|
return getServerFor(pp.getName());
|
|
}
|
|
|
|
public static ServerInfo getServerFor(String name) {
|
|
ServerInfo server = null;
|
|
if (plugin.getProxy().getPlayer(name) != null) return plugin.getProxy().getPlayer(name).getServer().getInfo();
|
|
if (pool != null) {
|
|
Jedis tmpRsc = pool.getResource();
|
|
try {
|
|
if (tmpRsc.hexists("player:" + name, "server"))
|
|
server = plugin.getProxy().getServerInfo(tmpRsc.hget("player:" + name, "server"));
|
|
} finally {
|
|
pool.returnResource(tmpRsc);
|
|
}
|
|
}
|
|
return server;
|
|
}
|
|
|
|
public static long getLastOnline(ProxiedPlayer pp) {
|
|
return getLastOnline(pp.getName());
|
|
}
|
|
|
|
private static long getUnixTimestamp() {
|
|
return TimeUnit.SECONDS.convert(System.currentTimeMillis(), TimeUnit.MILLISECONDS);
|
|
}
|
|
|
|
public static long getLastOnline(String name) {
|
|
long time = 0L;
|
|
if (plugin.getProxy().getPlayer(name) != null) return time;
|
|
if (pool != null) {
|
|
Jedis tmpRsc = pool.getResource();
|
|
try {
|
|
if (tmpRsc.hexists("player:" + name, "online"))
|
|
time = Long.valueOf(tmpRsc.hget("player:" + name, "online"));
|
|
} finally {
|
|
pool.returnResource(tmpRsc);
|
|
}
|
|
}
|
|
return time;
|
|
}
|
|
|
|
@Override
|
|
public void onEnable() {
|
|
plugin = this;
|
|
try {
|
|
loadConfig();
|
|
} catch (IOException e) {
|
|
e.printStackTrace();
|
|
}
|
|
if (pool != null) {
|
|
Jedis tmpRsc = pool.getResource();
|
|
try {
|
|
tmpRsc.set("server:" + serverId + ":playerCount", "0"); // reset
|
|
for (String i : tmpRsc.smembers("server:" + serverId + ":usersOnline")) {
|
|
tmpRsc.srem("server:" + serverId + ":usersOnline", i);
|
|
}
|
|
} finally {
|
|
pool.returnResource(tmpRsc);
|
|
}
|
|
getProxy().getScheduler().schedule(this, new Runnable() {
|
|
@Override
|
|
public void run() {
|
|
Jedis rsc = pool.getResource();
|
|
try {
|
|
rsc.set("server:" + serverId + ":playerCount", String.valueOf(getProxy().getOnlineCount()));
|
|
} finally {
|
|
pool.returnResource(rsc);
|
|
}
|
|
}
|
|
}, 3, 3, TimeUnit.SECONDS);
|
|
getProxy().getPluginManager().registerCommand(this, new Command("glist") {
|
|
@Override
|
|
public void execute(CommandSender sender, String[] args) {
|
|
sender.sendMessage(ChatColor.YELLOW + String.valueOf(getCount()) + " player(s) are currently online.");
|
|
if (args.length > 0 && args[0].equals("showall")) {
|
|
sender.sendMessage(ChatColor.YELLOW + "Players: " + Joiner.on(", ").join(getPlayers()));
|
|
} else {
|
|
sender.sendMessage(ChatColor.YELLOW + "To see all players online, use /glist showall.");
|
|
}
|
|
}
|
|
});
|
|
getProxy().getPluginManager().registerListener(this, this);
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public void onDisable() {
|
|
pool.destroy();
|
|
}
|
|
|
|
private void loadConfig() throws IOException {
|
|
if (!getDataFolder().exists()) {
|
|
getDataFolder().mkdir();
|
|
}
|
|
|
|
File exampleConfig = new File(getDataFolder(), "config.yml");
|
|
if (!exampleConfig.exists()) {
|
|
exampleConfig.createNewFile();
|
|
InputStream in = getResourceAsStream("example_config.yml");
|
|
OutputStream out = new FileOutputStream(exampleConfig);
|
|
byte[] buf = new byte[1024];
|
|
int len;
|
|
while ((len = in.read(buf)) > 0) {
|
|
out.write(buf, 0, len);
|
|
}
|
|
out.close();
|
|
in.close();
|
|
}
|
|
|
|
File file = new File(getDataFolder() + File.separator + "config.yml");
|
|
Yaml yaml = new Yaml();
|
|
Map rawYaml = (Map) yaml.load(new FileInputStream(file));
|
|
|
|
String redisServer = ((String) rawYaml.get("redis-server"));
|
|
serverId = ((String) rawYaml.get("server-id"));
|
|
List<?> tmp = (List<?>) rawYaml.get("linked-servers");
|
|
if (tmp != null)
|
|
for (Object i : tmp) {
|
|
if (i instanceof String) {
|
|
servers.add((String) i);
|
|
}
|
|
}
|
|
|
|
if (redisServer != null) {
|
|
if (!redisServer.equals("")) {
|
|
pool = new JedisPool(new JedisPoolConfig(), redisServer);
|
|
}
|
|
}
|
|
}
|
|
|
|
@EventHandler
|
|
public void onPlayerConnect(final PostLoginEvent event) {
|
|
if (pool != null) {
|
|
Jedis rsc = pool.getResource();
|
|
try {
|
|
rsc.sadd("server:" + serverId + ":usersOnline", event.getPlayer().getName());
|
|
rsc.hset("player:" + event.getPlayer().getName(), "online", "0");
|
|
rsc.hset("player:" + event.getPlayer().getName(), "online", (String)getProxy().getServers().keySet().toArray()[0]);
|
|
} finally {
|
|
pool.returnResource(rsc);
|
|
}
|
|
getProxy().getScheduler().schedule(this, new Runnable() {
|
|
@Override
|
|
public void run() {
|
|
Jedis rsc = pool.getResource();
|
|
try {
|
|
rsc.hset("player:" + event.getPlayer().getName(), "server", event.getPlayer().getServer().getInfo().getName());
|
|
} finally {
|
|
pool.returnResource(rsc);
|
|
}
|
|
}
|
|
}, 3, TimeUnit.SECONDS);
|
|
}
|
|
}
|
|
|
|
@EventHandler
|
|
public void onPlayerDisconnect(PlayerDisconnectEvent event) {
|
|
if (pool != null) {
|
|
Jedis rsc = pool.getResource();
|
|
try {
|
|
rsc.srem("server:" + serverId + ":usersOnline", event.getPlayer().getName());
|
|
rsc.hset("player:" + event.getPlayer().getName(), "online", String.valueOf(getUnixTimestamp()));
|
|
rsc.hdel("player:" + event.getPlayer().getName(), "server");
|
|
} finally {
|
|
pool.returnResource(rsc);
|
|
}
|
|
}
|
|
}
|
|
|
|
@EventHandler
|
|
public void onServerChange(ServerConnectedEvent event) {
|
|
if (pool != null) {
|
|
Jedis rsc = pool.getResource();
|
|
try {
|
|
rsc.hset("player:" + event.getPlayer().getName(), "server", event.getServer().getInfo().getName());
|
|
} finally {
|
|
pool.returnResource(rsc);
|
|
}
|
|
}
|
|
}
|
|
|
|
@EventHandler
|
|
public void onPing(ProxyPingEvent event) {
|
|
ServerPing old = event.getResponse();
|
|
int players = getCount();
|
|
ServerPing newResponse = new ServerPing(old.getProtocolVersion(), old.getGameVersion(), old.getMotd(), players, old.getMaxPlayers());
|
|
event.setResponse(newResponse);
|
|
}
|
|
}
|