Springboot整合RabbitMq
mq连接配置
mq配置类，声明队列信息
生产者
@RequestMapping(value="testFeign",method=RequestMethod.GET)
public String testFeign(@RequestParam Integer a, @RequestParam Integer b){
UserInfo userInfo = new UserInfo();
userInfo.setUserName("lizh");
userInfo.setPassWord("123");
byte[] user = DefaultCodecImpl.serialize(userInfo);//对象序列化
for (int i = 0; i < 9; i++) {
rabbitTemplate.convertAndSend("user",user);
}
return serviceAFeign.add(a,b);
}