问题标签 [rocketmq]

我想在我的机器上建立一个rocketmq集群，模式是主从，至于docker-compose

而且我只能同时启动一个经纪人。那就是说当我启动master时，slave退出，反之亦然，一些body可以帮忙吗？

这是我的 docker-compose.yml

从代理配置

从代理配置

当 broker slave 启动时，master 写入日志并退出；

========日志=======

我正在使用 RocketMQ 并希望从队列中获取每个新请求的消息

此代码在正常情况下工作正常。但是，如果我运行许多并发线程，有时 ms varrable 并不能准确地获得来自 MessageListenerConcurrently 回调的值。

我哪里错了？我如何在这里等待来自消费者的结果？

当发送消息并且没有发生异常时，方法updateFaultItem()将被执行。但是它是一个可用的代理，为什么将它添加到faultItemTable???

尝试使用 spring-cloud-stream-rocketmq 开发一个微服务项目。我有默认的 RocketMQ 服务器，我的配置是

但不是我想访问另一个 RocketMQ 服务器。我应该如何更改配置以使用两个 RocketMQ 服务器。请帮助我

运行环境：
- CentOS Linux release 7.8.2003 (Core) - openjdk 版本“11.0.8” 2020-07-14 LTS - rocketmq-all-4.7.1-bin-release

序言：
为了快速启动和运行，我将下载一个二进制版本。无需构建二进制工件。

问题描述：
由于RocketMQ启动脚本不支持java11，所以我根据网络搜索对启动文件进行了修改，修改文件runserver.sh、runbroker.sh、tools.sh大致相同主意。配置文件如下。

运行服务器.sh

运行经纪人.sh

工具.sh

启动 RocketMQ NameServer

之后我尝试添加环境变量ROCKETMQ_HOME指向我的RocketMQ目录，结果还是一样。

代理启动不退出，代码在哪里显示块？我找到了一些shedule，但没有找到任何等待的地方。在这段代码中，我只是喜欢一些服务器，但是在这上面执行，为什么主线程不退出？我进入服务器寻找一些细节，只是找到一些shedules，找不到任何地方等待（）来阻止主要的therad？

这里我使用 spring-cloud-starter-stream-rocketmq 和 spring-message 来发送消息 dn，例如

但是如果没有消耗，我想在队列中设置消息过期时间。

我知道rocketmq可以设置ttl，但我不知道是否可以为不同的消息设置以及如何在之前的代码中使用？

我有一个由三台机器组成的DLedger集群，例如SA00、SA01、SA02；

现在我创建一个主题 ops06 并导入一些数据；

我关闭了 topicRoute 指定的主机；

使用 ./bin/mqadmin topicRoute 查看该主题，会报“No topic route info in name server for the topic”错误；

那么 ./bin/mqadmin topicList 中不存在该主题；

这个问题有解决方案吗？

代理配置如下：

我猜主SA01节点还没有同步SA00的ops06数据。这应该如何解决？

期待你的答复。

我只是发送一个字符串，我不知道为什么会这样。 client-version: 4.5.2 server-version: 4.5.2

希望有人能帮助我！

在此处输入图像描述

在此处输入图像描述

例外情况如下：

2021-03-26 16:06:13 {:} 错误 [AsyncSenderExecutor_1] cpbpcSuperPushMissionExecutor:138 -- ======== onException ==========

java.util.ConcurrentModificationException：空

在 java.util.HashMap$HashIterator.nextNode(HashMap.java:1445)

在 java.util.HashMap$EntryIterator.next(HashMap.java:1479)

在 java.util.HashMap$EntryIterator.next(HashMap.java:1477)

在 org.apache.rocketmq.common.message.MessageDecoder.messageProperties2String(MessageDecoder.java:387)

在 org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendKernelImpl(DefaultMQProducerImpl.java:767)

在 org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:557)

在 org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.access 300 美元（DefaultMQProducerImpl.java:90）

在 org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl$3.run(DefaultMQProducerImpl.java:491)

在 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)

在 java.util.concurrent.FutureTask.run(FutureTask.java:266)

在 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)

在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)

在 java.lang.Thread.run(Thread.java:748)

我只想知道它为什么会抛出这个：sendDefaultImpl 调用超时。我知道它可能是由防火墙引起的，但我已经关闭它。我找不到原因。

线程“主”org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException 中的异常：在 org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:667) 在 org.apache.rocketmq 的 sendDefaultImpl 调用超时.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1343) 在 org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1289) 在 org.apache.rocketmq.client.producer .DefaultMQProducer.send(DefaultMQProducer.java:325) 在 com.zlx.mq.rocketmq.One.main(One.java:48)