万物各得其和以生,各得其养以成。一一《荀子》

介绍

使用异步多线程方案会导致CPU竞争强烈，故使用MQ

使用MQ能够大大降低项目耦合

名词：

Producer：生产者，发消息的

Consumer：消费者，收消息干活的

Broker：MQ本体

Topic：主题

Queue：消息队列，先进先出

Message：消息报文(内容，一般为json)

单机版本MQ原理

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
package com.ruben.mq;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;

import java.util.Optional;
import java.util.UUID;
import java.util.concurrent.LinkedBlockingDeque;

/**
 * @ClassName: RubenThreadMQ
 * @Description: 我还没有写描述
 * @Date: 2021/2/17 0017 14:52
 * *
 * @author: <achao1441470436@gmail.com>
 * @version: 1.0
 * @since: JDK 1.8
 */
public class RubenThreadMQ {
    private static LinkedBlockingDeque<JSONObject> msgs = new LinkedBlockingDeque<>();

    public static void main(String[] args) {
        Thread producerThread = new Thread(() -> {
            try {
                while (true) {
                    Thread.sleep(1000);
                    msgs.offer(JSON.parseObject("{\"userId\":\"" + UUID.randomUUID() + "\"}"));
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }, "producer");
        producerThread.start();
        Thread consumerThread = new Thread(() -> {
            while (true) {
                Optional.ofNullable(msgs.poll())
                        .ifPresent(data -> System.out.println(Thread.currentThread().getName() + "," + data.getString("userId")));
            }

        }, "consumer");
        consumerThread.start();
    }
}

宕机如何保证MQ消息不丢失

主流MQ都自带持久化策略，不用担心消息丢失

消费者不在，消息是否会丢失

不会，因为存在消息确认机制，必须要消费者消费该消息成功之后，再通知mq删除

MQ服务器端将消息推送给消费者：消费者已经和MQ保持了长连接

消费者主动拉取消息：消费者首次启动

抗高并发：消费者根据自身能力情况拉取MQ消息消费，默认情况取出一条

提高速率：消费者实现集群；批量获取消息消费

安装

首先安装Erlang语言，官网下载

image-20210217183947459

我这里选了个19.1版本

然后安装

image-20210217184210116

一直下一步就行

然后配置环境变量

image-20210217184629696

image-20210217184650180

然后把%ERLANG_HOME%\bin;添加到Path末尾

image-20210217184742685

然后确定

打开控制台，输入erl -version查看版本

如果成功提示版本则表明环境变量生效

image-20210217184900667

然后下载安装RabbitMQ，官网下载

我这里用的3.6.9版本，因为提前下好了

image-20210217190408633

一直下一步就可以了

找到安装目录，我这里是C:\Program Files\RabbitMQ Server\rabbitmq_server-3.6.9\sbin

执行

1
2
3
4
5
6
// 安装管理界面插件
rabbitmq-plugins.bat enable rabbitmq_management
// 启动服务
rabbitmqctl.bat start_app
// 启动mq
rabbitmq-server.bat start

image-20210217191707856

然后我们访问http://127.0.0.1:15672/即可进入

image-20210217191639746