[I] Expected the service ProducerImpl-0 [FAILED] to be RUNNING, but the service has FAILED [rocketmq-clients]

[via GitHub]

jieefeng opened a new issue, #933:
URL: https://github.com/apache/rocketmq-clients/issues/933

   ### Before Creating the Bug Report
   
   - [x] I found a bug, not just asking a question, which should be created in 
[GitHub Discussions](https://github.com/apache/rocketmq-clients/discussions).
   
   - [x] I have searched the [GitHub 
Issues](https://github.com/apache/rocketmq-clients/issues) and [GitHub 
Discussions](https://github.com/apache/rocketmq-clients/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.
   
   
   ### Programming Language of the Client
   
   Java
   
   ### Runtime Platform Environment
   
   jdk8
   1.代码部分
   public class ProducerExample {
   
       public static void main(String[] args) throws ClientException {
           // 接入点地址，需要设置成Proxy的地址和端口列表，一般是xxx:8080;xxx:8081
           // 此处为示例，实际使用时请替换为真实的 Proxy 地址和端口
           String endpoint = "192.168.80.131:5081";
           // 消息发送的目标Topic名称，需要提前创建。
           String topic = "pmhub_local";
           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("messageBody".getBytes())
                   .build();
           try {
               // 发送消息，需要关注发送结果，并捕获失败等异常。
               SendReceipt sendReceipt = producer.send(message);
               System.out.println(sendReceipt.getMessageId());
           } catch (ClientException e) {
               System.out.println(e);
           }
           // producer.close();
       }
   }
   2.报错部分
   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:24)
   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)
   
   进程已结束，退出代码为 1
   
   
   
   
   ### RocketMQ Version of the Client/Server
   
   3.服务端为Rocketmq5.1.0  
   4.客户端
       <dependencies>
           <dependency>
               <groupId>org.apache.rocketmq</groupId>
               <artifactId>rocketmq-client-java</artifactId>
               <version>5.0.7</version>
           </dependency>
       </dependencies>
   
   
   ### Run or Compiler Version
   
   _No response_
   
   ### Describe the Bug
   
   
5.Rocketmq-dashboard能正确连接到rmq服务端，但是Java客户端5.0.x不行，并且如果服务端是rmq'4.x版本我能正确连接到服务端。
   
   ### Steps to Reproduce
   
   我是按照rmq官网5.0的版本来进行实验的
   
   ### What Did You Expect to See?
   
   我想要解决这个问题的方法
   
   ### What Did You See Instead?
   
   我想要解决这个问题的方法
   
   ### Additional Context
   
   _No response_


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org