Springboot整合rabbitMQ

     org.springframework.boot
     spring-boot-starter-amqp

  #  rabbitmq
  rabbitmq:
    #rabbitmq服务器地址
    host: 127.0.0.1
    #rabbitmq端口号
    port: 5672
    #rabbitmq连接那台虚拟机
    virtual-host: /
    #rabbitmq密码
    password: guest
    #rabbitmq账号
    username: guest

1.在启动器添加@EnableRabbit注解

@SpringBootApplication(scanBasePackages = {"com.javaweb.*"})
@MapperScan("com.javaweb.**.mapper")
@EnableTransactionManagement
// 开启定时任务支持
@EnableScheduling
//开启rabbitMQ服务
@EnableRabbit
public class ApiApplication {
    public static void main(String[] args) {
        SpringApplication.run(ApiApplication.class, args);
        System.out.println("I启动成功");
    }
}

 @RequestMapping("/exchange")
    public JsonResult exchange(){
        DirectExchange directExchange=new DirectExchange("hello-java-exchange",true,true);
        amqpAdmin.declareExchange(directExchange);
        log.info("创建{}交换机成功","hello-java-exchange");
        return  JsonResult.success("创建交换机成功");
    }

@RequestMapping("/queue")
    public JsonResult queue(){
        Queue queue=new Queue("hello-java-queue",true,false,false);
        amqpAdmin.declareQueue(queue);
        log.info("创建{}交换机成功","hello-java-queue");
        return  JsonResult.success("创建队列成功");
    }

@RequestMapping("/binding")
    public JsonResult binding()
    {
        Binding binding=new Binding("hello-java-queue",
                                    Binding.DestinationType.QUEUE,
                                    "hello-java-exchange",
                                    "hello.java",
                                    null);
        amqpAdmin.declareBinding(binding);
        log.info("创建{}binding成功","hello-java");
        return  JsonResult.success("创建绑定成功");
    }

  @RequestMapping("/sendMessage")
    public JsonResult sendMessage()
    {
        rabbitTemplate.convertAndSend("hello-java-exchange","hello.java","哈哈哈哈");
       log.info("发送消息成功");
        return JsonResult.success("发送消息成功");
    }

@Configuration
public class MyRabbitConfig {
    @Bean
    public MessageConverter messageConverter(){
        return new Jackson2JsonMessageConverter();
    }
}

  @RequestMapping("/sendMessage")
    public JsonResult sendMessage()
    {
        Member member= memberService.getById(116);
        rabbitTemplate.convertAndSend("hello-java-exchange","hello.java",member);
       log.info("发送消息成功");
        return JsonResult.success("发送消息成功");
    }