java - 如何在 ActiveMQ Artemis 集群中启用 REST

Question

我们正在尝试设置一个 REST 接口(interface)，如 the ActiveMQ Artemis documentation 中所述。 。我们已经让它在 2.10.1 和 2.9.0 版本中工作，但只能在独立模式下工作。集群 2.9.0 是我们当前的生产环境，也是我们尝试设置 REST 接口(interface)的地方。

我们有一个使用基于文件的日志的集群主动/被动解决方案。我们的主动/被动解决方案前面有一个 Netscaler。我们发现this bug report这就是我们在系统中看到的。这个bug在2.3.0中得到了解决，所以我想我们应该运行TCP而不是in-vm？我们如何设置它？

我们工作 StdAlone 的配置:

<web bind="http://lxappqmanv01:8161" path="web">
   <app url="activemq-branding" war="activemq-branding.war"/>
   <app url="artemis-plugin" war="artemis-plugin.war"/>
   <app url="console" war="console.war"/>
   <app url="rest" war="artemis-rest-1.0-SNAPSHOT.war"/>
</web>

在broker.xml中我们添加了:

<acceptor name="in-vm">vm://0</acceptor>

在rest-messaging.xml中

<rest-messaging>
   <server-in-vm-id>0</server-in-vm-id>
   <use-link-headers>false</use-link-headers>
   <default-durable-send>false</default-durable-send>
   <dups-ok>true</dups-ok>
   <topic-push-store-dir>topic-push-store</topic-push-store-dir>
   <queue-push-store-dir>queue-push-store</queue-push-store-dir>
   <producer-time-to-live>0</producer-time-to-live>
   <producer-session-pool-size>10</producer-session-pool-size>
   <session-timeout-task-interval>1</session-timeout-task-interval>
   <consumer-session-timeout-seconds>300</consumer-session-timeout-seconds>
   <consumer-window-size>-1</consumer-window-size>
   <url>vm://0</url>
</rest-messaging>

在 web.xml 中

<web-app>
   <listener>
      <listener-class>com.myapp.artemis.MyResteasyBootstrap</listener-class>
   </listener>

   <listener>

<listener-class>org.apache.activemq.artemis.rest.integration.RestMessagingBootstrapListener</listener-class>
   </listener>

   <filter>
      <filter-name>Rest-Messaging</filter-name>

<filter-class>org.jboss.resteasy.plugins.server.servlet.FilterDispatcher</filter-class>
   </filter>

   <filter-mapping>
      <filter-name>Rest-Messaging</filter-name>
      <url-pattern>/*</url-pattern>
   </filter-mapping>
</web-app>

这工作正常(当包含下面的类时):

package com.myapp.artemis;

import javax.servlet.ServletContextEvent;
import org.jboss.resteasy.plugins.server.servlet.ResteasyBootstrap;
import org.jboss.resteasy.spi.Registry;


public class MyResteasyBootstrap extends ResteasyBootstrap {
    @Override
    public void contextInitialized(ServletContextEvent event)
    {
        super.contextInitialized(event);
        event.getServletContext().setAttribute(Registry.class.getName(), deployment.getRegistry());
    }
}

如何让它在集群环境中工作？我们如何使用TCP而不是虚拟机内？

Answer 1

如果您想使用 TCP 进行 REST，您只需在 rest-messaging.xml 中进行配置，例如:

<rest-messaging>
   <use-link-headers>false</use-link-headers>
   <default-durable-send>false</default-durable-send>
   <dups-ok>true</dups-ok>
   <topic-push-store-dir>topic-push-store</topic-push-store-dir>
   <queue-push-store-dir>queue-push-store</queue-push-store-dir>
   <producer-time-to-live>0</producer-time-to-live>
   <producer-session-pool-size>10</producer-session-pool-size>
   <session-timeout-task-interval>1</session-timeout-task-interval>
   <consumer-session-timeout-seconds>300</consumer-session-timeout-seconds>
   <consumer-window-size>-1</consumer-window-size>
   <url>tcp://127.0.0.1:61616</url>
</rest-messaging>

如果您想将 REST 与主/从 HA 对一起使用，那么您应该在主和从代理“前面”的单独计算机上配置 Web 应用程序服务器(例如 Tomcat 或 Jetty)，并使用如下 URL :

<url>(tcp://master:61616,tcp://slave:61616)?ha=true;reconnectAttempts=-1</url>

也就是说，我不建议使用 REST，因为虽然 REST 相对简单，但没有用于消息传递的标准 REST 接口(interface)，因此您的 REST 客户端将绑定(bind)到 ActiveMQ Artemis(这不利于应用程序可移植性)。通常，STOMP 是 REST 的良好替代品。 STOMP 是一种简单的、基于文本的协议(protocol)，可以在 JavaScript 中使用，并且可以在大多数与 REST 相同的地方使用，加上它的标准化，因此您会发现许多不同语言的客户端实现。

此外，REST 接口(interface)和远程代理之间的连接目前尚未实现安全性，这意味着任何客户端都可能连接到代理并使用或生成消息。