问题标签 [activemq-artemis]

我的 Artemis 代理有一个连接数据库的 JAAS 实现。我有一个主题队列，我发布到该队列会触发我们几个应用程序中的安全模块以重新获取/更新我们的用户/角色数据。我需要我的 JAAS 来做同样的事情。我想使用相同的主题队列来强制触发，但由于缺少会话，我无法在代理内部创建队列侦听器。（JAAS 实现在 Artemis 加载的 jar 中）。

我有一个 JBoss 集群，其中两个节点处于 HA 共享存储模式。

当我杀死活动节点 1 时，备份节点 2 成为活动节点。

当我重新启动节点 1 时，由于故障恢复，节点 1 成为实时服务器，节点 2 再次成为备份服务器。

但是，当我再次杀死节点 1 时，节点 2 成为实时服务器，但出现以下异常：

当然，我不能再使用这个队列了。

这是我的消息传递子系统定义（与standalone-ha 配置中定义的基本相同）：

这是正常行为还是配置错误？

编辑：

消费者部署在实时服务器和备份服务器上。队列在 Camel 上下文中使用，其在上下文中定义如下：

我是 ActiveMQ Artemis 的新手，

我想了解 ActiveMQ Artemis 中的对称集群。

这是我试图理解的例子。

我正在获取从集群节点消耗的主题消息和队列消息的列表，我如何获取有关节点的信息意味着哪个节点正在返回此信息（队列消息/主题消息）

我是 ActiveMQ Artemis 的新手

我已阅读文档并发现客户端使用连接器 来定义它如何连接到服务器。

我有一个 broker.xml 文件，它具有以下代码和平

所以这里接受者说，嘿，你可以在端口 61617 上与我连接，我正在监听它（这对我来说很有意义）但是连接器在这个 broker.xml 中的作用呢？连接器的目标端口与接受器中的端口相同（tcp://0.0.0.0:61616），我想了解连接器中提到的端口是什么意思，请解释一下。

我有 2 个 ActiveMQ Artemis 实例，只需使用命令 /.artemis create artemis/server1和

/.artemis 创建 artemis/server2

我正在使用linux ubantu。

这是server1 的 broker.xml：

这是server2 的 broker.xml：

同样在 server2 中，更改 bootstrap.xml，更改 Web 绑定端口

我正在使用StaticClusteredQueueExample和这个示例工作文件对其进行测试。

现在我正在对我的集群运行 ActiveMQ Artemis JMeter Performance，我正在使用这里的 JMeter 测试示例

现在，当我使用 Jmeter运行点对点测试时，消费者的错误率接近 50%（Jmeter 中的汇总报告），

但是我在 ubantu 系统中只运行一个节点（server1 或 server2 中的任何一个），它工作正常，错误率为 0%（Jmeter 中的聚合报告）。

您能否帮助我在使用 docker 运行多个实例（节点）时得到 50% 的错误率（Jmeter 中的汇总报告）

这是clustered-durable-subscription的示例，这里是clustered-static-discovery，在 clustered-static-discovery 中仅与一台服务器连接（集群使用集群配置自动与另一台服务器连接）。根据文档

通常持久订阅存在于单个节点上，并且一次只能有一个订阅者，但是，使用 ActiveMQ Artemis，可以在集群的不同节点上创建具有相同名称和客户端 ID 的持久订阅实例，并从中消费同时。这允许处理来自持久订阅的消息的工作以类似于跨集群负载平衡 JMS 队列的方式分布在集群中

如果我需要为静态集群添加额外的配置，或者持久订阅将在静态集群中正常工作，而无需为所有节点设置客户端 ID 和订阅（正如我在静态集群中提到的，我们只与一个节点建立连接）

Artemis 消息生产者 java 程序：

......

客户端（使用弹簧）->

对象消息转换器->

当我运行生产者程序时，向一个主题发送一条消息，其中客户端（弹簧部分）正在监听这个主题，但它无法成功接收消息。

在日志中获取以下跟踪（我也尝试使用简单消息转换器，但仍然面临同样的问题），如果您将检查下面的日志跟踪 ActiveMQMessageConsumer 正在抛出此异常。

我已经创建了带有 2 个节点的 Artemis 集群并成功连接到我的 Spring-boot 应用程序（github链接），实现基于clustered-static-discovery

现在我正在用它测试持久订阅有一些奇怪的行为我产生了 5 条消息并且只消耗了 3 条

这是整个配置

我已经通过http://localhost:816i/hawtio/ wrb UI for artemis 发现生产者只收到 5 个消息中的 5 个

（消息负载平衡-> 严格）

我在这里做错了什么？

我检查了 clustered-static-discovery，也检查了基于 udp 的集群，如果我在集群中有 2 个节点，则必须需要 2 个连接，如果我有 4 个，则必须需要 4 个连接才能循环使用消息。

假设我有 2 个服务器需要 2 个连接，如果我只创建了一个连接或侦听器，并且将产生 10 条消息，那么我将错过 5 条消息。

我们如何在一个连接中接收消息而不是创建多个连接（取决于使用了多少服务器节点）。因为有添加运行时节点的场景，所以我们会错过那些将要运行时添加节点的消息

这是示例我有 2 个节点（在集群中）和一个连接

在上面的示例中，生产者发送 20 条消息，但是当我打印输出时，它只打印 10 条消息而不是 20 条

我的 Artemis 代理配置如下：

如何告诉我的消费客户端连接到 Queue1？根据文档，我必须将地址名称和队列名称分开，::但我无法让它工作。

这将创建一个名为 的新地址PublishSubscribeWithPreDefinedQueues::Queue1。

有任何想法吗？谢谢！