Rocketmq: Multiple brokers and multiple mqnamesrv can not find the cluster in the RocketMQ-Console

Created on 30 Mar 2021 · 18Comments · Source: apache/rocketmq

docker启动单机环境、多broker多mqnamesrv均在rocket-console中无法发现集群，无法进行注册

机器IP(虚拟机，docker运行的宿主机)： 192.168.31.246
机器内存: 6g
机器系统版本: CentOS Linux release 7.9.2009 (Core)
docker版本: 1.13.1
docker API version: 1.26
rocketmq docker images: https://hub.docker.com/r/rocketmqinc/rocketmq

我参照的教程:

问题中选择的是单机版本，但是我使用集群版本搭建了多主broker，同样都注册不到namesrv上，一头雾水

单机版本: https://blog.csdn.net/qq_37470552/article/details/114083184

集群版本: https://www.cnblogs.com/qdhxhz/p/11096682.html

docker-compose.yml容器编排文件

此处编排的为namesrv，broker,rmq-console项目

version: '3.5'
services:
  rmqnamesrv:
    image: rocketmqinc/rocketmq
    container_name: rmqnamesrv
    restart: always
    ports:
      - 9876:9876
    environment:
      #内存分配
      JAVA_OPT_EXT: "-server -Xms1g -Xmx1g"
    volumes:
      - /home/rocketmq/namesrv/logs:/root/logs
    command: sh mqnamesrv
    networks:
      rmq:
        aliases:
          - rmqnamesrv

  rmqbroker:
    image: rocketmqinc/rocketmq
    container_name: rmqbroker
    restart: always
    depends_on:
      - rmqnamesrv
    ports:
      - 10909:10909
      - 10911:10911
    volumes:
      - /home/rocketmq/broker/logs:/root/logs
      - /home/rocketmq/broker/store:/root/store
      - /home/rocketmq/broker/conf/broker.conf:/opt/rocketmq-4.4.0/conf/broker.conf
    command: sh mqbroker  -c /opt/rocketmq-4.4.0/conf/broker.conf
    environment:
      NAMESRV_ADDR: "rmqnamesrv:9876"
      JAVA_OPT_EXT: "-server -Xms1g -Xmx1g -Xmn1g"
    networks:
      rmq:
        aliases:
          - rmqbroker

  rmqconsole:
    image: styletang/rocketmq-console-ng
    container_name: rocketmq-console
    restart: always
    ports:
      - 9877:8080
    depends_on:
      - rmqnamesrv
    volumes:
      - /etc/localtime:/etc/localtime:ro
      - /home/rocketmq/console/logs:/root/logs
    environment:
      JAVA_OPTS: "-Drocketmq.namesrv.addr=rmqnamesrv:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false"
    networks:
      rmq:
        aliases:
          - rmqconsole
networks:
  rmq:
    name: rmq
    driver: bridge

broker.conf

brokerClusterName=DefaultCluster
brokerName=broker-a
brokerId=0
# 修改为你宿主机的 IP
# 这个很有讲究 如果是正式环境 这里一定要填写内网地址（安全）
# 如果是用于测试或者本地这里建议要填外网地址,因为你的本地代码是无法连接到阿里云内网,只能连接外网
brokerIP1=192.168.31.246

defaultTopicQueueNums=4

autoCreateTopicEnable=true
autoCreateSubscriptionGroup=true

# Broker 对外服务的监听端口,
listenPort=10911
deleteWhen=04

# 文件回收120h
fileReservedTime=24
mapedFileSizeCommitLog=1073741824

mapedFileSizeConsumeQueue=300000

diskMaxUsedSpaceRatio=75%

maxMessageSize=65536
# Broker角色
# - ASYNC_MASTER 异步复制Master
# - SYNC_MASTER 同步双写Master
# - SLAVE
brokerRole=ASYNC_MASTER
# 刷盘方式
# - ASYNC_FLUSH 异步刷盘
# - SYNC_FLUSH 同步刷盘
flushDiskType=ASYNC_FLUSH

文件树:

在根目录的home文件夹下

broker的存储目录为: /home/rocketmq/broker/conf/broker.conf

docker ps容器的状态:

之前在centos出现过安全模块无法执行broker创建conf脚本的问题，关闭安全模块解决。所以三个容器的状态均启动完成

docker ps.jpg

控制台截图:

可以看出控制台报错了，并且没有监控到broker注册上面

运维模块的namesrv也选择了9876端口的namesrv

docker logs:

mamesrv:

[root@MiWiFi-RA69-srv conf]# docker logs 70504e6cea64
OpenJDK 64-Bit Server VM warning: Using the DefNew young collector with the CMS collector is deprecated and will likely be removed in a future release
OpenJDK 64-Bit Server VM warning: UseCMSCompactAtFullCollection is deprecated and will likely be removed in a future release.
The Name Server boot success. serializeType=JSON

broker:

容器运行时:

[root@MiWiFi-RA69-srv conf]# docker logs 2b6e096ff9db
The broker[broker-a, 192.168.31.246:10911] boot success. serializeType=JSON and name server is rmqnamesrv:9876

容器内挂载log:

/home/rocketmq/broker/logs/rocketmqlogs/broker.log

2021-03-30 10:11:54 INFO main - rocketmqHome=/opt/rocketmq-4.4.0
2021-03-30 10:11:54 INFO main - namesrvAddr=rmqnamesrv:9876
2021-03-30 10:11:54 INFO main - brokerIP1=192.168.31.246
2021-03-30 10:11:54 INFO main - brokerIP2=172.18.0.3
2021-03-30 10:11:54 INFO main - brokerName=broker-a
2021-03-30 10:11:54 INFO main - brokerClusterName=DefaultCluster
2021-03-30 10:11:54 INFO main - brokerId=0
2021-03-30 10:11:54 INFO main - brokerPermission=6
2021-03-30 10:11:54 INFO main - defaultTopicQueueNums=4
2021-03-30 10:11:54 INFO main - autoCreateTopicEnable=true
2021-03-30 10:11:54 INFO main - clusterTopicEnable=true
2021-03-30 10:11:54 INFO main - brokerTopicEnable=true
2021-03-30 10:11:54 INFO main - autoCreateSubscriptionGroup=true
2021-03-30 10:11:54 INFO main - messageStorePlugIn=
2021-03-30 10:11:54 INFO main - msgTraceTopicName=RMQ_SYS_TRACE_TOPIC
2021-03-30 10:11:54 INFO main - traceTopicEnable=false
2021-03-30 10:11:54 INFO main - sendMessageThreadPoolNums=1
2021-03-30 10:11:54 INFO main - pullMessageThreadPoolNums=24
2021-03-30 10:11:54 INFO main - queryMessageThreadPoolNums=12
2021-03-30 10:11:54 INFO main - adminBrokerThreadPoolNums=16
2021-03-30 10:11:54 INFO main - clientManageThreadPoolNums=32
2021-03-30 10:11:54 INFO main - consumerManageThreadPoolNums=32
2021-03-30 10:11:54 INFO main - heartbeatThreadPoolNums=4
2021-03-30 10:11:54 INFO main - endTransactionThreadPoolNums=16
2021-03-30 10:11:54 INFO main - flushConsumerOffsetInterval=5000
2021-03-30 10:11:54 INFO main - flushConsumerOffsetHistoryInterval=60000
2021-03-30 10:11:54 INFO main - rejectTransactionMessage=false
2021-03-30 10:11:54 INFO main - fetchNamesrvAddrByAddressServer=false
2021-03-30 10:11:54 INFO main - sendThreadPoolQueueCapacity=10000
2021-03-30 10:11:54 INFO main - pullThreadPoolQueueCapacity=100000
2021-03-30 10:11:54 INFO main - queryThreadPoolQueueCapacity=20000
2021-03-30 10:11:54 INFO main - clientManagerThreadPoolQueueCapacity=1000000
2021-03-30 10:11:54 INFO main - consumerManagerThreadPoolQueueCapacity=1000000
2021-03-30 10:11:54 INFO main - heartbeatThreadPoolQueueCapacity=50000
2021-03-30 10:11:54 INFO main - endTransactionPoolQueueCapacity=100000
2021-03-30 10:11:54 INFO main - filterServerNums=0
2021-03-30 10:11:54 INFO main - longPollingEnable=true
2021-03-30 10:11:54 INFO main - shortPollingTimeMills=1000
2021-03-30 10:11:54 INFO main - notifyConsumerIdsChangedEnable=true
2021-03-30 10:11:54 INFO main - highSpeedMode=false
2021-03-30 10:11:54 INFO main - commercialEnable=true
2021-03-30 10:11:54 INFO main - commercialTimerCount=1
2021-03-30 10:11:54 INFO main - commercialTransCount=1
2021-03-30 10:11:54 INFO main - commercialBigCount=1
2021-03-30 10:11:54 INFO main - commercialBaseCount=1
2021-03-30 10:11:54 INFO main - transferMsgByHeap=true
2021-03-30 10:11:54 INFO main - maxDelayTime=40
2021-03-30 10:11:54 INFO main - regionId=DefaultRegion
2021-03-30 10:11:54 INFO main - registerBrokerTimeoutMills=6000
2021-03-30 10:11:54 INFO main - slaveReadEnable=false
2021-03-30 10:11:54 INFO main - disableConsumeIfConsumerReadSlowly=false
2021-03-30 10:11:54 INFO main - consumerFallbehindThreshold=17179869184
2021-03-30 10:11:54 INFO main - brokerFastFailureEnable=true
2021-03-30 10:11:54 INFO main - waitTimeMillsInSendQueue=200
2021-03-30 10:11:54 INFO main - waitTimeMillsInPullQueue=5000
2021-03-30 10:11:54 INFO main - waitTimeMillsInHeartbeatQueue=31000
2021-03-30 10:11:54 INFO main - waitTimeMillsInTransactionQueue=3000
2021-03-30 10:11:54 INFO main - startAcceptSendRequestTimeStamp=0
2021-03-30 10:11:54 INFO main - traceOn=true
2021-03-30 10:11:54 INFO main - enableCalcFilterBitMap=false
2021-03-30 10:11:54 INFO main - expectConsumerNumUseFilter=32
2021-03-30 10:11:54 INFO main - maxErrorRateOfBloomFilter=20
2021-03-30 10:11:54 INFO main - filterDataCleanTimeSpan=86400000
2021-03-30 10:11:54 INFO main - filterSupportRetry=false
2021-03-30 10:11:54 INFO main - enablePropertyFilter=false
2021-03-30 10:11:54 INFO main - compressedRegister=false
2021-03-30 10:11:54 INFO main - forceRegister=true
2021-03-30 10:11:54 INFO main - registerNameServerPeriod=30000
2021-03-30 10:11:54 INFO main - transactionTimeOut=6000
2021-03-30 10:11:54 INFO main - transactionCheckMax=15
2021-03-30 10:11:54 INFO main - transactionCheckInterval=60000
2021-03-30 10:11:54 INFO main - aclEnable=false
2021-03-30 10:11:54 INFO main - listenPort=10911
2021-03-30 10:11:54 INFO main - serverWorkerThreads=8
2021-03-30 10:11:54 INFO main - serverCallbackExecutorThreads=0
2021-03-30 10:11:54 INFO main - serverSelectorThreads=3
2021-03-30 10:11:54 INFO main - serverOnewaySemaphoreValue=256
2021-03-30 10:11:54 INFO main - serverAsyncSemaphoreValue=64
2021-03-30 10:11:54 INFO main - serverChannelMaxIdleTimeSeconds=120
2021-03-30 10:11:54 INFO main - serverSocketSndBufSize=131072
2021-03-30 10:11:54 INFO main - serverSocketRcvBufSize=131072
2021-03-30 10:11:54 INFO main - serverPooledByteBufAllocatorEnable=true
2021-03-30 10:11:54 INFO main - useEpollNativeSelector=false
2021-03-30 10:11:54 INFO main - clientWorkerThreads=4
2021-03-30 10:11:54 INFO main - clientCallbackExecutorThreads=4
2021-03-30 10:11:54 INFO main - clientOnewaySemaphoreValue=65535
2021-03-30 10:11:54 INFO main - clientAsyncSemaphoreValue=65535
2021-03-30 10:11:54 INFO main - connectTimeoutMillis=3000
2021-03-30 10:11:54 INFO main - channelNotActiveInterval=60000
2021-03-30 10:11:54 INFO main - clientChannelMaxIdleTimeSeconds=120
2021-03-30 10:11:54 INFO main - clientSocketSndBufSize=131072
2021-03-30 10:11:54 INFO main - clientSocketRcvBufSize=131072
2021-03-30 10:11:54 INFO main - clientPooledByteBufAllocatorEnable=false
2021-03-30 10:11:54 INFO main - clientCloseSocketIfTimeout=false
2021-03-30 10:11:54 INFO main - useTLS=false
2021-03-30 10:11:54 INFO main - storePathRootDir=/root/store
2021-03-30 10:11:54 INFO main - storePathCommitLog=/root/store/commitlog
2021-03-30 10:11:54 INFO main - mapedFileSizeCommitLog=1073741824
2021-03-30 10:11:54 INFO main - mapedFileSizeConsumeQueue=300000
2021-03-30 10:11:54 INFO main - enableConsumeQueueExt=false
2021-03-30 10:11:54 INFO main - mappedFileSizeConsumeQueueExt=50331648
2021-03-30 10:11:54 INFO main - bitMapLengthConsumeQueueExt=64
2021-03-30 10:11:54 INFO main - flushIntervalCommitLog=500
2021-03-30 10:11:54 INFO main - commitIntervalCommitLog=200
2021-03-30 10:11:54 INFO main - useReentrantLockWhenPutMessage=false
2021-03-30 10:11:54 INFO main - flushCommitLogTimed=false
2021-03-30 10:11:54 INFO main - flushIntervalConsumeQueue=1000
2021-03-30 10:11:54 INFO main - cleanResourceInterval=10000
2021-03-30 10:11:54 INFO main - deleteCommitLogFilesInterval=100
2021-03-30 10:11:54 INFO main - deleteConsumeQueueFilesInterval=100
2021-03-30 10:11:54 INFO main - destroyMapedFileIntervalForcibly=120000
2021-03-30 10:11:54 INFO main - redeleteHangedFileInterval=120000
2021-03-30 10:11:54 INFO main - deleteWhen=04
2021-03-30 10:11:54 INFO main - diskMaxUsedSpaceRatio=75
2021-03-30 10:11:54 INFO main - fileReservedTime=24
2021-03-30 10:11:54 INFO main - putMsgIndexHightWater=600000
2021-03-30 10:11:54 INFO main - maxMessageSize=65536
2021-03-30 10:11:54 INFO main - checkCRCOnRecover=true
2021-03-30 10:11:54 INFO main - flushCommitLogLeastPages=4
2021-03-30 10:11:54 INFO main - commitCommitLogLeastPages=4
2021-03-30 10:11:54 INFO main - flushLeastPagesWhenWarmMapedFile=4096
2021-03-30 10:11:54 INFO main - flushConsumeQueueLeastPages=2
2021-03-30 10:11:54 INFO main - flushCommitLogThoroughInterval=10000
2021-03-30 10:11:54 INFO main - commitCommitLogThoroughInterval=200
2021-03-30 10:11:54 INFO main - flushConsumeQueueThoroughInterval=60000
2021-03-30 10:11:54 INFO main - maxTransferBytesOnMessageInMemory=262144
2021-03-30 10:11:54 INFO main - maxTransferCountOnMessageInMemory=32
2021-03-30 10:11:54 INFO main - maxTransferBytesOnMessageInDisk=65536
2021-03-30 10:11:54 INFO main - maxTransferCountOnMessageInDisk=8
2021-03-30 10:11:54 INFO main - accessMessageInMemoryMaxRatio=40
2021-03-30 10:11:54 INFO main - messageIndexEnable=true
2021-03-30 10:11:54 INFO main - maxHashSlotNum=5000000
2021-03-30 10:11:54 INFO main - maxIndexNum=20000000
2021-03-30 10:11:54 INFO main - maxMsgsNumBatch=64
2021-03-30 10:11:54 INFO main - messageIndexSafe=false
2021-03-30 10:11:54 INFO main - haListenPort=10912
2021-03-30 10:11:54 INFO main - haSendHeartbeatInterval=5000
2021-03-30 10:11:54 INFO main - haHousekeepingInterval=20000
2021-03-30 10:11:54 INFO main - haTransferBatchSize=32768
2021-03-30 10:11:54 INFO main - haMasterAddress=
2021-03-30 10:11:54 INFO main - haSlaveFallbehindMax=268435456
2021-03-30 10:11:54 INFO main - brokerRole=ASYNC_MASTER
2021-03-30 10:11:54 INFO main - flushDiskType=ASYNC_FLUSH
2021-03-30 10:11:54 INFO main - syncFlushTimeout=5000
2021-03-30 10:11:54 INFO main - messageDelayLevel=1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h
2021-03-30 10:11:54 INFO main - flushDelayOffsetInterval=10000
2021-03-30 10:11:54 INFO main - cleanFileForciblyEnable=true
2021-03-30 10:11:54 INFO main - warmMapedFileEnable=false
2021-03-30 10:11:54 INFO main - offsetCheckInSlave=false
2021-03-30 10:11:54 INFO main - debugLockEnable=false
2021-03-30 10:11:54 INFO main - duplicationEnable=false
2021-03-30 10:11:54 INFO main - diskFallRecorded=true
2021-03-30 10:11:54 INFO main - osPageCacheBusyTimeOutMills=1000
2021-03-30 10:11:54 INFO main - defaultQueryMaxNum=32
2021-03-30 10:11:54 INFO main - transientStorePoolEnable=false
2021-03-30 10:11:54 INFO main - transientStorePoolSize=5
2021-03-30 10:11:54 INFO main - fastFailIfNoBufferInStorePool=false
2021-03-30 10:11:55 INFO main - Replace, key: diskMaxUsedSpaceRatio, value: 75 -> 75%
2021-03-30 10:11:55 INFO main - Set user specified name server address: rmqnamesrv:9876
2021-03-30 10:11:55 WARN main - Load default transaction message hook service: TransactionalMessageServiceImpl
2021-03-30 10:11:55 WARN main - Load default discard message hook service: DefaultTransactionalMessageCheckListener
2021-03-30 10:11:55 INFO main - The broker dose not enable acl
2021-03-30 10:11:55 INFO FileWatchService - FileWatchService service started
2021-03-30 10:11:55 INFO PullRequestHoldService - PullRequestHoldService service started
2021-03-30 10:11:56 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:11:56 INFO main - Start transaction service!
2021-03-30 10:11:56 INFO main - The broker[broker-a, 192.168.31.246:10911] boot success. serializeType=JSON and name server is rmqnamesrv:9876
2021-03-30 10:12:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:12:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:12:06 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:12:36 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:12:56 INFO TransactionalMessageCheckService - create new topic TopicConfig [topicName=RMQ_SYS_TRANS_HALF_TOPIC, readQueueNums=1, writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, order=false]
2021-03-30 10:12:56 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:13:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:13:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:13:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:13:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:14:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:14:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:14:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:14:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:15:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:15:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:15:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:15:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:16:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:16:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:16:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:16:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:17:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:17:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:17:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:17:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:18:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:18:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:18:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:18:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:19:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:19:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:19:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:19:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:20:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:20:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:20:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:20:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:21:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:21:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:21:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:21:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:22:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:22:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:22:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:22:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:23:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:23:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:23:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:23:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:24:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:24:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:24:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:24:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:25:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:25:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:25:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:25:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:26:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:26:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:26:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:26:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:27:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:27:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:27:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:27:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:28:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:28:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:28:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:28:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:29:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:29:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:29:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:29:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:30:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:30:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:30:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:30:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:31:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:31:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:31:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:31:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:32:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:32:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:32:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:32:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:33:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:33:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:33:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:33:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:34:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:34:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:34:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:34:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:35:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:35:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:35:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:35:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:36:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:36:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:36:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:36:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:37:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:37:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:37:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:37:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:38:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:38:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:38:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:38:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:39:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:39:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:39:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:39:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:40:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:40:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:40:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:40:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:41:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:41:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:41:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:41:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:42:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:42:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:42:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:42:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:43:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:43:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:43:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:43:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:44:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:44:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:44:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:44:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:45:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:45:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:45:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:45:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:46:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:46:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:46:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:46:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:47:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:47:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:47:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:47:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:48:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:48:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:48:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:48:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:49:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:49:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:49:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:49:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:50:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:50:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:50:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:50:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:51:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:51:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:51:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:51:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:52:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:52:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:52:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:52:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:53:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:53:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:53:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:53:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:54:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:54:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:54:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:54:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:55:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:55:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:55:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:55:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:56:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:56:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:56:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:56:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:57:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:57:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:57:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:57:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:58:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:58:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:58:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:58:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:59:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 10:59:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 10:59:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 10:59:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:00:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 11:00:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 11:00:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:00:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:01:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 11:01:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 11:01:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:01:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:02:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 11:02:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 11:02:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:02:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:03:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 11:03:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 11:03:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:03:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:04:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 11:04:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 11:04:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:04:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:05:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 11:05:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 11:05:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:05:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:06:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 11:06:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 11:06:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:06:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:07:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 11:07:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 11:07:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:07:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:08:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 11:08:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 11:08:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:08:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:09:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 11:09:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 11:09:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:09:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:10:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 11:10:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 11:10:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:10:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:11:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 11:11:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 11:11:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:11:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:12:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 11:12:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 11:12:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:12:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:13:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 11:13:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 11:13:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:13:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:14:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 11:14:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 11:14:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:14:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:15:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 11:15:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 11:15:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:15:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:16:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 11:16:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 11:16:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:16:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:17:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 11:17:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 11:17:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:17:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:18:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 11:18:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 11:18:06 INFO brokerOutApi_thread_3 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:18:36 INFO brokerOutApi_thread_4 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:19:05 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes
2021-03-30 11:19:05 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes
2021-03-30 11:19:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:19:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK

rmq-console:

[2021-03-30 02:58:32.023] ERROR Unexpected error occurred in scheduled task.
java.lang.RuntimeException: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.31.246:10911> failed
    at com.google.common.base.Throwables.propagate(Throwables.java:160)
    at org.apache.rocketmq.console.task.DashboardCollectTask.collectTopic(DashboardCollectTask.java:156)
    at org.apache.rocketmq.console.task.DashboardCollectTask$$FastClassBySpringCGLIB$$c818b8cd.invoke(<generated>)
    at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204)
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:721)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)
    at org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:85)
    at org.apache.rocketmq.console.aspect.admin.MQAdminAspect.aroundMQAdminMethod(MQAdminAspect.java:63)
    at sun.reflect.GeneratedMethodAccessor95.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:629)
    at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:618)
    at org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:70)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:168)
    at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
    at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:656)
    at org.apache.rocketmq.console.task.DashboardCollectTask$$EnhancerBySpringCGLIB$$9a10db13.collectTopic(<generated>)
    at sun.reflect.GeneratedMethodAccessor105.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.springframework.scheduling.support.ScheduledMethodRunnable.run(ScheduledMethodRunnable.java:65)
    at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)
    at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:81)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)
Caused by: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.31.246:10911> failed
    at org.apache.rocketmq.remoting.netty.NettyRemotingClient.invokeSync(NettyRemotingClient.java:357)
    at org.apache.rocketmq.client.impl.MQClientAPIImpl.queryTopicConsumeByWho(MQClientAPIImpl.java:1488)
    at org.apache.rocketmq.tools.admin.DefaultMQAdminExtImpl.queryTopicConsumeByWho(DefaultMQAdminExtImpl.java:577)
    at org.apache.rocketmq.tools.admin.DefaultMQAdminExt.queryTopicConsumeByWho(DefaultMQAdminExt.java:325)
    at org.apache.rocketmq.console.service.client.MQAdminExtImpl.queryTopicConsumeByWho(MQAdminExtImpl.java:291)
    at sun.reflect.GeneratedMethodAccessor108.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:333)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:190)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)
    at org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:85)
    at org.apache.rocketmq.console.aspect.admin.MQAdminAspect.aroundMQAdminMethod(MQAdminAspect.java:63)
    at sun.reflect.GeneratedMethodAccessor95.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:629)
    at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:618)
    at org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:70)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:168)
    at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
    at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:213)
    at com.sun.proxy.$Proxy71.queryTopicConsumeByWho(Unknown Source)
    at org.apache.rocketmq.console.task.DashboardCollectTask.collectTopic(DashboardCollectTask.java:88)
    ... 30 common frames omitted
[2021-03-30 02:59:09.068] ERROR Unexpected error occurred in scheduled task.
java.lang.RuntimeException: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.31.246:10911> failed
    at com.google.common.base.Throwables.propagate(Throwables.java:160)
    at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:219)
    at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:218)
    at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:218)
    at org.apache.rocketmq.console.task.DashboardCollectTask.collectBroker(DashboardCollectTask.java:184)
    at org.apache.rocketmq.console.task.DashboardCollectTask$$FastClassBySpringCGLIB$$c818b8cd.invoke(<generated>)
    at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204)
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:721)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)
    at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
    at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:656)
    at org.apache.rocketmq.console.task.DashboardCollectTask$$EnhancerBySpringCGLIB$$9a10db13.collectBroker(<generated>)
    at sun.reflect.GeneratedMethodAccessor104.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.springframework.scheduling.support.ScheduledMethodRunnable.run(ScheduledMethodRunnable.java:65)
    at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)
    at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:81)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)
Caused by: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.31.246:10911> failed
    at org.apache.rocketmq.remoting.netty.NettyRemotingClient.invokeSync(NettyRemotingClient.java:357)
    at org.apache.rocketmq.client.impl.MQClientAPIImpl.getBrokerRuntimeInfo(MQClientAPIImpl.java:1089)
    at org.apache.rocketmq.tools.admin.DefaultMQAdminExtImpl.fetchBrokerRuntimeStats(DefaultMQAdminExtImpl.java:231)
    at org.apache.rocketmq.tools.admin.DefaultMQAdminExt.fetchBrokerRuntimeStats(DefaultMQAdminExt.java:194)
    at org.apache.rocketmq.console.service.client.MQAdminExtImpl.fetchBrokerRuntimeStats(MQAdminExtImpl.java:156)
    at sun.reflect.GeneratedMethodAccessor97.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:333)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:190)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)
    at org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:85)
    at org.apache.rocketmq.console.aspect.admin.MQAdminAspect.aroundMQAdminMethod(MQAdminAspect.java:63)
    at sun.reflect.GeneratedMethodAccessor95.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:629)
    at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:618)
    at org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:70)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:168)
    at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
    at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:213)
    at com.sun.proxy.$Proxy71.fetchBrokerRuntimeStats(Unknown Source)
    at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:209)
    ... 24 common frames omitted

question

Source

a2501521908

Most helpful comment

这么说是我没有JDK的原因是吗这个机子，我看看这个怎么研究下指向，的确是宿主机没有安装jdk想着镜像中存在了就没必要了安装了个docker就开始了
有报错的，是这个，无法连接的错误
java.lang.RuntimeException: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.31.246:10911> failed
  at com.google.common.base.Throwables.propagate(Throwables.java:160)
  at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:219)
  at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:218)
  at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:218)
  at org.apache.rocketmq.console.task.DashboardCollectTask.collectBroker(DashboardCollectTask.java:184)
  at org.apache.rocketmq.console.task.DashboardCollectTask$$FastClassBySpringCGLIB$$c818b8cd.invoke(<generated>)
  at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204)
  at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:721)
  at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)
  at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92)
  at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
  at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:656)
  at org.apache.rocketmq.console.task.DashboardCollectTask$$EnhancerBySpringCGLIB$$9a10db13.collectBroker(<generated>)
  at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  at java.lang.reflect.Method.invoke(Method.java:498)
  at org.springframework.scheduling.support.ScheduledMethodRunnable.run(ScheduledMethodRunnable.java:65)
  at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)
  at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:81)
  at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  at java.util.concurrent.FutureTask.run(FutureTask.java:266)
  at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
  at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
  at java.lang.Thread.run(Thread.java:745)
请问我使用的是官方的镜像吗？因为这样的话还得每次都挂载一个jdk的目录进去是否是很鸡肋？
rocketmqinc/rocketmq 这个是官方的镜像的
好的，我使用的就是这个镜像
那请问我必须按照这种的去给docker的容器中cp一份jar文件是吗，我看到了别人的解决方式是: https://blog.csdn.net/qq_18855485/article/details/99647626
这样的方式在容器删除掉或者别的机制后，岂不是得在脑子里记着给容器中cp一份，还是推荐使用物理机来管理，而不是容器~
当前是没有办法，也可以直接在容器里面改脚本，然后重启容器。可以在issue里面搜下，已经有提pr改过了。你现在docker镜像里面部署的rocketmq版本可能比较低，没有修复这个问题
啊？请问我docker默认没有敲定版本号，不是应该就是last版本吗？咦，是还有别的镜像源吗
可以去namesrv或者broker容器里面，lib下面看下jar包版本
jar文件均为4.4.0版本
这个版本比较老了
那应该怎么去操作，毕竟现在docker的镜像版本是last了已经，是等待重新发包吗？

https://github.com/apache/rocketmq-docker 看下这个文档，使用4.8.0

panzhi33 on 30 Mar 2021

❤1 👍1

All 18 comments

有可能是console到broker的网络不通导致的，可以telnet broker的节点信息看下

panzhi33 on 30 Mar 2021

有可能是console到broker的网络不通导致的，可以telnet broker的节点信息看下

您好，额不是的，我现在操作的单机，只有一台宿主机(192.168.31.246)上面起的容器去通信，他们之间通信也是这个IP，还有什么可以侦察日志的办法嘛？

因为我看到了自己本身打印的日志中出现了这些

2021-03-30 11:19:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:19:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK

说是注册成功了，是不是还有什么别的侦察方向，我试着Google了下别人的例子，结果并没有那么的理想。~

a2501521908 on 30 Mar 2021

有可能是console到broker的网络不通导致的，可以telnet broker的节点信息看下

您好，额不是的，我现在操作的单机，只有一台宿主机(192.168.31.246)上面起的容器去通信，他们之间通信也是这个IP，还有什么可以侦察日志的办法嘛？

因为我看到了自己本身打印的日志中出现了这些
2021-03-30 11:19:06 INFO brokerOutApi_thread_1 - register broker to name server rmqnamesrv:9876 OK
2021-03-30 11:19:36 INFO brokerOutApi_thread_2 - register broker to name server rmqnamesrv:9876 OK
说是注册成功了，是不是还有什么别的侦察方向，我试着Google了下别人的例子，结果并没有那么的理想。~

在namesrv容器中执行 sh mqadmin clusterList -n localhost:9876 看下集群信息，看看broker有没有注册上去
收发消息正常的嘛，可以通过运维命令来创建topic，group测试下。
也可以看下console里面的rocketmq-client.log

panzhi33 on 30 Mar 2021

报错，似乎没有注册上去。

[root@MiWiFi-RA69-srv conf]# docker exec -it 70504e6cea64 /bin/bash
[root@70504e6cea64 bin]# sh mqadmin clusterList -n localhost:9876
OpenJDK 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0
OpenJDK 64-Bit Server VM warning: ignoring option MaxPermSize=128m; support was removed in 8.0
org.apache.rocketmq.tools.command.SubCommandException: ClusterListSubCommand command failed
    at org.apache.rocketmq.tools.command.cluster.ClusterListSubCommand.execute(ClusterListSubCommand.java:93)
    at org.apache.rocketmq.tools.command.MQAdminStartup.main0(MQAdminStartup.java:135)
    at org.apache.rocketmq.tools.command.MQAdminStartup.main(MQAdminStartup.java:86)
Caused by: org.apache.rocketmq.acl.common.AclException: [10015:signature-failed] unable to calculate a request signature. error=[10015:signature-failed] unable to calculate a request signature. error=Algorithm HmacSHA1 not available
    at org.apache.rocketmq.acl.common.AclSigner.signAndBase64Encode(AclSigner.java:84)
    at org.apache.rocketmq.acl.common.AclSigner.calSignature(AclSigner.java:73)
    at org.apache.rocketmq.acl.common.AclSigner.calSignature(AclSigner.java:68)
    at org.apache.rocketmq.acl.common.AclUtils.calSignature(AclUtils.java:58)
    at org.apache.rocketmq.acl.common.AclClientRPCHook.doBeforeRequest(AclClientRPCHook.java:44)
    at org.apache.rocketmq.remoting.netty.NettyRemotingAbstract.doBeforeRpcHooks(NettyRemotingAbstract.java:172)
    at org.apache.rocketmq.remoting.netty.NettyRemotingClient.invokeSync(NettyRemotingClient.java:370)
    at org.apache.rocketmq.client.impl.MQClientAPIImpl.getBrokerClusterInfo(MQClientAPIImpl.java:1180)
    at org.apache.rocketmq.tools.admin.DefaultMQAdminExtImpl.examineBrokerClusterInfo(DefaultMQAdminExtImpl.java:275)
    at org.apache.rocketmq.tools.admin.DefaultMQAdminExt.examineBrokerClusterInfo(DefaultMQAdminExt.java:222)
    at org.apache.rocketmq.tools.command.cluster.ClusterListSubCommand.printClusterBaseInfo(ClusterListSubCommand.java:172)
    at org.apache.rocketmq.tools.command.cluster.ClusterListSubCommand.execute(ClusterListSubCommand.java:88)
    ... 2 more
Caused by: org.apache.rocketmq.acl.common.AclException: [10015:signature-failed] unable to calculate a request signature. error=Algorithm HmacSHA1 not available
    at org.apache.rocketmq.acl.common.AclSigner.sign(AclSigner.java:63)
    at org.apache.rocketmq.acl.common.AclSigner.signAndBase64Encode(AclSigner.java:79)
    ... 13 more
Caused by: java.security.NoSuchAlgorithmException: Algorithm HmacSHA1 not available
    at javax.crypto.Mac.getInstance(Mac.java:181)
    at org.apache.rocketmq.acl.common.AclSigner.sign(AclSigner.java:57)
    ... 14 more

收发不正常的，控制台没有结果根本会报错不知道投放到哪个broker

这时候是不是可以确定一些问题，抱歉对rocketmq的运维了解较少，还望指导！

a2501521908 on 30 Mar 2021

error=Algorithm HmacSHA1 not available

这个命令执行不了不是没有注册上去，可以看下这个文档修复下 https://blog.csdn.net/l18637220680/article/details/95379498
console容器里面的rocketmq-client.log有什么异常信息嘛

panzhi33 on 30 Mar 2021

这么说是我没有JDK的原因是吗这个机子，我看看这个怎么研究下指向，的确是宿主机没有安装jdk想着镜像中存在了就没必要了安装了个docker就开始了

有报错的，是这个，无法连接的错误

java.lang.RuntimeException: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.31.246:10911> failed
    at com.google.common.base.Throwables.propagate(Throwables.java:160)
    at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:219)
    at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:218)
    at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:218)
    at org.apache.rocketmq.console.task.DashboardCollectTask.collectBroker(DashboardCollectTask.java:184)
    at org.apache.rocketmq.console.task.DashboardCollectTask$$FastClassBySpringCGLIB$$c818b8cd.invoke(<generated>)
    at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204)
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:721)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)
    at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
    at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:656)
    at org.apache.rocketmq.console.task.DashboardCollectTask$$EnhancerBySpringCGLIB$$9a10db13.collectBroker(<generated>)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.springframework.scheduling.support.ScheduledMethodRunnable.run(ScheduledMethodRunnable.java:65)
    at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)
    at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:81)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)

请问我使用的是官方的镜像吗？因为这样的话还得每次都挂载一个jdk的目录进去是否是很鸡肋？

a2501521908 on 30 Mar 2021

这么说是我没有JDK的原因是吗这个机子，我看看这个怎么研究下指向，的确是宿主机没有安装jdk想着镜像中存在了就没必要了安装了个docker就开始了

有报错的，是这个，无法连接的错误

java.lang.RuntimeException: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.31.246:10911> failed
  at com.google.common.base.Throwables.propagate(Throwables.java:160)
  at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:219)
  at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:218)
  at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:218)
  at org.apache.rocketmq.console.task.DashboardCollectTask.collectBroker(DashboardCollectTask.java:184)
  at org.apache.rocketmq.console.task.DashboardCollectTask$$FastClassBySpringCGLIB$$c818b8cd.invoke(<generated>)
  at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204)
  at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:721)
  at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)
  at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92)
  at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
  at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:656)
  at org.apache.rocketmq.console.task.DashboardCollectTask$$EnhancerBySpringCGLIB$$9a10db13.collectBroker(<generated>)
  at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  at java.lang.reflect.Method.invoke(Method.java:498)
  at org.springframework.scheduling.support.ScheduledMethodRunnable.run(ScheduledMethodRunnable.java:65)
  at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)
  at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:81)
  at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  at java.util.concurrent.FutureTask.run(FutureTask.java:266)
  at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
  at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
  at java.lang.Thread.run(Thread.java:745)

请问我使用的是官方的镜像吗？因为这样的话还得每次都挂载一个jdk的目录进去是否是很鸡肋？

rocketmqinc/rocketmq 这个是官方的镜像的

panzhi33 on 30 Mar 2021

这么说是我没有JDK的原因是吗这个机子，我看看这个怎么研究下指向，的确是宿主机没有安装jdk想着镜像中存在了就没必要了安装了个docker就开始了
有报错的，是这个，无法连接的错误

java.lang.RuntimeException: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.31.246:10911> failed
    at com.google.common.base.Throwables.propagate(Throwables.java:160)
    at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:219)
    at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:218)
    at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:218)
    at org.apache.rocketmq.console.task.DashboardCollectTask.collectBroker(DashboardCollectTask.java:184)
    at org.apache.rocketmq.console.task.DashboardCollectTask$$FastClassBySpringCGLIB$$c818b8cd.invoke(<generated>)
    at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204)
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:721)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)
    at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
    at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:656)
    at org.apache.rocketmq.console.task.DashboardCollectTask$$EnhancerBySpringCGLIB$$9a10db13.collectBroker(<generated>)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.springframework.scheduling.support.ScheduledMethodRunnable.run(ScheduledMethodRunnable.java:65)
    at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)
    at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:81)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)

请问我使用的是官方的镜像吗？因为这样的话还得每次都挂载一个jdk的目录进去是否是很鸡肋？

rocketmqinc/rocketmq 这个是官方的镜像的

好的，我使用的就是这个镜像

那请问我必须按照这种的去给docker的容器中cp一份jar文件是吗，我看到了别人的解决方式是: https://blog.csdn.net/qq_18855485/article/details/99647626

这样的方式在容器删除掉或者别的机制后，岂不是得在脑子里记着给容器中cp一份，还是推荐使用物理机来管理，而不是容器~

a2501521908 on 30 Mar 2021

java.lang.RuntimeException: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.31.246:10911> failed
  at com.google.common.base.Throwables.propagate(Throwables.java:160)
  at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:219)
  at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:218)
  at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:218)
  at org.apache.rocketmq.console.task.DashboardCollectTask.collectBroker(DashboardCollectTask.java:184)
  at org.apache.rocketmq.console.task.DashboardCollectTask$$FastClassBySpringCGLIB$$c818b8cd.invoke(<generated>)
  at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204)
  at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:721)
  at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)
  at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92)
  at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
  at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:656)
  at org.apache.rocketmq.console.task.DashboardCollectTask$$EnhancerBySpringCGLIB$$9a10db13.collectBroker(<generated>)
  at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  at java.lang.reflect.Method.invoke(Method.java:498)
  at org.springframework.scheduling.support.ScheduledMethodRunnable.run(ScheduledMethodRunnable.java:65)
  at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)
  at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:81)
  at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  at java.util.concurrent.FutureTask.run(FutureTask.java:266)
  at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
  at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
  at java.lang.Thread.run(Thread.java:745)

请问我使用的是官方的镜像吗？因为这样的话还得每次都挂载一个jdk的目录进去是否是很鸡肋？

rocketmqinc/rocketmq 这个是官方的镜像的

好的，我使用的就是这个镜像

那请问我必须按照这种的去给docker的容器中cp一份jar文件是吗，我看到了别人的解决方式是: https://blog.csdn.net/qq_18855485/article/details/99647626

这样的方式在容器删除掉或者别的机制后，岂不是得在脑子里记着给容器中cp一份，还是推荐使用物理机来管理，而不是容器~

当前是没有办法，也可以直接在容器里面改脚本，然后重启容器。可以在issue里面搜下，已经有提pr改过了。你现在docker镜像里面部署的rocketmq版本可能比较低，没有修复这个问题

panzhi33 on 30 Mar 2021

java.lang.RuntimeException: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.31.246:10911> failed
    at com.google.common.base.Throwables.propagate(Throwables.java:160)
    at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:219)
    at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:218)
    at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:218)
    at org.apache.rocketmq.console.task.DashboardCollectTask.collectBroker(DashboardCollectTask.java:184)
    at org.apache.rocketmq.console.task.DashboardCollectTask$$FastClassBySpringCGLIB$$c818b8cd.invoke(<generated>)
    at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204)
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:721)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)
    at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
    at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:656)
    at org.apache.rocketmq.console.task.DashboardCollectTask$$EnhancerBySpringCGLIB$$9a10db13.collectBroker(<generated>)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.springframework.scheduling.support.ScheduledMethodRunnable.run(ScheduledMethodRunnable.java:65)
    at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)
    at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:81)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)

请问我使用的是官方的镜像吗？因为这样的话还得每次都挂载一个jdk的目录进去是否是很鸡肋？

rocketmqinc/rocketmq 这个是官方的镜像的

好的，我使用的就是这个镜像
那请问我必须按照这种的去给docker的容器中cp一份jar文件是吗，我看到了别人的解决方式是: https://blog.csdn.net/qq_18855485/article/details/99647626
这样的方式在容器删除掉或者别的机制后，岂不是得在脑子里记着给容器中cp一份，还是推荐使用物理机来管理，而不是容器~

啊？请问我docker默认没有敲定版本号，不是应该就是last版本吗？咦，是还有别的镜像源吗

a2501521908 on 30 Mar 2021

java.lang.RuntimeException: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.31.246:10911> failed
  at com.google.common.base.Throwables.propagate(Throwables.java:160)
  at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:219)
  at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:218)
  at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:218)
  at org.apache.rocketmq.console.task.DashboardCollectTask.collectBroker(DashboardCollectTask.java:184)
  at org.apache.rocketmq.console.task.DashboardCollectTask$$FastClassBySpringCGLIB$$c818b8cd.invoke(<generated>)
  at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204)
  at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:721)
  at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)
  at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92)
  at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
  at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:656)
  at org.apache.rocketmq.console.task.DashboardCollectTask$$EnhancerBySpringCGLIB$$9a10db13.collectBroker(<generated>)
  at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  at java.lang.reflect.Method.invoke(Method.java:498)
  at org.springframework.scheduling.support.ScheduledMethodRunnable.run(ScheduledMethodRunnable.java:65)
  at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)
  at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:81)
  at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  at java.util.concurrent.FutureTask.run(FutureTask.java:266)
  at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
  at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
  at java.lang.Thread.run(Thread.java:745)

请问我使用的是官方的镜像吗？因为这样的话还得每次都挂载一个jdk的目录进去是否是很鸡肋？

rocketmqinc/rocketmq 这个是官方的镜像的

啊？请问我docker默认没有敲定版本号，不是应该就是last版本吗？咦，是还有别的镜像源吗

可以去namesrv或者broker容器里面，lib下面看下jar包版本

panzhi33 on 30 Mar 2021

这么说是我没有JDK的原因是吗这个机子，我看看这个怎么研究下指向，的确是宿主机没有安装jdk想着镜像中存在了就没必要了安装了个docker就开始了
有报错的，是这个，无法连接的错误
java.lang.RuntimeException: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.31.246:10911> failed
    at com.google.common.base.Throwables.propagate(Throwables.java:160)
    at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:219)
    at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:218)
    at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:218)
    at org.apache.rocketmq.console.task.DashboardCollectTask.collectBroker(DashboardCollectTask.java:184)
    at org.apache.rocketmq.console.task.DashboardCollectTask$$FastClassBySpringCGLIB$$c818b8cd.invoke(<generated>)
    at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204)
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:721)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)
    at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
    at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:656)
    at org.apache.rocketmq.console.task.DashboardCollectTask$$EnhancerBySpringCGLIB$$9a10db13.collectBroker(<generated>)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.springframework.scheduling.support.ScheduledMethodRunnable.run(ScheduledMethodRunnable.java:65)
    at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)
    at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:81)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)
请问我使用的是官方的镜像吗？因为这样的话还得每次都挂载一个jdk的目录进去是否是很鸡肋？
rocketmqinc/rocketmq 这个是官方的镜像的
好的，我使用的就是这个镜像
那请问我必须按照这种的去给docker的容器中cp一份jar文件是吗，我看到了别人的解决方式是: https://blog.csdn.net/qq_18855485/article/details/99647626
这样的方式在容器删除掉或者别的机制后，岂不是得在脑子里记着给容器中cp一份，还是推荐使用物理机来管理，而不是容器~
当前是没有办法，也可以直接在容器里面改脚本，然后重启容器。可以在issue里面搜下，已经有提pr改过了。你现在docker镜像里面部署的rocketmq版本可能比较低，没有修复这个问题
啊？请问我docker默认没有敲定版本号，不是应该就是last版本吗？咦，是还有别的镜像源吗
可以去namesrv或者broker容器里面，lib下面看下jar包版本

jar文件均为4.4.0版本

a2501521908 on 30 Mar 2021

这么说是我没有JDK的原因是吗这个机子，我看看这个怎么研究下指向，的确是宿主机没有安装jdk想着镜像中存在了就没必要了安装了个docker就开始了
有报错的，是这个，无法连接的错误
java.lang.RuntimeException: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.31.246:10911> failed
  at com.google.common.base.Throwables.propagate(Throwables.java:160)
  at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:219)
  at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:218)
  at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:218)
  at org.apache.rocketmq.console.task.DashboardCollectTask.collectBroker(DashboardCollectTask.java:184)
  at org.apache.rocketmq.console.task.DashboardCollectTask$$FastClassBySpringCGLIB$$c818b8cd.invoke(<generated>)
  at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204)
  at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:721)
  at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)
  at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92)
  at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
  at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:656)
  at org.apache.rocketmq.console.task.DashboardCollectTask$$EnhancerBySpringCGLIB$$9a10db13.collectBroker(<generated>)
  at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  at java.lang.reflect.Method.invoke(Method.java:498)
  at org.springframework.scheduling.support.ScheduledMethodRunnable.run(ScheduledMethodRunnable.java:65)
  at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)
  at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:81)
  at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  at java.util.concurrent.FutureTask.run(FutureTask.java:266)
  at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
  at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
  at java.lang.Thread.run(Thread.java:745)
请问我使用的是官方的镜像吗？因为这样的话还得每次都挂载一个jdk的目录进去是否是很鸡肋？
rocketmqinc/rocketmq 这个是官方的镜像的
好的，我使用的就是这个镜像
那请问我必须按照这种的去给docker的容器中cp一份jar文件是吗，我看到了别人的解决方式是: https://blog.csdn.net/qq_18855485/article/details/99647626
这样的方式在容器删除掉或者别的机制后，岂不是得在脑子里记着给容器中cp一份，还是推荐使用物理机来管理，而不是容器~
当前是没有办法，也可以直接在容器里面改脚本，然后重启容器。可以在issue里面搜下，已经有提pr改过了。你现在docker镜像里面部署的rocketmq版本可能比较低，没有修复这个问题
啊？请问我docker默认没有敲定版本号，不是应该就是last版本吗？咦，是还有别的镜像源吗
可以去namesrv或者broker容器里面，lib下面看下jar包版本
jar文件均为4.4.0版本

这个版本比较老了

panzhi33 on 30 Mar 2021

这么说是我没有JDK的原因是吗这个机子，我看看这个怎么研究下指向，的确是宿主机没有安装jdk想着镜像中存在了就没必要了安装了个docker就开始了
有报错的，是这个，无法连接的错误
java.lang.RuntimeException: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.31.246:10911> failed
    at com.google.common.base.Throwables.propagate(Throwables.java:160)
    at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:219)
    at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:218)
    at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:218)
    at org.apache.rocketmq.console.task.DashboardCollectTask.collectBroker(DashboardCollectTask.java:184)
    at org.apache.rocketmq.console.task.DashboardCollectTask$$FastClassBySpringCGLIB$$c818b8cd.invoke(<generated>)
    at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204)
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:721)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)
    at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
    at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:656)
    at org.apache.rocketmq.console.task.DashboardCollectTask$$EnhancerBySpringCGLIB$$9a10db13.collectBroker(<generated>)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.springframework.scheduling.support.ScheduledMethodRunnable.run(ScheduledMethodRunnable.java:65)
    at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)
    at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:81)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)
请问我使用的是官方的镜像吗？因为这样的话还得每次都挂载一个jdk的目录进去是否是很鸡肋？
rocketmqinc/rocketmq 这个是官方的镜像的
好的，我使用的就是这个镜像
那请问我必须按照这种的去给docker的容器中cp一份jar文件是吗，我看到了别人的解决方式是: https://blog.csdn.net/qq_18855485/article/details/99647626
这样的方式在容器删除掉或者别的机制后，岂不是得在脑子里记着给容器中cp一份，还是推荐使用物理机来管理，而不是容器~
当前是没有办法，也可以直接在容器里面改脚本，然后重启容器。可以在issue里面搜下，已经有提pr改过了。你现在docker镜像里面部署的rocketmq版本可能比较低，没有修复这个问题
啊？请问我docker默认没有敲定版本号，不是应该就是last版本吗？咦，是还有别的镜像源吗
可以去namesrv或者broker容器里面，lib下面看下jar包版本
jar文件均为4.4.0版本
这个版本比较老了

那应该怎么去操作，毕竟现在docker的镜像版本是last了已经，是等待重新发包吗？

a2501521908 on 30 Mar 2021

这么说是我没有JDK的原因是吗这个机子，我看看这个怎么研究下指向，的确是宿主机没有安装jdk想着镜像中存在了就没必要了安装了个docker就开始了
有报错的，是这个，无法连接的错误
java.lang.RuntimeException: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.31.246:10911> failed
  at com.google.common.base.Throwables.propagate(Throwables.java:160)
  at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:219)
  at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:218)
  at org.apache.rocketmq.console.task.DashboardCollectTask.fetchBrokerRuntimeStats(DashboardCollectTask.java:218)
  at org.apache.rocketmq.console.task.DashboardCollectTask.collectBroker(DashboardCollectTask.java:184)
  at org.apache.rocketmq.console.task.DashboardCollectTask$$FastClassBySpringCGLIB$$c818b8cd.invoke(<generated>)
  at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204)
  at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:721)
  at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)
  at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92)
  at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
  at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:656)
  at org.apache.rocketmq.console.task.DashboardCollectTask$$EnhancerBySpringCGLIB$$9a10db13.collectBroker(<generated>)
  at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  at java.lang.reflect.Method.invoke(Method.java:498)
  at org.springframework.scheduling.support.ScheduledMethodRunnable.run(ScheduledMethodRunnable.java:65)
  at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)
  at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:81)
  at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  at java.util.concurrent.FutureTask.run(FutureTask.java:266)
  at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
  at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
  at java.lang.Thread.run(Thread.java:745)
请问我使用的是官方的镜像吗？因为这样的话还得每次都挂载一个jdk的目录进去是否是很鸡肋？
rocketmqinc/rocketmq 这个是官方的镜像的
好的，我使用的就是这个镜像
那请问我必须按照这种的去给docker的容器中cp一份jar文件是吗，我看到了别人的解决方式是: https://blog.csdn.net/qq_18855485/article/details/99647626
这样的方式在容器删除掉或者别的机制后，岂不是得在脑子里记着给容器中cp一份，还是推荐使用物理机来管理，而不是容器~
当前是没有办法，也可以直接在容器里面改脚本，然后重启容器。可以在issue里面搜下，已经有提pr改过了。你现在docker镜像里面部署的rocketmq版本可能比较低，没有修复这个问题
啊？请问我docker默认没有敲定版本号，不是应该就是last版本吗？咦，是还有别的镜像源吗
可以去namesrv或者broker容器里面，lib下面看下jar包版本
jar文件均为4.4.0版本
这个版本比较老了
那应该怎么去操作，毕竟现在docker的镜像版本是last了已经，是等待重新发包吗？

https://github.com/apache/rocketmq-docker 看下这个文档，使用4.8.0

panzhi33 on 30 Mar 2021

❤1 👍1

我在dockerHub中未发现4.8.0版本的镜像
https://hub.docker.com/r/apacherocketmq/rocketmq/tags?page=1&ordering=last_updated
我使用了4.6.0，但是似乎还是未解决问题

version: '3.5'
services:
  rmqnamesrv:
    image: apacherocketmq/rocketmq:4.6.0
    container_name: rmqnamesrv
    restart: always
    ports:
      - 9876:9876
    environment:
      #内存分配
      JAVA_OPT_EXT: "-server -Xms1g -Xmx1g"
    volumes:
      - /home/rocketmq/namesrv/logs:/root/logs
    command: sh mqnamesrv
    networks:
      rmq:
        aliases:
          - rmqnamesrv

  rmqbroker:
    image: apacherocketmq/rocketmq:4.6.0
    container_name: rmqbroker
    restart: always
    depends_on:
      - rmqnamesrv
    ports:
      - 10909:10909
      - 10911:10911
      - 10912:10912
    volumes:
      - /home/rocketmq/broker/logs:/root/logs
      - /home/rocketmq/broker/store:/root/store
      - /home/rocketmq/broker/conf/broker.conf:/home/rocketmq/rocketmq-4.8.0/conf/broker.conf
    command: sh mqbroker -n rmqnamesrv:9876 -c ../conf/broker.conf
    environment:
      NAMESRV_ADDR: "rmqnamesrv:9876"
      JAVA_OPT_EXT: "-server -Xms1g -Xmx1g -Xmn1g"
    networks:
      rmq:
        aliases:
          - rmqbroker

  rmqconsole:
    image: styletang/rocketmq-console-ng
    container_name: rocketmq-console
    restart: always
    ports:
      - 9877:8080
    depends_on:
      - rmqnamesrv
    volumes:
      - /etc/localtime:/etc/localtime:ro
      - /home/rocketmq/console/logs:/root/logs
    environment:
      JAVA_OPTS: "-Drocketmq.namesrv.addr=rmqnamesrv:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false"
    networks:
      rmq:
        aliases:
          - rmqconsole
networks:
  rmq:
    name: rmq
    driver: bridge

a2501521908 on 30 Mar 2021

我在dockerHub中未发现4.8.0版本的镜像
https://hub.docker.com/r/apacherocketmq/rocketmq/tags?page=1&ordering=last_updated
我使用了4.6.0，但是似乎还是未解决问题

version: '3.5'
services:
  rmqnamesrv:
    image: apacherocketmq/rocketmq:4.6.0
    container_name: rmqnamesrv
    restart: always
    ports:
      - 9876:9876
    environment:
      #内存分配
      JAVA_OPT_EXT: "-server -Xms1g -Xmx1g"
    volumes:
      - /home/rocketmq/namesrv/logs:/root/logs
    command: sh mqnamesrv
    networks:
      rmq:
        aliases:
          - rmqnamesrv

  rmqbroker:
    image: apacherocketmq/rocketmq:4.6.0
    container_name: rmqbroker
    restart: always
    depends_on:
      - rmqnamesrv
    ports:
      - 10909:10909
      - 10911:10911
      - 10912:10912
    volumes:
      - /home/rocketmq/broker/logs:/root/logs
      - /home/rocketmq/broker/store:/root/store
      - /home/rocketmq/broker/conf/broker.conf:/home/rocketmq/rocketmq-4.8.0/conf/broker.conf
    command: sh mqbroker -n rmqnamesrv:9876 -c ../conf/broker.conf
    environment:
      NAMESRV_ADDR: "rmqnamesrv:9876"
      JAVA_OPT_EXT: "-server -Xms1g -Xmx1g -Xmn1g"
    networks:
      rmq:
        aliases:
          - rmqbroker

  rmqconsole:
    image: styletang/rocketmq-console-ng
    container_name: rocketmq-console
    restart: always
    ports:
      - 9877:8080
    depends_on:
      - rmqnamesrv
    volumes:
      - /etc/localtime:/etc/localtime:ro
      - /home/rocketmq/console/logs:/root/logs
    environment:
      JAVA_OPTS: "-Drocketmq.namesrv.addr=rmqnamesrv:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false"
    networks:
      rmq:
        aliases:
          - rmqconsole
networks:
  rmq:
    name: rmq
    driver: bridge

是哪个命令的问题还是超时的问题呀

panzhi33 on 30 Mar 2021

检查到问题了，换了镜像之后现在通了，是这句yml配置:

  rmqbroker:
    image: apacherocketmq/rocketmq:4.6.0
    container_name: rmqbroker
    restart: always
    depends_on:
      - rmqnamesrv
    ports:
      - 10909:10909
      - 10911:10911
      - 10912:10912
    volumes:
      - /home/rocketmq/broker/logs:/root/logs
      - /home/rocketmq/broker/store:/root/store
      - /home/rocketmq/broker/conf/broker.conf:/home/rocketmq/rocketmq-4.8.0/conf/broker.conf
    command: sh mqbroker -n rmqnamesrv:9876 -c ../conf/broker.conf

因为那时候发现官方并没有4.8.0的镜像，但是我容器配置文件内指向的还是4.8.0 /home/rocketmq/rocketmq-4.8.0/conf/broker.conf，所以配置文件肯定找不到容器内，就会报错

现在更换了绝对路径为4.6.0之后可以跑通了！ /home/rocketmq/rocketmq-4.6.0/conf/broker.conf

其他的都是没问题的，就是更新了下官方的镜像就解决了问题了

感谢感谢，晚上回去总结一下！！

a2501521908 on 30 Mar 2021

Was this page helpful?

0 / 5 - 0 ratings