RabbitMQ安装及简单使用

news2024/10/7 14:24:02

说明：RabbitMQ（官网：）是一门异步通讯技术，使用异步通讯技术，可解决同步通讯的一些问题。

安装

本文介绍在云服务器上安装RabbitMQ，操作系统是CentOS 7，远程连接工具是WindTerm；

第一步：拉取镜像

镜像版本选择，3.8-management

docker pull rabbitmq:3.8-management

我这里显示已经安装过，首次安装会下载一些文件，等下载完成即可；
在这里插入图片描述

第二步：运行容器

输入下面命令，运行RabbitMQ容器，设置登录账号为：root，密码：123456

docker run \
 -e RABBITMQ_DEFAULT_USER=root \
 -e RABBITMQ_DEFAULT_PASS=123456 \
 -v mq-plugins:/plugins \
 --name mq \
 --hostname mq \
 -p 15672:15672 \
 -p 5672:5672 \
 -d \
 rabbitmq:3.8-management

第三步：登录MQ平台

可打开浏览器，输入：IP:15672，进入RabbitMQ的管理平台

在这里插入图片描述

查看设置的账户信息；

在这里插入图片描述

使用

打开IDEA，创建一个项目（rabbitmq_demo），项目下有两个服务模块（发送者sender，接受者receiver）

第一步：添加依赖

在父模块的pom.xml文件中添加这三个依赖，

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.9.RELEASE</version>
        <relativePath/>
    </parent>

    <dependencies>
        <!--lombok依赖，用于生成set、get、toString方法-->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>

        <!--AMQP依赖，包含RabbitMQ-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>

        <!--单元测试-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
        </dependency>
    </dependencies>

第二步：编码

父模块不写代码，两个子模块需要创建对应的启动类，然后具体代码写在对应的测试类里；

在这里插入图片描述

发送者测试代码（SenderTest.java）

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

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

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Test
    public void testSender() {
        rabbitTemplate.convertAndSend("demo.queue","hello rabbit mq!");
    }
}

发送者配置文件（application.yml），注意设置对应的IP地址

spring:
  rabbitmq:
    # MQ ip地址
    host: xx.xx.xx.xx
    # MQ的端口号
    port: 5672
    # 虚拟主机 每个用户单独对应一个 不同用户之间无法访问彼此的虚拟主机
    virtual-host: /
    # 用户名
    username: root
    # 密码
    password: 123456

接收者代码（ReceiverTest.java），注意修改对应的IP地址

import com.rabbitmq.client.*;
import org.springframework.boot.test.context.SpringBootTest;

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

@SpringBootTest
public class ReceiverTest {
    public static void main(String[] args) throws IOException, TimeoutException {

        // 1.建立连接
        ConnectionFactory factory = new ConnectionFactory();

        // 1.1.设置连接参数，分别是：主机名、端口号、vhost、用户名、密码
        factory.setHost("xxx.xxx.xxx.xxx");
        factory.setPort(5672);
        factory.setVirtualHost("/");
        factory.setUsername("root");
        factory.setPassword("123456");

        // 1.2.建立连接
        Connection connection = factory.newConnection();

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

        // 3.创建队列
        String queueName = "demo.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) {

                // 5.处理消息
                String message = new String(body);
                System.out.println("接收到消息：【" + message + "】");
            }
        });
        System.out.println("等待接收消息.....");
    }
}