首先说明参考地址:http://activemq.apache.org/async-sends.html
在这个官方文档中得知,ActiveMQ 默认在大多数情况下都是按照异步传输的。但是有些情况则不是,比如原文中写道
The cases that we are forced to send in sync mode are when persistent messages are being sent outside of a transaction.
意思是说当我们利用持久发送的模式,而且不利用事务的时候,就会按照同步的方式来发送。
文章中同样提到了利用异步传输,是在“容忍在交互失败时可能存在发生微小的数据丢失的情况下”。
设置异步通信可以应用下面三种方式
1.在在建立链接工厂的url中设置,如:
cf = new ActiveMQConnectionFactory("tcp:); |
2.在连接工厂中设置
((ActiveMQConnectionFactory)connectionFactory).setUseAsyncSend(true); |
3.在连接对象上直接设置
((ActiveMQConnection)connection).setUseAsyncSend(true); |
分享到:
相关推荐
NULL 博文链接:https://zhyt710.iteye.com/blog/250930
Apache ActiveMQ是Apache软件基金会开发的一个开源消息中间件,它实现了Java消息服务(JMS)规范,用于在分布式系统中高效、可靠地传输消息。在本案例中,我们讨论的是ActiveMQ的5.1.0版本,这在当时是一个较新的...
标签:activemq-jpa-store-5.1.0-javadoc.jar,activemq,jpa,store,5.1.0,javadoc,jar包下载,依赖包
在"apache-activemq-5.1.0-src"中,我们获得的是ActiveMQ的源代码版本,这对于我们深入理解其内部工作原理、定制功能或进行二次开发非常有价值。 **Apache ActiveMQ概述** Apache ActiveMQ是一个开源的消息中间件,...
这需要在`activemq.xml`配置文件中添加WebSocket传输器,如下所示: ```xml ``` 在项目中,使用Spring的`SimpleBroker`和`WebSocketMessageBrokerConfigurer`,如下: ```java @Configuration @...
1. **activemq-core-5.1.0.jar**:这是ActiveMQ的核心库,包含ActiveMQ服务器的主要功能,如队列管理、主题发布/订阅、消息持久化、网络连接和传输协议支持等。开发者可以使用此库创建和管理消息代理,以及生产者和...
在本项目实践中,我们主要探讨的是如何利用ActiveMQ和Celery构建一个异步任务调度系统,这在处理大量计算密集型或耗时的任务时尤为重要,特别是在人工智能(AI)的场景中。下面将详细介绍这两个关键组件以及它们在...
它允许分布式系统中的组件之间异步通信,支持多种协议,如AMQP、STOMP、OpenWire等。 "rar"是资源适配器归档的简称,它是Java EE环境中部署资源适配器的标准方式,使得应用程序能够与JMS服务器、数据库等集成。 ...
标签:activemq-ra-5.1.0.jar,activemq,ra,5.1.0,jar包下载,依赖包
标签:activemq-web-5.1.0.jar,activemq,web,5.1.0,jar包下载,依赖包
ActiveMQ提供了多种选项来确保消息的可靠传输,例如使用Durable Subscription可以保证即使消费者不在线,消息也不会丢失。同时,Spring的JMS模板也支持与数据库事务一起使用的事务性消息。 对于源码分析,可以深入...
项目nettythird为springboot整合activemq,项目nettyserver为开启一个netty服务,简单进行了超时问题的解决,以及如何向客户端定向发送数据问题,可以当作一个样例,编辑可直接运行,测试类在server项目下,需要一个...
官方版本,亲测可用
标签:activemq-xmpp-5.1.0.jar,activemq,xmpp,5.1.0,jar包下载,依赖包
标签:activemq-run-5.1.0.jar,activemq,run,5.1.0,jar包下载,依赖包
ActiveMQ是Apache软件基金会的产品,遵循JMS(Java消息服务)规范,支持多种协议,并且可以跨平台运行。它提供了一个高性能、可靠且易于使用的消息队列服务,使得应用能够通过消息传递方式解耦组件,提高系统的可...
2. **JMS 使用 ActiveMQ 传送文件.doc** - 这个文档应该直接涵盖了如何使用ActiveMQ进行文件传输的具体步骤,可能包括了创建消息、设置目的地、发送和接收文件的代码示例,以及如何处理错误和异常的情况。...
activemq5.15.0-1 jar
标签:activemq-xmpp-5.1.0-javadoc.jar,activemq,xmpp,5.1.0,javadoc,jar包下载,依赖包