用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.开始测试吧
分享到:
相关推荐
标题中的"ActiveMQ 使用Ajax 收发消息实战"指出我们将探讨如何使用ActiveMQ消息中间件与Ajax技术结合,实现Web应用程序中的异步消息传递。ActiveMQ是Apache软件基金会的一个项目,提供了一个开源的消息代理,支持...
4. **创建消息消费者**:为了接收消息,你需要创建一个`MessageListener`实现,如`MessageListenerAdapter`,它将监听指定的目的地,并调用你提供的方法来处理消息。在Spring配置中,将监听器绑定到目标目的地。 5....
2. **发送消息**:使用Ajax,客户端可以向ActiveMQ发布消息,这通常涉及构建JMS消息对象,设置目的地(如主题或队列),然后通过Ajax请求发送到服务器。 3. **接收消息**:同样,客户端会监听服务器的响应,一旦有新...
Flex整合ActiveMQ(JMS)是一项在Web应用开发中实现消息传递的重要技术,它结合了Flex前端的灵活性和ActiveMQ后端的高效消息队列服务。在这个过程中,Flex作为一个富互联网应用程序(RIA)平台,通过Java消息服务...
2. 将这些信息封装成一个对象(例如:Geturl),并通过JMS发送到消息队列。 3. MDB监听消息队列,接收到消息后,调用实体Bean(Entity Bean)将数据持久化到数据库。 三、主要数据结构 1. 基本数据结构:包括Get...
而Topic消息示例则演示了发布者如何向主题发布消息,监听者如何接收并处理这些消息,进行多轮发送和统计总耗时。 在消息模型方面,ActiveMQ支持两种主要类型:Queue和Topic。Queue遵循点对点(Point-to-Point)模型...
通过 Spring 的配置文件,可以定义连接工厂、目的地(如队列或主题)以及消息监听器,从而实现与 ActiveMQ 的集成。 在实际应用中,开发者通常会创建一个 Spring 配置文件来设置 JMS 相关组件,然后在 Java 代码中...
- 在 Servlet 中,可以定义一个方法,如 `sendMessage()`,接收前端传来的信息,然后使用 Session 创建一个 Producer,通过 Producer 发送消息到指定的 Queue 或 Topic。 4. **接收消息** - 使用 Session 创建一...
生产者需要创建JMS连接,基于该连接创建会话,设置是否支持事务以及消息确认方式,创建目的地(Destination)对象以发送或接收消息,创建消息生产者并指定主题名称,最后将消息发送到队列。消费者则需要实现Message...
- **使用JmsTemplate**:Spring提供的JmsTemplate类是发送和接收消息的便捷工具,可以通过它来发送简单或预定义的消息,同时处理消息的监听和回调。 - **消息生产者**:在SpringMVC的控制器中,我们可以创建一个...
7. **事件监听**:在客户端监听新消息的到来并进行处理。 8. **线程安全和并发控制**:在多用户环境下,确保消息的正确发送和接收。 9. **错误处理和异常机制**:如何处理网络中断、消息丢失等问题。 通过深入研究...
4. JMS性能提升:增强了JMS(Java消息服务)的性能,使得Java应用程序能够更有效地与消息队列交互。 5. 高可用性和弹性:WebSphere MQ在设计上考虑了系统的高可用性和弹性,提高了监听器的吞吐量,并增加了选择器的...
在开发中,开发者需要将ActiveMQ与C#应用程序结合,使用***框架来开发消息队列系统,这涉及到配置连接工厂、队列目的地、消息监听器容器等组件,以及编写消息消费者和生产者的代码逻辑。 在C#应用程序中使用***框架...
它实现了消息队列的基本功能,支持JMS 2.0特性,提供三种SessionMode,非持久化消息通过Redis发布。此外,Flash-MQ支持多消费者监听,但不支持互斥消费,提供高吞吐量,消息丢失率低,重复可控,且具有高可用性和...
- **Using Push without JMS**:在没有JMS的情况下使用推送。 - **Using TopicsContext to publish message**:使用TopicsContext发布消息。 - **Integrating Push with CDI events**:将推送与CDI事件集成在一起...
- **消息生产者**:创建并发送消息到队列或主题。 - **消息消费者**:接收并处理来自队列或主题的消息。 7. **JTA(Java Transaction API)1.1** - JTA 提供了分布式事务处理能力,确保跨多个资源的事务一致性。...
7. **JMS与消息传递**:WebLogic Server内置了JMS服务,支持点对点和发布/订阅模型的消息传递。理解和配置JMS队列和主题对于构建异步处理和解耦系统至关重要。 8. **性能优化**:优化WebLogic Server涉及调整JVM...
而消费者类则使用`@JmsListener`监听队列并处理接收到的消息: ```java @Service public class MessageConsumer { @JmsListener(destination = "myQueue") public void receiveMessage(String message) { System....
Java EE 6中的JMS支持队列和主题,以及消息驱动的bean,使得基于消息的系统更加可靠。 8. **WebSocket**: 虽然不是Java EE 6标准的一部分,但在后续的Java EE 7中引入,WebSocket提供了一种双向通信的协议,允许...
得到RSA密钥对,产生Signature对象,对用私钥对信息(info)签名,用指定算法产生签名对象,用私钥初始化签名对象,将待签名的数据传送给签名对象(须在初始化之后),用公钥验证签名结果,使用公钥初始化签名对象,用于...