RocketMQ4.5.X 實現(xiàn)修改生產者消費者日志保存路徑
更新時間：2021年07月03日 11:16:09 作者：qq_35251168
這篇文章主要介紹了RocketMQ4.5.X 實現(xiàn)修改生產者消費者日志保存路徑方式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
RocketMQ修改生產者消費者日志保存路徑
rocket默認是將所有日志文件保存到user.home的對于win系統(tǒng)就是C盤了。
1.修改RocketMQ中CLientLogger.class的源碼，把經(jīng)過更改的源碼重新打包后，去自己的maven倉庫替換rocketmq-client.-4.5.X.jar。
2.對于生產者的啟動類里需要配置JVM系統(tǒng)屬性：
如果不設置logUserSlf4j為true的話，啟動生產者的時候會報找不到日志配置文件的警告。
3.對于消費者，僅僅添加rq.lordir（日志保存路徑）就行了。
當然，以上情況是開發(fā)中每個開發(fā)人員需要獨立設置的，部署到線上的時候可以直接在源碼中寫路徑而不是系統(tǒng)屬性。
RocketMQ 日志操作
官網(wǎng)：http://rocketmq.apache.org/docs/logappender-example/
應用：將程序日志輸出到rocketmq，消費端可讀取日志數(shù)據(jù)進行相應處理
導入 jar 包
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-logappender</artifactId>
<version>4.7.1</version>
</dependency>
相關類
RocketmqLogbackAppender：發(fā)送到rocketmq
public class RocketmqLogbackAppender extends AppenderBase<ILoggingEvent> {
private String tag; //標簽
private String topic; //發(fā)送的topic
private String nameServerAddress; //namesrv地址
private String producerGroup; //發(fā)送群組
private MQProducer producer;
private Layout layout; //布局方式
private PreSerializationTransformer<ILoggingEvent> pst = new LoggingEventPreSerializationTransformer();
AsyncAppender：異步發(fā)送
public class AsyncAppender extends AsyncAppenderBase<ILoggingEvent> {
boolean includeCallerData = false;
AsyncAppenderBase
public class AsyncAppenderBase<E> extends UnsynchronizedAppenderBase<E>
implements AppenderAttachable<E> {
AppenderAttachableImpl<E> aai = new AppenderAttachableImpl<E>();
BlockingQueue<E> 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<E> {
void addAppender(Appender<E> newAppender);
boolean isAttached(Appender<E> appender);
Iterator<Appender<E>> iteratorForAppenders();
Appender<E> getAppender(String name);
void detachAndStopAllAppenders();
boolean detachAppender(Appender<E> appender);
boolean detachAppender(String name);
}
日志配置
logback.xml：放在resources目錄下
<?xml version="1.0" encoding="UTF-8"?>
<configuration debug="false">
<conversionRule conversionWord="clr" converterClass="org.springframework.boot.logging.logback.ColorConverter"/>
<conversionRule conversionWord="wex" converterClass="org.springframework.boot.logging.logback.WhitespaceThrowableProxyConverter"/>
<conversionRule conversionWord="wEx" converterClass="org.springframework.boot.logging.logback.ExtendedWhitespaceThrowableProxyConverter"/>
<property name="log.path" value="e:/hhhh/"/>
<property name="console.pattern" value="%clr(%d{${LOG_DATEFORMAT_PATTERN:-yyyy-MM-dd HH:mm:ss.SSS}}){faint} %clr(${LOG_LEVEL_PATTERN:-%5p}) %clr(${PID:- }){magenta} %clr(---){faint} %clr([%15.15t]){faint} %clr(%-40.40logger{39}){cyan} %clr(:){faint} %m%n${LOG_EXCEPTION_CONVERSION_WORD:-%wEx}"/>
<property name="file.pattern" value="%d{${LOG_DATEFORMAT_PATTERN:-yyyy-MM-dd HH:mm:ss.SSS}} ${LOG_LEVEL_PATTERN:-%5p} ${PID:- } --- [%t] %-40.40logger{39} : %m%n${LOG_EXCEPTION_CONVERSION_WORD:-%wEx}"/>
<appender name="console" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>${console.pattern}</pattern>
</encoder>
</appender>
<appender name="mqAppender1" class="org.apache.rocketmq.logappender.logback.RocketmqLogbackAppender">
<tag>tag</tag>
<topic>topic-log</topic>
<producerGroup>log-group</producerGroup>
<nameServerAddress>172.18.0.10:9876</nameServerAddress>
<layout>
<pattern>%date %p %t - %m%n</pattern>
</layout>
</appender>
<!-- 異步發(fā)送 -->
<appender name="mqAsyncAppender1" class="ch.qos.logback.classic.AsyncAppender">
<queueSize>1024</queueSize>
<discardingThreshold>80</discardingThreshold>
<maxFlushTime>2000</maxFlushTime>
<neverBlock>true</neverBlock>
<appender-ref ref="mqAppender1"/>
</appender>
<root level="info">
<appender-ref ref="console"/>
<appender-ref ref="mqAsyncAppender1"/>
</root>
</configuration>
將springboot應用打包，發(fā)布成docker容器
創(chuàng)建容器
#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監(jiān)控
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信息
以上為個人經(jīng)驗，希望能給大家一個參考，也希望大家多多支持腳本之家。
相關文章
idea2020.1最新版永久破解/pycharm也可用(步驟詳解)
這篇文章主要介紹了idea2020.1最新版永久破解/pycharm也可用,本文給大家分享簡單實現(xiàn)步驟，通過圖文并茂的形式給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2020-04-04
這篇文章主要介紹了Hibernate多對一單項關聯(lián),需要的朋友可以參考下2017-09-09
使用Java編寫一個簡單的Web的監(jiān)控系統(tǒng)
這篇文章主要介紹了使用Java編寫一個簡單的Web的監(jiān)控系統(tǒng)的例子,并且將重要信息轉為XML通過網(wǎng)頁前端顯示,非常之實用,需要的朋友可以參考下2015-11-11
java實現(xiàn)仿windows 字體設置選項卡實例
本篇文章介紹了java仿windows 字體設置選項卡,可實現(xiàn)類似windows字體設置效果,需要的朋友可以參考下。2016-10-10
這篇文章主要給大家介紹了關于Java中拷貝list數(shù)組幾種常見的方法,在Java中,List是一個接口,它有多個實現(xiàn)類,如ArrayList、LinkedList等,文中通過代碼介紹的非常詳細,需要的朋友可以參考下2023-08-08
Java?Stream如何將List分組成Map或LinkedHashMap
這篇文章主要給大家介紹了關于Java?Stream如何將List分組成Map或LinkedHashMap的相關資料,stream流是Java8的新特性,極大簡化了集合的處理操作,文中通過代碼介紹的非常詳細,需要的朋友可以參考下2023-12-12
這篇文章主要介紹了spring boot 配置文件后綴的一個坑，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-09-09
這篇文章主要介紹了Spring JDBC的使用詳解，幫助大家更好的理解和學習使用SpringBoot框架，感興趣的朋友可以了解下2021-05-05
這篇文章主要介紹了Spring-boot的debug調試代碼實例,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-12-12
這篇文章主要介紹了Spring中的bean相關知識，包括基本概念定義控制反轉IOC的問題，本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2022-03-03