spring activeMQ 整合(三): 确认机制ACK(收到消息后,应该有一个回应也就是确认答复)
2017-08-02 11:15
513 查看
之前写的spring
activemq整合的demo ,今天继续完善一下这个demo,让功能更强大。
Spring ActiveMQ
整合(一): 一个简单的demo,测试消息的发送与接收
Spring
继上篇文章之后,我消息发送失败后,可以重新发送了。但是至于别人有没有收到,这就不得而而而知了。
这时候就要用到ACK确认机制了。
JMS API中约定了Client端可以使用四种ACK_MODE,在javax.jms.Session接口中:
AUTO_ACKNOWLEDGE = 1 自动确认
CLIENT_ACKNOWLEDGE = 2 客户端手动确认
DUPS_OK_ACKNOWLEDGE = 3 自动批量确认
SESSION_TRANSACTED = 0 事务提交并确认
此外AcitveMQ补充了一个自定义的ACK_MODE: INDIVIDUAL_ACKNOWLEDGE = 4 单条消息确认
我们在开发JMS应用程序的时候,会经常使用到上述ACK_MODE,其中"INDIVIDUAL_ACKNOWLEDGE "只有ActiveMQ支持,当然开发者也可以使用它. ACK_MODE描述了Consumer与broker确认消息的方式(时机),比如当消息被Consumer接收之后,Consumer将在何时确认消息。对于broker而言,只有接收到ACK指令,才会认为消息被正确的接收或者处理成功了,通过ACK,可以在consumer与Broker之间建立一种简单的“担保”机制.
Client端指定了ACK_MODE,但是在Client与broker在交换ACK指令的时候,还需要告知ACK_TYPE,ACK_TYPE表示此确认指令的类型,不同的ACK_TYPE将传递着消息的状态,broker可以根据不同的ACK_TYPE对消息进行不同的操作。
比如Consumer消费消息时出现异常,就需要向broker发送ACK指令,ACK_TYPE为"REDELIVERED_ACK_TYPE",那么broker就会重新发送此消息。在JMS API中并没有定义ACT_TYPE,因为它通常是一种内部机制,并不会面向开发者。ActiveMQ中定义了如下几种ACK_TYPE(参看MessageAck类):
DELIVERED_ACK_TYPE = 0 消息"已接收",但尚未处理结束
STANDARD_ACK_TYPE = 2 "标准"类型,通常表示为消息"处理成功",broker端可以删除消息了
POSION_ACK_TYPE = 1 消息"错误",通常表示"抛弃"此消息,比如消息重发多次后,都无法正确处理时,消息将会被删除或者DLQ(死信队列)
REDELIVERED_ACK_TYPE = 3 消息需"重发",比如consumer处理消息时抛出了异常,broker稍后会重新发送此消息
INDIVIDUAL_ACK_TYPE = 4 表示只确认"单条消息",无论在任何ACK_MODE下
UNMATCHED_ACK_TYPE = 5 BROKER间转发消息时,接收端"拒绝"消息
到目前为止,我们已经清楚了大概的原理: Client端在不同的ACK_MODE时,将意味着在不同的时机发送ACK指令,每个ACK Command中会包含ACK_TYPE,那么broker端就可以根据ACK_TYPE来决定此消息的后续操作.
上面这一段呢就是:ACK_MODE与ACK_TYPE. 想要更多的了解,有兴趣的可以自行去看看,这里由于本文的重点是怎么实现,具体原理,可以自行了解一下。
plain copy
<!-- 消息监听容器 消息接收监听器用于异步接收消息 -->
<bean id="jmsContainerOne" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="connectionFactory" />
<property name="destination" ref="destinationOne" />
<property name="messageListener" ref="consumerMessageListenerOfOne" />
<property name="sessionAcknowledgeMode" value="4"></property>
</bean> view
plain cop
:给消息发送者一个回应“我收到你的消息了,你可以出队了,接受失败没有确认成功,会在原队列里面”,activemq在没有配置应答方式的时候,他是默认确认的。但是需求的各不同,就需要有不同的配置
以上就完成了activemq的消息确认。
原文地址:http://blog.csdn.net/dly1580854879/article/details/68490197
activemq整合的demo ,今天继续完善一下这个demo,让功能更强大。
Spring ActiveMQ
整合(一): 一个简单的demo,测试消息的发送与接收
Spring
ActiveMQ 整合(二): 重发机制(消息发送失败后的重新发送)
继上篇文章之后,我消息发送失败后,可以重新发送了。但是至于别人有没有收到,这就不得而而而知了。这时候就要用到ACK确认机制了。
1.ACK机制:
ACK (Acknowledgement),即确认字符,在数据通信中,接收站发给发送站的一种传输类控制字符。表示发来的数据已确认接收无误。JMS API中约定了Client端可以使用四种ACK_MODE,在javax.jms.Session接口中:
AUTO_ACKNOWLEDGE = 1 自动确认
CLIENT_ACKNOWLEDGE = 2 客户端手动确认
DUPS_OK_ACKNOWLEDGE = 3 自动批量确认
SESSION_TRANSACTED = 0 事务提交并确认
此外AcitveMQ补充了一个自定义的ACK_MODE: INDIVIDUAL_ACKNOWLEDGE = 4 单条消息确认
我们在开发JMS应用程序的时候,会经常使用到上述ACK_MODE,其中"INDIVIDUAL_ACKNOWLEDGE "只有ActiveMQ支持,当然开发者也可以使用它. ACK_MODE描述了Consumer与broker确认消息的方式(时机),比如当消息被Consumer接收之后,Consumer将在何时确认消息。对于broker而言,只有接收到ACK指令,才会认为消息被正确的接收或者处理成功了,通过ACK,可以在consumer与Broker之间建立一种简单的“担保”机制.
Client端指定了ACK_MODE,但是在Client与broker在交换ACK指令的时候,还需要告知ACK_TYPE,ACK_TYPE表示此确认指令的类型,不同的ACK_TYPE将传递着消息的状态,broker可以根据不同的ACK_TYPE对消息进行不同的操作。
比如Consumer消费消息时出现异常,就需要向broker发送ACK指令,ACK_TYPE为"REDELIVERED_ACK_TYPE",那么broker就会重新发送此消息。在JMS API中并没有定义ACT_TYPE,因为它通常是一种内部机制,并不会面向开发者。ActiveMQ中定义了如下几种ACK_TYPE(参看MessageAck类):
DELIVERED_ACK_TYPE = 0 消息"已接收",但尚未处理结束
STANDARD_ACK_TYPE = 2 "标准"类型,通常表示为消息"处理成功",broker端可以删除消息了
POSION_ACK_TYPE = 1 消息"错误",通常表示"抛弃"此消息,比如消息重发多次后,都无法正确处理时,消息将会被删除或者DLQ(死信队列)
REDELIVERED_ACK_TYPE = 3 消息需"重发",比如consumer处理消息时抛出了异常,broker稍后会重新发送此消息
INDIVIDUAL_ACK_TYPE = 4 表示只确认"单条消息",无论在任何ACK_MODE下
UNMATCHED_ACK_TYPE = 5 BROKER间转发消息时,接收端"拒绝"消息
到目前为止,我们已经清楚了大概的原理: Client端在不同的ACK_MODE时,将意味着在不同的时机发送ACK指令,每个ACK Command中会包含ACK_TYPE,那么broker端就可以根据ACK_TYPE来决定此消息的后续操作.
上面这一段呢就是:ACK_MODE与ACK_TYPE. 想要更多的了解,有兴趣的可以自行去看看,这里由于本文的重点是怎么实现,具体原理,可以自行了解一下。
2.实现消息确认:
1.首先在配置文件中配置你的应答方式是什么。我这里配置的是点对点的消息确认方式。
[html] viewplain copy
<!-- 消息监听容器 消息接收监听器用于异步接收消息 -->
<bean id="jmsContainerOne" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="connectionFactory" />
<property name="destination" ref="destinationOne" />
<property name="messageListener" ref="consumerMessageListenerOfOne" />
<property name="sessionAcknowledgeMode" value="4"></property>
</bean> view
plain cop
:给消息发送者一个回应“我收到你的消息了,你可以出队了,接受失败没有确认成功,会在原队列里面”,activemq在没有配置应答方式的时候,他是默认确认的。但是需求的各不同,就需要有不同的配置
以上就完成了activemq的消息确认。
原文地址:http://blog.csdn.net/dly1580854879/article/details/68490197
相关文章推荐
- Spring ActiveMQ 整合(三): 确认机制ACK(收到消息后,应该有一个回应也就是确认答复)
- Spring ActiveMQ 整合(三): 确认机制ACK(收到消息后,应该有一个回应也就是确认答复)
- springboot整合activemq,应答模式,消息重发机制,消息持久化
- Spring ActiveMQ 整合(二): 重发机制(消息发送失败后的重新发送)
- activemq的消息确认机制ACK
- ActiveMQ整合Spring实现消息机制二(消息接收端配置)
- ActiveMQ消息传送机制以及ACK机制详解
- 整合SpringBoot+Mysql+Redis实现缓存机制的一个Demo
- ActiveMQ的设置消息时长,事务,确认机制 ,持久化(六)
- Spring整合ActiveMQ实现简单的消息队列
- spring activeMQ 开启事物接收消息时自定义确认消息
- SpringBoot系列八:SpringBoot整合消息服务(SpringBoot 整合 ActiveMQ、SpringBoot 整合 RabbitMQ、SpringBoot 整合 Kafka)
- 详解Java消息队列-Spring整合ActiveMq
- linux下 消息中间件ActiveMQ整合spring笔记二 发消息
- spring boot 整合activemq 进行服务端消息推送(web页面)
- 学习淘淘商城第六十课(Spring与Activemq的整合及用JmsTemplate发送消息)
- ActiveMq与spring的整合--发送和接收消息
- RabbitMQ ACK 消息确认机制
- spring整合activemq发送MQ消息[queue模式]实例
- Java ActiveMQ 讲解(二)Spring ActiveMQ整合+注解消息监听