From 88c4824c4f4d1d94d38a26ef266f26cb630e62e5 Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Sun, 21 May 2017 19:29:56 +0800
Subject: [PATCH]

---
 .../test/websocket/ChatWebSocketServlet.java  | 19 +++++++++++++++----
 1 file changed, 15 insertions(+), 4 deletions(-)

diff --git a/test/org/redkale/test/websocket/ChatWebSocketServlet.java b/test/org/redkale/test/websocket/ChatWebSocketServlet.java
index 0114fe890..1b02005b3 100644
--- a/test/org/redkale/test/websocket/ChatWebSocketServlet.java
+++ b/test/org/redkale/test/websocket/ChatWebSocketServlet.java
@@ -10,6 +10,7 @@ import org.redkale.net.http.WebSocketServlet;
 import org.redkale.net.http.WebSocket;
 import java.io.*;
 import java.util.concurrent.atomic.*;
+import org.redkale.convert.json.JsonConvert;
 import org.redkale.util.Utility;
 
 /**
@@ -26,7 +27,7 @@ public class ChatWebSocketServlet extends WebSocketServlet {
     private final boolean debug;
 
     public ChatWebSocketServlet() {
-        debug = "true".equalsIgnoreCase(System.getProperty("debug", "false"));
+        debug = "true".equalsIgnoreCase(System.getProperty("debug", "true"));
         Thread t = new Thread() {
 
             {
@@ -37,7 +38,7 @@ public class ChatWebSocketServlet extends WebSocketServlet {
             public void run() {
                 while (true) {
                     try {
-                        sleep(60 * 1000);
+                        sleep(300 * 1000);
                     } catch (Exception e) {
                         return;
                     }
@@ -57,8 +58,9 @@ public class ChatWebSocketServlet extends WebSocketServlet {
             public void onMessage(String text) {
                 icounter.incrementAndGet();
                 counter.incrementAndGet();
-                if (debug) System.out.println("收到消息: " + text);
-                super.getWebSocketGroup().getWebSockets().forEach(x -> x.send(text));
+                ChatMessage message = jsonConvert.convertFrom(ChatMessage.class, text);
+                if (debug) System.out.println("收到消息: " + text + ", " + message);
+                super.getWebSocketGroup().getWebSockets().forEach(x -> x.send(message));
             }
 
             @Override
@@ -68,4 +70,13 @@ public class ChatWebSocketServlet extends WebSocketServlet {
         };
     }
 
+    public static class ChatMessage {
+
+        public String message;
+
+        @Override
+        public String toString() {
+            return JsonConvert.root().convertTo(this);
+        }
+    }
 }