下边是我的配置文件,启动日志没有发现启动定时消息的log,有大佬帮忙看一下吗
broker.conf
brokerName=broker-a
brokerId=0
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH
listenPort=10911
brokerIP1=192.168.43.24
autoCreateTopicEnable=true
autoCreateSubscriptionGroup=true
enableScheduleMessage=true
messageDelayLevel=1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h
enableTimerWheel=true
timerWheelEnableCheckpoint=true
timerWheelCheckPointIntervalMs=1000
timerWheelSpan=86400000
timerWheelBucketCount=3600
timerWheelAsyncDelivery=true
deleteWhen=04
fileReservedTime=48
maxMessageSize=4194304
maxTransferBytesOnMessageInMemory=262144 # 256KB
maxTransferCountOnMessageInMemory=32
proxy.json
"namesrvAddr": "namesrv:9876",
"proxyMode": "CLUSTER",
"enableGrpcServer": true,
"enableHttpServer": true,
"grpcServerPort": 8081,
"httpServerPort": 8080,
"enableTimerWheel": true,
"enableDelayMessage": true,
"enableTransaction": true,
"enableAcl": false,
"autoCreateTopicEnable": true,
"proxyIp": "192.168.43.24",
"timerWheel": {
"maxPrecisionMs": 100,
"bucketCount": 3600,
"asyncDelivery": true,
"enableCheckpoint": true,
"checkPointIntervalMs": 1000
}
}
docker-compose.yml
version: '3.8'
services:
namesrv:
image: apache/rocketmq:5.3.3
container_name: rmq-namesrv
restart: always
ports:
"9876:9876"
environment:
TZ=Asia/Shanghai
JAVA_OPT_EXT=-server -Xms512m -Xmx512m -Xmn256m
volumes:
D:/docker/rocketmq/namesrv/logs:/home/rocketmq/logs
D:/docker/rocketmq/namesrv/store:/home/rocketmq/store
command: sh mqnamesrv
networks:
rocketmq-net
broker:
image: apache/rocketmq:5.3.3
container_name: rmq-broker
restart: always
depends_on:
namesrv
ports:
"10911:10911"
"10909:10909"
"10912:10912"
environment:
TZ=Asia/Shanghai
NAMESRV_ADDR=namesrv:9876
JAVA_OPT_EXT=-server -Xms512m -Xmx512m -Xmn256m
volumes:
D:/docker/rocketmq/broker/logs:/home/rocketmq/logs
D:/docker/rocketmq/broker/store:/home/rocketmq/store
D:/docker/rocketmq/broker/conf:/home/rocketmq/conf
command: sh mqbroker -n namesrv:9876 -c /home/rocketmq/conf/broker.conf
networks:
rocketmq-net
proxy:
image: apache/rocketmq:5.3.3
container_name: rmq-proxy
restart: always
depends_on:
namesrv
broker
ports:
"8081:8081"
environment:
TZ=Asia/Shanghai
NAMESRV_ADDR=namesrv:9876
JAVA_OPT_EXT=-server -Xms512m -Xmx512m -Xmn256m
volumes:
D:/docker/rocketmq/proxy/logs:/home/rocketmq/logs
D:/docker/rocketmq/proxy/store:/home/rocketmq/store
D:/docker/rocketmq/proxy/conf:/home/rocketmq/conf
command: sh mqproxy -n namesrv:9876 -pc /home/rocketmq/conf/proxy.json
networks:
rocketmq-net
dashboard:
image: apacherocketmq/rocketmq-dashboard:latest
container_name: rmq-dashboard
restart: always
depends_on:
namesrv
broker
ports:
"8088:8082"
environment:
TZ=Asia/Shanghai
JAVA_OPTS=-Drocketmq.namesrv.addr=192.168.43.24:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false
networks:
rocketmq-net
networks:
rocketmq-net:
driver: bridge
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系列产品 Serverless 化。RocketMQ 中文社区:https://rocketmq-learning.com/