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

Browse Source
This commit is contained in:
Redkale
2020-12-25 20:51:18 +08:00
parent 433585a231
commit 564b814f77
3 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/org/redkale/mq/HttpMessageProcessor.java
View File

@@ -101,9 +101,9 @@ public class HttpMessageProcessor implements MessageProcessor {
HttpMessageResponse response = new HttpMessageResponse(context, request, callback, null, null, producer.getProducer(message)); HttpMessageResponse response = new HttpMessageResponse(context, request, callback, null, null, producer.getProducer(message));
servlet.execute(request, response); servlet.execute(request, response);
long o = System.currentTimeMillis() - now; long o = System.currentTimeMillis() - now;
if (cha > 1000 || e > 100 || o > 1000 || fine) { if ((cha > 1000 || e > 100 || o > 1000) && fine) {
logger.log(Level.FINE, "HttpMessageProcessor.process (mqs.delays = " + cha + " ms, mqs.blocks = " + e + " ms, mqs.executes = " + o + " ms) message: " + message); logger.log(Level.FINE, "HttpMessageProcessor.process (mqs.delays = " + cha + " ms, mqs.blocks = " + e + " ms, mqs.executes = " + o + " ms) message: " + message);
} else if (cha > 50 || e > 10 || o > 50 || finer) { } else if ((cha > 50 || e > 10 || o > 50) && finer) {
logger.log(Level.FINER, "HttpMessageProcessor.process (mq.delays = " + cha + " ms, mq.blocks = " + e + " ms, mq.executes = " + o + " ms) message: " + message); logger.log(Level.FINER, "HttpMessageProcessor.process (mq.delays = " + cha + " ms, mq.blocks = " + e + " ms, mq.executes = " + o + " ms) message: " + message);
} else if (finest) { } else if (finest) {
logger.log(Level.FINEST, "HttpMessageProcessor.process (mq.delay = " + cha + " ms, mq.block = " + e + " ms, mq.execute = " + o + " ms) message: " + message); logger.log(Level.FINEST, "HttpMessageProcessor.process (mq.delay = " + cha + " ms, mq.block = " + e + " ms, mq.execute = " + o + " ms) message: " + message);

7
src/org/redkale/mq/MessageClient.java
View File

@@ -34,10 +34,13 @@ public abstract class MessageClient {
protected boolean finer; protected boolean finer;
protected boolean fine;
protected MessageClient(MessageAgent messageAgent) { protected MessageClient(MessageAgent messageAgent) {
this.messageAgent = messageAgent; this.messageAgent = messageAgent;
this.finest = messageAgent == null ? false : messageAgent.logger.isLoggable(Level.FINEST); this.finest = messageAgent == null ? false : messageAgent.logger.isLoggable(Level.FINEST);
this.finer = messageAgent == null ? false : messageAgent.logger.isLoggable(Level.FINER); this.finer = messageAgent == null ? false : messageAgent.logger.isLoggable(Level.FINER);
this.fine = messageAgent == null ? false : messageAgent.logger.isLoggable(Level.FINE);
} }
protected CompletableFuture<Void> close() { protected CompletableFuture<Void> close() {
@@ -63,7 +66,9 @@ public abstract class MessageClient {
if (ncer != null) ncer.decrementAndGet(); if (ncer != null) ncer.decrementAndGet();
node.future.complete(msg); node.future.complete(msg);
long cha = now - msg.createtime; long cha = now - msg.createtime;
if (cha > 50 || finer) { if (cha > 1000 && fine) {
messageAgent.logger.log(Level.FINER, "MessageRespFutureNode.process (mqs.delays = " + cha + "ms) message: " + msg);
} else if (cha > 50 && finer) {
messageAgent.logger.log(Level.FINER, "MessageRespFutureNode.process (mq.delays = " + cha + "ms) message: " + msg); messageAgent.logger.log(Level.FINER, "MessageRespFutureNode.process (mq.delays = " + cha + "ms) message: " + msg);
} else if (finest) { } else if (finest) {
messageAgent.logger.log(Level.FINEST, "MessageRespFutureNode.process (mq.delay = " + cha + "ms) message: " + msg); messageAgent.logger.log(Level.FINEST, "MessageRespFutureNode.process (mq.delay = " + cha + "ms) message: " + msg);

4
src/org/redkale/mq/SncpMessageProcessor.java
View File

@@ -87,9 +87,9 @@ public class SncpMessageProcessor implements MessageProcessor {
response = new SncpMessageResponse(context, request, callback, null, producer.getProducer(message)); response = new SncpMessageResponse(context, request, callback, null, producer.getProducer(message));
servlet.execute(request, response); servlet.execute(request, response);
long o = System.currentTimeMillis() - now; long o = System.currentTimeMillis() - now;
if (cha > 1000 || e > 100 || o > 1000 || fine) { if ((cha > 1000 || e > 100 || o > 1000) && fine) {
logger.log(Level.FINE, "SncpMessageProcessor.process (mqs.delays = " + cha + " ms, mqs.blocks = " + e + " ms, mqs.executes = " + o + " ms) message: " + message); logger.log(Level.FINE, "SncpMessageProcessor.process (mqs.delays = " + cha + " ms, mqs.blocks = " + e + " ms, mqs.executes = " + o + " ms) message: " + message);
} else if (cha > 50 || e > 10 || o > 50 || finer) { } else if ((cha > 50 || e > 10 || o > 50) && finer) {
logger.log(Level.FINER, "SncpMessageProcessor.process (mq.delays = " + cha + " ms, mq.blocks = " + e + " ms, mq.executes = " + o + " ms) message: " + message); logger.log(Level.FINER, "SncpMessageProcessor.process (mq.delays = " + cha + " ms, mq.blocks = " + e + " ms, mq.executes = " + o + " ms) message: " + message);
} else if (finest) { } else if (finest) {
logger.log(Level.FINEST, "SncpMessageProcessor.process (mq.delay = " + cha + " ms, mq.block = " + e + " ms, mq.execute = " + o + " ms) message: " + message); logger.log(Level.FINEST, "SncpMessageProcessor.process (mq.delay = " + cha + " ms, mq.block = " + e + " ms, mq.execute = " + o + " ms) message: " + message);