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

SpringBoot定時(shí)監(jiān)聽RocketMQ的NameServer問(wèn)題及解決方案

 更新時(shí)間:2023年12月26日 11:35:07   作者:starjuly  
這篇文章主要介紹了SpringBoot定時(shí)監(jiān)聽RocketMQ的NameServer問(wèn)題及解決方案,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友參考下吧

問(wèn)題分析

  • 自己在測(cè)試環(huán)境部署了RocketMQ,發(fā)現(xiàn)namesrv很容易掛掉,于是就想著監(jiān)控,掛了就發(fā)郵件通知。
  • 查看了rocketmq-dashboard項(xiàng)目,發(fā)現(xiàn)只能監(jiān)控Broker,遂放棄這一路徑。
  • 于是就從報(bào)錯(cuò)的日志入手,發(fā)現(xiàn)最終可以根據(jù)RocketMQTemplate獲得可活動(dòng)的NameServer。

報(bào)錯(cuò)日志

報(bào)錯(cuò)日志如下:

12月 25 13:59:22 192.168.240.65 java[59571]: 2023-12-25 13:59:22.598  INFO 59571 --- [tWorkerThread_2] RocketmqRemoting                         : NETTY CLIENT PIPELINE: CLOSE 192.168.240.86:9876
12月 25 13:59:22 192.168.240.65 java[59571]: 2023-12-25 13:59:22.598  INFO 59571 --- [tWorkerThread_2] RocketmqRemoting                         : closeChannel: the channel[192.168.240.86:9876] was removed from channel table
12月 25 13:59:22 192.168.240.65 java[59571]: 2023-12-25 13:59:22.598  INFO 59571 --- [tWorkerThread_2] RocketmqRemoting                         : NETTY CLIENT PIPELINE: CLOSE 192.168.240.86:9876
12月 25 13:59:22 192.168.240.65 java[59571]: 2023-12-25 13:59:22.598  INFO 59571 --- [tWorkerThread_2] RocketmqRemoting                         : eventCloseChannel: the channel[null] has been removed from the channel table before
12月 25 13:59:22 192.168.240.65 java[59571]: 2023-12-25 13:59:22.598  INFO 59571 --- [lientSelector_1] RocketmqRemoting                         : closeChannel: close the connection to remote address[192.168.240.86:9876] result: true
12月 25 13:59:25 192.168.240.65 java[59571]: 2023-12-25 13:59:25.597  INFO 59571 --- [ntScan_thread_1] RocketmqRemoting                         : createChannel: begin to connect remote host[192.168.240.86:9876] asynchronously
12月 25 13:59:25 192.168.240.65 java[59571]: 2023-12-25 13:59:25.597  INFO 59571 --- [tWorkerThread_3] RocketmqRemoting                         : NETTY CLIENT PIPELINE: CONNECT  UNKNOWN => 192.168.240.86:9876
12月 25 13:59:25 192.168.240.65 java[59571]: 2023-12-25 13:59:25.598  WARN 59571 --- [ntScan_thread_1] RocketmqRemoting                         : createChannel: connect remote host[192.168.240.86:9876] failed, AbstractBootstrap$PendingRegistrationPromise@f2a3fc5(failure: io.netty.channel.AbstractChannel$AnnotatedConnectException: 拒絕連接: /192.168.240.86:9876)

根據(jù)日志可以發(fā)現(xiàn)是NettyRemotingClient類在做監(jiān)控,持續(xù)調(diào)用,具體核心方法:

org.apache.rocketmq.remoting.netty.NettyRemotingClient#createChannel

createChannel的源碼:

private Channel createChannel(String addr) throws InterruptedException {
        NettyRemotingClient.ChannelWrapper cw = (NettyRemotingClient.ChannelWrapper)this.channelTables.get(addr);
        if (cw != null && cw.isOK()) {
            return cw.getChannel();
        } else {
            if (this.lockChannelTables.tryLock(3000L, TimeUnit.MILLISECONDS)) {
                try {
                    cw = (NettyRemotingClient.ChannelWrapper)this.channelTables.get(addr);
                    boolean createNewConnection;
                    if (cw != null) {
                        if (cw.isOK()) {
                            Channel var4 = cw.getChannel();
                            return var4;
                        }
                        if (!cw.getChannelFuture().isDone()) {
                            createNewConnection = false;
                        } else {
                            this.channelTables.remove(addr);
                            createNewConnection = true;
                        }
                    } else {
                        createNewConnection = true;
                    }
                    if (createNewConnection) {
                        ChannelFuture channelFuture = this.bootstrap.connect(RemotingHelper.string2SocketAddress(addr));
                        LOGGER.info("createChannel: begin to connect remote host[{}] asynchronously", addr);
                        cw = new NettyRemotingClient.ChannelWrapper(channelFuture);
                        this.channelTables.put(addr, cw);
                    }
                } catch (Exception var8) {
                    LOGGER.error("createChannel: create channel exception", var8);
                } finally {
                    this.lockChannelTables.unlock();
                }
            } else {
                LOGGER.warn("createChannel: try to lock channel table, but timeout, {}ms", 3000L);
            }
            if (cw != null) {
                ChannelFuture channelFuture = cw.getChannelFuture();
                if (channelFuture.awaitUninterruptibly((long)this.nettyClientConfig.getConnectTimeoutMillis())) {
                    if (cw.isOK()) {
                        LOGGER.info("createChannel: connect remote host[{}] success, {}", addr, channelFuture.toString());
                        return cw.getChannel();
                    }
                    LOGGER.warn("createChannel: connect remote host[" + addr + "] failed, " + channelFuture.toString());
                } else {
                    LOGGER.warn("createChannel: connect remote host[{}] timeout {}ms, {}", new Object[]{addr, this.nettyClientConfig.getConnectTimeoutMillis(), channelFuture.toString()});
                }
            }
            return null;
        }
    }

從源碼中可以看到報(bào)錯(cuò)的日志數(shù)據(jù)

追溯

以NettyRemotingClient類為起點(diǎn),使用Debug分析,最終可以看到完整的調(diào)用鏈路:

監(jiān)控開發(fā)

那么監(jiān)控開發(fā)就很容易了,注冊(cè)RocketMQTemplate,使用定時(shí)任務(wù)監(jiān)聽即可,示例代碼如下:

@Slf4j
@Component
public class MQMonitorTask {
    @Resource
    private RocketMQTemplate rocketMQTemplate;
    @Scheduled(cron = "0/10 * * * * ?")
    public void scanNameServerBroker() {
        org.apache.rocketmq.remoting.RemotingClient remotingClient = rocketMQTemplate.getProducer()
                .getDefaultMQProducerImpl().getMqClientFactory().getMQClientAPIImpl().getRemotingClient();
        // 注冊(cè)的 NameServer
        List<String> nameServerAddressList = remotingClient.getNameServerAddressList();
        // 當(dāng)前活躍的 NameServer
        List<String> availableNameSrvList = remotingClient.getAvailableNameSrvList();
        log.info("nameServerAddressList:{}", JSONUtil.toJsonStr(nameServerAddressList));
        log.info("availableNameSrvList:{}", JSONUtil.toJsonStr(availableNameSrvList));
        // 只要 nameServerAddressList 和 availableNameSrvList 大小不一致,即可做郵件通知,具體閾值自己設(shè)置?。。?
        // TODO:郵件通知
    }
}

另外要在SprongBoot啟動(dòng)類加上注解@EnableScheduling來(lái)開啟定時(shí)任務(wù)。 

到此這篇關(guān)于SpringBoot定時(shí)監(jiān)聽RocketMQ的NameServer的文章就介紹到這了,更多相關(guān)SpringBoot定時(shí)監(jiān)聽NameServer內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • Swagger2不被SpringSecurity框架攔截的配置及說(shuō)明

    Swagger2不被SpringSecurity框架攔截的配置及說(shuō)明

    這篇文章主要介紹了Swagger2不被SpringSecurity框架攔截的配置及說(shuō)明,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2023-03-03
  • 18個(gè)Java8日期處理的實(shí)踐(太有用了)

    18個(gè)Java8日期處理的實(shí)踐(太有用了)

    這篇文章主要介紹了18個(gè)Java8日期處理的實(shí)踐(太有用了),文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2020-01-01
  • Springboot?application.yml配置文件拆分方式

    Springboot?application.yml配置文件拆分方式

    這篇文章主要介紹了Springboot?application.yml配置文件拆分方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2024-05-05
  • Java開發(fā)中的OOM內(nèi)存溢出問(wèn)題詳解

    Java開發(fā)中的OOM內(nèi)存溢出問(wèn)題詳解

    這篇文章主要介紹了Java開發(fā)中的OOM內(nèi)存溢出問(wèn)題詳解,OOM,全稱?Out?Of?Memory,意思是內(nèi)存耗盡或內(nèi)存溢出,當(dāng)JVM因?yàn)闆](méi)有足夠的內(nèi)存來(lái)為對(duì)象分配空間并且垃圾回收器也已經(jīng)沒(méi)有空間可回收時(shí),就會(huì)拋出這個(gè)?error,需要的朋友可以參考下
    2023-08-08
  • 微信java開發(fā)之實(shí)現(xiàn)微信主動(dòng)推送消息

    微信java開發(fā)之實(shí)現(xiàn)微信主動(dòng)推送消息

    這篇文章主要介紹了微信開發(fā)過(guò)程中的使用java實(shí)現(xiàn)微信主動(dòng)推送消息示例,需要的朋友可以參考下
    2014-03-03
  • Druid連接池未關(guān)閉導(dǎo)致內(nèi)存泄漏問(wèn)題

    Druid連接池未關(guān)閉導(dǎo)致內(nèi)存泄漏問(wèn)題

    這篇文章主要介紹了Druid連接池未關(guān)閉導(dǎo)致內(nèi)存泄漏問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2023-12-12
  • IDEA POM文件配置profile實(shí)現(xiàn)不同環(huán)境切換的方法步驟

    IDEA POM文件配置profile實(shí)現(xiàn)不同環(huán)境切換的方法步驟

    這篇文章主要介紹了IDEA POM文件配置profile實(shí)現(xiàn)不同環(huán)境切換的方法步驟
    2024-03-03
  • SpringMVC實(shí)現(xiàn)多文件上傳

    SpringMVC實(shí)現(xiàn)多文件上傳

    這篇文章主要為大家詳細(xì)介紹了SpringMVC實(shí)現(xiàn)多文件上傳功能,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2019-11-11
  • Java String類常用方法梳理總結(jié)

    Java String類常用方法梳理總結(jié)

    這篇文章主要介紹了Java String類常用方法梳理總結(jié),類 String 中包括用于檢查各個(gè)字符串的方法,比如用于比較字符串,搜索字符串,更多相關(guān)內(nèi)容需要的朋友可以參考一下
    2022-06-06
  • 一文詳解Java項(xiàng)目中如何優(yōu)雅的使用枚舉類型

    一文詳解Java項(xiàng)目中如何優(yōu)雅的使用枚舉類型

    枚舉類型在開發(fā)中是很常見的,有非常多的應(yīng)用場(chǎng)景,這篇文章我們就來(lái)學(xué)習(xí)一下項(xiàng)目中如何優(yōu)雅的使用枚舉類型,感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下
    2024-03-03

最新評(píng)論