使用 jdbc_ping 使用 JMS、Artemis 和 JGroups 设置 spring-boot 应用程序

Question

我已经在我的计算机上本地设置了一个 Artemis HA-Custer 示例，以了解它的基本工作原理。现在我想准备将其推送到 Kubernetes 集群中。因此，我想更改代理节点的初始成员发现方式，因此我也可以在云中使用它。我想将 JMS 和 JGroups 与“jdbc_ping”一起使用。其实我不确定，如果我做得对，所以也许你可以告诉我。

到目前为止，经纪人已成功地将他们的信息放入 db-table 中并且显然已连接。当我从我的 java 应用程序中尝试以下 connectionFactory 时，它启动时没有错误并与代理连接。但在某些方面，我不确定它是否正确运行。

@Bean
public ConnectionFactory connectionFactory() {
    TransportConfiguration transportConfiguration = new TransportConfiguration(NettyConnectorFactory.class.getName());

    ConnectionFactory cf = ActiveMQJMSClient.createConnectionFactoryWithHA(JMSFactoryType.CF, transportConfiguration);
    return cf;
}

所以现在唯一的问题是，如何正确设置 connectionFactory 以使用 JGroups。

更新：

INFO 24528 --- [enerContainer-1] o.s.j.l.DefaultMessageListenerContainer  : JMS message listener invoker needs to establish shared Connection

ERROR 24528 --- [enerContainer-1] o.s.j.l.DefaultMessageListenerContainer  : Could not refresh JMS Connection for destination 'TestA' - retrying using FixedBackOff{interval=5000, currentAttempts=0, maxAttempts=unlimited}. Cause: Failed to create session factory; nested exception is ActiveMQInternalErrorException[errorType=INTERNAL_ERROR message=AMQ219004: Failed to initialise session factory]

Answer 1

ActiveMQ Artemis documentation 涵盖了这个：

最后，支持jgroups 方案，它为服务器发现提供了udp 方案的替代方案。 URL 模式可以是jgroups://channelName?file=jgroups-xml-conf-filename，其中jgroups-xml-conf-filename 是指类路径上包含JGroups 配置的XML 文件，也可以是jgroups://channelName?properties=some-jgroups-properties。在这两种情况下，channelName 是给创建的 jgroups 通道的名称。

在您的代码中，您可以执行以下操作：

@Bean
public ConnectionFactory connectionFactory() {
    return new ActiveMQConnectionFactory("jgroups://channelName?file=jgroups-xml-conf-filename");
}

在您的情况下，客户端将需要访问代理正在使用的同一数据库，以便使用该信息进行发现。