代码拉取完成，页面将自动刷新
Rabbitmq实现延时消息的两种方式
使用队列的ttl特性，即配置死信队列的消息重新路由到消费队列中，同一个队列的消息过期时间将相同，即使消息本身可能带上了ttl，同样会因队头的消息未过期而无法消费；
spring:
cloud:
stream:
bindings:
input:
destination: delay_message_queue_input
group: test-service
output:
destination: delay_message_queue_output
producer:
required-groups: test-service
rabbit:
bindings:
input:
consumer:
exchangeType: direct
output:
producer:
ttl: 3000
autoBindDlq: true
deadLetterExchange: delay_message_queue_input
deadLetterQueueName: delay_message_queue_input.test-service
定义两个队列delay_message_queue_output及delay_message_queue_input，并将delay_message_queue_output声明为延时队列，设定队列的ttl为3000ms，
deadLetterExchange及deadLetterQueueName表示若消息过期将转发至此交换机。
使用延时交换机实现延时消息更加灵活，可以针对每个消息设置任意的过期时间，交换机中的消息如果过期将路由到绑定的队列中进行消费；
spring:
cloud:
stream:
bindings:
input:
destination: delay_message_exchange
group: test-service
output:
destination: delay_message_exchange
rabbit:
bindings:
input:
consumer:
delayed-exchange: true
output:
producer:
delayed-exchange: true
定义两个队列并声明为延时exchnage，delayed-exchange需rabbitmq延时插件支持，在发送消息时带上x-delay参数指定过期时间；
public void sendDelayExchangeMessage(String message) {
log.info("send message {}", message);
processor.output().send(MessageBuilder.withPayload(message).setHeader("x-delay",20000).build());
}
mvn clean compile exec:exec -Dexec.executable="java" -Dexec.args="-cp %classpath com.hugesoft.Application --spring.rabbitmq.host=192.168.88.100 --spring.profiles.active=queue
mvn clean compile exec:exec -Dexec.executable="java" -Dexec.args="-cp %classpath com.hugesoft.Application --spring.rabbitmq.host=192.168.88.100 --spring.profiles.active=exchange"
使用队列的方式只能用于所有消息的过期时间均相同的情况下，延时中的消息总数可以延时队列中查看到，使用交换机插件的方式更加灵活，可以针对每个消息设置不同的超时，适应更多的业务场景，延时中的消息总数可以延时的交换机中查看到；
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
1. 开源生态
2. 协作、人、软件
3. 评估模型