11月 16, 2022 | Nix.Huang

客户端代码

//设置ack 模式未客户端确认
headers.setAck("client");
subscription = session.subscribe(headers, new MessageHandler(session, null) );

//使用NACK帧告诉broker,消费失败，请求其重新投递
StompHeaders ackHeaders = new StompHeaders();
ackHeaders.setMessageId(headers.getMessageId());
ackHeaders.set("subscription", subscription.getSubscriptionId());
subscription.getSubscriptionId();
session.acknowledge(ackHeaders, true);

//设置ack 模式未客户端确认

headers.setAck("client");

subscription = session.subscribe(headers, new MessageHandler(session, null) );

//使用NACK帧告诉broker,消费失败，请求其重新投递

StompHeaders ackHeaders = new StompHeaders();

ackHeaders.setMessageId(headers.getMessageId());

ackHeaders.set("subscription", subscription.getSubscriptionId());

subscription.getSubscriptionId();

session.acknowledge(ackHeaders, true);

broker.xml 配置

 <plugins>
	<redeliveryPlugin fallbackToDeadLetter="true"
			sendToDlqIfMaxRetriesExceeded="true">
	    <redeliveryPolicyMap>
		<redeliveryPolicyMap>
			<redeliveryPolicyEntries>
				<redeliveryPolicy queue="javacodercn"
					maximumRedeliveries="4"
					redeliveryDelay="10000"
					initialRedeliveryDelay="5000"
					useExponentialBackOff="true"/>
			</redeliveryPolicyEntries>
		</redeliveryPolicyMap>
	    </redeliveryPolicyMap>
	</redeliveryPlugin>
</plugins>

<redeliveryPlugin fallbackToDeadLetter="true"

sendToDlqIfMaxRetriesExceeded="true">

<redeliveryPolicy queue="javacodercn"

maximumRedeliveries="4"

redeliveryDelay="10000"

initialRedeliveryDelay="5000"

useExponentialBackOff="true"/>

</redeliveryPolicyEntries>

</redeliveryPolicyMap>

</redeliveryPlugin>

</plugins>

useExponentialBackOff 表示使用指数延时，时间分别为5s, 25s, 125s

参考文档

stomp-specification-1.1
示例源码

Posted in: spring practise

知行合一，止于至善

activeMQ 支持STOMP协议重试(redelivery)配置

客户端代码

broker.xml 配置

参考文档

站内搜索