[I] [Bug] docker部署5.2.0版本，开启proxy后，发送消息报错 [rocketmq]

[via GitHub]

qingchunchencheng opened a new issue, #8470:
URL: https://github.com/apache/rocketmq/issues/8470

   ### 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/discussions).
   
   - [X] I have searched the [GitHub 
Issues](https://github.com/apache/rocketmq/issues) and [GitHub 
Discussions](https://github.com/apache/rocketmq/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 {
   
       public static void main(String[] args) throws ClientException, 
IOException {
           // 接入点地址，需要设置成Proxy的地址和端口列表，一般是xxx:8080;xxx:8081。
   //        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模式都测试过，均有问题


-- 
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