首页 > 其他分享 >消息队列部署选择

消息队列部署选择

时间:2023-02-07 15:23:16浏览次数:45  
标签:选择 队列 RabbitMQ queue 部署 实例 集群 模式 高可用性

部署是单机还是集群呢?你们高可用是怎么保证的呢?

如果有人问到你 MQ 的知识,高可用是必问的。上一讲提到,MQ 会导致系统可用性降低。所以只要你用了 MQ,接下来问的一些要点肯定就是围绕着 MQ 的那些缺点怎么来解决了。

RabbitMQ 的高可用性

RabbitMQ 是比较有代表性的,因为是基于主从(非分布式)做高可用性的,我们就以 RabbitMQ 为例子讲解第一种 MQ 的高可用性怎么实现。

RabbitMQ 有三种模式:单机模式、普通集群模式、镜像集群模式。

单机模式

单机模式,就是 Demo 级别的,一般就是你本地启动了玩玩儿的,没人生产用单机模式。

普通集群模式(无高可用性)

普通集群模式,意思就是在多台机器上启动多个 RabbitMQ 实例,每台机器启动一个。你创建的 queue,只会放在一个 RabbitMQ 实例上,但是每个实例都同步 queue 的元数据(元数据可以认为是 queue 的一些配置信息,通过元数据,可以找到 queue 所在实例)。你消费的时候,实际上如果连接到了另外一个实例,那么那个实例会从 queue 所在实例上拉取数据过来。

 

 

这种方式确实很麻烦,也不怎么好,没做到所谓的分布式,就是个普通集群。因为这导致你要么消费者每次随机连接一个实例然后拉取数据,要么固定连接那个 queue 所在实例消费数据,前者有数据拉取的开销,后者导致单实例性能瓶颈

而且如果那个放 queue 的实例宕机了,会导致接下来其他实例就无法从那个实例拉取,如果你开启了消息持久化,让 RabbitMQ 落地存储消息的话,消息不一定会丢,得等这个实例恢复了,然后才可以继续从这个 queue 拉取数据。

所以这个事儿就比较尴尬了,这就没有什么所谓的高可用性这方案主要是提高吞吐量的,就是说让集群中多个节点来服务某个 queue 的读写操作。

镜像集群模式(高可用性)

这种模式,才是所谓的 RabbitMQ 的高可用模式。跟普通集群模式不一样的是,在镜像集群模式下,你创建的 queue,无论是元数据还是 queue 里的消息都会存在于多个实例上,就是说,每个 RabbitMQ 节点都有这个 queue 的一个完整镜像,包含 queue 的全部数据的意思。然后每次你写消息到 queue 的时候,都会自动把消息同步到多个实例的 queue 上。

 

 

那么如何开启这个镜像集群模式呢?其实很简单,RabbitMQ 有很好的管理控制台,就是在后台新增一个策略,这个策略是镜像集群模式的策略,指定的时候是可以要求数据同步到所有节点的,也可以要求同步到指定数量的节点,再次创建 queue 的时候,应用这个策略,就会自动将数据同步到其他的节点上去了。

 

标签:选择,队列,RabbitMQ,queue,部署,实例,集群,模式,高可用性
From: https://www.cnblogs.com/songyunjie/p/17098544.html

相关文章

  • centos7+nginx+uwsgi+python3.7.4+django部署实践
    yuminstallpython3yuminstallpython3-develyum-yinstallgccgcc-c++pip3installuwsgipython3​​manage.py​​runserver10.5.1.65:82uwsgi--iniuwsgi.i......
  • 选择排序
    选择排序算法原理:  首先在未排序序列中假设第一个元素为最小或者最大元素,然后再从剩余的元素中选择最小的(或者最大的)元素,然后放到已排序的头部或者尾部。以此类推,直到......
  • 外卖CPS小程序部署指南,个人获取美团外卖小程序跳转链接
    大家好,我是小悟上次利用闲暇时间弄了个外卖CPS小程序,并把代码开源出来,还是有挺多小伙伴来领取源码的。不仅有同行的人,还有跨行的人,也摸索着搞出来小程序推一推。有几个小伙......
  • 线上项目的服务部署
     跨服的部署:1跨服节点1的节点:route、manage、db、idip、common2 跨服节点2-3的节点:route、manage、db、idip3 跨服节点4-10的节点:route、manage、......
  • k8s部署xxl-job-admin
    概述XXL-JOB是一个轻量级分布式任务调度平台,其核心设计目标是开发迅速、学习简单、轻量级、易扩展。现已开放源代码并接入多家公司线上产品线,开箱即用。xxl-job-admin需......
  • 基于k8s的kafka部署
    1.官方  https://kafka.apache.org2.k8s部署2.1.编译镜像DockerfileENVKAFKA_USER=kafka\KAFKA_DATA_DIR=/var/lib/kafka/data\JAVA_HOME=/usr/lib/jvm/java......
  • 一步步调教Cobbler安装、配置、部署
    原地址:https://blog.csdn.net/TzuHenry_AZ/article/details/1218836041.准备环境:关闭防火墙、配好yum源、服务器配好IP、SElinux关闭。2.安装epel源:[root@solomon11:49......
  • 租用服务器如何选择带宽,带宽越大越好吗
    首先要了解带宽是什么~ 对于服务器来说带宽分两种:上行带宽和下行带宽上行带宽:是指在服务器上传数据的速度,对用户来说是从服务器里下载数据的速度。下行带宽:就是指服务......
  • (转)go语言-golang基础-queue队列和stack堆栈
    原文:https://www.cnblogs.com/malukang/p/12708850.html1.queue队列队列(queue),是一种FIFO(FirstInFirstOut)先进先出的线性表。通常用数据或者链表来实现队列。队......
  • 姜雨:从牛羊基因组选择到分子设计育种
     https://mp.weixin.qq.com/s/l6BgFt6-aw1aBIprNR4A_Q ......