安装

Windows安装

安装erLang语言

进入官网

下载完之后一直下一步安装即可，安装完成后进入目录，配置环境变量

安装RabbitMQ服务端

Release RabbitMQ 3.7.3 · rabbitmq/rabbitmq-server (github.com)

一直下一步安装即可

安装完成后打开安装目录，进入到这个文件夹打开命令行

输入命令安装插件

rabbitmq-plugins enable rabbitmq_management

完成后双击rabbitmq-server.bat

打开http://localhost:15672/

用户名密码是guest/guest

Linux下使用 Docker 安装

直接拉取最新版

docker pull rabbitmq

运行容器

docker run -d --name rabbit -p 15672:15672 -p 5672:5672 rabbitmq

进入容器

docker exec -it rabbit /bin/bash

开启管理插件

rabbitmq-plugins enable rabbitmq_management

打开管理网站 http://localhost:15672/

用户名密码均为guest

实操

新建Maven项目

添加依赖

<dependency>
        <groupId>com.rabbitmq</groupId>
        <artifactId>amqp-client</artifactId>
        <version>5.0.0</version>
</dependency>

编写发送端

package org.example;

import java.util.concurrent.TimeoutException;

import com.rabbitmq.client.Channel;  
import com.rabbitmq.client.Connection;  
import com.rabbitmq.client.ConnectionFactory;  

public class Send  
{  
    //队列名称
    private final static String QUEUE_NAME = "helloMQ";  

    public static void main(String[] argv) throws java.io.IOException, TimeoutException  
    {  
        /**
         * 创建连接连接到MabbitMQ
         */  
        ConnectionFactory factory = new ConnectionFactory();  
        //设置MabbitMQ所在主机ip或者主机名
        factory.setHost("localhost");  
        //创建一个连接
        Connection connection = factory.newConnection();  
        //创建一个频道
        Channel channel = connection.createChannel();  
        //指定一个队列
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);  
        //发送的消息
        String message = "hello world!";  
        //往队列中发出一条消息
        channel.basicPublish("", QUEUE_NAME, null, message.getBytes());  
        System.out.println(" [x] Sent '" + message + "'");  
        //关闭频道和连接
        channel.close();  
        connection.close();  
     }  
}

编写接收端

package org.example;

import com.rabbitmq.client.*;

import java.io.IOException;

public class Recv {

    // 队列名称
    private final static String QUEUE_NAME = "helloMQ";

    public static void main(String[] argv) throws Exception {

        // 打开连接和创建频道，与发送端一样
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();
        //声明队列，主要为了防止消息接收者先运行此程序，队列还不存在时创建队列。
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        System.out.println(" [*] Waiting for messages. To exit press CTRL+C");

        //创建消费者
        Consumer consumer = new DefaultConsumer(channel) {
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties,
                    byte[] body) throws IOException {
                String message = new String(body, "UTF-8");
                System.out.println(" [x] Received '" + message + "'");
            }
        };
        channel.basicConsume(QUEUE_NAME, true, consumer);
    }
}