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

Browse Source
This commit is contained in:
kamhung
2015-11-13 09:27:11 +08:00
parent 4589c4d9df
commit 3fad050730
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/com/wentch/redkale/net/http/WebSocketServlet.java
View File

@@ -82,17 +82,17 @@ public abstract class WebSocketServlet extends HttpServlet implements Nameable {
@Override @Override
public final void execute(final HttpRequest request, final HttpResponse response) throws IOException { public final void execute(final HttpRequest request, final HttpResponse response) throws IOException {
final boolean debug = logger.isLoggable(Level.FINER); final boolean debug = logger.isLoggable(Level.FINEST);
if (!"GET".equalsIgnoreCase(request.getMethod()) if (!"GET".equalsIgnoreCase(request.getMethod())
|| !request.getConnection().contains("Upgrade") || !request.getConnection().contains("Upgrade")
|| !"websocket".equalsIgnoreCase(request.getHeader("Upgrade"))) { || !"websocket".equalsIgnoreCase(request.getHeader("Upgrade"))) {
if (debug) logger.finer("WebSocket connect abort, (Not GET Method) or (Connection != Upgrade) or (Upgrade != websocket). request=" + request); if (debug) logger.finest("WebSocket connect abort, (Not GET Method) or (Connection != Upgrade) or (Upgrade != websocket). request=" + request);
response.finish(true); response.finish(true);
return; return;
} }
String key = request.getHeader("Sec-WebSocket-Key"); String key = request.getHeader("Sec-WebSocket-Key");
if (key == null) { if (key == null) {
if (debug) logger.finer("WebSocket connect abort, Not found Sec-WebSocket-Key header. request=" + request); if (debug) logger.finest("WebSocket connect abort, Not found Sec-WebSocket-Key header. request=" + request);
response.finish(true); response.finish(true);
return; return;
} }
@@ -101,7 +101,7 @@ public abstract class WebSocketServlet extends HttpServlet implements Nameable {
webSocket.node = node; webSocket.node = node;
Serializable sessionid = webSocket.onOpen(request); Serializable sessionid = webSocket.onOpen(request);
if (sessionid == null) { if (sessionid == null) {
if (debug) logger.finer("WebSocket connect abort, Not found sessionid. request=" + request); if (debug) logger.finest("WebSocket connect abort, Not found sessionid. request=" + request);
response.finish(true); response.finish(true);
return; return;
} }
@@ -123,7 +123,7 @@ public abstract class WebSocketServlet extends HttpServlet implements Nameable {
HttpContext context = response.getContext(); HttpContext context = response.getContext();
Serializable groupid = webSocket.createGroupid(); Serializable groupid = webSocket.createGroupid();
if (groupid == null) { if (groupid == null) {
if (debug) logger.finer("WebSocket connect abort, Create groupid abort. request = " + request); if (debug) logger.finest("WebSocket connect abort, Create groupid abort. request = " + request);
response.finish(true); response.finish(true);
return; return;
} }
@@ -135,7 +135,7 @@ public abstract class WebSocketServlet extends HttpServlet implements Nameable {
@Override @Override
public void failed(Throwable exc, Void attachment) { public void failed(Throwable exc, Void attachment) {
logger.log(Level.FINER, "WebSocket connect abort, Response send abort. request = " + request, exc); logger.log(Level.FINEST, "WebSocket connect abort, Response send abort. request = " + request, exc);
response.finish(true); response.finish(true);
} }
}); });