Linux使用docker安装RabbitMq

1150 阅读 0 点赞

RabbitMQ是一个实现了AMQP（Advanced Message Queuing Protocol）高级消息队列协议的消息队列服务，用Erlang语言。是面向消息的中间件。

你可以把它想像成一个邮局：你把信件放入邮箱，邮递员就会把信件投递到你的收件人处。在这个比喻中，RabbitMQ是一个邮箱、邮局、邮递员。RabbitMQ和邮局的主要区别是，它处理的不是纸，而是接收、存储和发送二进制的数据——消息。

主要流程：生产者（Producer）与消费者（Consumer）和 RabbitMQ 服务（Broker）建立连接，然后生产者发布消息（Message）同时需要携带交换机（Exchange）名称以及路由规则（Routing Key），这样消息会到达指定的交换机，然后交换机根据路由规则匹配对应的 Binding，最终将消息发送到匹配的消息队列（Quene），最后 RabbitMQ 服务将队列中的消息投递给订阅了该队列的消费者（消费者也可以主动拉取消息）。

1、安装docker

点击下面链接查看教程

Docker教程（1）：Linux安装docker

2、使用docker在线拉取RabbitMq镜像或者导入RabbitMq.tar压缩包

2.1、docker在线拉取RabbitMq镜像

docker pull rabbitmq:3-management

2.2、docker导入RabbitMq.tar压缩包

docker load -i RabbitMq.tar

3、使用docker启动RabbitMq

15672 是控制面板
5672 是rabbitmq实际运行端口

docker run \
 -e RABBITMQ_DEFAULT_USER=badianboke \
 -e RABBITMQ_DEFAULT_PASS=123321 \
 --name mq \
 --hostname mq1 \
 -p 15672:15672 \
 -p 5672:5672 \
 -d \
 rabbitmq:3-management

4、查看Rabbitmq控制台

http://170.106.116.159:15672/

Linux使用docker安装RabbitMq

4、新建生产者/发布者消费测试类并运行

package cn.badianboke.mq.helloworld;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import org.junit.Test;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

public class PublisherTest {
    @Test
    public void testSendMessage() throws IOException, TimeoutException {
        // 1.建立连接
        ConnectionFactory factory = new ConnectionFactory();
        // 1.1.设置连接参数，分别是：主机名、端口号、vhost、用户名、密码
        factory.setHost("170.106.116.159");
        factory.setPort(5672);
        factory.setVirtualHost("/");
        factory.setUsername("badianboke");
        factory.setPassword("123321");
        // 1.2.建立连接
        Connection connection = factory.newConnection();

        // 2.创建通道Channel
        Channel channel = connection.createChannel();

        // 3.创建队列
        String queueName = "simple.queue";
        channel.queueDeclare(queueName, false, false, false, null);

        // 4.发送消息
        String message = "hello, rabbitmq!";
        channel.basicPublish("", queueName, null, message.getBytes());
        System.out.println("Send Message Successfully: " + message);

        // 5.关闭通道和连接
        channel.close();
        connection.close();

    }
}

运行截图

Linux使用docker安装RabbitMq

5、新建消费者测试类并运行

package cn.badianboke.mq.helloworld;

import com.rabbitmq.client.*;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

public class ConsumerTest {

    public static void main(String[] args) throws IOException, TimeoutException {
        // 1.建立连接
        ConnectionFactory factory = new ConnectionFactory();
        // 1.1.设置连接参数，分别是：主机名、端口号、vhost、用户名、密码
        factory.setHost("170.106.116.159");
        factory.setPort(5672);
        factory.setVirtualHost("/");
        factory.setUsername("badianboke");
        factory.setPassword("123321");
        // 1.2.建立连接
        Connection connection = factory.newConnection();

        // 2.创建通道Channel
        Channel channel = connection.createChannel();

        // 3.创建队列
        String queueName = "simple.queue";
        channel.queueDeclare(queueName, false, false, false, null);

        // 4.订阅消息
        channel.basicConsume(queueName, true, new DefaultConsumer(channel){
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope,
                                       AMQP.BasicProperties properties, byte[] body) throws IOException {
                // 5.处理消息
                String message = new String(body);
                System.out.println("Received Message: " + message);
            }
        });
        System.out.println("Waiting for Message...");
    }
}

运行截图

Linux使用docker安装RabbitMq