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-11-11 22:55:58 +08:00
parent bbefa788fd
commit 210b8dcf9d
2 changed files with 18 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -25,6 +25,8 @@ public class HttpMessageProcessor implements MessageProcessor {
protected final boolean finest;
protected final boolean finer;
protected final Logger logger;
protected final MessageProducers producer;
@@ -52,6 +54,7 @@ public class HttpMessageProcessor implements MessageProcessor {
public HttpMessageProcessor(Logger logger, ThreadHashExecutor workExecutor, MessageProducers producer, NodeHttpServer server, Service service, HttpServlet servlet) {
this.logger = logger;
this.finest = logger.isLoggable(Level.FINEST);
this.finer = logger.isLoggable(Level.FINER);
this.producer = producer;
this.server = server;
this.service = service;
@@ -80,7 +83,12 @@ public class HttpMessageProcessor implements MessageProcessor {
private void execute(final MessageRecord message, final Runnable callback) {
HttpMessageRequest request = null;
try {
if (finest) logger.log(Level.FINEST, "HttpMessageProcessor.process (mq.delay = " + (System.currentTimeMillis() - message.createtime) + " ms) message: " + message);
long cha = System.currentTimeMillis() - message.createtime;
if (cha > 50 || finer) {
logger.log(Level.FINER, "HttpMessageProcessor.process (mq.delay = " + cha + " ms) message: " + message);
} else if (finest) {
logger.log(Level.FINEST, "HttpMessageProcessor.process (mq.delay = " + cha + " ms) message: " + message);
}
if (multiconsumer) message.setResptopic(null); //不容许有响应
HttpContext context = server.getHttpServer().getContext();
request = new HttpMessageRequest(context, message);

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

@@ -32,9 +32,12 @@ public abstract class MessageClient {
protected boolean finest;
protected boolean finer;
protected MessageClient(MessageAgent messageAgent) {
this.messageAgent = messageAgent;
this.finest = messageAgent == null ? false : messageAgent.logger.isLoggable(Level.FINEST);
this.finer = messageAgent == null ? false : messageAgent.logger.isLoggable(Level.FINER);
}
protected CompletableFuture<Void> close() {
@@ -59,7 +62,12 @@ public abstract class MessageClient {
AtomicLong ncer = node.getCounter();
if (ncer != null) ncer.decrementAndGet();
node.future.complete(msg);
if (finest) messageAgent.logger.log(Level.FINEST, "MessageRespFutureNode.process (mq.delay = " + (now - msg.createtime) + "ms) message: " + message);
long cha = now - msg.createtime;
if (cha > 50 || finer) {
messageAgent.logger.log(Level.FINER, "MessageRespFutureNode.process (mq.delay = " + cha + "ms) message: " + message);
} else if (finest) {
messageAgent.logger.log(Level.FINEST, "MessageRespFutureNode.process (mq.delay = " + cha + "ms) message: " + message);
}
};
MessageConsumer one = messageAgent.createConsumer(new String[]{respTopic}, respConsumerid, processor);