欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

RocketMQ4.5.X 實(shí)現(xiàn)修改生產(chǎn)者消費(fèi)者日志保存路徑

 更新時(shí)間:2021年07月03日 11:16:09   作者:qq_35251168  
這篇文章主要介紹了RocketMQ4.5.X 實(shí)現(xiàn)修改生產(chǎn)者消費(fèi)者日志保存路徑方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

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)文章

  • java 指定某個(gè)jdk版本方法

    java 指定某個(gè)jdk版本方法

    這篇文章主要介紹了java 指定某個(gè)jdk版本方法的相關(guān)資料,需要的朋友可以參考下
    2017-05-05
  • 重新理解Java泛型

    重新理解Java泛型

    這篇文章主要介紹了重新理解Java泛型,具有一定參考價(jià)值,需要的朋友可以了解下。
    2017-11-11
  • 解讀thymeleaf模板引擎中th:if的使用

    解讀thymeleaf模板引擎中th:if的使用

    這篇文章主要介紹了解讀thymeleaf模板引擎中th:if的使用,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2022-10-10
  • Spring Boot 3.x 集成 Eureka Server/Client的詳細(xì)過程

    Spring Boot 3.x 集成 Eureka Server/Cl

    隨著SpringBoot 3.x版本的開發(fā)嘗試,本文記錄了在集成Eureka Server/Client時(shí)所遇到的問題和解決方案,文中詳細(xì)介紹了搭建服務(wù)、配置文件和測(cè)試步驟,感興趣的朋友跟隨小編一起看看吧
    2024-09-09
  • idea中如何去掉不想commit的文件

    idea中如何去掉不想commit的文件

    這篇文章主要介紹了idea中如何去掉不想commit的文件,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2023-02-02
  • Spring入門到精通之注解開發(fā)詳解

    Spring入門到精通之注解開發(fā)詳解

    Spring是輕代碼而重配置的框架,配置比較繁重,影響開發(fā)效率,所以注解開發(fā)是一種趨勢(shì)。本文將通過示例為大家詳細(xì)講講Spring如何實(shí)現(xiàn)注解開發(fā),感興趣的可以學(xué)習(xí)一下
    2022-07-07
  • java8根據(jù)某一屬性過濾去重的實(shí)例

    java8根據(jù)某一屬性過濾去重的實(shí)例

    這篇文章主要介紹了java8根據(jù)某一屬性過濾去重的實(shí)例,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2022-05-05
  • java鏈表數(shù)據(jù)結(jié)構(gòu)LinkedList插入刪除元素時(shí)間復(fù)雜度面試精講

    java鏈表數(shù)據(jù)結(jié)構(gòu)LinkedList插入刪除元素時(shí)間復(fù)雜度面試精講

    這篇文章主要為大家介紹了java LinkedList插入和刪除元素的時(shí)間復(fù)雜度面試精講,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2023-10-10
  • Java?NIO與IO的區(qū)別以及比較

    Java?NIO與IO的區(qū)別以及比較

    這篇文章主要介紹了Java?NIO與IO的區(qū)別以及比較,文章通過圍繞主題展開詳細(xì)的內(nèi)容介紹,具有一定的參考價(jià)值,需要的小伙伴可以參考一下
    2022-09-09
  • springboot + mybatis-plus實(shí)現(xiàn)多表聯(lián)合查詢功能(注解方式)

    springboot + 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

最新評(píng)論