QuickStart Demo ERROR: Task was cancelled.

[HappyAxin]

@Slf4j
public class SyncProducer {

    public static void main(String[] args) {
        // 接入点地址，需要设置成Proxy的地址和端口列表，一般是xxx:8081;xxx:8081。
        String endpoint = "ip:8081";
        // 消息发送的目标Topic名称，需要提前创建。
        String topic = "TestTopic";
        ClientServiceProvider provider = ClientServiceProvider.loadService();
        ClientConfigurationBuilder builder = ClientConfiguration.newBuilder().setEndpoints(endpoint);
        ClientConfiguration configuration = builder.build();
        // 初始化Producer时需要设置通信配置以及预绑定的Topic。
        // 普通消息发送。
        try (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();
            // 发送消息，需要关注发送结果，并捕获失败等异常。
            SendReceipt sendReceipt = producer.send(message);
            log.info("Send message successfully, messageId={}", sendReceipt.getMessageId());
        } catch (ClientException | IOException e) {
            log.error("Failed to send message", e);
        }
    }
}

Exception

Connected to the target VM, address: '127.0.0.1:2291', transport: 'socket'
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 com.xmzn.common.mq.producer.SyncProducer.main(SyncProducer.java:35)
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.base/java.lang.Thread.run(Thread.java:1583)
Disconnected from the target VM, address: '127.0.0.1:2291', transport: 'socket'

[cctock]

我也遇到这个问题，想请问一下如何排查，是集群部署的问题？ rocketmq 相关日志看不到有用信息
rockermq 5.1.3 enable-proxy
rockermq-client-java 5.0.5

[HappyAxin]

说实话，我觉得是Bug，我按照官方案例跑也跑不起来，但是没人解决，像是个被遗弃的项目

[lvgitt]

一直没人解决，真是烂

[MmringZee]

我也遇到了这个问题，但我的情况是，和broker在同一个ip的项目可以正常运行，但是另一个机器ip上的项目就会报“Expected the service PushConsumerImpl-0 [FAILED] to be RUNNING, but the service has FAILED” 和 “Task was cancelled”

[MmringZee]

broker.conf里配置了brokerIP1和brokerIP2为这个broker所在的ip就行了，也不知道为啥 = =

[leizhiyuan]

多网卡的时候，这里给客户端返回的ip可能选错了。无法联通，也会抱着个错误

[iamcheeming]

proxy是不是开放了不同的端口？可以自定义proxy内的端口。
"remotingListenPort": 18080, "grpcServerPort": 18081
compose.yaml中
ports: - 18080:18080 - 18081:18081
然后再看看是不是解决了你的问题

[MmringZee]

proxy是不是开放了不同的端口？可以自定义proxy内的端口。 "remotingListenPort": 18080, "grpcServerPort": 18081 compose.yaml中 ports: - 18080:18080 - 18081:18081 然后再看看是不是解决了你的问题

虽然不是这个问题但谢谢了 , 是ip的问题 , 没有配brokerIP被k8s的多网卡干扰了.
不过之前我部署的时候没在官方文档找到很具体的同时指定conf和proxy.json的启动命令, 还是后来在一个博客搜到的 = =

[leizhiyuan]

1. 吧tls关掉看看
2. 可以提供一下服务端的日志。
3. sdk日志在~/logs/rocketmq/rocketmq-client.log，也可以发出来看看

[pxd98]

是不是因为你的broker在windows机器上跑的。
producer或者proxy发送消息的步骤简单可以分为两步，第一步是去nameserver获取这个topic的路由信息，第二步是往路由信息中拿到的broker地址直接发送。这个broker的地址在不设置的情况下是这里代码 (remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingUtil.java)实现的：

public static String getLocalAddress() {
        try {
            // Traversal Network interface to get the first non-loopback and non-private address
            Enumeration<NetworkInterface> enumeration = NetworkInterface.getNetworkInterfaces();
            ArrayList<String> ipv4Result = new ArrayList<String>();
            ArrayList<String> ipv6Result = new ArrayList<String>();
            while (enumeration.hasMoreElements()) {
                final NetworkInterface networkInterface = enumeration.nextElement();
                if (isBridge(networkInterface)) {
                    continue;
                }

                final Enumeration<InetAddress> en = networkInterface.getInetAddresses();
                while (en.hasMoreElements()) {
                    final InetAddress address = en.nextElement();
                    if (!address.isLoopbackAddress()) {
                        if (address instanceof Inet6Address) {
                            ipv6Result.add(normalizeHostAddress(address));
                        } else {
                            ipv4Result.add(normalizeHostAddress(address));
                        }
                    }
                }
            }

            // prefer ipv4
            if (!ipv4Result.isEmpty()) {
                for (String ip : ipv4Result) {
                    if (ip.startsWith("127.0") || ip.startsWith("192.168")) {
                        continue;
                    }

                    return ip;
                }

                return ipv4Result.get(ipv4Result.size() - 1);
            } else if (!ipv6Result.isEmpty()) {
                return ipv6Result.get(0);
            }
            //If failed to find,fall back to localhost
            final InetAddress localHost = InetAddress.getLocalHost();
            return normalizeHostAddress(localHost);
        } catch (Exception e) {
            log.error("Failed to obtain local address", e);
        }

        return null;
    }

这个在多网卡和windows机器上好像有点问题。所以建议你手动在broker.conf里设置brokerIP1，然后你在proxy的机器上telnet这个地址和broker的端口，只要能通应该就没问题了。
你要排查原因的话也可以，就是在proxy这里打印出来你的消息发送的broker地址，理论上你这个错误，那么这个地址是不通的。

[jaylu163]

我也遇到这样的问题

我的环境是centos7.9 搭建的namesrv是 2个namesrv 分开部署，2个 broker(1主1从) 开启proxy后
部署截图如下：
主节点

从节点：

防火墙开放了端口8088，8900
看到 logs/broker.log日志没有错误

客户端发消息就报错：

[JavaHello]

topic 需要手动创建，可能是 subscription group 没有创建