消息协议介绍
import lombok.Data; @Data public class CouponRecordMessage { /** * 消息id */ private String messageId; /** * 订单号 */ private String outTradeNo; /** * 库存锁定任务id */ private Long taskId; }
//发送延迟消息 for(CouponTaskDO couponTaskDO : couponTaskDOList){ CouponRecordMessage couponRecordMessage = new CouponRecordMessage(); couponRecordMessage.setOutTradeNo(orderOutTradeNo); couponRecordMessage.setTaskId(couponTaskDO.getId()); rabbitTemplate.convertAndSend(rabbitMQConfig.getEventExchange(),rabbitMQConfig.getCouponReleaseDelayRoutingKey(),couponRecordMessage); log.info("优惠券锁定消息发送成功:{}",couponRecordMessage.toString()); }
@Autowired private RabbitTemplate rabbitTemplate; @Autowired private RabbitMQConfig rabbitMQConfig;
本文作者为DBC,转载请注明。