RabbitMQ

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.2.4.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.atguigu</groupId>
    <artifactId>spring-boot-rabbitmq01</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>spring-boot-rabbitmq01</name>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.springframework.amqp</groupId>
            <artifactId>spring-rabbit-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

#连接的IP地址
spring.rabbitmq.host=113.222.25.89
#连接用户
spring.rabbitmq.username=root
#连接密码
spring.rabbitmq.password=root

package com.atguigu.springboo;
import org.springframework.amqp.rabbit.annotation.EnableRabbit;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
/*
自动配置
1.RabbitAutoConfiguration
2.自动配置了连接工厂
3.rabbitProperties封装了RabbitMQ的配置
4.RabbitTemplate:给rabbitmq发送消息和接受消息
5.amqpAdmin:RabbitMQ系统管理功能组件
6.@RabbitListener+@EnableRabbit 监听消息队列的内容
 */
@EnableRabbit //开启基于注解的Rabbit模式
@SpringBootApplication
public class SpringBootRabbitmq01Application {
    public static void main(String[] args) {
        SpringApplication.run(SpringBootRabbitmq01Application.class, args);
    }
}

package com.atguigu.springboo;
import com.atguigu.springboo.bean.Book;
import org.junit.jupiter.api.Test;
import org.springframework.amqp.core.AmqpAdmin;
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;
@SpringBootTest
class SpringBootRabbitmq01ApplicationTests {
    @Autowired
    RabbitTemplate rabbitTemplate;
    @Autowired
    AmqpAdmin amqpAdmin;
    @Test
    public void createExchange(){
        //创建交换器
        //amqpAdmin.declareExchange(new DirectExchange("amqpadmin.exchange"));
        //创建队列
        //amqpAdmin.declareQueue(new Queue("amqpadmin.queue",true));
        //参数绑定
        amqpAdmin.declareBinding( new Binding("amqpadmin.queue",Binding.DestinationType.QUEUE,"amqpadmin.exchange","amqp,haha",null));
    }
    /*
    单播(点对点)
     */
    @Test
    void contextLoads() {
        //message需要自己构造; 可以定义消息体内容和消息头
        // rabbitTemplate.send(exchage,routeKey,message);
        //object默认当成消息体只需要传入要发送的对象,自动序列化发送给rabbitmq
        //rabbitTemplate.convertAndSend(exchahe,routeKey,object);
        Map<String,Object> map=new HashMap<>();
        map.put("msg","你真帅啊");
        map.put("data", Arrays.asList("helloword",123,true));
        //对象被默认序列化
        rabbitTemplate.convertAndSend("exchange.direct","atguigu.news",map );
    }
    //接受数据
    @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 Book("红楼梦",20));
    }
}

package com.atguigu.springboo.config;
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class MyAMQPConfig {
    @Bean
    public MessageConverter messageConverter(){
        return  new Jackson2JsonMessageConverter();
    }
}