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

修改getCreatetime

Browse Source
This commit is contained in:
Redkale
2022-06-27 19:56:07 +08:00
parent f38143ff7b
commit 862018b63f
5 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/org/redkale/net/Context.java
View File

@@ -124,7 +124,7 @@ public class Context {
if (workHashExecutor != null) { if (workHashExecutor != null) {
workHashExecutor.execute(request.getHashid(), () -> { workHashExecutor.execute(request.getHashid(), () -> {
try { try {
long cha = System.currentTimeMillis() - request.getCreatetime(); long cha = System.currentTimeMillis() - request.getCreateTime();
servlet.execute(request, response); servlet.execute(request, response);
if (cha > 1000 && response.context.logger.isLoggable(Level.WARNING)) { if (cha > 1000 && response.context.logger.isLoggable(Level.WARNING)) {
response.context.logger.log(Level.WARNING, "hash execute servlet delays=" + cha + "ms, request=" + request); response.context.logger.log(Level.WARNING, "hash execute servlet delays=" + cha + "ms, request=" + request);

2
src/main/java/org/redkale/net/http/HttpServlet.java
View File

@@ -155,7 +155,7 @@ public class HttpServlet extends Servlet<HttpContext, HttpRequest, HttpResponse>
* if (sessionid != null) request.setCurrentUserid(userService.currentUserid(sessionid)); * if (sessionid != null) request.setCurrentUserid(userService.currentUserid(sessionid));
* *
* if (finer) response.recycleListener((req, resp) -&#62; { //记录处理时间比较长的请求 * if (finer) response.recycleListener((req, resp) -&#62; { //记录处理时间比较长的请求
* long e = System.currentTimeMillis() - ((HttpRequest) req).getCreatetime(); * long e = System.currentTimeMillis() - ((HttpRequest) req).getCreateTime();
* if (e &#62; 200) logger.finer("http-execute-cost-time: " + e + " ms. request = " + req); * if (e &#62; 200) logger.finer("http-execute-cost-time: " + e + " ms. request = " + req);
* }); * });
* response.nextEvent(); * response.nextEvent();

6
src/main/java/org/redkale/net/http/WebSocket.java
View File

@@ -112,7 +112,7 @@ public abstract class WebSocket<G extends Serializable, T> {
Inflater inflater; //解压 Inflater inflater; //解压
long createtime = System.currentTimeMillis(); long createTime = System.currentTimeMillis();
List<WebSocketPacket> delayPackets; List<WebSocketPacket> delayPackets;
@@ -148,8 +148,8 @@ public abstract class WebSocket<G extends Serializable, T> {
return sendPacket(new WebSocketPacket(FrameType.PONG, data)); return sendPacket(new WebSocketPacket(FrameType.PONG, data));
} }
public final long getCreatetime() { public final long getCreateTime() {
return createtime; return createTime;
} }
/** /**

4
src/main/java/org/redkale/net/http/WebSocketReadHandler.java
View File

@@ -278,7 +278,7 @@ public class WebSocketReadHandler implements CompletionHandler<Integer, ByteBuff
@Override @Override
public void completed(Integer count, ByteBuffer readBuffer) { public void completed(Integer count, ByteBuffer readBuffer) {
if (count < 1) { if (count < 1) {
if (debug) logger.log(Level.FINEST, "WebSocket(" + webSocket + ") abort on read buffer count, force to close channel, live " + (System.currentTimeMillis() - webSocket.getCreatetime()) / 1000 + " seconds"); if (debug) logger.log(Level.FINEST, "WebSocket(" + webSocket + ") abort on read buffer count, force to close channel, live " + (System.currentTimeMillis() - webSocket.getCreateTime()) / 1000 + " seconds");
webSocket.kill(CLOSECODE_ILLPACKET, "read buffer count is " + count); webSocket.kill(CLOSECODE_ILLPACKET, "read buffer count is " + count);
return; return;
} }
@@ -353,7 +353,7 @@ public class WebSocketReadHandler implements CompletionHandler<Integer, ByteBuff
public void failed(Throwable exc, ByteBuffer attachment2) { public void failed(Throwable exc, ByteBuffer attachment2) {
if (webSocket.initiateClosed) return; if (webSocket.initiateClosed) return;
if (exc != null) { if (exc != null) {
if (debug) context.getLogger().log(Level.FINEST, "WebSocket(" + webSocket + ") read WebSocketPacket failed, force to close channel, live " + (System.currentTimeMillis() - webSocket.getCreatetime()) / 1000 + " seconds", exc); if (debug) context.getLogger().log(Level.FINEST, "WebSocket(" + webSocket + ") read WebSocketPacket failed, force to close channel, live " + (System.currentTimeMillis() - webSocket.getCreateTime()) / 1000 + " seconds", exc);
webSocket.kill(CLOSECODE_WSEXCEPTION, "read websocket-packet failed"); webSocket.kill(CLOSECODE_WSEXCEPTION, "read websocket-packet failed");
} else { } else {
webSocket.kill(CLOSECODE_WSEXCEPTION, "decode websocket-packet error"); webSocket.kill(CLOSECODE_WSEXCEPTION, "decode websocket-packet error");

2
src/main/java/org/redkale/net/http/WebSocketWriteHandler.java
View File

@@ -91,7 +91,7 @@ public class WebSocketWriteHandler implements CompletionHandler<Integer, Void> {
} }
webSocket.kill(RETCODE_SENDEXCEPTION, "websocket send message failed on CompletionHandler"); webSocket.kill(RETCODE_SENDEXCEPTION, "websocket send message failed on CompletionHandler");
if (exc != null && context.getLogger().isLoggable(Level.FINER)) { if (exc != null && context.getLogger().isLoggable(Level.FINER)) {
context.getLogger().log(Level.FINER, "WebSocket sendMessage on CompletionHandler failed, force to close channel, live " + (System.currentTimeMillis() - webSocket.getCreatetime()) / 1000 + " seconds", exc); context.getLogger().log(Level.FINER, "WebSocket sendMessage on CompletionHandler failed, force to close channel, live " + (System.currentTimeMillis() - webSocket.getCreateTime()) / 1000 + " seconds", exc);
} }
} }