add Spam Check...

src/cn/citycraft/SimpleProtect/SimpleProtect.java

@@ -10,6 +10,7 @@ import cn.citycraft.SimpleProtect.listen.Explosion;
 import cn.citycraft.SimpleProtect.listen.HighRedstone;
 import cn.citycraft.SimpleProtect.listen.NetherDoor;
 import cn.citycraft.SimpleProtect.listen.Nightvision;
+import cn.citycraft.SimpleProtect.listen.Spam;
 import cn.citycraft.SimpleProtect.listen.Tip;
 
 public class SimpleProtect extends JavaPlugin {
@@ -58,7 +59,13 @@ public class SimpleProtect extends JavaPlugin {
 			Bukkit.getScheduler().runTaskTimer(this, redstone, 20, 20);
 			getLogger().info("防止玩家高频红石已加载!");
 		}
-
+		if (Config.getInstance().getBoolean("Spam.Enable", true)) {
+			Spam spam = new Spam(this);
+			Bukkit.getPluginManager().registerEvents(spam, this);
+			Bukkit.getScheduler().runTaskTimer(this, spam, 20, 20);
+			getCommand("spam").setExecutor(spam);
+			getLogger().info("防止玩家聊天刷屏已加载!");
+		}
 		getLogger().info("==========" + servername + pluginname + "==========");
 	}
 

src/cn/citycraft/SimpleProtect/listen/Spam.java

@@ -0,0 +1,195 @@
+/*
+ * To change this template, choose Tools | Templates and open the template in the editor.
+ */
+package cn.citycraft.SimpleProtect.listen;
+
+import java.util.HashMap;
+
+import org.bukkit.Bukkit;
+import org.bukkit.command.Command;
+import org.bukkit.command.CommandExecutor;
+import org.bukkit.command.CommandSender;
+import org.bukkit.entity.Player;
+import org.bukkit.event.EventHandler;
+import org.bukkit.event.Listener;
+import org.bukkit.event.player.AsyncPlayerChatEvent;
+import org.bukkit.event.player.PlayerCommandPreprocessEvent;
+
+import cn.citycraft.SimpleProtect.SimpleProtect;
+
+/**
+ *
+ * @author 蒋天蓓
+ */
+public class Spam implements Runnable, Listener, CommandExecutor {
+
+	private final HashMap<String, Long> lT;
+	private final HashMap<String, String> lC;
+	HashMap<Player, Integer> tc = new HashMap<Player, Integer>();
+	HashMap<Player, Player> cc = new HashMap<Player, Player>();
+	String AntiMsg;
+	boolean adminchat;
+	SimpleProtect plugin;
+
+	public Spam(SimpleProtect main) {
+		plugin = main;
+		this.lT = new HashMap<String, Long>();
+		this.lC = new HashMap<String, String>();
+	}
+
+	public boolean AntiChat(String n, String s) {
+		String lm = lC.get(n);
+		Long lt = lT.get(n);
+		long nt = System.currentTimeMillis() / 1000;
+		if (lm == null || lt == null) {
+			AntiMsg = "";
+			SaveMsg(n, s);
+			return false;
+		}
+		if (lt + plugin.getConfig().getLong("Spam.ChatWait", 1) > nt) {
+			AntiMsg = "请不要短时间内发送大量消息！";
+			return true;
+		}
+		if (lm.equals(s)) {
+			if (lt + plugin.getConfig().getLong("Spam.SameChatWait", 5) > nt) {
+				AntiMsg = "请不要短时间内发送重复的消息！";
+				return true;
+			}
+		}
+		AntiMsg = "";
+		SaveMsg(n, s);
+		return false;
+	}
+
+	public boolean CommandWait(String n, String s) {
+		String lm = lC.get(n);
+		Long lt = lT.get(n);
+		long nt = System.currentTimeMillis() / 1000;
+		if (lm == null || lt == null) {
+			AntiMsg = "";
+			SaveMsg(n, s);
+			return false;
+		}
+		if (lt + plugin.getConfig().getLong("Spam.CommandWait", 1) > nt) {
+			AntiMsg = "请不要短时间内发送大量命令";
+			return true;
+		}
+		if (lm.equals(s)) {
+			if (lt + plugin.getConfig().getLong("Spam.SameCommandWait", 3) > nt) {
+				AntiMsg = "请不要短时间内发送相同的命令";
+				return true;
+			}
+		}
+		SaveMsg(n, s);
+		return false;
+	}
+
+	@Override
+	public boolean onCommand(CommandSender sender, Command command, String label, String[] args) {
+		if (command.getName().equalsIgnoreCase("spam")) {
+			if (!sender.hasPermission("spam.admin")) {
+				sender.sendMessage(plugin.servername + " " + plugin.getmessage("no-permission"));
+				return true;
+			}
+			if (args.length == 2) {
+				Player p = Bukkit.getPlayer(args[1]);
+				if (args[0].equalsIgnoreCase("add")) {
+					if (p != null) {
+						cc.put(p, p);
+						sender.sendMessage(plugin.servername + "  §c已禁止玩家 " + p.getDisplayName()
+								+ " §c聊天！");
+					} else {
+						sender.sendMessage(plugin.servername + "  §c玩家不存在或不在线！");
+					}
+				}
+				if (args[0].equalsIgnoreCase("del")) {
+					if (p != null && cc.containsKey(p)) {
+						cc.remove(p);
+						sender.sendMessage(plugin.servername + "  §a已允许玩家 " + p.getDisplayName()
+								+ " §a聊天！");
+					} else {
+						sender.sendMessage(plugin.servername + "  §c玩家未被禁言或不存在！");
+					}
+				}
+				if (args[0].equalsIgnoreCase("admin")) {
+					if (args[1].equalsIgnoreCase("on")) {
+						adminchat = true;
+						sender.sendMessage(plugin.servername + "  §a服务器已开启管理员聊天！");
+						return true;
+					}
+					if (args[1].equalsIgnoreCase("off")) {
+						adminchat = false;
+						sender.sendMessage(plugin.servername + "  §c服务器已关闭管理员聊天！");
+						return true;
+					}
+				}
+				return true;
+			}
+			return false;
+		}
+		return false;
+	}
+
+	@EventHandler(ignoreCancelled = true)
+	public void PlayerChat(AsyncPlayerChatEvent e) {
+		Player p = e.getPlayer();
+		String n = p.getName();
+		String s = e.getMessage();
+		if (p.hasPermission("fcp.ignore.spam"))
+			return;
+		if (adminchat) {
+			p.sendMessage(plugin.servername + "  §c服务器已开启管理员聊天！");
+			e.setCancelled(true);
+			return;
+		}
+		if (cc.containsKey(p)) {
+			p.sendMessage(plugin.servername + "  §c您已被禁言，请联系管理员解禁！");
+			e.setCancelled(true);
+			return;
+		}
+		if (AntiChat(n, s)) {
+			p.sendMessage(plugin.servername + "§6[§4刷屏检测§6] §c" + AntiMsg);
+			e.setCancelled(true);
+			put(p);
+		}
+	}
+
+	@EventHandler(ignoreCancelled = true)
+	public void PlayerCommand(PlayerCommandPreprocessEvent e) {
+		Player p = e.getPlayer();
+		String n = p.getName();
+		String s = e.getMessage();
+		if (p.hasPermission("fcp.ignore.spam"))
+			return;
+		if (CommandWait(n, s)) {
+			put(p);
+			p.sendMessage(plugin.servername + "§6[§4命令检测§6] §c" + AntiMsg);
+			e.setCancelled(true);
+		}
+	}
+
+	public void put(Player p) {
+		if (tc.containsKey(p)) {
+			int t = tc.get(p);
+			if (t > plugin.getConfig().getLong("Spam.KickCheck", 3)) {
+				p.sendMessage(plugin.servername + "  §c您由于多次刷屏已被禁言，请联系管理解禁！");
+				cc.put(p, p);
+			} else {
+				tc.put(p, t + 1);
+			}
+		} else {
+			tc.put(p, 1);
+		}
+	}
+
+	@Override
+	public void run() {
+		tc.clear();
+	}
+
+	public void SaveMsg(String n, String s) {
+		lC.put(n, s);
+		lT.put(n, System.currentTimeMillis() / 1000);
+	}
+
+}

src/config.yml

@@ -48,4 +48,15 @@ SafeNetherDoor:
   World: world
   X: -51
   Y: 73
-  Z: 38
+  Z: 38
+  
+  #刷屏保护
+Spam: 
+  #是否开启
+  Enable: true
+  ChatWait: 3
+  SameChatWait: 8
+  CommandWait: 2
+  SameCommandWait: 3
+  KickCheck: 3
+  KickReset: 10