Fix motd broadcast and use native netty transports

Author: Kazzuk

gradle/libs.versions.toml

@@ -56,6 +56,8 @@ fastutil-short-sets = { group = "org.cloudburstmc.fastutil.sets", name = "short-
 fastutil-short-object-maps = { group = "org.cloudburstmc.fastutil.maps", name = "short-object-maps", version.ref = "fastutil" }
 
 bedrock-connection = { group = "org.cloudburstmc.protocol", name = "bedrock-connection", version = "3.0.0.Beta12-20260209.180455-4" }
+netty-transport-native-epoll = { group = "io.netty", name = "netty-transport-native-epoll", version = "4.1.101.Final" }
+netty-transport-native-kqueue = { group = "io.netty", name = "netty-transport-native-kqueue", version = "4.1.101.Final" }
 block-state-updater = { group = "org.cloudburstmc", name = "block-state-updater", version = "1.21.110-SNAPSHOT" }
 jopt-simple = { group = "net.sf.jopt-simple", name = "jopt-simple", version = "5.0.4" }
 leveldb-mcpe-jni = { group = "net.daporkchop", name = "leveldb-mcpe-jni", version = "0.0.10-SNAPSHOT" }

server/build.gradle.kts

@@ -15,6 +15,10 @@ dependencies {
     api(libs.bedrock.connection) {
         exclude("com.nukkitx.fastutil")
     }
+    compileOnly(libs.netty.transport.native.epoll)
+    compileOnly(libs.netty.transport.native.kqueue)
+    runtimeOnly(libs.netty.transport.native.epoll) { artifact { classifier = "linux-x86_64" } }
+    runtimeOnly(libs.netty.transport.native.kqueue) { artifact { classifier = "osx-x86_64" } }
     api(libs.block.state.updater)
     api(libs.bundles.fastutil)
     api(libs.leveldb.mcpe.jni)

server/src/main/java/org/cloudburstmc/server/network/BedrockInterface.java

@@ -4,7 +4,14 @@
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.Channel;
 import io.netty.channel.EventLoopGroup;
+import io.netty.channel.epoll.Epoll;
+import io.netty.channel.epoll.EpollDatagramChannel;
+import io.netty.channel.epoll.EpollEventLoopGroup;
+import io.netty.channel.kqueue.KQueue;
+import io.netty.channel.kqueue.KQueueDatagramChannel;
+import io.netty.channel.kqueue.KQueueEventLoopGroup;
 import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.DatagramChannel;
 import io.netty.channel.socket.nio.NioDatagramChannel;
 import lombok.extern.log4j.Log4j2;
 import org.cloudburstmc.api.event.server.QueryRegenerateEvent;
@@ -29,17 +36,30 @@
 public class BedrockInterface implements AdvancedSourceInterface {
 
     private final CloudServer server;
-
     private final EventLoopGroup eventLoopGroup;
     private final List<Channel> channels = new ArrayList<>();
     private final BedrockPong advertisement = new BedrockPong();
 
-    public BedrockInterface(CloudServer server) throws Exception {
+    public BedrockInterface(CloudServer server) {
         this.server = server;
 
-        this.eventLoopGroup = new NioEventLoopGroup();
+        Class<? extends DatagramChannel> datagramChannelClass;
+        if (Epoll.isAvailable()) {
+            this.eventLoopGroup = new EpollEventLoopGroup();
+            datagramChannelClass = EpollDatagramChannel.class;
+            log.debug("Using Epoll transport");
+        } else if (KQueue.isAvailable()) {
+            this.eventLoopGroup = new KQueueEventLoopGroup();
+            datagramChannelClass = KQueueDatagramChannel.class;
+            log.debug("Using KQueue transport");
+        } else {
+            this.eventLoopGroup = new NioEventLoopGroup();
+            datagramChannelClass = NioDatagramChannel.class;
+            log.debug("Using NIO transport");
+        }
+
         ServerBootstrap bootstrap = new ServerBootstrap()
-                .channelFactory(RakChannelFactory.server(NioDatagramChannel.class)) // TODO: Epoll, KQueue and IO Uring support
+                .channelFactory(RakChannelFactory.server(datagramChannelClass))
                 .group(this.eventLoopGroup)
                 .childHandler(new BedrockServerInitializer() {
                     @Override
@@ -79,7 +99,7 @@ public void sendRawPacket(InetSocketAddress socketAddress, ByteBuf payload) {
     @Override
     public void setName(String name) {
         QueryRegenerateEvent info = this.server.getQueryInformation();
-        String[] names = name.split("!@#");  //Split double names within the program
+        String[] names = name.split("!@#"); // Split double names within the program
         String motd = Utils.rtrim(names[0].replace(";", "\\;"), '\\');
         String subMotd = names.length > 1 ? Utils.rtrim(names[1].replace(";", "\\;"), '\\') : "";
         String gm = this.server.getDefaultGamemode().getName();
@@ -89,10 +109,12 @@ public void setName(String name) {
                 .subMotd(subMotd.trim().isEmpty() ? "Cloudburst" : subMotd)
                 .playerCount(info.getPlayerCount())
                 .maximumPlayerCount(info.getMaxPlayerCount())
-                .version("1")
-                .protocolVersion(0)
+                .version(ProtocolInfo.getDefaultMinecraftVersion())
+                .protocolVersion(ProtocolInfo.getDefaultProtocolVersion())
                 .gameType(gm.substring(0, 1).toUpperCase() + gm.substring(1))
-                .nintendoLimited(false);
+                .nintendoLimited(false)
+                .ipv4Port(this.server.getPort())
+                .serverId(this.server.getServerUniqueId().getMostSignificantBits());
 
         for (Channel channel : this.channels) {
             channel.config().setOption(RakChannelOption.RAK_ADVERTISEMENT, this.advertisement.toByteBuf());
@@ -101,10 +123,6 @@ public void setName(String name) {
 
     @Override
     public boolean process() {
-//        NukkitSessionListener listener;
-//        while ((listener = disconnectQueue.poll()) != null) {
-//            listener.player.close(listener.player.getLeaveMessage(), listener.disconnectReason, false);
-//        }
         return true;
     }
 
@@ -120,21 +138,4 @@ public void shutdown() {
     public void emergencyShutdown() {
         this.shutdown();
     }
-//
-//    @RequiredArgsConstructor
-//    private class NukkitSessionListener implements Consumer<DisconnectReason> {
-//        private final CloudPlayer player;
-//        private String disconnectReason = null;
-//
-//        @Override
-//        public void accept(DisconnectReason disconnectReason) {
-//            if (disconnectReason == DisconnectReason.TIMED_OUT) {
-//                this.disconnectReason = "Timed out";
-//            } else {
-//                this.disconnectReason = "Disconnected from Server";
-//            }
-//            // Queue for disconnect on main thread.
-//            BedrockInterface.this.disconnectQueue.add(this);
-//        }
-//    }
 }