SpringBoot整合RabbitMq

spring.rabbitmq.host=192.168.0.106
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
#spring.rabbitmq.virtual-host=

@Service
public class BookService {

    @RabbitListener(queues = "atguigu.news")
    public void receive(Book book){
        System.out.println("收到消息："+book);
    }

    @RabbitListener(queues = "atguigu")
    public void receive02(Message message){
        System.out.println(message.getBody());
        System.out.println(message.getMessageProperties());
    }
}

public class Book {
    private String bookName;
    private String author;
}

@Configuration
public class MyAMQPConfig {

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

**
 * 自动配置
 *  1、RabbitAutoConfiguration
 *  2、有自动配置了连接工厂ConnectionFactory；
 *  3、RabbitProperties 封装了 RabbitMQ的配置
 *  4、 RabbitTemplate ：给RabbitMQ发送和接受消息；
 *  5、 AmqpAdmin ： RabbitMQ系统管理功能组件;
 *     AmqpAdmin：创建和删除 Queue，Exchange，Binding
 *  6、@EnableRabbit +  @RabbitListener 监听消息队列的内容
 *
 */
@EnableRabbit
@SpringBootApplication
public class SpringbootrabbitmqApplication {

   public static void main(String[] args) {
      SpringApplication.run(SpringbootrabbitmqApplication.class, args);
   }

}

@RunWith(SpringRunner.class)
@SpringBootTest
public class SpringbootrabbitmqApplicationTests {

   @Autowired
   RabbitTemplate rabbitTemplate;

   @Autowired
   AmqpAdmin amqpAdmin;

   @Test
   public void createExchange(){

//    amqpAdmin.declareExchange(new DirectExchange("amqpadmin.exchange"));
//    System.out.println("创建完成");

//    amqpAdmin.declareQueue(new Queue("amqpadmin.queue",true));
//    创建绑定规则

      amqpAdmin.declareBinding(new Binding("amqpadmin.queue", Binding.DestinationType.QUEUE,
            "amqpadmin.exchange","amqp.haha",null));

   }

   /**
    * 1、单播（点对点）
    */
   @Test
   public void contextLoads() {
      //Message需要自己构造一个;定义消息体内容和消息头
      //rabbitTemplate.send(exchage,routeKey,message);

      //object默认当成消息体，只需要传入要发送的对象，自动序列化发送给rabbitmq；
      //rabbitTemplate.convertAndSend(exchage,routeKey,object);
      Map<String,Object> map = new HashMap<>();
      map.put("msg","这是第一个消息");
      map.put("data", Arrays.asList("helloworld",123,true));
      //对象被默认序列化以后发送出去
      //rabbitTemplate.convertAndSend("exchange.direct","atguigu.news",map);
      rabbitTemplate.convertAndSend("exchange.direct","atguigu.news",new com.hourui.bean.Book("西游记22","吴承恩22"));

   }

   //接受数据,如何将数据自动的转为json发送出去
   @Test
   public void receive(){
      Object o = rabbitTemplate.receiveAndConvert("atguigu.news");
      System.out.println(o.getClass());
      System.out.println(o);
   }

   /**
    * 广播
    */
   @Test
   public void sendMsg(){
      rabbitTemplate.convertAndSend("exchange.fanout","",new com.hourui.bean.Book("全职法师","莫凡"));
   }
   
}