案例实战-SpringBoot2.X 延迟消息生产和消费实战开发

DBC 2.2K 0
直接测试就好了
@RestController
@RequestMapping("/api/admin/merchant")
public class MerchantAccountController {
    @Autowired
    private RabbitTemplate rabbitTemplate;

    @RequestMapping("check")
    public Object chect(){
        //TODO 修改数据库的商家账号状态
        rabbitTemplate.convertAndSend(RabbitMQConfig.NEW_MERCHANT_EXCHANGE,RabbitMQConfig.NEW_MERCHANT_ROUTIING_KEY,"商家账号通过审核");
        Map<String,Object> map = new HashMap<>();
        map.put("code",0);
        map.put("msg","账号审核通过,请10秒内上传一个商品");
        return map;
    }
}

我们就可以直接看到相应的延时操作啦!

案例实战-SpringBoot2.X 延迟消息生产和消费实战开发插图
10秒后,此消息来到了死信!

发表评论 取消回复
表情 图片 链接 代码

分享