微服务框架

【SpringCloud+RabbitMQ+Docker+Redis+搜索+分布式，系统详解springcloud微服务技术栈课程|黑马程序员Java微服务】

服务异步通讯

53 MQ 集群

53.5 仲裁队列【SpringAMQP】

53.5.1 仲裁队列

之前我们在 浏览器的控制台完成了仲裁队列 的创建，

但是最终我们肯定是要 回到Java 代码的

SpringAMQP创建仲裁队列：

SpringAMQP连接集群，只需要在yaml中配置即可：

试试，先改下 配置【消费者中】

addresses: IP:8071,IP:8072,IP:8073,

OK

来一个新的配置类

package cn.itcast.mq.config;

import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.QueueBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * ClassName: QuorumConfig
 * date: 2022/11/10 15:50
 *
 * @author DingJiaxiong
 */

@Configuration
public class QuorumConfig {

    @Bean
    public Queue quorumQueue(){

        return QueueBuilder.durable("quorum.queue2").quorum().build();
    }

}

OK，把之前那些配置类 都注掉，因为现在是一个全新的 集群了， 直接运行可能会 出现问题

【严谨】

每一个配置类 都这样

监听留一个

一个都不保留，就联系不上 MQ 了

OK，直接启动消费者 服务

OK，启动成功

查看浏览器 控制台 8081

OK，创建成功，也有两个从节点

看看 8082 和 8083

没毛病【这就是通过代码 创建仲裁队列】

OK。 高级篇 就撒花了， 黑马牛逼！！！！！！！！！！！！！！！！1