ActiveMQ Artemis上的REST接口

问题描述

我正在尝试根据Artemis REST interface文档通过使用Maven构建.war文件来向ActiveMQ Artemis添加REST接口。生成.war文件后，将其移至/opt/artemis/apache-artemis-2.13.0/web/目录中并启动ActiveMQ Artemis。

启动ActiveMQ Artemis时出现下一个异常：

WARN [org.eclipse.jetty.webapp.WebAppContext] Failed startup of context o.e.j.w.WebAppContext@4cb702ce{/artemis-rest,file:///var/lib/test-broker/tmp/jetty-0_0_0_0-8161-artemis-rest_war-_artemis-rest-any-15304647904836420970.dir/webapp/,UNAVAILABLE}{/opt/artemis/apache-artemis-2.13.0/web/artemis-rest.war}: java.lang.RuntimeException: You must install RESTEasy as a Bootstrap Listener and it must be listed before this class
    at org.apache.activemq.artemis.rest.integration.RestMessagingBootstrapListener.contextInitialized(RestMessagingBootstrapListener.java:39) [artemis-rest-2.13.0.jar:2.13.0]

此外，在HTTP请求http://192.168.0.50:8161/artemis-rest/queues/test上获得503：

HTTP ERROR 503 Service Unavailable
URI:    /artemis-rest/queues/test
STATUS: 503
MESSAGE:    Service Unavailable
SERVLET:    -

我没有安装RESTeasy，因为找不到方法，因此我下载了RESTeasy jaxrs版本3.13.0.jar的jar文件，并将其放在WEB-INF/lib目录中，还包括依赖项在pom.xml中实现。

让我告诉我我的配置：

pom.xml

<project xmlns="http://maven.apache.org/POM/4.0.0"
   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">

   <modelVersion>4.0.0</modelVersion>
   <groupId>org.somebody</groupId>
   <artifactId>artemis-rest</artifactId>
   <packaging>war</packaging>
   <name>My App</name>
   <version>1.0-SNAPSHOT</version>

   <dependencies>
      <dependency>
        <groupId>org.jboss.resteasy</groupId>
        <artifactId>resteasy-jaxrs</artifactId>
        <version>3.13.0.Final</version>
      </dependency>
      <dependency>
         <groupId>org.apache.activemq.rest</groupId>
         <artifactId>artemis-rest</artifactId>
         <version>2.13.0</version>
         <exclusions>
            <exclusion>
               <groupId>*</groupId>
               <artifactId>*</artifactId>
            </exclusion>
         </exclusions>
      </dependency>
   </dependencies>
</project>

web.xml

<?xml version="1.0" encoding="UTF-8"?>
<!-- This web.xml file is not required when using Servlet 3.0 container,see implementation details http://jersey.java.net/nonav/documentation/latest/jax-rs.html -->
<web-app>
   <listener>
      <listener-class>org.jboss.resteasy.plugins.server.servlet.ResteasyBootstrap</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>
   <context-param>
        <param-name>rest.messaging.config.file</param-name>
        <param-value>file:///WEB-INF/rest-messaging.xml</param-value>
   </context-param>
</web-app>

rest-messaging.xml

<?xml version="1.0" encoding="UTF-8"?>
<!-- This web.xml file is not required when using Servlet 3.0 container,see implementation details http://jersey.java.net/nonav/documentation/latest/jax-rs.html -->
<rest-messaging>
    <server-in-vm-id>0</server-in-vm-id> <!-- deprecated,use "url" -->
    <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> <!-- deprecated,use "url" -->
    <url>vm://0</url>
</rest-messaging>

如果需要，我还可以附加broker.xml，jolokia-access.xml和bootstrap.xml文件，但对我来说似乎可以。我发现了有关此here的较旧问题，但这无助于解决这个问题。

如果您知道将REST接口添加到ActiveMQ Artemis的其他方法，请通知我。

解决方法

不幸的是，ActiveMQ Artemis的REST文档尚未经过验证或更新。

您可以在战争文件中获得所需的一切，并使用此pom.xml排除大部分不需要的内容：

<project xmlns="http://maven.apache.org/POM/4.0.0"
   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">

   <modelVersion>4.0.0</modelVersion>
   <groupId>org.somebody</groupId>
   <artifactId>artemis-rest</artifactId>
   <packaging>war</packaging>
   <name>My App</name>
   <version>1.0-SNAPSHOT</version>

   <dependencies>
      <dependency>
         <groupId>org.apache.activemq.rest</groupId>
         <artifactId>artemis-rest</artifactId>
         <version>2.13.0</version>
         <exclusions>
            <exclusion>
               <groupId>org.apache.activemq</groupId>
               <artifactId>*</artifactId>
            </exclusion>
            <exclusion>
               <groupId>io.netty</groupId>
               <artifactId>*</artifactId>
            </exclusion>
            <exclusion>
               <groupId>org.eclipse.jetty.aggregate</groupId>
               <artifactId>*</artifactId>
            </exclusion>
            <exclusion>
               <groupId>org.apache.httpcomponents</groupId>
               <artifactId>*</artifactId>
            </exclusion>
            <exclusion>
               <groupId>org.jboss.logging</groupId>
               <artifactId>*</artifactId>
            </exclusion>
            <exclusion>
               <groupId>org.jboss.logmanager</groupId>
               <artifactId>*</artifactId>
            </exclusion>
         </exclusions>
      </dependency>
   </dependencies>
</project>

确保将虚拟机内接收器添加到您的broker.xml中，例如：

      <acceptors>
         ...
         <acceptor name="invm">vm://0</acceptor>
      </acceptors>

此外，如果您像这样构造项目，则可以自动包括REST配置XML：

|-- pom.xml
`-- src
   `-- main
       `-- webapp
           `-- WEB-INF
               `-- web.xml
       `-- resources
           `-- rest.xml

然后您可以像这样在web.xml中引用它：

   <context-param>
        <param-name>rest.messaging.config.file</param-name>
        <param-value>rest.xml</param-value>
   </context-param>

一般来说，我建议使用ActiveMQ Artemis REST接口反对，主要有两个原因：

您的代码不会是可移植的，因为ActiveMQ Artemis REST接口是自定义（即未标准化）接口。
STOMP协议无处不在，简单，标准化，并且可以在几乎可以使用REST的每种情况和环境中使用。

我建议您使用STOMP代替ActiveMQ Artemis REST接口。

activemq-artemis maven resteasy

ActiveMQ Artemis上的REST接口

问题描述

解决方法

相关问答