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);
    }

消费者