RocketMQ4.5.X 实现修改生产者消费者日志保存路径

RocketMQ4.5.X 实现修改生产者消费者日志保存路径

RocketMQ修改生产者消费者日志保存路径

rocket默认是将所有日志文件保存到user.home的对于win系统就是C盘了。

1.修改RocketMQ中CLientLogger.class的源码，把经过更改的源码重新打包后，去自己的maven仓库替换rocketmq-client.-4.5.X.jar。

2.对于生产者的启动类里需要配置JVM系统属性：

如果不设置logUserSlf4j为true的话，启动生产者的时候会报找不到日志配置文件的警告。

3.对于消费者，仅仅添加rq.lordir（日志保存路径）就行了。

当然，以上情况是开发中每个开发人员需要独立设置的，部署到线上的时候可以直接在源码中写路径而不是系统属性。

RocketMQ 日志操作

官网：http://rocketmq.apache.org/docs/logappender-example/

应用：将程序日志输出到rocketmq，消费端可读取日志数据进行相应处理

导入 jar 包

org.apache.rocketmq

rocketmq-logappender

4.7.1

相关类

RocketmqLogbackAppender：发送到rocketmq

public class RocketmqLogbackAppender extends AppenderBase {

private String tag; //标签

private String topic; //发送的topic

private String nameServerAddress; //namesrv地址

private String producerGroup; //发送群组

private MQProducer producer;

private Layout layout; //布局方式

private PreSerializationTransformer pst = new LoggingEventPreSerializationTransformer();

AsyncAppender：异步发送

public class AsyncAppender extends AsyncAppenderBase {

boolean includeCallerData = false;

AsyncAppenderBase

public class AsyncAppenderBase extends UnsynMShMYhJchronizedAppenderBase

implements AppenderAttachable {

AppenderAttachableImpl aai = new AppenderAttachableImpl();

BlockingQueue blockingQueue;

public static final int DEFAULT_QUEUE_SIZE = 256;

int queueSize = DEFAULT_QUEUE_SIZE;

int appenderCount = 0;

static final int UNDEFINED = -1;

int discardingThreshold = UNDEFINED;

boolean neverBlock = false;

Worker worker = new Worker();

public static final int DEFAULT_MAX_FLUSH_TIME = 1000;

int maxFlushTime = DEFAULT_MAX_FLUSH_TIME;

AppenderAttachable：引用、删除appender

public interface AppenderAttachable {

void addAppender(Appender newAppender);

boolean isAttached(Appender appender);

Iterator> iteratorForAppenders();

Appender getAppender(String name);

void detachAndStopAllAppenders();

boolean detachAppender(Appender appender);

boolean detachAppender(String name);

}

日志配置

logback.xml：放在resources目录下

${console.pattern}

tag

topic-log

log-group

172.18.0.10:9876

%date %p %t - %m%n

1024

80

2000

true

将springboot应用打包，发布成docker容器

创建容器

#namesrv

docker run -it -d --net fixed --ip 172.18.0.10 -p 9876:9876 \

-e java_OPT="-server -Xms256m -Xmx256m -Xmn128m" \

--name namesrv lihu12344/rocketmq:4.7.1 bash bin/mqnamesrv

#broker

docker run -it -d --net fixed --ip 172.18.0.20 \

-e NAMESRV_ADDR="172.18.0.10:9876" \

-e JAVA_OPT="-server -Xms512m -Xmx512m -Xmn256m" \

-v /usr/rocketmq/single/broker.conf:/home/rocketmq/rcketmq-4.7.1/conf/broker.conf \

--name broker lihu12344/rocketmq:4.7.1 \

bash bin/mqbroker autoCreateTopicEnable=true -c conf/broker.conf

#应用程序

docker run -it -d --net fixed --ip 172.18.0.21 -p 8080:8080 --name rocketmq-log rocketmq-log

rocketmq监控

docker run -it -d --net fixed --ip 172.18.0.4 -p 8008:8080 \

-e "JAVA_OPTS=-Drocketmq.namesrv.addr=172.18.0.10:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false" \

--name rocketmq-console styletang/rocketmq-console-ng

使用测试

192.168.57.127:8008

查看topic

查看topic-log message信息

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。