You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by "zhouhaibing (via GitHub)" <gi...@apache.org> on 2025/07/30 02:14:17 UTC
[D] rocketmq 5.2.0 消费者无法消费消息 [rocketmq]
GitHub user zhouhaibing created a discussion: rocketmq 5.2.0 消费者无法消费消息
spring boot 版本 3.3
jdk版本 21
docker-compose部署文件
` command: sh mqnamesrv
broker:
image: apache/rocketmq:5.2.0
container_name: rmqbroker
ports:
- 10909:10909
- 10911:10911
- 10912:10912
volumes:
- /root/deploy/rocketmq/conf/broker.conf:/home/rocketmq/rocketmq-5.2.0/conf/broker.conf
environment:
- NAMESRV_ADDR=rmqnamesrv:9876
depends_on:
- namesrv
networks:
- rocketmq
command: sh mqbroker -c /home/rocketmq/rocketmq-5.2.0/conf/broker.conf
proxy:
image: apache/rocketmq:5.2.0
container_name: rmqproxy
networks:
- rocketmq
depends_on:
- broker
- namesrv
ports:
- 8181:8181
- 8182:8182
volumes:
- /root/deploy/rocketmq/conf/proxy/proxy.json:/home/rocketmq/rocketmq-5.2.0/conf/proxy.json
restart: on-failure
environment:
- NAMESRV_ADDR=rmqnamesrv:9876
command: sh mqproxy -pc /home/rocketmq/rocketmq-5.2.0/conf/proxy.json
rmqconsole:
image: apacherocketmq/rocketmq-dashboard
container_name: rmqconsole
ports:
- 8087:8087
#network_mode: "host"
#privileged: true
environment:
JAVA_OPTS: -Dserver.port=8087 -Drocketmq.namesrv.addr=192.168.1.130:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false -Drocketmq.config.accessKey=rocketmq2 -Drocketmq.config.secretKey=12345678
volumes:
- /docker/alibaba/rocketmq/console-ng/data:/tmp/rocketmq-console/data
network_mode: "host"
privileged: true
networks:
rocketmq:
driver: bridge
`
broker.conf文件
`listenPort=10911
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
namesrvAddr = 192.168.1.130:9876
brokerIP1 = 192.168.1.130
# 是否允许broker自动创建Topic
autoCreateTopicEnable=true
#是否允许broker自动创建订阅组
autoCreateSubscriptionGroup=true`
proxy.json文件
`{
"remotingListenPort":8181,
"grpcServerPort":8182
}
`
发送消息代码
`PatientInfoModifyMessage modifyMessage = new PatientInfoModifyMessage();
modifyMessage.setBaseId("1949751120993714177");
modifyMessage.setHospitalId(6);
modifyMessage.setDiseaseType("T");
SendReceipt sendReceipt = template.syncSendNormalMessage("PATIENT_INFO_MODIFY", JSON.toJSONString(modifyMessage));`
消费消息代码
`@RocketMQMessageListener(
topic = MqConstants.PATIENT_INFO_MODIFY_TOPIC,
consumerGroup = MqConstants.PATIENT_INFO_MODIFY_IM_WARN_GROUP
)`
rocketmq 配置
`rocketmq:
producer:
endpoints: 192.168.1.130:8182
topic:
push-consumer:
endpoints: 192.168.1.130:8182
access-key:
secret-key:
topic:
tag: "*"
request-timeout: 60`
经调试，发送消息到mq是没问题的，在dashboard里面是可以查看到消息的
但是就是消费不了消息，服务运行没有任何异常
![Uploading image.png…]()
GitHub link: https://github.com/apache/rocketmq/discussions/9582
----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@rocketmq.apache.org
Re: [D] rocketmq 5.2.0 消费者无法消费消息 [rocketmq]
Posted by "zhouhaibing (via GitHub)" <gi...@apache.org>.
GitHub user zhouhaibing edited a discussion: rocketmq 5.2.0 消费者无法消费消息
spring boot 版本 3.3
jdk版本 21
docker-compose部署文件
```
version: '3.8'
services:
namesrv:
image: apache/rocketmq:5.2.0
container_name: rmqnamesrv
ports:
- 9876:9876
networks:
- rocketmq
command: sh mqnamesrv
broker:
image: apache/rocketmq:5.2.0
container_name: rmqbroker
ports:
- 10909:10909
- 10911:10911
- 10912:10912
volumes:
- /root/deploy/rocketmq/conf/broker.conf:/home/rocketmq/rocketmq-5.2.0/conf/broker.conf
environment:
- NAMESRV_ADDR=rmqnamesrv:9876
depends_on:
- namesrv
networks:
- rocketmq
command: sh mqbroker -c /home/rocketmq/rocketmq-5.2.0/conf/broker.conf
proxy:
image: apache/rocketmq:5.2.0
container_name: rmqproxy
networks:
- rocketmq
depends_on:
- broker
- namesrv
ports:
- 8181:8181
- 8182:8182
volumes:
- /root/deploy/rocketmq/conf/proxy/proxy.json:/home/rocketmq/rocketmq-5.2.0/conf/proxy.json
restart: on-failure
environment:
- NAMESRV_ADDR=rmqnamesrv:9876
command: sh mqproxy -pc /home/rocketmq/rocketmq-5.2.0/conf/proxy.json
rmqconsole:
image: apacherocketmq/rocketmq-dashboard
container_name: rmqconsole
ports:
- 8087:8087
#network_mode: "host"
#privileged: true
environment:
JAVA_OPTS: -Dserver.port=8087 -Drocketmq.namesrv.addr=192.168.1.130:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false -Drocketmq.config.accessKey=rocketmq2 -Drocketmq.config.secretKey=12345678
volumes:
- /docker/alibaba/rocketmq/console-ng/data:/tmp/rocketmq-console/data
network_mode: "host"
privileged: true
networks:
rocketmq:
driver: bridge
```
broker.conf文件
```
listenPort=10911
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
namesrvAddr = 192.168.1.130:9876
brokerIP1 = 192.168.1.130
# 是否允许broker自动创建Topic
autoCreateTopicEnable=true
#是否允许broker自动创建订阅组
autoCreateSubscriptionGroup=true
```
proxy.json文件
```
{
"remotingListenPort":8181,
"grpcServerPort":8182
}
```
发送消息代码
```
PatientInfoModifyMessage modifyMessage = new PatientInfoModifyMessage();
modifyMessage.setBaseId("1949751120993714177");
modifyMessage.setHospitalId(6);
modifyMessage.setDiseaseType("T");
SendReceipt sendReceipt = template.syncSendNormalMessage("PATIENT_INFO_MODIFY", JSON.toJSONString(modifyMessage));
```
消费消息代码
```
@RocketMQMessageListener(
topic = MqConstants.PATIENT_INFO_MODIFY_TOPIC,
consumerGroup = MqConstants.PATIENT_INFO_MODIFY_IM_WARN_GROUP
)
```
rocketmq 配置
```
rocketmq:
producer:
endpoints: 192.168.1.130:8182
topic:
push-consumer:
endpoints: 192.168.1.130:8182
access-key:
secret-key:
topic:
tag: "*"
request-timeout: 60
```
经调试，发送消息到mq是没问题的，在dashboard里面是可以查看到消息的
但是就是消费不了消息，服务运行没有任何异常
![Uploading image.png…]()
GitHub link: https://github.com/apache/rocketmq/discussions/9582
----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@rocketmq.apache.org
Re: [D] rocketmq 5.2.0 消费者无法消费消息 [rocketmq]
Posted by "zhouhaibing (via GitHub)" <gi...@apache.org>.
GitHub user zhouhaibing added a comment to the discussion: rocketmq 5.2.0 消费者无法消费消息
已经解决，最根本的问题是，自己对消费者进行了封装，应该是有问题，改成最原始的方式，就可以了
GitHub link: https://github.com/apache/rocketmq/discussions/9582#discussioncomment-13929403
----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@rocketmq.apache.org
Re: [D] rocketmq 5.2.0 消费者无法消费消息 [rocketmq]
Posted by "zhouhaibing (via GitHub)" <gi...@apache.org>.
GitHub user zhouhaibing edited a discussion: rocketmq 5.2.0 消费者无法消费消息
spring boot 版本 3.3
jdk版本 21
docker-compose部署文件
```
version: '3.8'
services:
namesrv:
image: apache/rocketmq:5.2.0
container_name: rmqnamesrv
ports:
- 9876:9876
networks:
- rocketmq
command: sh mqnamesrv
broker:
image: apache/rocketmq:5.2.0
container_name: rmqbroker
ports:
- 10909:10909
- 10911:10911
- 10912:10912
volumes:
- /root/deploy/rocketmq/conf/broker.conf:/home/rocketmq/rocketmq-5.2.0/conf/broker.conf
environment:
- NAMESRV_ADDR=rmqnamesrv:9876
depends_on:
- namesrv
networks:
- rocketmq
command: sh mqbroker -c /home/rocketmq/rocketmq-5.2.0/conf/broker.conf
proxy:
image: apache/rocketmq:5.2.0
container_name: rmqproxy
networks:
- rocketmq
depends_on:
- broker
- namesrv
ports:
- 8181:8181
- 8182:8182
volumes:
- /root/deploy/rocketmq/conf/proxy/proxy.json:/home/rocketmq/rocketmq-5.2.0/conf/proxy.json
restart: on-failure
environment:
- NAMESRV_ADDR=rmqnamesrv:9876
command: sh mqproxy -pc /home/rocketmq/rocketmq-5.2.0/conf/proxy.json
rmqconsole:
image: apacherocketmq/rocketmq-dashboard
container_name: rmqconsole
ports:
- 8087:8087
#network_mode: "host"
#privileged: true
environment:
JAVA_OPTS: -Dserver.port=8087 -Drocketmq.namesrv.addr=192.168.1.130:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false -Drocketmq.config.accessKey=rocketmq2 -Drocketmq.config.secretKey=12345678
volumes:
- /docker/alibaba/rocketmq/console-ng/data:/tmp/rocketmq-console/data
network_mode: "host"
privileged: true
networks:
rocketmq:
driver: bridge
```
broker.conf文件
```
listenPort=10911
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
namesrvAddr = 192.168.1.130:9876
brokerIP1 = 192.168.1.130
# 是否允许broker自动创建Topic
autoCreateTopicEnable=true
#是否允许broker自动创建订阅组
autoCreateSubscriptionGroup=true
```
proxy.json文件
```
{
"remotingListenPort":8181,
"grpcServerPort":8182
}
```
发送消息代码
```
PatientInfoModifyMessage modifyMessage = new PatientInfoModifyMessage();
modifyMessage.setBaseId("1949751120993714177");
modifyMessage.setHospitalId(6);
modifyMessage.setDiseaseType("T");
SendReceipt sendReceipt = template.syncSendNormalMessage("PATIENT_INFO_MODIFY", JSON.toJSONString(modifyMessage));
```
消费消息代码
```
@RocketMQMessageListener(
topic = MqConstants.PATIENT_INFO_MODIFY_TOPIC,
consumerGroup = MqConstants.PATIENT_INFO_MODIFY_IM_WARN_GROUP
)
```
rocketmq 配置
```
rocketmq:
producer:
endpoints: 192.168.1.130:8182
topic:
push-consumer:
endpoints: 192.168.1.130:8182
access-key:
secret-key:
topic:
tag: "*"
request-timeout: 60
```
经调试，发送消息到mq是没问题的，在dashboard里面是可以查看到消息的
但是就是消费不了消息，服务运行没有任何异常
<img width="2515" height="456" alt="image" src="https://github.com/user-attachments/assets/f3680b15-3971-4fe5-bf2b-b93cacdb35e4" />
GitHub link: https://github.com/apache/rocketmq/discussions/9582
----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@rocketmq.apache.org
Re: [D] rocketmq 5.2.0 消费者无法消费消息 [rocketmq]
Posted by "zhouhaibing (via GitHub)" <gi...@apache.org>.
GitHub user zhouhaibing edited a discussion: rocketmq 5.2.0 消费者无法消费消息
spring boot 版本 3.3
jdk版本 21
docker-compose部署文件
```
version: '3.8'
services:
namesrv:
image: apache/rocketmq:5.2.0
container_name: rmqnamesrv
ports:
- 9876:9876
networks:
- rocketmq
command: sh mqnamesrv
broker:
image: apache/rocketmq:5.2.0
container_name: rmqbroker
ports:
- 10909:10909
- 10911:10911
- 10912:10912
volumes:
- /root/deploy/rocketmq/conf/broker.conf:/home/rocketmq/rocketmq-5.2.0/conf/broker.conf
environment:
- NAMESRV_ADDR=rmqnamesrv:9876
depends_on:
- namesrv
networks:
- rocketmq
command: sh mqbroker -c /home/rocketmq/rocketmq-5.2.0/conf/broker.conf
proxy:
image: apache/rocketmq:5.2.0
container_name: rmqproxy
networks:
- rocketmq
depends_on:
- broker
- namesrv
ports:
- 8181:8181
- 8182:8182
volumes:
- /root/deploy/rocketmq/conf/proxy/proxy.json:/home/rocketmq/rocketmq-5.2.0/conf/proxy.json
restart: on-failure
environment:
- NAMESRV_ADDR=rmqnamesrv:9876
command: sh mqproxy -pc /home/rocketmq/rocketmq-5.2.0/conf/proxy.json
rmqconsole:
image: apacherocketmq/rocketmq-dashboard
container_name: rmqconsole
ports:
- 8087:8087
#network_mode: "host"
#privileged: true
environment:
JAVA_OPTS: -Dserver.port=8087 -Drocketmq.namesrv.addr=192.168.1.130:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false -Drocketmq.config.accessKey=rocketmq2 -Drocketmq.config.secretKey=12345678
volumes:
- /docker/alibaba/rocketmq/console-ng/data:/tmp/rocketmq-console/data
network_mode: "host"
privileged: true
networks:
rocketmq:
driver: bridge
```
broker.conf文件
`listenPort=10911
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
namesrvAddr = 192.168.1.130:9876
brokerIP1 = 192.168.1.130
# 是否允许broker自动创建Topic
autoCreateTopicEnable=true
#是否允许broker自动创建订阅组
autoCreateSubscriptionGroup=true`
proxy.json文件
`{
"remotingListenPort":8181,
"grpcServerPort":8182
}
`
发送消息代码
`PatientInfoModifyMessage modifyMessage = new PatientInfoModifyMessage();
modifyMessage.setBaseId("1949751120993714177");
modifyMessage.setHospitalId(6);
modifyMessage.setDiseaseType("T");
SendReceipt sendReceipt = template.syncSendNormalMessage("PATIENT_INFO_MODIFY", JSON.toJSONString(modifyMessage));`
消费消息代码
`@RocketMQMessageListener(
topic = MqConstants.PATIENT_INFO_MODIFY_TOPIC,
consumerGroup = MqConstants.PATIENT_INFO_MODIFY_IM_WARN_GROUP
)`
rocketmq 配置
`rocketmq:
producer:
endpoints: 192.168.1.130:8182
topic:
push-consumer:
endpoints: 192.168.1.130:8182
access-key:
secret-key:
topic:
tag: "*"
request-timeout: 60`
经调试，发送消息到mq是没问题的，在dashboard里面是可以查看到消息的
但是就是消费不了消息，服务运行没有任何异常
![Uploading image.png…]()
GitHub link: https://github.com/apache/rocketmq/discussions/9582
----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@rocketmq.apache.org
Re: [D] rocketmq 5.2.0 消费者无法消费消息 [rocketmq]
Posted by "zhouhaibing (via GitHub)" <gi...@apache.org>.
GitHub user zhouhaibing edited a discussion: rocketmq 5.2.0 消费者无法消费消息
GitHub link: https://github.com/apache/rocketmq/discussions/9582
----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@rocketmq.apache.org