万物各得其和以生,各得其养以成。一一《荀子》
介绍
使用异步多线程方案会导致CPU竞争强烈，故使用MQ
使用MQ能够大大降低项目耦合
名词：
Producer：生产者，发消息的
Consumer：消费者，收消息干活的
Broker：MQ本体
Topic：主题
Queue：消息队列，先进先出
Message：消息报文(内容，一般为json)
单机版本MQ原理
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语言，官网下载
我这里选了个19.1版本
然后安装
一直下一步就行
然后配置环境变量
然后把%ERLANG_HOME%\bin;添加到Path末尾
然后确定
打开控制台，输入erl -version查看版本
如果成功提示版本则表明环境变量生效
然后下载安装RabbitMQ，官网下载
我这里用的3.6.9版本，因为提前下好了
一直下一步就可以了
找到安装目录，我这里是C:\Program Files\RabbitMQ Server\rabbitmq_server-3.6.9\sbin
执行
// 安装管理界面插件 rabbitmq-plugins.bat enable rabbitmq_management // 启动服务 rabbitmqctl.bat start_app // 启动mq rabbitmq-server.bat start
然后我们访问http://127.0.0.1:15672/即可进入
