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

优化

Browse Source
This commit is contained in:
redkale
2023-10-14 09:19:08 +08:00
parent 48c1263ea1
commit 8ed540890b
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/main/java/org/redkale/mq/MessageServlet.java
View File

@@ -53,19 +53,19 @@ public abstract class MessageServlet implements MessageProcessor {
try { try {
Traces.computeIfAbsent(message.getTraceid()); Traces.computeIfAbsent(message.getTraceid());
long now = System.currentTimeMillis(); long now = System.currentTimeMillis();
long cha = now - message.createTime; long delay = now - message.createTime;
long e = now - time; long block = now - time;
Request request = createRequest(context, message); Request request = createRequest(context, message);
response = createResponse(context, request); response = createResponse(context, request);
//执行逻辑 //执行逻辑
context.execute(servlet, request, response); context.execute(servlet, request, response);
long o = System.currentTimeMillis() - now; long exems = System.currentTimeMillis() - now;
if ((cha > 1000 || e > 100 || o > 1000) && logger.isLoggable(Level.FINE)) { if ((delay > 1000 || block > 100 || exems > 1000) && logger.isLoggable(Level.FINE)) {
logger.log(Level.FINE, getClass().getSimpleName() + ".process (mqs.delays = " + cha + " ms, mqs.blocks = " + e + " ms, mqs.executes = " + o + " ms) message: " + message); logger.log(Level.FINE, getClass().getSimpleName() + ".process (mqs.delay-slower = " + delay + " ms, mqs.block = " + block + " ms, mqs.executes = " + exems + " ms) message: " + message);
} else if ((cha > 50 || e > 10 || o > 50) && logger.isLoggable(Level.FINER)) { } else if ((delay > 50 || block > 10 || exems > 50) && logger.isLoggable(Level.FINER)) {
logger.log(Level.FINER, getClass().getSimpleName() + ".process (mq.delays = " + cha + " ms, mq.blocks = " + e + " ms, mq.executes = " + o + " ms) message: " + message); logger.log(Level.FINER, getClass().getSimpleName() + ".process (mq.delay-slowly = " + delay + " ms, mq.block = " + block + " ms, mq.executes = " + exems + " ms) message: " + message);
} else if (logger.isLoggable(Level.FINEST)) { } else if (logger.isLoggable(Level.FINEST)) {
logger.log(Level.FINEST, getClass().getSimpleName() + ".process (mq.delay = " + cha + " ms, mq.block = " + e + " ms, mq.execute = " + o + " ms) message: " + message); logger.log(Level.FINEST, getClass().getSimpleName() + ".process (mq.delay-normal = " + delay + " ms, mq.block = " + block + " ms, mq.execute = " + exems + " ms) message: " + message);
} }
} catch (Throwable ex) { } catch (Throwable ex) {
if (response != null) { if (response != null) {