C:\Users\24724>erl -version
Erlang (SMP,ASYNC_THREADS) (BEAM) emulator version 13.1.3

rabbitmq-plugins enable rabbitmq_management

 <dependencies>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>5.1.7.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.amqp</groupId>
            <artifactId>spring-rabbit</artifactId>
            <version>2.1.8.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
        </dependency>

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-test</artifactId>
            <version>5.1.7.RELEASE</version>
        </dependency>
    </dependencies>

/**
 *
 * 發(fā)送消息
 */
public class Producer_HelloWorld {
    public static void main(String[] args) throws IOException, TimeoutException {

        //1.創(chuàng)建連接工廠
        ConnectionFactory factory = new ConnectionFactory();
        //2. 設(shè)置參數(shù)
        factory.setHost("localhost");//ip  默認(rèn)值 localhost
        factory.setPort(5672); //端口  默認(rèn)值 5672
        factory.setVirtualHost("/ittest");//虛擬機(jī) 默認(rèn)值/
        factory.setUsername("guest");//用戶名 默認(rèn) guest
        factory.setPassword("guest");//密碼 默認(rèn)值 guest
        //3. 創(chuàng)建連接 Connection
        Connection connection = factory.newConnection();
        //4. 創(chuàng)建Channel
        Channel channel = connection.createChannel();
        //5. 創(chuàng)建隊列Queue
        /*
        queueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete, Map<String, Object> arguments)
        參數(shù)：
            1. queue：隊列名稱
            2. durable:是否持久化，當(dāng)mq重啟之后，還在
            3. exclusive：
                * 是否獨(dú)占。只能有一個消費(fèi)者監(jiān)聽這隊列
                * 當(dāng)Connection關(guān)閉時，是否刪除隊列
                *
            4. autoDelete:是否自動刪除。當(dāng)沒有Consumer時，自動刪除掉
            5. arguments：參數(shù)。

         */
        //如果沒有一個名字叫hello_world的隊列，則會創(chuàng)建該隊列，如果有則不會創(chuàng)建
        channel.queueDeclare("hello_world",true,false,false,null);
        /*
        basicPublish(String exchange, String routingKey, BasicProperties props, byte[] body)
        參數(shù)：
            1. exchange：交換機(jī)名稱。簡單模式下交換機(jī)會使用默認(rèn)的 ""
            2. routingKey：路由名稱
            3. props：配置信息
            4. body：發(fā)送消息數(shù)據(jù)

         */

        String body = "hello rabbitmq~~~";

        //6. 發(fā)送消息
        channel.basicPublish("","hello_world",null,body.getBytes());


        //7.釋放資源
        channel.close();
        connection.close();
    }
}

public class Consumer_HelloWorld {
    public static void main(String[] args) throws IOException, TimeoutException {
        //1.創(chuàng)建連接工廠
        ConnectionFactory factory = new ConnectionFactory();
        //2. 設(shè)置參數(shù)
        factory.setHost("localhost");//ip  默認(rèn)值 localhost
        factory.setPort(5672); //端口  默認(rèn)值 5672
        factory.setVirtualHost("/ittest");//虛擬機(jī) 默認(rèn)值/
        factory.setUsername("guest");//用戶名 默認(rèn) guest
        factory.setPassword("guest");//密碼 默認(rèn)值 guest
        //3. 創(chuàng)建連接 Connection
        Connection connection = factory.newConnection();
        //4. 創(chuàng)建Channel
        Channel channel = connection.createChannel();
        //5. 創(chuàng)建隊列Queue
        /*
        queueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete, Map<String, Object> arguments)
        參數(shù)：
            1. queue：隊列名稱
            2. durable:是否持久化，當(dāng)mq重啟之后，還在
            3. exclusive：
                * 是否獨(dú)占。只能有一個消費(fèi)者監(jiān)聽這隊列
                * 當(dāng)Connection關(guān)閉時，是否刪除隊列
                *
            4. autoDelete:是否自動刪除。當(dāng)沒有Consumer時，自動刪除掉
            5. arguments：參數(shù)。

         */
        //如果沒有一個名字叫hello_world的隊列，則會創(chuàng)建該隊列，如果有則不會創(chuàng)建
        channel.queueDeclare("hello_world",true,false,false,null);

        /*
        basicConsume(String queue, boolean autoAck, Consumer callback)
        參數(shù)：
            1. queue：隊列名稱
            2. autoAck：是否自動確認(rèn)
            3. callback：回調(diào)對象

         */
        // 接收消息
        Consumer consumer = new DefaultConsumer(channel){
            /*
                回調(diào)方法，當(dāng)收到消息后，會自動執(zhí)行該方法

                1. consumerTag：標(biāo)識
                2. envelope：獲取一些信息，交換機(jī)，路由key...
                3. properties:配置信息
                4. body：數(shù)據(jù)

             */
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
                System.out.println("consumerTag："+consumerTag);
                System.out.println("Exchange："+envelope.getExchange());
                System.out.println("RoutingKey："+envelope.getRoutingKey());
                System.out.println("properties："+properties);
                System.out.println("body："+new String(body));
            }
        };
        channel.basicConsume("hello_world",true,consumer);


        //關(guān)閉資源？不要,因?yàn)橐恢北O(jiān)聽消息
    }
}