`

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

    博客分类:
  • jms
阅读更多

用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.开始测试吧

分享到:
评论
1 楼 object_object 2011-12-22  
好帖子,最近在做聊天室,兄弟帮大忙了

相关推荐

    ActiveMQ 使用Ajax 收发消息实战

    标题中的"ActiveMQ 使用Ajax 收发消息实战"指出我们将探讨如何使用ActiveMQ消息中间件与Ajax技术结合,实现Web应用程序中的异步消息传递。ActiveMQ是Apache软件基金会的一个项目,提供了一个开源的消息代理,支持...

    spring jms tomcat 异步消息传递入门实例

    4. **创建消息消费者**:为了接收消息,你需要创建一个`MessageListener`实现,如`MessageListenerAdapter`,它将监听指定的目的地,并调用你提供的方法来处理消息。在Spring配置中,将监听器绑定到目标目的地。 5....

    activemq ajax方式demo

    2. **发送消息**:使用Ajax,客户端可以向ActiveMQ发布消息,这通常涉及构建JMS消息对象,设置目的地(如主题或队列),然后通过Ajax请求发送到服务器。 3. **接收消息**:同样,客户端会监听服务器的响应,一旦有新...

    Flex整合ActiveMQ(JMS)

    Flex整合ActiveMQ(JMS)是一项在Web应用开发中实现消息传递的重要技术,它结合了Flex前端的灵活性和ActiveMQ后端的高效消息队列服务。在这个过程中,Flex作为一个富互联网应用程序(RIA)平台,通过Java消息服务...

    企业分布式计算实验报告

    2. 将这些信息封装成一个对象(例如:Geturl),并通过JMS发送到消息队列。 3. MDB监听消息队列,接收到消息后,调用实体Bean(Entity Bean)将数据持久化到数据库。 三、主要数据结构 1. 基本数据结构:包括Get...

    Apache_ActiveMQ教程.doc

    而Topic消息示例则演示了发布者如何向主题发布消息,监听者如何接收并处理这些消息,进行多轮发送和统计总耗时。 在消息模型方面,ActiveMQ支持两种主要类型:Queue和Topic。Queue遵循点对点(Point-to-Point)模型...

    ActiveMQ简单教程

    通过 Spring 的配置文件,可以定义连接工厂、目的地(如队列或主题)以及消息监听器,从而实现与 ActiveMQ 的集成。 在实际应用中,开发者通常会创建一个 Spring 配置文件来设置 JMS 相关组件,然后在 Java 代码中...

    ActiveMQServlet+jquery实现

    - 在 Servlet 中,可以定义一个方法,如 `sendMessage()`,接收前端传来的信息,然后使用 Session 创建一个 Producer,通过 Producer 发送消息到指定的 Queue 或 Topic。 4. **接收消息** - 使用 Session 创建一...

    Apache_ActiveMQ教程

    生产者需要创建JMS连接,基于该连接创建会话,设置是否支持事务以及消息确认方式,创建目的地(Destination)对象以发送或接收消息,创建消息生产者并指定主题名称,最后将消息发送到队列。消费者则需要实现Message...

    spring整合Activemq源码

    - **使用JmsTemplate**:Spring提供的JmsTemplate类是发送和接收消息的便捷工具,可以通过它来发送简单或预定义的消息,同时处理消息的监听和回调。 - **消息生产者**:在SpringMVC的控制器中,我们可以创建一个...

    activemq示例

    7. **事件监听**:在客户端监听新消息的到来并进行处理。 8. **线程安全和并发控制**:在多用户环境下,确保消息的正确发送和接收。 9. **错误处理和异常机制**:如何处理网络中断、消息丢失等问题。 通过深入研究...

    WebSphere MQ介绍教程

    4. JMS性能提升:增强了JMS(Java消息服务)的性能,使得Java应用程序能够更有效地与消息队列交互。 5. 高可用性和弹性:WebSphere MQ在设计上考虑了系统的高可用性和弹性,提高了监听器的吞吐量,并增加了选择器的...

    C# ActiveMQ 和Spring.NET框架开发示例

    在开发中,开发者需要将ActiveMQ与C#应用程序结合,使用***框架来开发消息队列系统,这涉及到配置连接工厂、队列目的地、消息监听器容器等组件,以及编写消息消费者和生产者的代码逻辑。 在C#应用程序中使用***框架...

    需求规格说明书及设计文档1

    它实现了消息队列的基本功能,支持JMS 2.0特性,提供三种SessionMode,非持久化消息通过Redis发布。此外,Flash-MQ支持多消费者监听,但不支持互斥消费,提供高吞吐量,消息丢失率低,重复可控,且具有高可用性和...

    JSF帮组文档

    - **Using Push without JMS**:在没有JMS的情况下使用推送。 - **Using TopicsContext to publish message**:使用TopicsContext发布消息。 - **Integrating Push with CDI events**:将推送与CDI事件集成在一起...

    J2EE5.0API(帮助手册)

    - **消息生产者**:创建并发送消息到队列或主题。 - **消息消费者**:接收并处理来自队列或主题的消息。 7. **JTA(Java Transaction API)1.1** - JTA 提供了分布式事务处理能力,确保跨多个资源的事务一致性。...

    BEA WebLogic Server 管理指南

    7. **JMS与消息传递**:WebLogic Server内置了JMS服务,支持点对点和发布/订阅模型的消息传递。理解和配置JMS队列和主题对于构建异步处理和解耦系统至关重要。 8. **性能优化**:优化WebLogic Server涉及调整JVM...

    springboot集成activemq的实例代码

    而消费者类则使用`@JmsListener`监听队列并处理接收到的消息: ```java @Service public class MessageConsumer { @JmsListener(destination = "myQueue") public void receiveMessage(String message) { System....

    JAVA EE 6 英文API.rar

    Java EE 6中的JMS支持队列和主题,以及消息驱动的bean,使得基于消息的系统更加可靠。 8. **WebSocket**: 虽然不是Java EE 6标准的一部分,但在后续的Java EE 7中引入,WebSocket提供了一种双向通信的协议,允许...

    JAVA上百实例源码以及开源项目源代码

    得到RSA密钥对,产生Signature对象,对用私钥对信息(info)签名,用指定算法产生签名对象,用私钥初始化签名对象,将待签名的数据传送给签名对象(须在初始化之后),用公钥验证签名结果,使用公钥初始化签名对象,用于...

Global site tag (gtag.js) - Google Analytics