插件的安装,本文就不做描述了,插件安装后如下,就说明安装成功了
1 添加pom依赖,yml配置就不讲了
2 核心类,定义交换机的代码改成如下,其它的定义队列,设置绑定关系,设置死信等,都是一样的,唯一就是Binding那里,最后添加.noargs(),idea也会自动识别处理的,就不粘代码了
@Beanpublic CustomExchange delayed_Exchang_1(){Map<String, Object> map = new HashMap<>();//自定义交换机的类型,后面的参数自己调整,topic,direct等map.put("x-delayed-type","topic");CustomExchange customExchange = new CustomExchange("delayed_Exchang_1", "x-delayed-message", true, false,map);return customExchange;}
3 生产者核心代码
MessageProperties messageProperties = new MessageProperties();
//延迟5秒
messageProperties.setDelay(5000);Message message = new Message("消息".getBytes(), messageProperties);rabbitTemplate.convertAndSend("delayed_Exchang_1","china.chongqing.aa",message);