首先说明参考地址: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
);
分享到:
相关推荐
标签:activemq-jpa-store-5.1.0-javadoc.jar,activemq,jpa,store,5.1.0,javadoc,jar包下载,依赖包
JMS提供了一种异步通信模型,允许应用程序之间通过解耦的方式进行通信,从而提高系统的可扩展性和可靠性。ActiveMQ作为JMS的实现,支持多种协议,如OpenWire、AMQP、STOMP、MQTT和WS-Notification,使得不同平台和...
NULL 博文链接:https://zhyt710.iteye.com/blog/250930
在"apache-activemq-5.1.0-src"中,我们获得的是ActiveMQ的源代码版本,这对于我们深入理解其内部工作原理、定制功能或进行二次开发非常有价值。 **Apache ActiveMQ概述** Apache ActiveMQ是一个开源的消息中间件,...
1. **activemq-core-5.1.0.jar**:这是ActiveMQ的核心库,包含ActiveMQ服务器的主要功能,如队列管理、主题发布/订阅、消息持久化、网络连接和传输协议支持等。开发者可以使用此库创建和管理消息代理,以及生产者和...
这需要在`activemq.xml`配置文件中添加WebSocket传输器,如下所示: ```xml ``` 在项目中,使用Spring的`SimpleBroker`和`WebSocketMessageBrokerConfigurer`,如下: ```java @Configuration @...
标题中的"activemq-rar-5.1.0.rar"指的是Apache ActiveMQ的一个RAR(Resource Adapter Archive)版本,这是ActiveMQ的特定版本,用于在Java应用服务器中部署和管理消息代理服务。RAR文件是一种特殊格式的归档,通常...
在本项目实践中,我们主要探讨的是如何利用ActiveMQ和Celery构建一个异步任务调度系统,这在处理大量计算密集型或耗时的任务时尤为重要,特别是在人工智能(AI)的场景中。下面将详细介绍这两个关键组件以及它们在...
标签: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模板也支持与数据库事务一起使用的事务性消息。 对于源码分析,可以深入...
2. **JMS 使用 ActiveMQ 传送文件.doc** - 这个文档应该直接涵盖了如何使用ActiveMQ进行文件传输的具体步骤,可能包括了创建消息、设置目的地、发送和接收文件的代码示例,以及如何处理错误和异常的情况。...
项目nettythird为springboot整合activemq,项目nettyserver为开启一个netty服务,简单进行了超时问题的解决,以及如何向客户端定向发送数据问题,可以当作一个样例,编辑可直接运行,测试类在server项目下,需要一个...
官方版本,亲测可用
ActiveMQ是Apache软件基金会的产品,遵循JMS(Java消息服务)规范,支持多种协议,并且可以跨平台运行。它提供了一个高性能、可靠且易于使用的消息队列服务,使得应用能够通过消息传递方式解耦组件,提高系统的可...
标签: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软件基金会开发的一款开源消息中间件,它实现了Java消息服务(JMS)标准,为分布式系统提供高效、可靠的...了解并熟练掌握这三种创建方式,将有助于更好地利用ActiveMQ实现分布式系统间的异步通信。
在这个小例子中,我们将探讨ActiveMQ的三种主要的消息收发方式:点对点、发布/订阅和事务处理模式。 1. **点对点(Point-to-Point)模式**: 在点对点模式下,消息从一个生产者发送到一个队列,然后由一个或多个...