Squashed 'examples/' changes from 8b0f158f..efaab610

tengamesinc · tengamesinc · commit 446c53fd412d · 2025-05-18T09:25:16.000+02:00
efaab610 Merge pull request #14 from congcoi123/develop 5ee13efc fix: minor changes dc9a7028 build: set more suitable values 1a0f2b72 fix: some test classes beb8ed2a feat: upgrade framework to 0.6.3 git-subtree-dir: examples git-subtree-split: efaab61041cd73f36ff74fbe027ea9399114bbdd
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -59,3 +59,6 @@
 - Upgraded dependencies
 - Declared behaviors for packets processing with annotations
 - Bugs fixed
+
+## 0.6.3 2025-06-01 Feature release
+- Upgraded dependencies
diff --git a/README.md b/README.md
@@ -29,8 +29,8 @@ This project contains a collection of examples that show you how to manipulate t
 
 ## Dependencies
 ```txt
-- tenio-core 0.6.0
-- tenio-engine 0.6.0
+- tenio-core 0.6.3
+- tenio-engine 0.6.2
 ```
 
 ## Requirements
diff --git a/VERSION b/VERSION
@@ -1 +1 @@
-20250511.0.6.2
+20250601.0.6.3
diff --git a/configuration.example4.xml b/configuration.example4.xml
@@ -19,7 +19,7 @@
 	<Network>
 		<Sockets>
 			<Port name="tcp" type="tcp">8032</Port>
-			<Port name="udp" type="udp">20004,20005,20006,20007,20008,20009</Port>
+			<Port name="udp" type="udp" cacheSize="80">20004</Port>
 		</Sockets>
 		<Properties>
 			<Property name="websocket-using-ssl">false</Property>
@@ -36,13 +36,13 @@
 
 	<Configuration>
 		<Workers>
-			<Worker name="socket-acceptor">10</Worker>
-			<Worker name="socket-reader">40</Worker>
-			<Worker name="socket-writer">60</Worker>
+			<Worker name="socket-acceptor">8</Worker>
+			<Worker name="socket-reader">16</Worker>
+			<Worker name="socket-writer">16</Worker>
 			<Worker name="websocket-producer">1</Worker>
 			<Worker name="websocket-consumer">2</Worker>
 			<Worker name="http-worker">8</Worker>
-			<Worker name="internal-processor">40</Worker>
+			<Worker name="internal-processor">8</Worker>
 		</Workers>
 		<Schedules>
 			<!-- Get the period checking in seconds which server can keep the empty 
diff --git a/configuration.example6.xml b/configuration.example6.xml
@@ -29,19 +29,19 @@
 			<Property name="socket-writer-buffer-size">1024</Property>
 			<Property name="packet-compression-threshold-bytes">10240</Property>
 			<Property name="allow-change-session">false</Property>
-			<Property name="max-connections-per-ip">1000</Property>
+			<Property name="max-connections-per-ip">2000</Property>
 		</Properties>
 	</Network>
 
 	<Configuration>
 		<Workers>
-			<Worker name="socket-acceptor">5</Worker>
-			<Worker name="socket-reader">30</Worker>
-			<Worker name="socket-writer">30</Worker>
+			<Worker name="socket-acceptor">8</Worker>
+			<Worker name="socket-reader">16</Worker>
+			<Worker name="socket-writer">16</Worker>
 			<Worker name="websocket-producer">1</Worker>
 			<Worker name="websocket-consumer">2</Worker>
 			<Worker name="http-worker">8</Worker>
-			<Worker name="internal-processor">20</Worker>
+			<Worker name="internal-processor">8</Worker>
 		</Workers>
 		<Schedules>
 			<!-- Get the period checking in seconds which server can keep the empty 
@@ -61,13 +61,13 @@
 		</Schedules>
 		<Properties>
 			<Property name="data-serialization">zero</Property>
-			<Property name="max-packet-queue-size">300</Property>
-			<Property name="max-request-queue-size">300</Property>
+			<Property name="max-packet-queue-size">2000</Property>
+			<Property name="max-request-queue-size">2000</Property>
 			<!-- When the server get disconnection of one client, can be hold its 
 				player instance until timeout -->
 			<Property name="keep-player-on-disconnection">false</Property>
 			<!-- The maximum number of players which game can handle -->
-			<Property name="max-number-players">1000</Property>
+			<Property name="max-number-players">2000</Property>
 			<!-- The maximum number of rooms which game can handle -->
 			<Property name="max-number-rooms">1000</Property>
 			<!-- The max IDLE time in seconds which server can wait from the last 
diff --git a/pom.xml b/pom.xml
@@ -5,7 +5,7 @@
 
 	<groupId>io.github.congcoi123</groupId>
 	<artifactId>tenio-examples</artifactId>
-	<version>0.6.0</version>
+	<version>0.6.3</version>
 
 	<name>${project.groupId}:${project.artifactId}</name>
 	<description>
@@ -38,7 +38,7 @@
 		<jdk.release>17</jdk.release>
 		<jdk.vendor>oracle</jdk.vendor>
 
-		<io.github.congcoi123.tenio.core.version>0.6.2</io.github.congcoi123.tenio.core.version>
+		<io.github.congcoi123.tenio.core.version>0.6.3</io.github.congcoi123.tenio.core.version>
 		<io.github.congcoi123.tenio.engine.version>0.6.2</io.github.congcoi123.tenio.engine.version>
 		<org.apache.commons.version>3.17.0</org.apache.commons.version>
 
diff --git a/src/main/java/com/tenio/examples/example10/handler/PlayerLoggedInHandler.java b/src/main/java/com/tenio/examples/example10/handler/PlayerLoggedInHandler.java
@@ -41,7 +41,7 @@ public void handle(Player player, PlayerLoggedInResult result) {
     if (result == PlayerLoggedInResult.SUCCESS) {
       var parcel =
           msgmap().putIntegerArray(SharedEventKey.KEY_ALLOW_TO_ACCESS_UDP_CHANNEL,
-              new int[] { DatagramEstablishedState.ALLOW_TO_ACCESS, api().getCurrentAvailableUdpPort() });
+              new int[] { DatagramEstablishedState.ALLOW_TO_ACCESS, api().getUdpPort() });
 
       response().setContent(parcel.toBinary()).setRecipientPlayer(player).write();
     }
diff --git a/src/main/java/com/tenio/examples/example3/handler/PlayerLoggedInHandler.java b/src/main/java/com/tenio/examples/example3/handler/PlayerLoggedInHandler.java
@@ -42,7 +42,7 @@ public void handle(Player player, PlayerLoggedInResult result) {
       var parcel =
           map().putZeroArray(SharedEventKey.KEY_ALLOW_TO_ACCESS_UDP_CHANNEL,
               array().addByte(DatagramEstablishedState.ALLOW_TO_ACCESS)
-                  .addInteger(api().getCurrentAvailableUdpPort()));
+                  .addInteger(api().getUdpPort()));
 
       response().setContent(parcel.toBinary()).setRecipientPlayer(player).write();
     }
diff --git a/src/main/java/com/tenio/examples/example4/TestClientMovement.java b/src/main/java/com/tenio/examples/example4/TestClientMovement.java
@@ -176,8 +176,8 @@ public void onReceivedTCP(byte[] binaries) {
 
             int countPackets = localCounter.getCountUdpPacketsOneMinute();
             double lostPacket =
-                ((double) (Example4Constant.ONE_MINUTE_EXPECT_RECEIVE_PACKETS - countPackets)
-                    / (double) Example4Constant.ONE_MINUTE_EXPECT_RECEIVE_PACKETS) * (double) 100;
+                ((double) (Example4Constant.ONE_MINUTE_EXPECT_RECEIVE_TOTAL_PACKETS - countPackets)
+                    / (double) Example4Constant.ONE_MINUTE_EXPECT_RECEIVE_TOTAL_PACKETS) * (double) 100;
 
             statistic.addLostPackets(lostPacket);
             logLostPacket(lostPacket);
diff --git a/src/main/java/com/tenio/examples/example4/constant/Example4Constant.java b/src/main/java/com/tenio/examples/example4/constant/Example4Constant.java
@@ -41,7 +41,7 @@ public final class Example4Constant {
 
   public static final int ONE_SECOND_EXPECT_RECEIVE_PACKETS = 10;
 
-  public static final int ONE_MINUTE_EXPECT_RECEIVE_PACKETS =
+  public static final int ONE_MINUTE_EXPECT_RECEIVE_TOTAL_PACKETS =
       ONE_SECOND_EXPECT_RECEIVE_PACKETS * 60 * NUMBER_OF_PLAYERS;
 
   private Example4Constant() {
diff --git a/src/main/java/com/tenio/examples/example4/handler/PlayerLoggedInHandler.java b/src/main/java/com/tenio/examples/example4/handler/PlayerLoggedInHandler.java
@@ -39,10 +39,11 @@ public final class PlayerLoggedInHandler extends AbstractHandler
   @Override
   public void handle(Player player, PlayerLoggedInResult result) {
     if (result == PlayerLoggedInResult.SUCCESS) {
+      player.setNeverDeported(true);
       var parcel =
           map().putZeroArray(SharedEventKey.KEY_ALLOW_TO_ACCESS_UDP_CHANNEL,
               array().addByte(DatagramEstablishedState.ALLOW_TO_ACCESS)
-                  .addInteger(api().getCurrentAvailableUdpPort()));
+                  .addInteger(api().getUdpPort()));
 
       response().setContent(parcel.toBinary()).setRecipientPlayer(player).write();
     }
diff --git a/src/main/java/com/tenio/examples/example6/TestClientEchoStress.java b/src/main/java/com/tenio/examples/example6/TestClientEchoStress.java
@@ -48,7 +48,7 @@ of this software and associated documentation files (the "Software"), to deal
 public final class TestClientEchoStress implements SocketListener {
 
   private static final int SOCKET_PORT = 8032;
-  private static final int NUMBER_CLIENTS = 1000;
+  private static final int NUMBER_CLIENTS = 2000;
   private static final boolean ENABLED_DEBUG = true;
   /**
    * List of TCP clients
@@ -69,9 +69,7 @@ public TestClientEchoStress() {
       request.putString(SharedEventKey.KEY_PLAYER_LOGIN, name);
       tcp.send(request);
 
-      if (ENABLED_DEBUG) {
-        System.err.println("Login Request -> " + request);
-      }
+      System.err.println("Login Request -> " + request);
     }
   }
 
diff --git a/src/main/java/com/tenio/examples/example6/handler/PlayerLoggedInHandler.java b/src/main/java/com/tenio/examples/example6/handler/PlayerLoggedInHandler.java
@@ -38,6 +38,7 @@ public final class PlayerLoggedInHandler extends AbstractHandler
   @Override
   public void handle(Player player, PlayerLoggedInResult result) {
     if (result == PlayerLoggedInResult.SUCCESS) {
+      player.setNeverDeported(true);
       var parcel = map()
           .putString(SharedEventKey.KEY_CLIENT_SERVER_ECHO,
               String.format("Welcome to server: %s", player.getIdentity()))

Original file line number	Diff line number	Diff line change
`@@ -41,7 +41,7 @@ public void handle(Player player, PlayerLoggedInResult result) {`
`41`	`41`	`if (result == PlayerLoggedInResult.SUCCESS) {`
`42`	`42`	`var parcel =`
`43`	`43`	`msgmap().putIntegerArray(SharedEventKey.KEY_ALLOW_TO_ACCESS_UDP_CHANNEL,`
`44`		`- new int[] { DatagramEstablishedState.ALLOW_TO_ACCESS, api().getCurrentAvailableUdpPort() });`
	`44`	`+ new int[] { DatagramEstablishedState.ALLOW_TO_ACCESS, api().getUdpPort() });`
`45`	`45`
`46`	`46`	`response().setContent(parcel.toBinary()).setRecipientPlayer(player).write();`
`47`	`47`	`}`
Original file line number	Diff line number	Diff line change
`@@ -42,7 +42,7 @@ public void handle(Player player, PlayerLoggedInResult result) {`
`42`	`42`	`var parcel =`
`43`	`43`	`map().putZeroArray(SharedEventKey.KEY_ALLOW_TO_ACCESS_UDP_CHANNEL,`
`44`	`44`	`array().addByte(DatagramEstablishedState.ALLOW_TO_ACCESS)`
`45`		`- .addInteger(api().getCurrentAvailableUdpPort()));`
	`45`	`+ .addInteger(api().getUdpPort()));`
`46`	`46`
`47`	`47`	`response().setContent(parcel.toBinary()).setRecipientPlayer(player).write();`
`48`	`48`	`}`