qingchunchencheng
commented
1 month ago version: '3.9' networks: dmp: name: dmp driver: bridge services: rmqnamesrv: image: apache/rocketmq:5.2.0 container_name: rmqnamesrv ports:
- 9876:9876 volumes:
-
/imedical/rocketmq/nameserver/logs:/home/rocketmq/logs restart: always environment: TZ: Asia/Shanghai JAVA_OPT_EXT: "-server -Xms128m -Xmx128m -Xmn128m" privileged: true command: sh mqnamesrv -n 192.168.182.110:9876 networks: dmp: aliases:
- rmqnamesrv
rmqbroker: image: apache/rocketmq:5.2.0 container_name: rmqbroker ports:
- 10911:10911
- 10912:10912
- 10909:10909
- 28087:8080
- 28088:8081 volumes:
- /imedical/rocketmq/broker/logs:/home/rocketmq/logs
- /imedical/rocketmq/broker/store:/home/rocketmq/store
-
/imedical/rocketmq/broker/conf:/home/rocketmq/conf restart: always environment: TZ: Asia/Shanghai JAVA_OPT_EXT: "-server -Xms256m -Xmx256m -Xmn256m" privileged: true command: sh mqbroker -c /home/rocketmq/conf/broker.conf --enable-proxy -pc /home/rocketmq/conf/rmq-proxy.json networks: dmp: aliases:
- rmqbroker
rmqdashboard: image: apacherocketmq/rocketmq-dashboard container_name: rocketmq-dashboard ports:
- 9101:8080
restart: always
environment:
TZ: Asia/Shanghai
JAVA_OPTS: -Drocketmq.namesrv.addr=192.168.182.110:9876
privileged: true
networks:
dmp:
aliases:
- rmqdashboard
answeropensource
leizhiyuan
Before Creating the Bug Report
[X] I found a bug, not just asking a question, which should be created in GitHub Discussions.
[X] I have searched the GitHub Issues and GitHub Discussions of this repository and believe that this is not a duplicate.
[X] I have confirmed that this bug belongs to the current repository, not other repositories of RocketMQ.
Runtime platform environment
centos，docker
RocketMQ version
5.1.4|5.2.0
JDK Version
jdk1.8
Describe the Bug
生产消息时报错 Exception in thread "main" java.lang.IllegalStateException: Expected the service ProducerImpl-0 [FAILED] to be RUNNING, but the service has FAILED at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractService.checkCurrentState(AbstractService.java:381) at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractService.awaitRunning(AbstractService.java:305) at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractIdleService.awaitRunning(AbstractIdleService.java:165) at org.apache.rocketmq.client.java.impl.producer.ProducerBuilderImpl.build(ProducerBuilderImpl.java:93) at ProducerExample.main(ProducerExample.java:31) Caused by: java.util.concurrent.CancellationException: Task was cancelled. at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractFuture.cancellationExceptionWithCause(AbstractFuture.java:1543) at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:586) at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:567) at org.apache.rocketmq.shaded.com.google.common.util.concurrent.FluentFuture$TrustedFuture.get(FluentFuture.java:91) at org.apache.rocketmq.client.java.impl.ClientImpl.startUp(ClientImpl.java:188) at org.apache.rocketmq.client.java.impl.producer.ProducerImpl.startUp(ProducerImpl.java:114) at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractIdleService$DelegateService$1.run(AbstractIdleService.java:62) at org.apache.rocketmq.shaded.com.google.common.util.concurrent.Callables.lambda$threadRenaming$3(Callables.java:103) at java.lang.Thread.run(Thread.java:750)
Steps to Reproduce
import org.apache.rocketmq.client.apis.ClientConfiguration; import org.apache.rocketmq.client.apis.ClientConfigurationBuilder; import org.apache.rocketmq.client.apis.ClientException; import org.apache.rocketmq.client.apis.ClientServiceProvider; import org.apache.rocketmq.client.apis.message.Message; import org.apache.rocketmq.client.apis.producer.Producer; import org.apache.rocketmq.client.apis.producer.SendReceipt; import org.slf4j.Logger; import org.slf4j.LoggerFactory;
import java.io.IOException;
public class ProducerExample {
// String endpoint = "192.168.182.110:50001"; String endpoint = "192.168.182.110:28087"; // 消息发送的目标Topic名称，需要提前创建。 // String topic = "TestTopic"; String topic = "test"; ClientServiceProvider provider = ClientServiceProvider.loadService(); ClientConfigurationBuilder builder = ClientConfiguration.newBuilder().setEndpoints(endpoint); ClientConfiguration configuration = builder.build(); // 初始化Producer时需要设置通信配置以及预绑定的Topic。 Producer producer = provider.newProducerBuilder() .setTopics(topic) .setClientConfiguration(configuration) .build(); // 普通消息发送。 Message message = provider.newMessageBuilder() .setTopic(topic) // 设置消息索引键，可根据关键字精确查找某条消息。 .setKeys("messageKey") // 设置消息Tag，用于消费端根据指定Tag过滤消息。 .setTag("messageTag") // 消息体。 .setBody("messageBody1".getBytes()) .build(); try { System.out.println("开始发送"); // 发送消息，需要关注发送结果，并捕获失败等异常。 SendReceipt sendReceipt = producer.send(message); System.out.println("发送成功"); log.info("Send message successfully, messageId={}", sendReceipt.getMessageId()); } catch (ClientException e) { System.out.println("失败"); log.error("Failed to send message", e); } //producer.close(); } }
What Did You Expect to See?
正常能发送消息
What Did You See Instead?
报错如上
Additional Context
local模式和cluster模式都测试过，均有问题