RocketMQ4.5.X 實(shí)現(xiàn)修改生產(chǎn)者消費(fèi)者日志保存路徑
RocketMQ修改生產(chǎn)者消費(fèi)者日志保存路徑
rocket默認(rèn)是將所有日志文件保存到user.home的對(duì)于win系統(tǒng)就是C盤了。
1.修改RocketMQ中CLientLogger.class的源碼,把經(jīng)過更改的源碼重新打包后,去自己的maven倉庫替換rocketmq-client.-4.5.X.jar。
2.對(duì)于生產(chǎn)者的啟動(dòng)類里需要配置JVM系統(tǒng)屬性:
如果不設(shè)置logUserSlf4j為true的話,啟動(dòng)生產(chǎn)者的時(shí)候會(huì)報(bào)找不到日志配置文件的警告。
3.對(duì)于消費(fèi)者,僅僅添加rq.lordir(日志保存路徑)就行了。
當(dāng)然,以上情況是開發(fā)中每個(gè)開發(fā)人員需要獨(dú)立設(shè)置的,部署到線上的時(shí)候可以直接在源碼中寫路徑而不是系統(tǒng)屬性。
RocketMQ 日志操作
官網(wǎng):http://rocketmq.apache.org/docs/logappender-example/
應(yīng)用:將程序日志輸出到rocketmq,消費(fèi)端可讀取日志數(shù)據(jù)進(jìn)行相應(yīng)處理
導(dǎo)入 jar 包
<dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-logappender</artifactId> <version>4.7.1</version> </dependency>
相關(guān)類
RocketmqLogbackAppender
:發(fā)送到rocketmq
public class RocketmqLogbackAppender extends AppenderBase<ILoggingEvent> { private String tag; //標(biāo)簽 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應(yīng)用打包,發(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 #應(yīng)用程序 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
使用測(cè)試
192.168.57.127:8008
查看topic
查看topic-log message信息
以上為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。
相關(guān)文章
Spring Boot 3.x 集成 Eureka Server/Cl
隨著SpringBoot 3.x版本的開發(fā)嘗試,本文記錄了在集成Eureka Server/Client時(shí)所遇到的問題和解決方案,文中詳細(xì)介紹了搭建服務(wù)、配置文件和測(cè)試步驟,感興趣的朋友跟隨小編一起看看吧2024-09-09java鏈表數(shù)據(jù)結(jié)構(gòu)LinkedList插入刪除元素時(shí)間復(fù)雜度面試精講
這篇文章主要為大家介紹了java LinkedList插入和刪除元素的時(shí)間復(fù)雜度面試精講,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-10-10springboot + mybatis-plus實(shí)現(xiàn)多表聯(lián)合查詢功能(注解方式)
這篇文章主要介紹了springboot + mybatis-plus實(shí)現(xiàn)多表聯(lián)合查詢功能,是最簡(jiǎn)單的一種注解方式,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2020-09-09