投稿
  1. 极客之音首页
  2. 后端开发

RabbitMQ ⾼可⽤普通集群搭建（Docker版）

小半 • • 后端开发 • 阅读 73

导读：本篇文章讲解 RabbitMQ ⾼可⽤普通集群搭建（Docker版），希望对大家有帮助，欢迎收藏，转发！站点地址：www.bmabk.com

1 简介

普通集群： 默认的集群模式, ⽐如有节点 node1和node2、node3，三个节点是普通集群，但是他们仅有相同的元数据,即交换机、队列的结构；
消息只存在其中的⼀个节点⾥⾯，假如消息A，存储在node1节点，消费者连接node1个节点消费消息时，可以直接取出来；但如果 消费者是连接的是其他节点那rabbitmq会把 queue 中的消息从存储它的节点中取出，并经过连接节点转发后再发送给消费者。

问题： 假如node1故障，那node2⽆法获取node1存储未被消费的消息；如果node1持久化后故障，那需要等node1恢复后才可以正常消费。如果ndoe1没做持久化后故障，那消息将会丢失。

该模式更适合于消息⽆需持久化的场景，如⽇志传输的队列。

注意： 集群需要保证各个节点有相同的token令牌。

erlang.cookie是erlang的分布式token⽂件，集群内各个节点的erlang.cookie需要相同，才可以互相通信。

2 搭建

2.1 环境准备

192.168.38.50 node1
192.168.38.51 node2
192.168.38.52 node3

2.2 启动

2.2.1 node1

docker run -d -h node1 --name rabbitMq \
--add-host node1:192.168.38.50 \
--add-host node2:192.168.38.51 \
--add-host node3:192.168.38.52 \
-p4369:4369 -p5671-5672:5671-5672 -p15671-15672:15671-15672 -p 25672:25672 \
-e RABBITMQ_NODENAME=rabbitmq@node1 \
-e RABBITMQ_ERLANG_COOKIE='rosh_rabbitmq_cluster' \
-e RABBITMQ_DEFAULT_USER=admin \
-e RABBITMQ_DEFAULT_PASS=admin \
rabbitmq:management

2.2.2 node2

 docker run -d -h node2 --name rabbitMq \
--add-host node1:192.168.38.50 \
--add-host node2:192.168.38.51 \
--add-host node3:192.168.38.52 \
-p4369:4369 -p5671-5672:5671-5672 -p15671-15672:15671-15672 -p 25672:25672 \
-e RABBITMQ_NODENAME=rabbitmq@node2 \
-e RABBITMQ_ERLANG_COOKIE='rosh_rabbitmq_cluster' \
-e RABBITMQ_DEFAULT_USER=admin \
-e RABBITMQ_DEFAULT_PASS=admin \
rabbitmq:management

2.2.3 node3

 docker run -d -h node3 --name rabbitMq \
--add-host node1:192.168.38.50 \
--add-host node2:192.168.38.51 \
--add-host node3:192.168.38.52 \
-p4369:4369 -p5671-5672:5671-5672 -p15671-15672:15671-15672 -p 25672:25672 \
-e RABBITMQ_NODENAME=rabbitmq@node3 \
-e RABBITMQ_ERLANG_COOKIE='rosh_rabbitmq_cluster' \
-e RABBITMQ_DEFAULT_USER=admin \
-e RABBITMQ_DEFAULT_PASS=admin \
rabbitmq:management

2.3 加入集群

2.3.1 节点1

docker exec -it rabbitMq bash
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl start_app
#查看状态
rabbitmqctl cluster_status

2.3.2 节点2、节点3

docker exec -it rabbitMq bash
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl join_cluster --ram rabbitmq@node1
rabbitmqctl start_app

2.3.3 查看节点信息

命令： rabbitmqctl cluster_status
在这里插入图片描述
描述： 访问主节点控制台

在这里插入图片描述

3 整合SpringBoot

在这里插入图片描述

3.1 pom

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>org.example</groupId>
    <artifactId>java-maven</artifactId>
    <version>1.0-SNAPSHOT</version>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.0.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <java.version>1.8</java.version>
    </properties>


    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <!--日志-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-logging</artifactId>
        </dependency>
        <!--rabbitmq-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>
        <!--公用包-->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.71</version>
        </dependency>
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-collections4</artifactId>
            <version>4.2</version>
        </dependency>
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-lang3</artifactId>
        </dependency>

    </dependencies>


    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <version>2.3.0.RELEASE</version>
            </plugin>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.8.1</version>
                <configuration>
                    <source>1.8</source>
                    <target>1.8</target>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>

3.2 application.yml

server:
  port: 8080

spring:
  rabbitmq:
    username: admin
    password: admin
    virtual-host: /
    #集群
    addresses: 192.168.38.50:5672,192.168.38.51:5672,192.168.38.52:5672
    #手动消费消息
    listener:
      simple:
        acknowledge-mode: manual

3.3 RabbitMqConsts

public final class RabbitMqConsts {

    private RabbitMqConsts() {

    }


    public static final String DIRECT_EXCHANGE_NAME = "direct_exchange";

    public static final String DIRECT_QUEUE = "direct_queue";

    public static final String ROUTING_KEY = "direct_routing_key";


}

3.4 RabbitMqConfig

@Configuration
public class RabbitMqConfig {



    /**
     *  direct交换机
     */
    @Bean
    public Exchange directExchange() {
        return ExchangeBuilder.directExchange(RabbitMqConsts.DIRECT_EXCHANGE_NAME).durable(true).build();
    }

    /**
     *  队列
     */
    @Bean
    public Queue directQueue() {
        return QueueBuilder.durable(RabbitMqConsts.DIRECT_QUEUE).build();
    }


    /**
     *  绑定关系
     */
    @Bean
    public Binding directBinding() {
        return BindingBuilder.bind(directQueue()).to(directExchange()).with(RabbitMqConsts.ROUTING_KEY).noargs();
    }

}

3.5 RabbitmqConsumer

@Component
@RabbitListener(queues = RabbitMqConsts.DIRECT_QUEUE)
@Slf4j
public class RabbitmqConsumer {


    @RabbitHandler
    public void receiveMessage(Message message, String body, Channel channel) throws IOException {
        log.info("接收到消息：{}", body);
        long deliveryTag = message.getMessageProperties().getDeliveryTag();
        channel.basicAck(deliveryTag, false);

    }
}

3.6 Controller

@RestController
@RequestMapping("/provider")
public class ProviderController {


    @Autowired
    private RabbitTemplate rabbitTemplate;


    @GetMapping("/send")
    public String send() {
        String message = "Hello SpringBoot RabbitMq";
        rabbitTemplate.convertAndSend(RabbitMqConsts.DIRECT_EXCHANGE_NAME, RabbitMqConsts.ROUTING_KEY, message);
        return "发送成功";
    }

}

3.7 启动类

@SpringBootApplication
public class RoshSerucityApplication {

    public static void main(String[] args) {
        SpringApplication.run(RoshSerucityApplication.class);
    }

}

3.8 启动

描述： 查看队列。
在这里插入图片描述
测试： 发送消息。

在这里插入图片描述
在这里插入图片描述

4 挂掉node1节点测试

4.1 停掉node1

docker stop rabbitMq

在这里插入图片描述

4.2 查看node2 控制台

在这里插入图片描述

4.3 发送消息

在这里插入图片描述

4.4 node1重启

在这里插入图片描述

4.5 查看node2控制台

在这里插入图片描述

版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。

文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/15075.html

赞 (0)
小半的头像小半
0 0

相关推荐

极客之音——专业性很强的中文编程技术网站，欢迎收藏到浏览器，订阅我们！