`
can_do
  • 浏览: 263322 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

AMQ中Acknowledge那些事

阅读更多
应答模式和transaction的关系==>
0.Session.SESSION_TRANSACTED (0)
1.Session.AUTO_ACKNOWLEDGE (1)
2.Session.CLIENT_ACKNOWLEDGE (2)
3.Session.DUPS_OK_ACKNOWLEDGE (3)
4.EMQSession.INDIVIDUAL_ACKNOWLEDGE (4)
说明:SESSION_TRANSACTED是专门用作事务的应答模式的,非事务时,采用其他4种。
/////////////begin//////
1.AUTO_ACKNOWLEDGE     With this acknowledgment mode, the session automatically acknowledges a client's receipt of a message either
                        when the session has successfully returned from a call to receive or when the message listener the session has
            called to process the message successfully returns.
            ==>receive方法本身成功返回或者而onMessage时,是在成功处理消息返回,因为onMessage时,处理消息的过程在onMessage方法中完成。
2.DUPS_OK_ACKNOWLEDGE     With this acknowledgment mode, the session automatically acknowledges a client's receipt of a message either
                        when the session has successfully returned from a call to receive or when the message listener the session has
            called to process the message successfully returns. Acknowlegements may be delayed in this mode to increase
            performance at the cost of the message being redelivered this client fails.
3.CLIENT_ACKNOWLEDGE     With this acknowledgment mode, the client acknowledges a consumed message by calling the message's acknowledge method.
4.SESSION_TRANSACTED     Messages will be consumed when the transaction commits.
/////////////end////////
AUTO_ACKNOWLEDGE和DUPS_OK_ACKNOWLEDGE的区别是【DUPS_OK_ACKNOWLEDGE】会出现重复应答,即当客户端失败时,redelivered消息会被分发到客户端,
而【AUTO_ACKNOWLEDGE】时,redelivered消息不会分发到客户端,即仅当mq server重启后才会分发到客户端;
分享到:
评论

相关推荐

    java通过AMQ通讯

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

    AMQ 实现消息队列 基本DEMO

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

    AMQ样例,参考

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

    amq最近安装包

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

    AMQ接收与发送

    总结来说,"AMQ接收与发送"涵盖了ActiveMQ中的核心概念和操作,包括消息的生产和消费、接收与发送端的分离、MQ控制台的使用,以及如何在实际环境中配置和运行这些组件。理解这些知识点有助于开发者构建可靠、高效的...

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

    电气特性中,输入逻辑高电平VIH最小为2.5V,最大为Vcc+0.3V;输入逻辑低电平VIL最大为0.8V。输出逻辑高电平VOH最小为2.4V,最大为Vcc;输出逻辑低电平VOL最大为0.4V。发射器的差分数据输入摆幅Vin,P-P在200mVpp到...

    spring整合amq

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

    AMQ28-SR4-M1-V1.0

    - 适用于高性能计算环境中的高速网络连接。 3. **其他光学链路:** - 可用于多种其他类型的光学链路,如存储区域网络(SAN)等。 #### 四、绝对最大额定值 - **电源电压(Vcc):** 从-0.5V到+3.6V。 - **存储温度...

    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...

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

    本文将详细介绍如何在CentOS环境中安装配置ActiveMQ (AMQ) 集群和Zookeeper集群。这两种集群技术对于分布式系统的消息传递和服务协调至关重要。通过具体步骤指导,我们将确保读者能够顺利搭建并运行这些集群。 ####...

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

    然后使用amq_scraper.py脚本中保存的CSV文件获取JSON文件。 用法是: amq_scraper.py <sheet> 一些较旧的文件可能包含JSON错误,必须手动更正。 但是,如果您从此存储库下载JSON文件而不是再次抓取它们,则应该...

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

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

    ActiveMQ(AMQ)单浏览器AJAX多页面客户端的支持(clientId)

    ActiveMQ(AMQ)是Apache软件基金会开发的一个开源消息中间件,它支持多种协议,包括OpenWire、STOMP、MQTT、AMQP等,广泛应用于分布式系统中的异步通信和解耦。在Web应用程序中,AJAX(Asynchronous JavaScript and...

    amq-spring-jms.pdf

    在Spring框架中,使用Spring JMS可以很方便地将ActiveMQ集成到Spring应用中。这包括创建消息代理、定义连接工厂、消息目的地以及使用模板来发送和接收消息等操作。 ActiveMQ的使用场景非常广泛,包括企业级消息传递...

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

    带有填充属性的 JBOSS_FUSE_INSTALL_DIR/etc/ 中的 wmq.to.amq.properties 文件 用法 部署路由后,使用 IBM MQ 查看器将测试消息发送到您的 IBM MQ 队列。 消息将由骆驼端点提取并传递到 AMQ 端点。

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

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

    jboss-amq-quickstarts:JBoss A-MQ快速入门

    当您在README文件中遇到此值时,请确保将其替换为JBoss A-MQ安装的实际路径。 建议的快速入门方法 我们建议您按照以下方法进行快速入门: 无论您的专业水平如何,建议您从helloworld-jms快速入门开始。 这是最简单...

Global site tag (gtag.js) - Google Analytics