Use VelocityMessage

Author: xiaozhangup

pom.xml

@@ -7,8 +7,8 @@
 	<version>3.6.7</version>
 	<repositories>
 		<repository>
-			<id>spigot-repo</id>
-			<url>https://hub.spigotmc.org/nexus/content/repositories/snapshots/</url>
+			<id>paper-repo</id>
+			<url>https://repo.papermc.io/repository/maven-public/</url>
 		</repository>
 		<repository>
 			<id>CodeMC</id>
@@ -22,20 +22,20 @@
 	<dependencies>
 		<!--Spigot API -->
 		<dependency>
-			<groupId>org.spigotmc</groupId>
-			<artifactId>spigot-api</artifactId>
-			<version>1.18.1-R0.1-SNAPSHOT</version>
+			<groupId>io.papermc.paper</groupId>
+			<artifactId>paper-api</artifactId>
+			<version>1.20.1-R0.1-SNAPSHOT</version>
 			<scope>provided</scope>
 		</dependency>
 		<dependency>
 			<groupId>org.jsoup</groupId>
 			<artifactId>jsoup</artifactId>
-			<version>1.14.2</version>
+			<version>1.15.3</version>
 		</dependency>
 		<dependency>
 			<groupId>mysql</groupId>
 			<artifactId>mysql-connector-java</artifactId>
-			<version>8.0.17</version>
+			<version>8.0.28</version>
 		</dependency>
 		<dependency>
 			<groupId>org.xerial</groupId>

src/me/xiaozhangup/velocity/VelocityMessage.java

@@ -0,0 +1,28 @@
+package me.xiaozhangup.velocity;
+
+import net.kyori.adventure.text.Component;
+import net.kyori.adventure.text.serializer.gson.GsonComponentSerializer;
+import org.bukkit.Bukkit;
+import org.bukkit.plugin.Plugin;
+
+public class VelocityMessage {
+
+    Plugin plugin;
+
+    public VelocityMessage(Plugin plugin) {
+        this.plugin = plugin;
+
+        plugin.getServer().getMessenger().registerOutgoingPluginChannel(plugin, "slime:old");
+        plugin.getServer().getMessenger().registerOutgoingPluginChannel(plugin, "slime:modern");
+    }
+
+    public void broadcast(String string) {
+        Bukkit.getServer().sendPluginMessage(plugin, "slime:pull", string.getBytes());
+    }
+
+    public void broadcast(Component component) {
+        String string = GsonComponentSerializer.gson().serialize(component);
+        Bukkit.getServer().sendPluginMessage(plugin, "slime:pull", string.getBytes());
+    }
+
+}

src/moe/feo/bbstoper/BBSToper.java

@@ -1,5 +1,6 @@
 package moe.feo.bbstoper;
 
+import me.xiaozhangup.velocity.VelocityMessage;
 import org.bstats.bukkit.Metrics;
 import org.bukkit.Bukkit;
 import org.bukkit.plugin.java.JavaPlugin;
@@ -13,10 +14,12 @@ public class BBSToper extends JavaPlugin {
 	public static BBSToper getInstance() {
 		return bbstoper;
 	}
+	public static VelocityMessage velocity;
 
 	@Override
 	public void onEnable() {
 		bbstoper = this;
+		velocity = new VelocityMessage(bbstoper);
 		this.saveDefaultConfig();
 		Option.load();
 		Message.saveDefaultConfig();

src/moe/feo/bbstoper/CLI.java

@@ -278,11 +278,7 @@ public void task() {
 					sql.updatePoster(poster);// 更新poster
 					if (issucceed) {
 						sender.sendMessage(Message.PREFIX.getString() + Message.REWARDGIVED.getString());
-						for (Player p :Bukkit.getOnlinePlayers()) {// 给有奖励权限且能看见此玩家(防止Vanish)的玩家广播
-							if (!p.canSee((Player)sender)) continue;
-							if (!p.hasPermission("bbstoper.reward")) continue;
-							p.sendMessage(Message.PREFIX.getString() + Message.BROADCAST.getString().replaceAll("%PLAYER%", player.getName()));
-						}
+						BBSToper.velocity.broadcast(Message.PREFIX.getString() + Message.BROADCAST.getString().replaceAll("%PLAYER%", player.getName()));
 					}
 					if (isovertime) {
 						int rewardtimes = Option.REWARD_TIMES.getInt();

src/moe/feo/bbstoper/Crawler.java

@@ -136,11 +136,7 @@ public void activeReward() {// 主动给玩家发奖励
 					sql.addTopState(bbsname, time);
 					poster.setRewardtime(poster.getRewardtime() + 1);
 					sql.updatePoster(poster);// 把poster储存起来
-					for (Player p :Bukkit.getOnlinePlayers()) {// 给有奖励权限且能看见此玩家(防止Vanish)的玩家广播
-						if (!p.canSee(olplayer)) continue;
-						if (!p.hasPermission("bbstoper.reward")) continue;
-						p.sendMessage(Message.PREFIX.getString() + Message.BROADCAST.getString().replaceAll("%PLAYER%", player.getName()));
-					}
+					BBSToper.velocity.broadcast(Message.PREFIX.getString() + Message.BROADCAST.getString().replaceAll("%PLAYER%", player.getName()));
 				}
 			}
 		}