RabbitMQ 集群环境安装
突然发现自己的英语能力很差,文档看的云里雾里,在安装RabbitMQ集群的时候遇到了很大的麻烦。
安装RabbitMQ的集群环境,首先得来讲如何安装非集群环境
Step1:安装Erlang
啥是Erlang? Look –> http://en.wikipedia.org/wiki/Erlang_%28programming_language%29
下载Erlang的SRC - otp_src_R13B04.tar.gz
./configure --prefix=/usr/local/erlang
make
make install
Step2: 安装Python 2.6以上版本(大部分Linux版本都自带了Python2.6以上版本)
Step3:如果没有simplejson-2.1.1这个Python的lib,需要从此处下载
Step4:下载RabbitMQ Server Package rabbitmq-server-generic-unix-1.7.2.tar.gz
Step5:解压后,进入/home/rabbitmq_server-1.7.2/sbin 目录,运行./rabbitmq-server
如果出现:
+---+ +---+
| | | |
| | | |
| | | |
| +---+ +-------+
| |
| RabbitMQ +---+ |
| | | |
| v1.7.2 +---+ |
| |
+-------------------+
AMQP 8-0
Copyright (C) 2007-2010 LShift Ltd., Cohesive Financial TechnologiesLLC., and Rabbit Technologies Ltd.
Licensed under the MPL. Seehttp://www.rabbitmq.com/
node : rabbit@replica1
app descriptor: /home/rabbitmq_server-1.7.2/sbin/../ebin/rabbit.app
home dir : /root
cookie hash :pR5H9kY3Wra/XdLELT5hgQ==
log :/var/log/rabbitmq/rabbit.log
sasl log :/var/log/rabbitmq/rabbit-sasl.log
database dir : /var/lib/rabbitmq/mnesia/rabbit
starting internal event notification system ...done
starting logging server ...done
starting database ...done
-- kernel ready
starting alarm handler ...done
starting queue supervisor ...done
starting node monitor ...done
starting cluster router ...done
-- core initialized
starting empty DB check ...done
starting codec correctness check ...done
starting exchange recovery ...done
starting queue recovery ...done
starting persister ...done
starting guid generator ...done
-- message delivery logic ready
starting error log relay ...done
starting networking ...done
-- network listeners available
brokerrunning
则代表启动成功。
接下来,就来阐述一下我安装RabbitMQ的方法
首先:我非常欣赏官方文档的详细和无厘头。
官方文档非常详细的介绍了手动配置和自动配置两种手段,手动配置是利用了sbin目录里提供的rabbitmqctl脚本,非常强大而YD,具体就不阐述了,里面有非常靠谱的介绍。但是,不靠谱的是,文档忘记说明三个问题,虽然可能在RabbitMQ Erlang开发人员的眼里,简直是小儿科。
[*]RabbitMQ完全依赖Erlang的Cluster,所以,要构建起RabbitMQ的集群环境,还是需要了解一点Erlang, 不然就是盲人摸象,摸到哪算哪。
这里首先非常感谢Erlang-China上的文档说明:
http://erlang-china.org/study/erlang-distribute-security.html, 让我明白了几个问题:
a. 为什么我的.erlang.cookie不在RabbitMQ文档里说的/var/lib/rabbitmq/.erlang.cookie
因为Erlang产生的.erlang.cookie是在$HOME/.erlang.cookie
既然你完全依赖Erlang的集群环境,你就没必要特别指出你是在/var/lib/rabbitmq里了,何苦呢,如果说你要设置$HOME, 那也得问问我这个使用者感受,是不。
b. 节点间的通信,首要条件是互相可见,Erlang的安全级别只有两种(All or No),要么啥权限都有,要么啥都没有。我非常欣赏这种设计,比起所谓的ACL,在强大的网络和通信能力的光环之下,以及内部网络的基础上,简直是可有可无。
c. 如何保证节点(server)间互相能通信,Erlang采用了Cookie匹配的做法:如果在命令行里面带上 -setcookie ,则在当前节点使用这个cookie值,否则会使用 $HOME/.erlang.cookie。清晰啊···
d. 我非常喜欢-setcookie的做法,直接··
具体的设置方法,该文章讲的非常清楚,我就不赘述了。从中我学到了3样事情:
f. 如何检查节点间是否可以通讯:net_adm:ping(‘foo@192.168.0.2‘).
g. 如何得知当前的Erlang集群中有哪些server:node().
h. 特别注意foo@192.168.0.2,这表明当前的用户,foo1@192.168.0.2 和foo2@192.168.0.2 是代表两个不一样的Erlang节点。
Note:由于我好暂时不需要Security相关的东西,所以也没花功夫去看。
2. 建立在1的基础上,我们已经知道如何配置Erlang的集群了,接下来就是RabbitMQ
a. 删除/var/lib/rabbitmq/mnesia
似乎Erlang或者是MQ做了一些让人摸不着头脑的事情,一旦启动过了MQ(单机版)就会随机产生一个Cookie,并且,这个cookie是会保存在Mnesia的Schema中的。所以如果你在安装好MQ之后,异常兴奋,如我这般启动过了MQ,那就会掉入文档的一个陷阱中。
b. 修改 rabbit-server 脚本
经管有文档中已经有非常傻瓜的配置方法了,并且也提到了:
As an alternative, you can insert the option "-setcookie cookie" in the erl call in the rabbitmq-server and rabbitmqctl scripts.
但是因为信任度的关系,我还是相信了Erlang-China。修改的rabbit-server日下:
${RABBITMQ_EBIN_PATH} \
${RABBITMQ_START_RABBIT} \
-sname ${RABBITMQ_NODENAME}\
-boot ${RABBITMQ_BOOT_FILE}\
${RABBITMQ_CONFIG_ARG} \
+W w \
${RABBITMQ_SERVER_ERL_ARGS}\
${RABBITMQ_LISTEN_ARG} \
-sasl errlog_type error \
-kernel error_logger'{file,"'${RABBITMQ_LOGS}'"}' \
-sasl sasl_error_logger'{file,"'${RABBITMQ_SASL_LOGS}'"}' \
-os_mon start_cpu_sup true \
-os_mon start_disksup false\
-os_mon start_memsup false \
-mnesia dir"\"${RABBITMQ_MNESIA_DIR}\"" \
${RABBITMQ_CLUSTER_CONFIG_OPTION} \
namerabbit@replica2 -setcookie rabbit \
${RABBITMQ_SERVER_START_ARGS} \
"$@"
其中,要注意的地方是:
i. rabbit@replica2, replica2是指的当前server的hostName(etc/hosts)。
ii. 设置的cookie是叫rabbit,也就是说这个名字可以随便定,无所谓。
iii. 同样,我试过不用Host而用IP,结果似乎不能运行(但是在Erlang的集群配置中,IP还是HostName并不是一个big issue。
3. 启动rabbit-server,直接点,别rabbitmq-server –detach了。
4. 另起一个console,运行
CentOS4.4-64:replica:root > ./rabbitmqctl status
Status of node rabbit@replica ...
[{running_applications,[{rabbit,"RabbitMQ","1.7.2"},
{mnesia,"MNESIA CXC 13812","4.4.13"},
{os_mon,"CPO CXC 13846","2.2.5"},
{sasl,"SASL CXC 13811","2.1.9"},
{stdlib,"ERTS CXC 13810","1.16.5"},
{kernel,"ERTS CXC 13810","2.13.5"}]},
{nodes,},
{running_nodes,}]
...done.
童鞋们,集群了,咱也是文化狼了···
页:
[1]