RabbitMQ安装

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();
    }
}

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