`
gao_xianglong
  • 浏览: 466980 次
  • 性别: Icon_minigender_1
  • 来自: 深圳
社区版块
存档分类
最新评论

记录amq的一些参数解释

阅读更多

createSession(paramA,paramB);
paramA是设置事务的,paramB设置acknowledgment mode
paramA设置为false时:paramB的值可为Session.AUTO_ACKNOWLEDGE,Session.CLIENT_ACKNOWLEDGE,DUPS_OK_ACKNOWLEDGE其中一个。
paramA设置为true时:paramB的值忽略, acknowledgment mode被jms服务器设置为SESSION_TRANSACTED 。
Session.AUTO_ACKNOWLEDGE为自动确认,客户端发送和接收消息不需要做额外的工作。
Session.CLIENT_ACKNOWLEDGE为客户端确认。客户端接收到消息后,必须调用javax.jms.Message的acknowledge方法。jms服务器才会删除消息。
DUPS_OK_ACKNOWLEDGE允许副本的确认模式。一旦接收方应用程序的方法调用从处理消息处返回,会话对象就会确认消息的接收;而且允许重复确认。在需要考虑资源使用时,这种模式非常有效。

 

异步发送消息
ActiveMQ 支持生产者以同步或异步模式发送消息。使用不同的模式对send 方法的
反应时间有巨大的影响,反映时间是衡量ActiveMQ 吞吐量的重要因素,使用异步发送
可以提高系统的性能。
在默认大多数情况下,AcitveMQ 是以异步模式发送消息。例外的情况:在没有使用
事务的情况下,生产者以PERSISTENT 传送模式发送消息。在这种情况下,send 方法都
同步的,并且一直阻塞直到ActiveMQ 发回确认消息:消息已经存储在持久性数据存
储中。这种确认机制保证消息不会丢失,但会造成生产者阻塞从而影响反应时间。
高性能的程序一般都能容忍在故障情况下丢失少量数据。如果编写这样的程序,可
以通过使用异步发送来提高吞吐量(甚至在使用PERSISTENT 传送模式的情况下)。

 

分享到:
评论

相关推荐

    java通过AMQ通讯

    Java通过AMQ通讯是一种在分布式系统中实现消息传递的技术,主要使用了Apache ActiveMQ(简称AMQ)这一开源的消息中间件。AMQ是基于Java Message Service(JMS)规范的,它提供了一种高效、可靠的平台,使得应用程序...

    AMQ 实现消息队列 基本DEMO

    AMQ(ActiveMQ)是Apache软件基金会开发的一款开源消息中间件,它实现了多种消息协议,如OpenWire、STOMP、XMPP、AMQP等,能够有效地支持分布式系统中的异步通信。消息队列是一种设计模式,它允许应用程序通过将消息...

    amq最近安装包

    3. **配置文件**:AMQ的核心配置位于 `conf/activemq.xml` 文件中,用户可以根据实际需求调整队列、主题、网络连接等参数。 4. **启动和监控**:通过执行 `bin/activemq start` 启动服务,并使用 `bin/activemq ...

    AMQ样例,参考

    标题中的“AMQ样例,参考”提示我们,这是一个关于ActiveMQ应用的示例,用于指导用户理解如何在实际环境中部署和使用ActiveMQ。ActiveMQ是Apache软件基金会开发的一个开源消息代理,它作为消息中间件,允许应用程序...

    AMQ接收与发送

    - `logs`:日志文件,记录了ActiveMQ服务器的运行情况和错误信息。 - `pom.xml`(如果使用Maven)或`build.gradle`(如果使用Gradle):构建文件,定义了项目的依赖和构建规则。 ### 6. 安装与运行 要运行这个示例...

    AMQ28-SR4-M1-V1.0

    通过以上对AMQ28-SR4-M1-V1.0 100G QSFP28 SR4 光模块的手册内容的详细解析,我们可以清晰地了解到该产品的技术特点、性能参数以及应用场景,为用户在选择合适的光模块时提供了重要的参考依据。

    10Gtek AMQ10-SR4-M1 (JH2)V1.1.pdf

    【10Gtek AMQ10-SR4-M1(JH2)V1.1.pdf】是一款由10Gtek公司推出的40GBASE-SR QSFP+光收发器规格书,主要针对高速网络连接,特别是数据中心和高性能计算环境。这款产品支持40GBASE-SR4和QDR应用,符合QSFP+电气多源...

    spring整合amq

    标题中的“spring整合amq”指的是将Spring框架与ActiveMQ(AMQ)集成,以便在Spring应用程序中使用消息队列进行通信。ActiveMQ是Apache软件基金会的一个开源项目,它是一个功能丰富的消息代理,实现了多种消息协议,...

    springboot+amq+javamail+maven

    在"springboot+amq+javamail+maven"的项目中,这些技术是如何整合的呢? 1. **SpringBoot与ActiveMQ集成**:SpringBoot可以通过添加对应的依赖来集成ActiveMQ。在配置文件中,我们可以设置ActiveMQ服务器的相关参数...

    ActiveMQ Web开发 amq.js

    最新在做ActiveMQ Web端开发时,绕了很多路找到了这个插件,小编在这里就贡献了给爱学习小伙伴用。

    amq-examples:此存储库包含一组与 Red Hat AMQ 消息传递套件组件一起使用的示例

    红帽 AMQ 示例 该存储库包含一组与 Red Hat AMQ 消息传递套件组件一起使用的示例。 :股票报价应用程序展示了来自浏览器的rhea javascript 客户端、websockets 和 TLS 连接 :简单Hello World的NodeJS应用特色rhea ...

    AMQ-Scripts:脚本的全面存储库,可提高AMQ的生活质量

    AMQ脚本这是所有脚本的万能库,可提高“中游戏/生活质量的所有脚本。用法可以通过将大多数脚本导入浏览器扩展程序来使用它们,例如用于.js文件的和用于.css文件的 。 在特定项目的文件夹中可以找到更多信息。 design...

    IMB MQ 报错问题记录

    IMB MQ 报错问题记录

    random-amq:一个让我搞乱amq东西的地方(animemusicquiz.com)

    随机数量 一个让我搞乱amq东西的地方(animemusicquiz.com) ... 一些较旧的文件可能包含JSON错误,必须手动更正。 但是,如果您从此存储库下载JSON文件而不是再次抓取它们,则应该解决这些问题。 另一个问题是

    CentOS环境安装配置AMQ集群及zookeeper集群

    ### CentOS环境下AMQ集群与Zookeeper集群安装配置详解 #### 一、概述 本文将详细介绍如何在CentOS环境中安装配置ActiveMQ (AMQ) 集群和Zookeeper集群。这两种集群技术对于分布式系统的消息传递和服务协调至关重要...

    amq-scripts:动漫音乐测验脚本集

    AMQ脚本userscripts动漫音乐测验的* monkey用户脚本集合amqCoopPaste.user.js Kinda现在在官方团队模式下已经无法使用,但是如果每个人都一个人玩,以个人玩家的身份玩游戏,每个正确答案仍然会提供更多XP /音符。...

    amq-spring-jms.pdf

    最后,ActiveMQ提供了一些特殊功能,例如消息持久化和事务处理,这在确保消息传递的可靠性方面非常重要。通过上述提供的信息,我们可以得知ActiveMQ是一个功能强大的消息中间件,非常适合于构建复杂的分布式应用程序...

    camel-amq-integrator:骆驼项目定义了外部AMQ 7的生产者和消费者

    JMS和文件示例 介绍 本示例使用骆驼框架创建一个简单的生产者和消费者。 建造 您将需要首先编译此示例: mvn compile 消费者运行 如果您键入该示例应运行 mvn camel:run 这将创建队列“ testclient.payment....

    springboot-amq-s2i

    Red Hat JBoss A-MQ xPaaS产品应该已经安装并在OpenShift安装上运行,一种运行A-MQ服务的简单方法是遵循与amq63-basic模板相关的OpenShift的A-MQ xPaaS映像的文档。 。 然后,以下命令将打包您的应用并在OpenShift...

    camel-wmq-amq:Camel IBM Websphere MQ 到 Active MQ 桥接路由

    骆驼-wmq-amq Camel IBM Websphere MQ 到 Active MQ 桥接路由 先决条件 IBM 为安装在 Fuse 上的 MQ 客户端提供了 OSGi jar 文件IBM_MQ_INSTALL_DIR/java/lib/OSGi 运行 AMQ 代理 带有填充属性的 JBOSS_FUSE_INSTALL...

Global site tag (gtag.js) - Google Analytics