Merge commit '2e965dbf2eec46e1d71b1a676c68965bbc09ede7' into develop

Author: congcoi123

framework/core/CHANGELOG.md

@@ -131,4 +131,11 @@
 - It should force to close sessions and disconnect players in some scenarios
 
 ## 0.7.2 2026-04-25 Feature release
-- Fixed issues which caused theGame Server takes time to shut down
+- Fixed issues which caused the Game Server takes time to shut down
+
+## 0.7.3 2026-05-29 Feature release
+- Fixed several issues in ServerApi
+- Improved the performance by offloading tasks from IO bound workers
+- Used EnumMap in EventHandler to increase lookup speed
+- Supported multi UDP channels
+- Renamed and added new APIs

framework/core/README.md

@@ -108,7 +108,7 @@ Maven Central
 <dependency>
     <groupId>io.github.congcoi123</groupId>
     <artifactId>tenio-core</artifactId>
-    <version>0.7.2</version>
+    <version>0.7.3</version>
 </dependency>
 ```
 GitHub

framework/core/TODO.md

@@ -1,2 +1,3 @@
 ### TODO LIST
-- [ ] Makes proper session reconnection handling
+- [ ] Makes proper session reconnection handling
+- [ ] Players should own its inbound queue in case we need to create NPC on server

framework/core/VERSION

@@ -1 +1 @@
-20260425.0.7.2
+20260529.0.7.3

framework/core/configuration.example.xml

@@ -24,16 +24,22 @@
               - Use 1 or let the cacheSize to be absent on macOS/Windows (SO_REUSEPORT not reliable).
               - On Linux, increase for better load balancing if SO_REUSEPORT is enabled.
              -->
-            <Port name="udp" type="udp" cacheSize="100">20004</Port>
+            <Port name="udp" type="udp" cacheSize="10">20004</Port>
             <Port name="http" type="http">9999</Port>
         </Sockets>
         <Properties>
             <Property name="websocket-using-ssl">false</Property>
-            <Property name="websocket-sender-buffer-size">1024</Property>
-            <Property name="websocket-receiver-buffer-size">1024</Property>
-            <Property name="socket-acceptor-buffer-size">1024</Property>
-            <Property name="socket-reader-buffer-size">1024</Property>
-            <Property name="socket-writer-buffer-size">1024</Property>
+            <!--
+                1 KB  -> 1024
+                8 KB  -> 8192
+                16 KB -> 16384
+                32 KB -> 32768
+            -->
+            <Property name="websocket-sender-buffer-size">1024</Property>   <!-- 1KB -->
+            <Property name="websocket-receiver-buffer-size">1024</Property> <!-- 1KB -->
+            <Property name="socket-acceptor-buffer-size">1024</Property>    <!-- 1KB -->
+            <Property name="socket-reader-buffer-size">1024</Property>      <!-- 1KB -->
+            <Property name="socket-writer-buffer-size">1024</Property>      <!-- 1KB -->
             <!-- This will never compress packets if the threshold is less than or equals to 0 -->
             <Property name="packet-compression-threshold-bytes">10240</Property>
             <Property name="allow-change-session">false</Property>
@@ -43,7 +49,10 @@
 
     <Configuration>
         <Workers>
-            <Worker name="socket-reader">1</Worker>
+            <!-- The processor handle socket and datagram connection requests -->
+            <Worker name="processor">1</Worker>
+            <!-- In case udp channel is in use, half of the socket-reader workers will be used for them -->
+            <Worker name="socket-reader">4</Worker>
             <Worker name="socket-writer">2</Worker>
             <Worker name="websocket-producer">1</Worker>
             <Worker name="websocket-consumer">2</Worker>

framework/core/pom.xml

@@ -5,7 +5,7 @@
 
     <groupId>io.github.congcoi123</groupId>
     <artifactId>tenio-core</artifactId>
-    <version>0.7.2</version>
+    <version>0.7.3</version>
     <packaging>jar</packaging>
 
     <name>${project.groupId}:${project.artifactId}</name>
@@ -42,15 +42,15 @@
         <io.github.congcoi123.tenio.common>0.7.0</io.github.congcoi123.tenio.common>
 
         <io.netty.version>4.2.12.Final</io.netty.version>
-        <org.eclipse.jetty.server.version>12.1.6</org.eclipse.jetty.server.version>
+        <org.eclipse.jetty.server.version>12.1.7</org.eclipse.jetty.server.version>
         <org.eclipse.jetty.ee10.servlet.version>12.1.6</org.eclipse.jetty.ee10.servlet.version>
         <jakarta.servlet.api.version>6.1.0</jakarta.servlet.api.version>
         <javax.servlet.version>2.5</javax.servlet.version>
         <org.jline.version>3.30.9</org.jline.version>
         <org.apache.commons.lang3.version>3.19.0</org.apache.commons.lang3.version>
         <org.apache.httpcomponents.httpcore.version>4.4.16</org.apache.httpcomponents.httpcore.version>
 
-        <logging.log4j.version>2.25.3</logging.log4j.version>
+        <logging.log4j.version>2.25.4</logging.log4j.version>
 
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 

framework/core/src/main/java/com/tenio/core/api/ServerApi.java

@@ -174,12 +174,14 @@ default Room createRoom(InitialRoomSetting roomSetting) {
   Optional<Player> getPlayerByIdentity(String identity);
 
   /**
-   * Fetches the current number of players activating on the server.
+   * Retrieves the snapshot of the number of players in the management list.
+   * This is expected to provide the most recent update of the player count.
+   * This operation is thread-safe and provides an atomic count.
    *
-   * @return the current number of players ({@code integer} value)
-   * @since 0.5.0
+   * @return the most recent update of the number of players in the list
+   * @since 0.7.3
    */
-  int getPlayerCount();
+  int getSnapshotPlayerCount();
 
   /**
    * Ensures the calculation on the player list is thread-safe.
@@ -190,14 +192,17 @@ default Room createRoom(InitialRoomSetting roomSetting) {
   void computePlayers(Consumer<Iterator<Player>> onComputed);
 
   /**
-   * Retrieves a read-only global player management list on the server. This method should be used
-   * to prevent the "escape references" issue.
+   * Retrieves a snapshot of the read-only player management list.
+   * This is expected to provide the most recent update of the player list.
+   * This method should be used to prevent the "escape references" issue
+   * and provides thread-safe access to the player collection.
    *
-   * @return a list of all {@link Player}s in the management list on the server
+   * @return the recent update of the list of all {@link Player}s in the management list
    * @see PlayerManager
    * @see List
+   * @since 0.7.3
    */
-  List<Player> getReadonlyPlayersList();
+  List<Player> getSnapshotPlayersList();
 
   /**
    * Retrieves a room instance by using its ID.
@@ -217,21 +222,22 @@ default Room createRoom(InitialRoomSetting roomSetting) {
   void computeRooms(Consumer<Iterator<Room>> onComputed);
 
   /**
-   * Retrieves a read-only global room management list on the server. This method should be used
-   * to prevent the "escape references" issue.
+   * Retrieves the most recent rooms in the room management list.
    *
-   * @return a list of all rooms {@link Room} in the management list on the server
+   * @return a most recent up-to-date list of all {@link Room}s in the management list
    * @see RoomManager
    * @see List
+   * @since 0.7.3
    */
-  List<Room> getReadonlyRoomsList();
+  List<Room> getSnapshotRoomsList();
 
   /**
-   * Fetches the current number of rooms on the server.
+   * Fetches the most recent number of rooms in the management list.
    *
-   * @return the current number of rooms ({@code integer} value)
+   * @return the most recent number of rooms ({@code integer} value)
+   * @since 0.7.3
    */
-  int getRoomCount();
+  int getSnapshotRoomCount();
 
   /**
    * Allows a player to join a particular room.

framework/core/src/main/java/com/tenio/core/api/implement/ServerApiImpl.java

@@ -104,7 +104,7 @@ public void logout(Player player, ConnectionDisconnectMode connectionDisconnectM
     }
 
     try {
-      if (player.containsSession() && player.getSession().isPresent()) {
+      if (player.containsSession() && player.getSession().isPresent() && player.getSession().get().isActivated()) {
         // check process on method ZeroProcessorImpl#processSessionWillBeClosed
         Session session = player.getSession().get();
         session.close(connectionDisconnectMode, playerDisconnectMode);
@@ -175,8 +175,8 @@ public Optional<Player> getPlayerByIdentity(String identity) {
   }
 
   @Override
-  public int getPlayerCount() {
-    return getPlayerManager().getPlayerCount();
+  public int getSnapshotPlayerCount() {
+    return getPlayerManager().getSnapshotPlayerCount();
   }
 
   @Override
@@ -185,8 +185,8 @@ public void computePlayers(Consumer<Iterator<Player>> onComputed) {
   }
 
   @Override
-  public List<Player> getReadonlyPlayersList() {
-    return getPlayerManager().getReadonlyPlayersList();
+  public List<Player> getSnapshotPlayersList() {
+    return getPlayerManager().getSnapshotPlayersList();
   }
 
   @Override
@@ -200,13 +200,13 @@ public void computeRooms(Consumer<Iterator<Room>> onComputed) {
   }
 
   @Override
-  public List<Room> getReadonlyRoomsList() {
-    return getRoomManager().getReadonlyRoomsList();
+  public List<Room> getSnapshotRoomsList() {
+    return getRoomManager().getSnapshotRoomsList();
   }
 
   @Override
-  public int getRoomCount() {
-    return getRoomManager().getRoomCount();
+  public int getSnapshotRoomCount() {
+    return getRoomManager().getSnapshotRoomCount();
   }
 
   @Override

framework/core/src/main/java/com/tenio/core/command/system/implement/InfoCommand.java

@@ -47,12 +47,12 @@ public void execute(List<String> arguments) {
     switch (action) {
       case "player":
         CommandUtility.INSTANCE.showConsoleMessage(
-            "There are " + api().getPlayerCount() + " players > The first 10 entities > " +
-                api().getReadonlyPlayersList().subList(0, Math.min(api().getPlayerCount(), 10)));
+            "There are " + api().getSnapshotPlayerCount() + " players > The first 10 entities > " +
+                api().getSnapshotPlayersList().subList(0, Math.min(api().getSnapshotPlayerCount(), 10)));
         break;
 
       case "room":
-        var rooms = api().getReadonlyRoomsList();
+        var rooms = api().getSnapshotRoomsList();
         CommandUtility.INSTANCE.showConsoleMessage(
             "There are " + rooms.size() + " rooms > The first 10 entities > " +
                 rooms.subList(0, Math.min(rooms.size(), 10)));

framework/core/src/main/java/com/tenio/core/configuration/constant/CoreConstant.java

@@ -25,7 +25,6 @@ of this software and associated documentation files (the "Software"), to deal
 package com.tenio.core.configuration.constant;
 
 import com.tenio.core.network.zero.engine.ZeroAcceptor;
-import com.tenio.core.server.core.ZeroProcessor;
 
 /**
  * Defines core constants used throughout the server application.
@@ -143,14 +142,6 @@ public final class CoreConstant {
    */
   public static final int DELAY_BEFORE_SERVER_IS_READY_IN_MILLISECONDS = 100;
 
-  /**
-   * The default thread pool size of processor.
-   *
-   * @see ZeroProcessor
-   * @since 0.7.0
-   */
-  public static final int DEFAULT_PROCESSOR_THREAD_POOL_SIZE = 1;
-
   /**
    * The default thread pool size of engine.
    *