Optimized HproseTcpClient and HproseTcpServer.

More fast and robust than before.

Author: andot

example/tcphelloexam/pom.xml

@@ -3,7 +3,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>org.hprose</groupId>
     <artifactId>tcphelloexam</artifactId>
-    <version>1.5.0</version>
+    <version>1.6.1</version>
     <packaging>jar</packaging>
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
@@ -15,7 +15,7 @@
         <dependency>
             <groupId>org.hprose</groupId>
             <artifactId>hprose-java</artifactId>
-            <version>1.6.0-beta5</version>
+            <version>1.6.1</version>
         </dependency>
     </dependencies>
 </project>

example/tcphelloexam/src/main/java/hprose/tcphelloexam/TCPHelloClient.java

@@ -10,21 +10,22 @@
 public class TCPHelloClient {
     public static void main(String[] args) throws IOException, URISyntaxException, InterruptedException {
         System.out.println("START");
+        HproseTcpClient.setReactorThreads(2);
         long start = System.currentTimeMillis();
-        int threadNumber = 10;
+        int threadNumber = 8;
+        final int roundNumber = 125000;
         Thread[] threads = new Thread[threadNumber];
+        final HproseTcpClient client = new HproseTcpClient("tcp://localhost:4321");
+        client.setFullDuplex(true);
+        client.setMaxPoolSize(2);
         for (int i = 0; i < threadNumber; i++) {
             threads[i] = new Thread() {
                 @Override
                 public void run() {
                     try {
-                        HproseTcpClient client = new HproseTcpClient("tcp://localhost:4321");
-                        client.setFullDuplex(true);
-                        client.setMaxPoolSize(1);
-                        for (int i = 0; i < 100000; i++) {
+                        for (int i = 0; i < roundNumber; i++) {
                             client.invoke("hello", new Object[] {"World"});
                         }
-                        client.close();
                     } catch (IOException ex) {
                         Logger.getLogger(TCPHelloClient.class.getName()).log(Level.SEVERE, null, ex);
                     }
@@ -36,8 +37,8 @@ public void run() {
             threads[i].join();
         }
         long end = System.currentTimeMillis();
-        System.out.println(end - start);
-        HproseTcpClient client = new HproseTcpClient("tcp://localhost:4321");
+        System.out.println("总耗时: " + (end - start));
+        System.out.println(((threadNumber * roundNumber) * 1000/(end - start)) + " QPS");
         start = System.currentTimeMillis();
         for (int i = 0; i < 10; i++) {
             client.invoke("hello", new Object[] {"World"}, new HproseCallback1<String>() {

example/tcphelloexam/src/main/java/hprose/tcphelloexam/TCPHelloServer.java

@@ -10,6 +10,7 @@ public static String hello(String name) {
     }
     public static void main(String[] args) throws IOException, URISyntaxException, InterruptedException {
         HproseTcpServer server = new HproseTcpServer("tcp://localhost:4321");
+        server.setReactorThreads(2);
 /*
         server.addFilter(new HproseFilter() {
             public String getString(ByteBuffer buffer) {

pom.xml

@@ -3,7 +3,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>org.hprose</groupId>
     <artifactId>hprose-java</artifactId>
-    <version>1.6.0</version>
+    <version>1.6.1</version>
     <name>Hprose for Java</name>
     <description>Hprose is a High Performance Remote Object Service Engine.
 
@@ -49,7 +49,7 @@
         <connection>scm:git:https://github.com/hprose/hprose-java.git</connection>
         <developerConnection>scm:git:https://github.com/hprose/hprose-java.git</developerConnection>
         <url>https://github.com/hprose/hprose-java</url>
-        <tag>v1.6.0</tag>
+        <tag>v1.6.1</tag>
     </scm>
     <developers>
         <developer>