Rabbitmq集群实施手册

Rabbitmq安装与集群实施手册

环境说明

3rabbitmq-1

4rabbitmq-2

一、安装EHang

1.安装依赖包

yum-yinstallmakegccgcc-c++kcmcl-develm4ncurses-developenssl-dcvel

2.编译安装erlang_R16B

上传erlang_R16B至目录/srv/source：

cd/srv/sourcc/crlang_R16B

./configure-prefix=/usr/local/erlang_R16B—with-ssl-enable-threads-enable-smp-support

—cnablc-kcriicl-pol)—criablc-liipc—wiilioul-javau

make&&makeinstall

3.配置erlang环境

In-s/usr/local/erlang_R16B/bin/erl/usr/bin/erl

vi/etc/profile

加入以下内容

ERL_HOME=/usr/local/erlang_R16B

exportPATH=$PATH:$ERL_HOMEA)in

立即生效

source/etc/proflle

4.测试一下是否安装成功，在控制台输入命令erl,显示

ErlangR16BQ2(erts-5.10.3)[source][64-bit][smp:24:24][async-threads:1G][hipe]

[kernel-poll:false]

EshellV5.10.3(abortwithAG)

1>

二、安装python2.7.5

1.安装依赖包

yum-yinstallzlibzlib-dcvel

2.编译安装Python-2.7.6

上传Python-2.7.6至/srv/source目录

cdZsrv/source/Pylhon-2.7.6

./configure-prefix=/usr/local/Python-2.7.6

make&&makeinstall

vi/etc/profile

加入以下内容

PYTHON_HOME=/usr/kKal/Python-2.7.6

exportPATH=$PATH:$PYTHON_HOME/bin

立即生效

source/etc/profile

3.检查是否安装成功

python-V

Python2.7.6

三、安装rabbitmq-server-3.5.4

1.安装依赖包

yum-yinstallxmlto

2.编译安装rabbitmq-server-3.5.4

上传rabbitmq-server-3.5.4.tar至/srv/source目录

tar-xvfrabbitmq-server-3.5.4.tar

cd/srv/source/rabbitmq-seiver-3.5.4

make

makeinstallTARGET_DIR=/srv/rabbitmq-3.5.4SBIN_DIR=/srv/rabbitmq-3.5.4/sbin

MAN_DIR=/srv/rabbitmq-3.5.4/man〃将rabbitmq编译到/srv/rabbitmq-354目录

3.安装web插件管理界面

cd/si*v/rabbitmq-3.5.4/sbin

inkdir/etc/rabbitinq/

./rabbilmq-pluginsenablenibbilmq_managemenl

4.配置hosts文件

vi/etc/hosts

添加

3rabbitmq-l

4rabbitmq-2

5.配置环境变量

vi.bash_profile

添加

RABBITMQ_HOME=/srv/rabbi（mq-3.5.4/rabbitmq

exportPATH=$PATH:$RABBITMQ_HOME/sbin

使配置生效

source.bash_profile

6.启动

rabbitmq-servcr-detached

7.停止：

rabbitmqctlstop（只是提供停止的方法，暂时不停止）

四、登录

配置用户，

rabbitmqctladd_userjycfmqjycfmq

rabbitmqctlset_user_tagsjycfmqadministrator

打开页面

http://l92.168J.13:15672

用户名:jycfmq

密码:jycfmq

五、配置集群

服务器rabbitmq-1与rabbitmq-2都安装好rabbitmq后开始进行集群配置

rabbitmq集群基于erlang,所以需要保证/root/.erlang_cookie一致，用其中一个费盖另

一个即可。

1.停止rabbitmq服务，两台服务器分别执行

rabbitmqctlstop

确认完全停止

ps-eflgreprabbitmq

2.配置节点

rabbNmq-1节点配置：

RABBITMQ_NODE_PORT=5672

RABBITMQ_SERVER_START_ARGS=',-rabbitmq_managcmcntlistener[{port.l5672}]”

RABBITMQ_NODENAME=rabbit@rabbitmq-lrabbitmq-server-detached

rabbitmq-2节点配置：

RABBITMQ_NODE_PORT=5672

RABBITMQ_SERVER_START_ARGS="-rabbitmq_managementlistener[{port,l5672}]"

RABBITMQ_NODENAME=rabbit@rabbitmq-2rabbitmq-server-detached

3.确认节点可以运行

rabbitmq-1服务器执行：

rabbitmqctlcluster_status-nrabbit@rabbitmq-1

rabbitmq-2服务器执行：

rabbitmqctlcluster_status-nrabbit@rabbitmq-2

4停止rabbitmq服务

rabbitmq-1服务器执行：

rabbitmqctl-nrabbit@rabbitmq-1stop_app

rabbitmq-2服务器执行:

rabbitmqctl-nrabbit@rabbitmq-2stop_app

确认服务停止：

ps-eflgreprabbitmq

5.启动rabbitmq服务，仅在rabbitmq-1执行

rabbitmqctl-nrabbit@rabbitmq-1start_app

6.开始集群，rabbitmq-2加入rabbitmq-1

rabbitmqctl-nrabbit@rabbitmq-2join_cluster-ramrabbit@rabbitmq-1

7.通过rabbitmq-1启动rabbitmq-2在rabbitmq-1执行

rabbitmqctl-nrabbit@rabbitmq-2start_app

8.查乔集群状态，两台服务器分别执行

rabbitmqctlckisicr_status

显示如下：

Clusterstatusofnode'rabbit@rabbitmq-2'...

[{nodes,[{disc,['rabbit@rabbitmq-l']},{ram,['rabbit@rabbitmq-2']}]},

{running_nodes,['rabbit@rabbitmq-l','rabbit@rabbitmq-2']},

{cluster_name,<<"rabbit@rabbitmq-l">>}J

{partitions^]}]

9.登录rabbitmq,确认集群成功

在浏览器中输入：3:15672(注意修改服务器地址)

IfaRabbitMQ

Username:guest

Password:........I

Login

登录成功后，首页点击【Overview］，查看节点状态，如果成功，会有两个节点

OverviewConnectionsChannelsExchangesQueuesAdmin

▼Nodes

NameAledescriptors(7)Socketdeicnptocs?)Erlangprocess«sMemoryDiskspaceInfo

rabbittPrabbitmq-123120344MB46GBDisc1StMs

■46GB

rabbit9rabbitmq2120243MBRAM1

■MM&XSMqhwatwma1%“MBIM

六、配置rabbitmq

1.登录rabbitmq

在浏览器中输入：http:.，”3:15672（注意修改服务器地址）

2.添加vhost：jycfOl

a.点击Admin选项卡，右侧选择VirtualHosts

UMT

ihRabbitMQCMw:ratatOMburtvO.OUQS^

mtNQ34.1.6rt*mN穗03

VirtualHosts

EhD*WX(>)

O**v4«wHetwMkMM»Hfittt

HMMU*mK<MdvUnMhedIMal,g<fientTodk«4putM4eWr«f/QC<

/MatKaM5j

KMMIJ7CfO；

Uttr：Irrtrng

IfaRabbitMQOnt”：raMHOubmtuftidmw!

WaWtMQ3Al.ErtanpR|«eO)

VirtualHosts

O*«<v4e«HMM9Mx»od(MMMQ*races

NameUsersUnMfcedVoUlFr«mdlenlVodlc*lpublbhdc^er/pe4

Addviniala，

C‘.・•・•----v

Setpermission

►Deletethisvhost

UM<：fvcfnn

IfaRabbitMQOu<^：raMdtMMntuftIffimse：

KjbMMQ3A.1,tfHeOJ

Users

▼ABUMTSPotecZ

口21，）2Item;.2a3■U>18

CMIKC«Mdftuilhant»HAp«Mw«xd

|GWJtorJ

3.添加策略

a.点击Admin选项卡，右侧选择Policies

OverviewConnectionQveve5Wtu»l5：gV

Policies

▼ANpolkies

b.下方选择Add/updateapolicy,依次输入参数，点击Addpolicy添加

Add/updateapolicy

Virtualhost:phjrOl

Name:|ha-two

Pattern:

Applyto:Exchangesandqueues

Priority:

Definition:ha-modeexactlyStringv|

ha-params2NumberV

Stringv|

ha-sync3iodeautomaticX

String

HA■：LVHT7H?)・HApararndOlF^VncEQOej：?)点击可自动添加

FederationFcdcrsbonupstrcannxt(?)Federationupstream(?)

QueuesMessageTTL|AutoexpireMaxlength|Maxlengthbytes

DeadletterexchangeDeadletterroutingkey

ExchangesAternateexchange

Addpolicy

参数：

ha-modeexactly

ha-params2

ha-sync-modeautomatic

4.手动创建一个队列lest,测试集群是否正常运行

a.选择Queues标签

OverviewConnectionsChannelsExchanges|QueuesAdmin

b.选择Addanewqueue,新建一个队列lest,具体配置如图:

Addanewqueue

AddMessageTTL(?)|Autoexpire(?)|Maxlength(?)|Maxlengthbytes(?)

Deadletterexchange(?)|Deadletterroutingkey(?)|Maximumpriority(?)

Addqueue

点击［Addqueue］添加成功后,rabbilmq-l服务器显示:

OverviewMessagesMessagerates

VirtualhostNameNodeFeaturesStateReadyUnackedTotalincomingdeliver/getack

phjrOltestrabbitmq-2+1Dha-twoidle000

rabbitmq-2服务器显示:

OverviewMessagesMessagerates

VirtualhostNameNodeFeaturesStateReadyUnackedTotalincomingdeliver/getack

phjrOltes