[整地]ChunksExplorerLimiter —— 还在担心玩家跑图吗？[1.7.x-1.15.x] - 服务端插件

a1294790523

本帖最后由 a1294790523 于 2020-6-9 13:50 编辑

ChunksExplorerLimiter

跑图克星

还在担心玩家跑图吗？这个插件提供了通过限制跑图区块来限制玩家跑图的插件，尽情使用吧！

（温馨提示：在使用世界生成/预加载工具时请将该世界移出包含列表，否则将导致误报）

插件截图：

插件下载：

ChunksExplorerLimiter-1.8.jar (7.69 KB, 下载次数: 481)

更新日志：

指令：
以下命令权限都为cel.use，默认op拥有

/cel reload——重载插件配置

/cel stats——查看玩家跑图信息

配置文件（区块数量限制建议根据服务器实际情况调整）：

源代码（使用CC0协议）：

package sandtechnology.chunksexplorerlimiter;
import org.bukkit.Bukkit;
import org.bukkit.Location;
import org.bukkit.command.Command;
import org.bukkit.command.CommandExecutor;
import org.bukkit.command.CommandSender;
import org.bukkit.event.EventHandler;
import org.bukkit.event.EventPriority;
import org.bukkit.event.Listener;
import org.bukkit.event.world.ChunkPopulateEvent;
import org.bukkit.plugin.PluginManager;
import org.bukkit.plugin.java.JavaPlugin;
import java.util.Comparator;
import java.util.List;
import java.util.Map;
import java.util.UUID;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.stream.Collectors;
//v1.2 感谢@Karlatemp的建议，已进行修改
//v1.3 再次根据@Karlatemp的建议进行修改
//v1.4 再再次根据@Karlatemp的建议进行修改
//v1.5 再再再次根据@Karlatemp的建议进行修改
//v1.7 解决了CME，不再存储玩家跑图信息，支持1.7.10并添加查看跑图信息的指令
//v1.8 解决了不会提示跑图警告信息的bug，放宽踢出时的延迟，感谢huzpsb的提醒
public class ChunksExplorerLimiter extends JavaPlugin implements CommandExecutor, Listener {
private final Map<UUID, AtomicInteger> chunksExplorerMap = new ConcurrentHashMap<>();
private String prefix;
private String chunksLimitKickMessage;
private int chunksLimit;
private String chunksLimitWarningMessage;
private List<String> worlds;
private double warningRate;
public ChunksExplorerLimiter() {
}
@Override
public void onEnable() {
saveDefaultConfig();
settingVars();
getCommand("CEL").setExecutor(this);
Bukkit.getScheduler().runTaskTimerAsynchronously(this, chunksExplorerMap::clear, 0, getConfig().getLong("cleanTime") * 20);
Bukkit.getPluginManager().registerEvents(this, this);
}
private void settingVars() {
if (getConfig().getInt("version") == 1) {
getConfig().set("warningRate", 0.8);
getConfig().set("version", 2);
saveConfig();
}
prefix = getConfig().getString("prefix");
chunksLimit = getConfig().getInt("chunksLimit");
worlds = getConfig().getStringList("worlds");
warningRate = getConfig().getDouble("warningRate");
chunksLimitWarningMessage = getConfig().getString("chunksLimitWarningMessage");
chunksLimitKickMessage = getConfig().getString("chunksLimitKickMessage");
}
@Override
public boolean onCommand(CommandSender sender, Command command, String label, String[] args) {
if (args.length == 1) {
if (args[0].equalsIgnoreCase("reload")) {
//不直接调用onDisable和onEnable方法
PluginManager pluginManager = getServer().getPluginManager();
pluginManager.disablePlugin(this);
pluginManager.enablePlugin(this);
sender.sendMessage("§a" + prefix + "重载完成！");
return true;
} else if (args[0].equalsIgnoreCase("stats")) {
Bukkit.getScheduler().runTaskAsynchronously(this, () ->
sender.sendMessage("§a跑图数据如下：\n" + chunksExplorerMap.entrySet().stream().sorted(Comparator.comparingInt(e -> e.getValue().get())).limit(10).map(e -> getServer().getOfflinePlayer(e.getKey()).getName() + ":" + e.getValue().get() + "个区块").collect(Collectors.joining("\n"))));
return true;
}
}
sender.sendMessage("命令帮助：" +
"\n /cel reload ——重载插件" +
"\n /cel stats ——查看Top10跑图信息");
return true;
}
@Override
public void onDisable() {
}
@EventHandler(priority = EventPriority.HIGHEST)
public void onChunkGenerated(ChunkPopulateEvent event) {
if (!worlds.contains(event.getChunk().getWorld().getName())) {
return;
}
//获取每个玩家距离生成区块的距离，选取最近一个玩家
Location location = event.getChunk().getBlock(7, 127, 7).getLocation();
event.getChunk().getWorld().getPlayers().stream().min(Comparator.comparingDouble(player -> player.getLocation().distanceSquared(location))).ifPresent(
player -> {
UUID uuid = player.getUniqueId();
int current = chunksExplorerMap.computeIfAbsent(uuid, (key) -> new AtomicInteger(0)).incrementAndGet();
//强转int截断取整避免浮点数
if ((int) (chunksLimit * warningRate) == current) {
player.sendMessage(prefix + chunksLimitWarningMessage);
}
if (current >= chunksLimit) {
Bukkit.getScheduler().runTaskLater(this, () ->
{
if (player.isOnline()) {
player.kickPlayer(prefix + chunksLimitKickMessage);
}
}, 3);
}
}
);
}
}

复制代码

本插件所用所有代码均为原创,不存在借用/抄袭等行为

玄月月

你跑你

呢（草）

Karlatemp

import com.google.common.cache.Cache;
import com.google.common.cache.CacheBuilder;
import com.google.common.cache.CacheLoader;
import com.google.common.cache.LoadingCache;
import org.bukkit.Bukkit;
import org.bukkit.Location;
import org.bukkit.command.Command;
import org.bukkit.command.CommandSender;
import org.bukkit.entity.Player;
import org.bukkit.event.EventHandler;
import org.bukkit.event.EventPriority;
import org.bukkit.event.world.ChunkPopulateEvent;
import org.bukkit.plugin.PluginManager;
import org.bukkit.plugin.java.JavaPlugin;
import org.jetbrains.annotations.NotNull;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.nio.file.Files;
import java.nio.file.OpenOption;
import java.nio.file.StandardOpenOption;
import java.util.*;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.logging.Level;
public class AKM extends JavaPlugin {
public void onEnable() {
try {
if (Files.notExists(dataPath)) {
Files.write(dataPath, new byte[]{'{', '}'}); // 直接写byte他不香吗 ?
// - Files.write(dataPath, Collections.singleton("{}"), StandardCharsets.UTF_8);
} /*// + */ else {
// 直接使用数据流，不经过String, 减少内存使用+减少CPU使用
try (BufferedReader reader = Files.newBufferedReader(path, StandardCharsets.UTF_8)) {
chunksExplorerMap.putAll(gson.fromJson(reader, Map.class));
}
}
// - chunksExplorerMap.putAll(gson.fromJson(String.join("\n", Files.readAllLines(getDataFolder().toPath().resolve("data.json"), StandardCharsets.UTF_8)), chunksExplorerMapType));
} catch (IOException e) {
// 亲爱的, Logger怎么用都8知道??
// - getLogger().warning("玩家跑图数据加载失败！");
// - e.printStackTrace();
getLogger().log(Level.WARNING, "玩家跑图数据加载失败！", e);
}
}
private LoadingCache<UUID, AtomicInteger> chunksExplorerMap;
public void onDisable() {
// 直接使用数据流，不经过String, 减少内存使用+减少CPU使用
try /*+*/ (BufferedWriter writer = Files.newBufferedWriter(dataPath, StandardCharsets.UTF_8)) {
// Files.write(dataPath, Collections.singleton(gson.toJson(chunksExplorerMap)), StandardCharsets.UTF_8);
gson.toJson(chunksExplorerMap, writer);
} catch (IOException e) {
// - getLogger().warning("玩家跑图数据保存失败！");
// - e.printStackTrace();
getLogger().log(Level.WARNING, "玩家跑图数据保存失败！", e);
}
//... chunksExplorerMap Initialize
chunksExplorerMap = CacheBuilder.newBuilder().expireAfterAccess(
getConfig().getLong("cleanTime"), TimeUnit.SECONDS
).build(new CacheLoader<UUID, AtomicInteger>() {
@Override
public AtomicInteger load(@NotNull UUID key) throws Exception {
return new AtomicInteger();
}
});
this.Config_ChunksLimit = getConfig().getInt("chunksLimit");
Config_ChunksWarmingLimit = (int) (Config_ChunksLimit * 0.8);
// 由
// if (chunksExplorerMap.get(uuid) > getConfig().getInt("chunksLimit"))
// 推出
Config_ChunksRealLimit = Config_ChunksLimit + 1;
this.Config_Prefix = getConfig().getString("prefix");
this.Config_chunksLimitWarningMessage = getConfig().getString("chunksLimitWarningMessage");
Config_chunksLimitKickMessage = getConfig().getString("chunksLimitKickMessage");
worlds = getConfig().getStringList("worlds");
}
public boolean onCommand(CommandSender sender, Command command, String label, String[] args) {
if (args.length == 1) {
switch (args[0].toLowerCase()) { // Command: /ecl reload
case "rl":
case "reload":
if (!sender.hasPermission("cel.reload")) {
sender.sendMessage(command.getPermissionMessage());
return true;
}
// 不要直接玩onEnable()/onDisable(), 那样的话会造成[监听器]和[各种定时/延时]没能正确注销
PluginManager pm = Bukkit.getPluginManager();
pm.disablePlugin(this);
pm.enablePlugin(this);
sender.sendMessage("§6ChunksExplorerLimiter§r>>§b 重载完成！");
return true; // End execute
}
}
// Default send version info
if (!sender.hasPermission("cel.version")) {
sender.sendMessage(command.getPermissionMessage());
return true;
}
sender.sendMessage("§bChunksExplorerLimiter §6v1.2§r by§b a1294790523");
return true;
}
private int Config_ChunksLimit; // 在onEnable中定义
private int Config_ChunksRealLimit; // 在onEnable中定义
private int Config_ChunksWarmingLimit;
private String
Config_Prefix, Config_chunksLimitWarningMessage,
Config_chunksLimitKickMessage;
private List<String> worlds;
@EventHandler(priority = EventPriority.HIGHEST)
public void onChunkGenerated(ChunkPopulateEvent event) {
// if (getConfig().getStringList("worlds").stream().noneMatch(event.getChunk().getWorld().getName()::equals)) {
if (!worlds.contains(event.getChunk().getWorld().getName())) {
return;
}
//获取每个玩家距离生成区块的距离，选取最近一个玩家
Location location = event.getChunk().getBlock(7, 127, 7).getLocation();
final Optional<Player> nearest = location.getWorld().getPlayers().stream().min(Comparator.comparingDouble(
player -> player.getLocation().distanceSquared(location))
);
if (!nearest.isPresent()) {
// Player not found
return;
}
Player player = nearest.get();
// chunksExplorerMap.put(uuid, chunksExplorerMap.getOrDefault(uuid, 0) + 1);
int current;
try {
current = chunksExplorerMap.get(player.getUniqueId()).incrementAndGet();
} catch (ExecutionException error) {
// Oh 我亲爱的上帝, 这不应该[不可能]发生
throw new RuntimeException(error);
}
/*
真的牛逼，配置是 chunksLimit 然后源码是 [C]hunksLimit
==>
if (chunksExplorerMap.get(uuid) * 0.8 ==
if (chunksExplorerMap.get(uuid) >
第一句怎么也不会触发吧，触发第二句的时候就已经把人T了, 哇, 真的牛逼兄弟
=============================================================
if (chunksExplorerMap.get(uuid) * 0.8 == getConfig().getInt("ChunksLimit")) {
sendMessage(uuid, getConfig().getString("chunksLimitWarningMessage"));
}
if (chunksExplorerMap.get(uuid) > getConfig().getInt("chunksLimit")) {
Player player = getServer().getPlayer(uuid);
if (player != null) {
player.kickPlayer(Config_Prefix + getConfig().getString("chunksLimitKickMessage"));
}
}
*/
if (current == Config_ChunksWarmingLimit) {
player.sendMessage(Config_Prefix + Config_chunksLimitWarningMessage);
// sendMessage(player, Config_chunksLimitWarningMessage);
}
if (current == Config_ChunksRealLimit) { // int特性, 不需要大于 / 等于
player.kickPlayer(Config_Prefix + Config_chunksLimitKickMessage);
}
}
}

复制代码