zoukankan      html  css  js  c++  java
  • 消息队列的使用 RabbitMQ (二): Windows 环境下集群的实现与优化

    一、RabbitMQ 集群的基本概念

    一个 RabbitMQ 中间件(broker) 由一个或多个 erlang 节点组成,节点之间共享 用户名、虚拟目录、队列消息、运行参数 等, 这个 节点的集合被称为集群。

    举例说明, A、B、C 三个节点同在一个集群中, 发布端向 A 节点发送消息, 消费者可在 B 或 C 接收到消息。消息被消费后被删除。这是最基础的集群模式,不涉及到消息的镜像(high availabilit)。

    不足之处就是当接收消息的节点挂掉后, 其他节点无法取到该节点中未被消费的消息。若做消息持久化, 则在重新启动该节点后,未消费信息可被获取。 若未做消息持久化,则消息丢失。

    二、集群的配置

    1、配置 host

    假设现有 A、B 两台机器,其配置如下

    A

    IP: 178.101.200.160   

    节点名: rabbit-A

    B

    IP:178.101.200.161

    节点名: rabbit-B

    上面所说的节点名,可在 rabbitmq mangement 界面中查看,也可以在命令行中查看。 

    进入RabbitMQ Management 管理界面,右下角 rabbit@3vjap-ysd-0 中的 3vjap-ysd-0 即为当前节点名。

    下面开始配置 hosts:

    在 A、B 的 hosts 文件中,绑定 IP 与 节点名, 如下:

    178.101.20.160    rabbit-A

    178.101.20.161    rabbit-B

    2、配置环境变量文件 rabbitmq-env.conf

    环境变量文件,定义了 rabbitmq 的日志文件、数据存储位置。

    在目录 C:UsersAdministratorAppDataRoamingRabbitMQ 下创建  rabbitmq-env.conf 文件。

    A 中 rabbitmq-env.conf 文件内容如下:

    NODENAME=rabbit@rabbit-A

    NODE_IP_ADDRESS=178.101.20.160 

    NODE_PORT=5672

    RABBITMQ_MNESIA_BASE=C:UsersAdministratorAppDataRoamingRabbitMQdb

    RABBITMQ_LOG_BASE=C:UsersAdministratorAppDataRoamingRabbitMQlog

    B 中 rabbitmq-env.conf 文件内容如下: 

    NODENAME=rabbit@rabbit-B

    NODE_IP_ADDRESS=178.101.20.161

    NODE_PORT=5672

    RABBITMQ_MNESIA_BASE=C:UsersAdministratorAppDataRoamingRabbitMQdb

    RABBITMQ_LOG_BASE=C:UsersAdministratorAppDataRoamingRabbitMQlog

    3、统一 .erlang.cookie  文件

    erlang.cookie是erlang实现分布式的必要文件,erlang分布式的每个节点上要保持相同的.erlang.cookie文件。只有这个文件一致的节点,才能加入到集群中。

    该文件一般存放在两个地方:

    %WINDIR% (c:Windows.erlang.cookie)   此处在我的电脑上是: C:WindowsSystem32configsystemprofile.erlang.cookie

    %HOMEDRIVE%%HOMEPATH% (C:Users\%USERNAME%.erlang.cookie )

    将所有位置的 cookie 文件都替换为机器 A 下的 cookie 文件(注意,此处说的是所有位置,两台机器有四个 cookie 文件,这个四个位置的 cookie 文件都必须相同)。

    4、命令行中添加节点

    在机器 A 中 :

    1)、以管理员身份开启 cmd

    2)、进入工具目录  cd  c:Program FilesRabbitMQ Server abbitmq_server-3.6.6sbin  

    3)、重置 RabbitMQ 

    rabbitmqctl stop_app
    
    rabbitmqctl reset
    
    rabbitmqctl start_app

    在机器 B 中:

    1)、以管理员身份开启 cmd

    2)、进入工具目录  

    cd  c:Program FilesRabbitMQ Server
    abbitmq_server-3.6.6sbin  

    3)、添加 A 节点

    rabbitmqctl stop_app
    rabbitmqctl reset 
    rabbtimqctl join_cluster rabbit@rabbit-A
    rabbitmqctl start_app

    注意,此处在机器 A 中添加 B 节点与 B 中添加 A 节点是同一个效果。

    这样就完成了集群的配置,现在可以在RabbitMQ Management 看到了。

    下面是配置了三个节点之后的集群图:

     相关的两个命令:

    查看集群状态 : rabbitmqctl cluster_status

    删除添加到集群中的队列:rabbitmqctl forget_cluster_node rabbit@rabbit-A

    三、集群状态下发布消息优化

    1、可用 DNS 负载均衡功能。申请一个域名,对应机器 A、B 的 IP 地址, 每次发布消息,可利用 dns 解析的特性自动实现负载均衡。

    2、easynetq 随机选择域名

    var bus = RabbitHutch.CreateBus("host=myfirsthost,mysecondhost", x => x.Register<IClusterHostSelectionStrategy<ConnectionFactoryInfo>, RandomClusterHostSelectionStrategy<ConnectionFactoryInfo>>()); 

    四、消息镜像(高可用性)

         未完待续。

    参考: 

    http://www.rabbitmq.com/clustering.html

    https://blog.csdn.net/u010029983/article/details/45337365

    https://www.cnblogs.com/hegx/p/6097147.html

  • 相关阅读:
    人生十鉴
    ASP.NET MVC 3 Preview 1 发布
    基于IPagedList 的 Asp.Net MVC 分页
    jenkins 更改用户
    MATLAB常用日期和时间函数
    Could not load file or assembly 'AjaxControlToolkit' or one of its dependencies. 错误解决
    ORA00932: inconsistent datatypes: expected A got B
    几种数据库的大数据批量插入
    水晶报表 无效索引。 (异常来自 HRESULT:0x8002000B (DISP_E_BADINDEX))错误的解决
    oracle 更新多条数据
  • 原文地址:https://www.cnblogs.com/yaolin1228/p/8797629.html
Copyright © 2011-2022 走看看