用ajax发送jms消息监听指定队列并从中取出消息的小例子

1.下载 apache-activemq-5.3.0-bin.zip

2.下载例子 jsmqtest.rar

3.用eclipse 打开   jsmqtest 工程，并把 D:\apache-activemq-5.3.0\lib中的jar导入

4.启动 D:\apache-activemq-5.3.0\bin\activemq.bat

5.打开 http://127.0.0.1/jsmqtest/index.htm页面

6.开始测试吧





说明：

1.引入activemq-web-5.3.0.jar 包，里面有封装好的AjaxServlet ； _amq.js； amq.js；behaviour.js

2. 配置 D:\jetty-6.1.7-atf\webapps\jsmqtest\WEB-INF\web.xml

    添加

   <context-param>
      <param-name>org.apache.activemq.brokerURL</param-name>
      <param-value>tcp://localhost:61616</param-value>
   </context-param>


   <servlet>
      <servlet-name>AjaxServlet</servlet-name>
      <servlet-class>org.apache.activemq.web.AjaxServlet</servlet-class>
</servlet>

<servlet-mapping>
    <servlet-name>AjaxServlet</servlet-name>
    <url-pattern>/amq/*</url-pattern>
</servlet-mapping>
3.在html页面增加监听方法，用于监听jms中间件消息，jms队列可以是  topic 也可以是queue；

4.启动web服务器和jms服务器

5.打开 http://127.0.0.1/jsmqtest/index.htm页面 只要jms“queue://mqtes”队列中有消息，html页面就会自动显示出来。



6.开始测试吧

评论

2 楼 goumin1818 2012-06-08  

您还熟悉ActiveMQ吗？ 能给一些指导吗？QQ：237567685

1 楼 goumin1818 2012-06-08  

可以用了，发送一条消息后，得刷新页面！后天还报错




严重: Servlet.service() for servlet AjaxServlet threw exception
java.lang.NoClassDefFoundError: org/eclipse/jetty/continuation/ContinuationSupport
at org.apache.activemq.web.MessageListenerServlet.doMessages(MessageListenerServlet.java:309)
at org.apache.activemq.web.MessageListenerServlet.doGet(MessageListenerServlet.java:246)
at org.apache.activemq.web.AjaxServlet.doGet(AjaxServlet.java:47)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:690)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:803)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:290)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:206)
at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:233)
at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:175)
at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:128)
at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:102)
at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:109)
at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:263)
at org.apache.coyote.http11.Http11Processor.process(Http11Processor.java:844)
at org.apache.coyote.http11.Http11Protocol$Http11ConnectionHandler.process(Http11Protocol.java:584)
at org.apache.tomcat.util.net.JIoEndpoint$Worker.run(JIoEndpoint.java:447)
at java.lang.Thread.run(Thread.java:619)