第一步：使用之前先安装好RabbitMQ，建议安装在linux系统下
安装配置RabbitMQ：https://blog.csdn.net/qq_33450681/article/details/85339315 第二步：在配置文件下配置
代码语言：javascript复制rabbitmq:
host: 192.168.0.100
port: 5672
virtual-host: /mall
username: mall
password: mall
publisher-confirms: true #如果对异步消息需要回调必须设置为true
1234567浏览器访问http://192.168.0.100:15672/#/
第三步：业务中使用发送消息
代码语言：javascript复制 @Autowired
private OmsOrderSettingMapper orderSettingMapper;
@Autowired
private AmqpTemplate amqpTemplate;
/**
* 发送检查支付结果的消息队列
* @param orderSn
* @param count
*/
@Override
public void sendDelayPaymentCheck(String orderSn, int count) {
//获取订单超时时间
OmsOrderSetting orderSetting = orderSettingMapper.selectByPrimaryKey(1L);
long delayTimes = orderSetting.getNormalOrderOvertime() * 60 * 1000;
//将需要发送的数据封装到hashmap中
HashMap<Object, Object> hashMap = new HashMap<>();
hashMap.put("out_trade_no",orderSn);
hashMap.put("count",count);
//给延迟队列发送消息
amqpTemplate.convertAndSend(QueueEnum.QUEUE_PAY_CANCEL.getExchange(), QueueEnum.QUEUE_PAY_CANCEL.getRouteKey(), hashMap, new MessagePostProcessor() {
@Override
public Message postProcessMessage(Message message) throws AmqpException {
//给消息设置延迟毫秒值
message.getMessageProperties().setExpiration(String.valueOf(delayTimes));
return message;
}
});
}
12345678910111213141516171819202122232425262728293031第四步：定义QueueEnum枚举
代码语言：javascript复制 /**
* 支付通知队列
*/
QUEUE_PAY_CANCEL("mall.pay.direct","mall.pay.cancel","mall.pay.cancel")
1234更多内容请见原文，原文转载自：https://blog.csdn.net/weixin_44519496/article/details/120534802
