lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2016-10-10 15:48:57 +08:00
parent 8ca79face5
commit 036b248092
2 changed files with 9 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
test/org/redkale/test/websocket/ChatWebSocketServlet.java
View File

@@ -9,12 +9,8 @@ import org.redkale.net.http.WebServlet;
import org.redkale.net.http.WebSocketServlet; import org.redkale.net.http.WebSocketServlet;
import org.redkale.net.http.WebSocket; import org.redkale.net.http.WebSocket;
import java.io.*; import java.io.*;
import static java.lang.Thread.sleep;
import java.text.*;
import java.util.concurrent.atomic.*; import java.util.concurrent.atomic.*;
import static java.lang.Thread.sleep; import org.redkale.util.Utility;
import static java.lang.Thread.sleep;
import static java.lang.Thread.sleep;
/** /**
* *
@@ -33,8 +29,6 @@ public class ChatWebSocketServlet extends WebSocketServlet {
debug = "true".equalsIgnoreCase(System.getProperty("debug", "false")); debug = "true".equalsIgnoreCase(System.getProperty("debug", "false"));
Thread t = new Thread() { Thread t = new Thread() {
private final DateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
{ {
setName("Debug-ChatWebSocket-ShowCount-Thread"); setName("Debug-ChatWebSocket-ShowCount-Thread");
} }
@@ -47,7 +41,7 @@ public class ChatWebSocketServlet extends WebSocketServlet {
} catch (Exception e) { } catch (Exception e) {
return; return;
} }
System.out.println(format.format(new java.util.Date()) + ": 消息总数: " + counter.get() + ",间隔消息数: " + icounter.getAndSet(0)); System.out.println(Utility.now() + ": 消息总数: " + counter.get() + ",间隔消息数: " + icounter.getAndSet(0));
} }
} }
}; };

18
test/org/redkale/test/websocket/VideoWebSocketServlet.java
View File

@@ -113,17 +113,13 @@ public class VideoWebSocketServlet extends WebSocketServlet {
public static void main(String[] args) throws Throwable { public static void main(String[] args) throws Throwable {
CountDownLatch cdl = new CountDownLatch(1); CountDownLatch cdl = new CountDownLatch(1);
AnyValue.DefaultAnyValue config = new AnyValue.DefaultAnyValue(); AnyValue.DefaultAnyValue config = AnyValue.create()
config.addValue("threads", System.getProperty("threads")); .addValue("threads", System.getProperty("threads"))
config.addValue("bufferPoolSize", System.getProperty("bufferPoolSize")); .addValue("bufferPoolSize", System.getProperty("bufferPoolSize"))
config.addValue("responsePoolSize", System.getProperty("responsePoolSize")); .addValue("responsePoolSize", System.getProperty("responsePoolSize"))
config.addValue("host", System.getProperty("host", "0.0.0.0")); .addValue("host", System.getProperty("host", "0.0.0.0"))
config.addValue("port", System.getProperty("port", "8070")); .addValue("port", System.getProperty("port", "8070"))
config.addValue("root", System.getProperty("root", "./root3/")); .addValue("root", System.getProperty("root", "./root3/"));
AnyValue.DefaultAnyValue resConf = new AnyValue.DefaultAnyValue();
resConf.setValue("cacheMaxLength", "200M");
resConf.setValue("cacheMaxItemLength", "10M");
config.setValue("ResourceServlet", resConf);
HttpServer server = new HttpServer(); HttpServer server = new HttpServer();
server.addHttpServlet("/pipes", new VideoWebSocketServlet(), "/listen/*"); server.addHttpServlet("/pipes", new VideoWebSocketServlet(), "/listen/*");
server.init(config); server.init(config);