问题标签 [rocketmq]

我正在尝试建立一个 RocketMQ 集群，只有一个名称服务器，1 个主服务器和 2 个从服务器。但是，我遇到了一些问题。

我正在运行的版本是从github/rocketmq-all-4.1.0-incubating.zip下载的。

代理使用 运行mqbroker -c broker.conf，其中 broker.conf 对于主服务器和从服务器不同。对于主人，我有：

对于奴隶：

第二个奴隶有brokerId=2。代理启动良好，从属日志的某些部分：

因为我怀疑代理正在尝试连接到最初没有运行的名称服务器，所以它重试并最终成功？

但是，稍后在尝试 clusterList 时，我只看到列出了一个代理，它恰好是一个从属 ( 172.22.1.17) 并且brokerId=2在配置中具有（尽管这里它被列为 0）：

此外，当向主人发送消息时，我得到SLAVE_NOT_AVAILABLE.

这是为什么？代理是否配置正确？如果是这样， 为什么会clusterList错误地报告它们？

我在使用 Rocket MQ（v4.1.0-incubating）客户端时遇到了关键问题，如下所示：

即使我用谷歌搜索了很多，我也不知道如何解决它，没有任何正确的答案。

这是我的异步方式生产者代码：

}

我正在使用 RocketMQ 并希望有序地生产和消费数据。我遵循了订单示例： https ://rocketmq.apache.org/docs/order-example/

但是在消费者监听器中，消息并没有有序地传递。谁能告诉这个订单消息是如何工作的？

RocketMQ 支持按标签过滤，这里我深挖一下 Broker 的源码。经纪人似乎做了以下比较： subscriptionData.getCodeSet().contains(tagsCode.intValue());在org.apache.rocketmq.broker.filter.ExpressionMessageFilter#isMatchedByConsumeQueue. 所以我想知道两个标签是否有可能具有相同的哈希码，如果发生这种情况，一些味精将不会被过滤？我找不到任何代码来比较 Broker 中的实际标签字符串，我错过了什么吗？

PS：我的RocketMQ版本是：4.2.0-incubating-SNAPSHOT

我在我的服务器上构建了一个rocketmq服务，它是2m-noslave集群，它可以向rocketmq发送消息，但是我的消费者无法接收消息，有人告诉我哪里错了，认为......这是我的消费者类代码：

我的 RocketMQ 服务器在这里输入图像描述

我在macOS Sierra ( 10.12.3) 上设置了 RocketMQ (4.1.0-incubating-release)并按照这个指令启动了它的名称服务器和代理。名称服务器和代理启动良好。但是我无法创建新主题或查看主题列表或查看任何主题的状态。我收到以下错误。

我尝试自己编译源代码并从 Apache 的站点下载编译后的二进制文件。我还尝试了 4.0.0-incubating-release二进制文件。它允许我使用sh mqadmin topicList. 但由于上述异常，它不允许我创建新主题。

我在任何 RocketMQ 日志（namesrv.log、broker.log 或 remoting.log）中都看不到任何相关日志。

我想知道这是一个错误还是我的设置有问题。

目前，我们的虚拟机配置了 18GB 内存，8 核 CPU。

我们在同一台机器上运行代理和名称服务器。

截至目前，我们有大约 3563 个主题。因此，名称服务器和代理从 18GB 消耗 13GB。

我在创建新主题时面临延迟问题。（对于创建新主题大约需要 13 到 15 秒）。

我希望在几分之一秒内创建一个主题。

我能知道这个延迟问题的原因吗？

快速说明：我们希望在 RocketMQ 中创建数百万个主题。
我们也知道它需要足够的内存/内核来管理这些。

RocketMQ 是否足以处理数百万个主题...？

版本：rocketmq-all-4.1.0-incubating

我们发送 msg 1000 QPS，同步发送，但抛出异常：-

[TIMEOUT_CLEAN_QUEUE] broker 忙，开始流控一段时间

有相关代码：

我发现broker默认sendMessageThreadPoolNums的值为1，</p>

但是以前的版本不是1，如果我配置sendMessageThreadPoolNums = 100，可以解决这个问题吗？这将导致与默认值不同。谢谢

首先，祝大家新年快乐。
有人在他们的项目中使用 RocketMQ 吗？似乎没有门户或管理控制台之类的东西，我们可以直接创建类似于 Activemq 的主题。对此有任何想法吗？

提前致谢，Harinath。

我已经在 ubuntu 服务器（18GB 内存和 6 核）中安装了 rocketMQ-4.1，还安装了用于仪表板的 RocketMQ 控制台。

https://github.com/apache/rocketmq-externals/tree/master/rocketmq-console

然后我创建了 dotNet 客户端，用于在具有动态主题名称的 for 循环中为 100,500,1000 个主题创建主题。

在代理日志和 topic.json 中，我可以在从程序发出创建请求后的几秒钟内看到创建的主题。但在控制台中显示 1000 个主题需要 5-10 分钟。是否存在控制台滞后或需要时间来创建主题本身并在 topic.json 中仅显示主题元？

我还对在同一主机（Windows 10 笔记本电脑 16GB 和 8core）内运行 dotnet 和 RocketMQ 服务器进行了测试，它运行良好并且能够在仪表板中看到主题。

让我知道是否有人遇到同样的问题或有任何微调 RocketMQ 服务器的建议。