3

我正在运行 Jetty hightide 8.1.8.v20121106，并使用 jquery/javascript 部署了一个小型 webapp 来监听 JMS 主题，当收到消息时，它将显示在页面上。我有一个 Java 应用程序，它将连接到 JMS 主题并发布消息，我希望 Java 应用程序发布的这些消息被 Jetty 上的 webapp 使用。

当 javascript webapp 发布消息或侦听消息时，Jetty 未连接到 tcp://localhost:61616。日志显示 Jetty 一直连接到 vm://localhost。有什么方法可以让 Jetty 使用我的 ActiveMQ 服务器而不是它自己的嵌入式服务器？帮助表示赞赏。

配置文件如下：

码头加.xml

<New id="cf" class="org.eclipse.jetty.plus.jndi.Resource">
    <Arg>jms/connectionFactory</Arg>
    <Arg>
          <New class="org.apache.activemq.ActiveMQConnectionFactory">
                <Arg>tcp://localhost:61616</Arg>
          </New>
    </Arg>
</New>

<New id="interestingTopic"  class="org.eclipse.jetty.plus.jndi.Resource">
    <Arg>jms/interestingTopic</Arg>
    <Arg>
          <New class="org.apache.activemq.command.ActiveMQTopic">
                <Arg>my.test</Arg>
          </New>
    </Arg>
</New>

webapp 的web.xml

<web-app>
    <context-param>
        <param-name>org.apache.activemq.brokerURL</param-name>
        <param-value>tcp://localhost:61616</param-value>
        <description>The URL of the Message Broker to connect to</description>
    </context-param>

    <context-param>
        <param-name>org.apache.activemq.embeddedBroker</param-name>
        <param-value>true</param-value>
        <description>Whether we should include an embedded broker or not</description>
    </context-param>

    <filter>
        <filter-name>session</filter-name>
        <filter-class>org.apache.activemq.web.SessionFilter</filter-class>
        <!-- <filter-class>org.eclipse.jetty.continuation.ContinuationFilter</filter-class> -->
    </filter>

    <filter-mapping>
        <filter-name>session</filter-name>
        <url-pattern>/*</url-pattern>
    </filter-mapping>

    <listener>
                <listener-class>org.apache.activemq.web.SessionListener</listener-class>
        </listener>

    <servlet>
        <servlet-name>AjaxServlet</servlet-name>
        <servlet-class>org.apache.activemq.web.AjaxServlet</servlet-class>
        <load-on-startup>1</load-on-startup>
    </servlet>

    <servlet>
        <servlet-name>MessageServlet</servlet-name>
        <servlet-class>org.apache.activemq.web.MessageServlet</servlet-class>
        <load-on-startup>1</load-on-startup>
    </servlet>

    <servlet-mapping>
        <servlet-name>AjaxServlet</servlet-name>
        <url-pattern>/amq/*</url-pattern>
    </servlet-mapping>

    <servlet-mapping>
        <servlet-name>MessageServlet</servlet-name>
        <url-pattern>/message/*</url-pattern>
    </servlet-mapping>

    <!-- Default page to serve -->
    <welcome-file-list>
        <welcome-file>index.html</welcome-file>
    </welcome-file-list>

    <resource-env-ref>
                <resource-env-ref-name>jms/interestingTopic</resource-env-ref-name>
                <resource-env-ref-type>javax.jms.Topic</resource-env-ref-type>
        </resource-env-ref>

    <resource-ref>
            <description>Connection Factory</description>
        <res-ref-name>jms/connectionFactory</res-ref-name>
        <res-type>javax.jms.ConnectionFactory</res-type>
        <res-auth>Container</res-auth>
    </resource-ref>
</web-app>

我用于收听该主题的 Java 脚本代码

window.onload = function() {
    org.activemq.Amq.init({ uri: 'amq', logging: true, timeout: 45, clientId:('geo_1') });
};

var amq = org.activemq.Amq;
var msgTopic = 'topic://my.test';
var clientId = 'geo_1';

function addTopicListener() {
    var myHandler = { 
            rcvMessage: function(message) {
                //<message type="zmg">test test</message>
                var type = message.getAttribute('type');

                switch (type) {
                    case 'zmsg':
                    {
                        var text = message.childNodes[0].data;
                        document.getElementById('zmsg_container').innerHTML += ' | '+text;
                        break;
                    }
                }
            }
    };

    amq.addListener('myHandler', msgTopic, myHandler.rcvMessage);
};

function delTopicListener() {
    amq.removeListener('myHandler', msgTopic);
}

最后是我的 Java 应用程序中用于发布的代码

private void init() throws NamingException {
        Properties props = new Properties();
        props.setProperty(Context.INITIAL_CONTEXT_FACTORY,"org.apache.activemq.jndi.ActiveMQInitialContextFactory");
        props.setProperty(Context.PROVIDER_URL,"tcp://localhost:61616");
        props.setProperty("topic.test", "my.test");
        ctx = new InitialContext(props);

        System.out.println("JMS Context Initialized");
    }

    private void connect() throws NamingException, JMSException {
        connectionFactory = (TopicConnectionFactory)ctx.lookup("ConnectionFactory");
        conn = connectionFactory.createTopicConnection();
        myTopic = (Topic)ctx.lookup("test");
        session = conn.createTopicSession(false, TopicSession.AUTO_ACKNOWLEDGE);
        publisher = session.createPublisher(myTopic);

        System.out.println("JMS Connection started");
    }
4

2 回答 2

1

在网上搜索并浏览了许多有关配置 Jetty 和 ActiveMQ 的网站之后；我终于遇到了一个网站，该网站讨论了使用 activemq 对码头进行集群，并让码头使用了 activemq 的 web 控制台（http://java.dzone.com/articles/activemq-configuring-multiple）。那个网站真的很有帮助。

所以我只是在 Jetty 中缺少了一个额外的 XML 配置部分。使用上面的 XML 配置，我必须附加以下内容：

<New id="url" class="org.eclipse.jetty.plus.jndi.Resource">
        <Arg>jmx/url</Arg>
        <Arg>
            <New class="java.lang.String">
                <Arg>service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi,service:jmx:rmi:///jndi/rmi://localhost:1299/jmxrmi</Arg>
            </New>
        </Arg>
</New>

之后，我启动了 Jetty 和 ActiveMQ，并且确定 jetty 连接到 ActiveMQ 并且没有像以前默认创建自己的 vm://localhost 连接。

感谢那些提供帮助的人，这让我能够专注于我的问题。

于 2013-02-05T18:26:14.603 回答
0

您的 java 代码中的这一行将导致在本地 VM 中创建一个 ActiveMQ 代理实例（这有点像一把双刃剑......）：

props.setProperty(Context.PROVIDER_URL,"vm://localhost?broker.persistent=false");

如果您在myamqhost上运行了另一个 ActiveMQ 代理，则将该行修改为如下所示（假设代理正在侦听端口 61616）：

props.setProperty(Context.PROVIDER_URL,"tcp://myamqhost:61616");

请参阅ActiveMQ JNDI 支持。

您可能还想查看ActiveMQ Ajax Client。

于 2013-02-04T17:44:01.077 回答