SpringCloud之RabbitMQ设计者模式

up:: SpringCloud分布式锁原理

说明：

需要在Linux虚拟机上安装。。。

RabbitMQ在LinuxCentOS7上安装

实现生产者消费者模式

package com.imooc.cloud.mall.practice.cartorder.utils;
 
import java.util.concurrent.ArrayBlockingQueue;
 
public class MyBlockingQueue {
    public static void main(String[] args) {
        ArrayBlockingQueue<Object> queue = new ArrayBlockingQueue<>(10);
        Runnable producer  = new Runnable() {
            @Override
            public void run() {
                while(true){
                    try{
                        queue.put(new Object());
                        System.out.println("生产者已生产");
                    }catch (InterruptedException e){
                        e.printStackTrace();
                    }
                }
            }
        };
 
        new Thread(producer).start();
 
        Runnable consumer  = new Runnable() {
            @Override
            public void run() {
                while(true){
                    try{
                        queue.take();
                        System.out.println("消费者已消费");
                    }catch (InterruptedException e){
                        e.printStackTrace();
                    }
                }
            }
        };
        new Thread(consumer).start();
    }
}