消息队列对于处理高并发还是非常不错的选择。所以电商必然会采取这种方式。废话不多说。贴代码先。
搭建环境：
Mac OS X 10.10.5 VMware Fusion8 Centos 6.7 rabbitmq-server-3.5.6-1.noarch.rpm erlang-17.4-1.el6.x86_64.rpm
- rabbitmq的搭建
wget http://www.rabbitmq.com/releases/erlang/erlang-17.4-1.el6.x86_64.rpm yum install erlang-17.4-1.el6.x86_64.rpm
- 安装rabbitmq
wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.5.6/rabbitmq-server-3.5.6-1.noarch.rpm rpm --import http://www.rabbitmq.com/rabbitmq-signing-key-public.asc yum install rabbitmq-server-3.5.6-1.noarch.rpm
- 安装rabbitmq插件
安装RabbitMQ WebUI管理插件
rabbitmq-plugins enable rabbitmq_management
service rabbitmq-server restart
打开浏览器登录http://127.0.0.1: 15672
启动RabbitMQ Server
service rabbitmq-server start
- 集群搭建
太啰嗦的就不说了。需要注意的我会在这里提出：
- 你的host需要修改 在node1代码块可以看到。如果不改变，重启 shutdown -r now
- 你的.erlang.cookie 也是需要修改并都保持一样。
- 修改配置文件的时候要注意括号。
stop [<pid_file>] 停止服务根据进程号 stop_app start_app wait <pid_file> 暂停 reset 重置 force_reset 强制重置 rotate_logs <suffix> 日志文件 后缀 join_cluster <clusternode> [—ram] 加入集群 cluster_status 集群状态 change_cluster_node_type disc | ram 改变集群节点类型 forget_cluster_node [--offline] 取消节点 rename_cluster_node oldnode1 newnode1 [oldnode2] [newnode2 …] 重命名节点 update_cluster_nodes clusternode 更新节点 force_boot 重置引导 sync_queue queue 同步队列 cancel_sync_queue queue 取消同步队列 purge_queue queue 清除队列 set_cluster_name name 设置集群名称 add_user <username> <password> 添加用户 delete_user <username> 删除用户 change_password <username> <newpassword> 修改密码 clear_password <username> 清除密码 set_user_tags <username> <tag> ...设置角色权限 list_users 查看所有的用户 add_vhost <vhostpath> 添加主机 delete_vhost <vhostpath> 删除主机 list_vhosts [<vhostinfoitem> …] 所有主机 set_permissions [-p <vhostpath>] <user> <conf> <write> <read> 给主机指定用户 clear_permissions [-p <vhostpath>] <username> 清除一个主机的用户 list_permissions [-p <vhostpath>] 一个主机下面的绑定的用户 list_user_permissions <username> 用户的权限
node1：
sjk@192.168.10.73's password: Last login: Tue Nov 3 00:16:23 2015 from 192.168.10.14 [sjk@rabbitmq-node1 ~]$ ls Desktop Documents Downloads Music Pictures Public Templates Videos [sjk@rabbitmq-node1 ~]$ cd /usr/local/ [sjk@rabbitmq-node1 local]$ ls bin games jdk1.7.0_80 lib64 nginx sbin src usr etc include lib libexec openssl share tomcat [sjk@rabbitmq-node1 local]$ ls bin games jdk1.7.0_80 lib64 nginx sbin src usr etc include lib libexec openssl share tomcat [sjk@rabbitmq-node1 local]$ cd /usr/programmer/ [sjk@rabbitmq-node1 programmer]$ ls apache-tomcat-8.0.26.tar.gz nginx-1.9.4.tar.gz erlang-17.4-1.el6.x86_64.rpm openssl-1.0.2c.tar.gz go1.4.2.linux-amd64.tar.gz rabbitmq-server-3.5.6-1.noarch.rpm jdk-7u80-linux-x64.tar.gz redis-3.0.3.tar mongodb-linux-x86_64-3.0.6.tgz solr-5.2.1.tgz mongodb-osx-x86_64-3.0.6.tgz zookeeper-3.4.6.tar.gz nginx-1.8.0.tar.gz [sjk@rabbitmq-node1 programmer]$ cat /etc/hosts 192.168.10.73 rabbitmq-node1.com rabbitmq-node1 192.168.10.74 rabbitmq-node2.com rabbitmq-node2 192.168.10.75 rabbitmq-node3.com rabbitmq-node3 [sjk@rabbitmq-node1 programmer]$ vim /etc/hosts [sjk@rabbitmq-node1 programmer]$ sudo -i [sudo] password for sjk: [root@rabbitmq-node1 ~]# vim /etc/hosts [root@rabbitmq-node1 ~]# service rabbitmq-server start Starting rabbitmq-server: SUCCESS rabbitmq-server. [root@rabbitmq-node1 ~]# cd /etc/rabbitmq/ [root@rabbitmq-node1 rabbitmq]# ls enabled_plugins [root@rabbitmq-node1 rabbitmq]# mv /usr/rabbitmq.config /etc/rabbitmq/ [root@rabbitmq-node1 rabbitmq]# cat /var/lib/rabbitmq/.erlang.cookie ATDTSAHIFSBKTQDSYKMA [root@rabbitmq-node1 rabbitmq]# service rabbitmq-server stop Stopping rabbitmq-server: rabbitmq-server. [root@rabbitmq-node1 rabbitmq]# vim rabbitmq.config [root@rabbitmq-node1 rabbitmq]# vim /etc/rabbitmq/rabbitmq-env.conf [root@rabbitmq-node1 rabbitmq]# vim /etc/rabbitmq/rabbitmq-env.conf [root@rabbitmq-node1 rabbitmq]# service rabbitmq-server start Starting rabbitmq-server: SUCCESS rabbitmq-server. [root@rabbitmq-node1 rabbitmq]# service rabbitmq-server stop Stopping rabbitmq-server: rabbitmq-server. [root@rabbitmq-node1 rabbitmq]# ls enabled_plugins rabbitmq.config rabbitmq-env.conf [root@rabbitmq-node1 rabbitmq]# cat rabbitmq-env.conf RABBITMQ_MNESIA_BASE=/var/lib/rabbitmq/ #需要使用的MNESIA数据库的路径 RABBITMQ_LOG_BASE=/var/log/rabbitmq/ #log的路径 RABBITMQ_PLUGINS_DIR=/usr/lib/rabbitmq/lib/rabbitmq_server-3.5.6/plugins/ #插件的路径 [root@rabbitmq-node1 rabbitmq]# vim rabbitmq.config [root@rabbitmq-node1 rabbitmq]# service rabbitmq-server start Starting rabbitmq-server: FAILED - check /var/log/rabbitmq/startup_{log, _err} rabbitmq-server. [root@rabbitmq-node1 rabbitmq]# cat /var/log/rabbitmq/startup_err Crash dump was written to: erl_crash.dump could not start kernel pid (application_controller) (error in config file "/etc/rabbitmq/rabbitmq.config" (253): syntax error before: ']') [root@rabbitmq-node1 rabbitmq]# vim rabbitmq.config [root@rabbitmq-node1 rabbitmq]# service rabbitmq-server start Starting rabbitmq-server: SUCCESS rabbitmq-server. [root@rabbitmq-node1 rabbitmq]# service rabbitmq-server stop Stopping rabbitmq-server: rabbitmq-server. [root@rabbitmq-node1 rabbitmq]# service rabbitmq-server start Starting rabbitmq-server: SUCCESS rabbitmq-server. [root@rabbitmq-node1 rabbitmq]# rabbitmqctl cluster_status Cluster status of node 'rabbit@rabbitmq-node1' ... [{nodes,[{disc,['rabbit@rabbitmq-node1']}]}, {running_nodes,['rabbit@rabbitmq-node1']}, {cluster_name,<<"rabbit@rabbitmq-node1.com">>}, {partitions,[]}] [root@rabbitmq-node1 rabbitmq]# rabbitmqctl stop_app Stopping node 'rabbit@rabbitmq-node1' ... [root@rabbitmq-node1 rabbitmq]# rabbitmqctl reset Resetting node 'rabbit@rabbitmq-node1' ... [root@rabbitmq-node1 rabbitmq]# rabbitmqctl join_cluster rabbit@rabbitmq-node1 Clustering node 'rabbit@rabbitmq-node1' with 'rabbit@rabbitmq-node1' ... Error: cannot_cluster_node_with_itself [root@rabbitmq-node1 rabbitmq]# rabbitmqctl start_app Starting node 'rabbit@rabbitmq-node1' ... [root@rabbitmq-node1 rabbitmq]# rabbitmqctl cluster_status Cluster status of node 'rabbit@rabbitmq-node1' ... [{nodes,[{disc,['rabbit@rabbitmq-node1','rabbit@rabbitmq-node2', 'rabbit@rabbitmq-node3']}]}, {running_nodes,['rabbit@rabbitmq-node1']}, {cluster_name,<<"rabbit@rabbitmq-node1.com">>}, {partitions,[]}] [root@rabbitmq-node1 rabbitmq]# rabbitmqctl add_user lxc root Creating user "lxc" ... [root@rabbitmq-node1 rabbitmq]# rabbitmqctl set_user_tags lxc administrator Setting tags for user "lxc" to [administrator] ... [root@rabbitmq-node1 rabbitmq]#
node2：
sjk@192.168.10.74's password: Last login: Tue Nov 3 12:52:44 2015 from 192.168.10.14 [sjk@rabbitmq-node2 ~]$ cd /usr/local/ [sjk@rabbitmq-node2 local]$ ls bin games jdk1.7.0_80 lib64 sbin src etc include lib libexec share tomcat [sjk@rabbitmq-node2 local]$ cd /usr/programmer/ [sjk@rabbitmq-node2 programmer]$ l;s -bash: l: command not found -bash: s: command not found [sjk@rabbitmq-node2 programmer]$ ls apache-tomcat-8.0.26.tar.gz nginx-1.8.0.tar.gz erlang-17.4-1.el6.x86_64.rpm nginx-1.9.4.tar.gz go1.4.2.linux-amd64.tar.gz rabbitmq-server-3.5.6-1.noarch.rpm jdk-7u80-linux-x64.tar.gz redis-3.0.3.tar mongodb-linux-x86_64-3.0.6.tgz solr-5.2.1.tgz mongodb-osx-x86_64-3.0.6.tgz zookeeper-3.4.6.tar.gz [sjk@rabbitmq-node2 programmer]$ sudo -i [sudo] password for sjk: [root@rabbitmq-node2 ~]# vim /etc/hosts [root@rabbitmq-node2 ~]# service rabbitmq-server start Starting rabbitmq-server: SUCCESS rabbitmq-server. [root@rabbitmq-node2 ~]# cd /etc/rabbitmq/ [root@rabbitmq-node2 rabbitmq]# ls enabled_plugins [root@rabbitmq-node2 rabbitmq]# mv /usr/rabbitmq.config /etc/rabbitmq/ [root@rabbitmq-node2 rabbitmq]# cat /var/lib/rabbitmq/.erlang.cookie ATDTSAHIFSBKTQDSYKMA [root@rabbitmq-node2 rabbitmq]# service rabbitmq-server stop Stopping rabbitmq-server: rabbitmq-server. [root@rabbitmq-node2 rabbitmq]# ls enabled_plugins rabbitmq.config [root@rabbitmq-node2 rabbitmq]# vim rabbitmq-env.conf [root@rabbitmq-node2 rabbitmq]# vim rabbitmq-env.conf [root@rabbitmq-node2 rabbitmq]# vim rabbitmq.config [root@rabbitmq-node2 rabbitmq]# service rabbitmq-server start Starting rabbitmq-server: SUCCESS rabbitmq-server. [root@rabbitmq-node2 rabbitmq]# rabbitmqctl cluster_status Cluster status of node 'rabbit@rabbitmq-node2' ... [{nodes,[{disc,['rabbit@rabbitmq-node2']}]}, {running_nodes,['rabbit@rabbitmq-node2']}, {cluster_name,<<"rabbit@rabbitmq-node2.com">>}, {partitions,[]}] [root@rabbitmq-node2 rabbitmq]# rabbitmqctl stop_app Stopping node 'rabbit@rabbitmq-node2' ... [root@rabbitmq-node2 rabbitmq]# rabbitmqctl reset Resetting node 'rabbit@rabbitmq-node2' ... [root@rabbitmq-node2 rabbitmq]# rabbitmqctl join_cluster rabbit@rabbitmq-node1 Clustering node 'rabbit@rabbitmq-node2' with 'rabbit@rabbitmq-node1' ... [root@rabbitmq-node2 rabbitmq]# [root@rabbitmq-node2 rabbitmq]# rabbitmqctl start_app Starting node 'rabbit@rabbitmq-node2' ... [root@rabbitmq-node2 rabbitmq]#
node3：
sjk@192.168.10.75's password: Last login: Tue Nov 3 12:59:37 2015 from 192.168.10.14 [sjk@rabbitmq-node3 ~]$ cat /etc/rabbitmq/ cat: /etc/rabbitmq/: 是一个目录 [sjk@rabbitmq-node3 ~]$ ls Desktop Documents Downloads Music Pictures Public Templates Videos [sjk@rabbitmq-node3 ~]$ sudo -i [sudo] password for sjk: [root@rabbitmq-node3 ~]# vim /etc/hosts [root@rabbitmq-node3 ~]# [root@rabbitmq-node3 ~]# [root@rabbitmq-node3 ~]# service rabbitmq-server start Starting rabbitmq-server: SUCCESS rabbitmq-server. [root@rabbitmq-node3 ~]# cd /etc/rabbitmq/ [root@rabbitmq-node3 rabbitmq]# ls enabled_plugins rabbitmq.config rabbitmq.config.example [root@rabbitmq-node3 rabbitmq]# scp rabbitmq.config root@192.168.10.73:/usr/ The authenticity of host '192.168.10.73 (192.168.10.73)' can't be established. RSA key fingerprint is ba:e1:f0:bd:2f:67:15:cd:50:e2:cf:df:87:01:b9:13. Are you sure you want to continue connecting (yes/no)? yes Warning: Permanently added '192.168.10.73' (RSA) to the list of known hosts. root@192.168.10.73's password: rabbitmq.config 100% 19KB 19.1KB/s 00:00 [root@rabbitmq-node3 rabbitmq]# scp rabbitmq.config root@192.168.10.74:/usr/ The authenticity of host '192.168.10.74 (192.168.10.74)' can't be established. RSA key fingerprint is ba:e1:f0:bd:2f:67:15:cd:50:e2:cf:df:87:01:b9:13. Are you sure you want to continue connecting (yes/no)? yes Warning: Permanently added '192.168.10.74' (RSA) to the list of known hosts. root@192.168.10.74's password: rabbitmq.config 100% 19KB 19.1KB/s 00:00 [root@rabbitmq-node3 rabbitmq]# cat /var/lib/rabbitmq/.erlang.cookie ATDTSAHIFSBKTQDSYKMA [root@rabbitmq-node3 rabbitmq]# service rabbitmq-server stop Stopping rabbitmq-server: rabbitmq-server. [root@rabbitmq-node3 rabbitmq]# ls enabled_plugins rabbitmq.config rabbitmq.config.example [root@rabbitmq-node3 rabbitmq]# vim rabbitmq-env.conf [root@rabbitmq-node3 rabbitmq]# vim rabbitmq-env.conf [root@rabbitmq-node3 rabbitmq]# vim rabbitmq.config [root@rabbitmq-node3 rabbitmq]# service rabbitmq-server start Starting rabbitmq-server: SUCCESS rabbitmq-server. [root@rabbitmq-node3 rabbitmq]# rabbitmqctl cluster_status Cluster status of node 'rabbit@rabbitmq-node3' ... [{nodes,[{disc,['rabbit@rabbitmq-node3']}]}, {running_nodes,['rabbit@rabbitmq-node3']}, {cluster_name,<<"rabbit@rabbitmq-node3.com">>}, {partitions,[]}] [root@rabbitmq-node3 rabbitmq]# rabbitmqctl stop_app Stopping node 'rabbit@rabbitmq-node3' ... [root@rabbitmq-node3 rabbitmq]# rabbitmqctl reset Resetting node 'rabbit@rabbitmq-node3' ... [root@rabbitmq-node3 rabbitmq]# rabbitmqctl join_cluster rabbit@rabbitmq-node1 Clustering node 'rabbit@rabbitmq-node3' with 'rabbit@rabbitmq-node1' ... Error: mnesia_not_running [root@rabbitmq-node3 rabbitmq]# rabbitmqctl join_cluster rabbit@rabbitmq-node1 Clustering node 'rabbit@rabbitmq-node3' with 'rabbit@rabbitmq-node1' ... [root@rabbitmq-node3 rabbitmq]# rabbitmqctl start_app Starting node 'rabbit@rabbitmq-node3' ... [root@rabbitmq-node3 rabbitmq]#
rabbitmq.config 的内容：我删除了一些注释。因为So Long~
%% -*- mode: erlang -*-
%% ----------------------------------------------------------------------------
%% RabbitMQ Sample Configuration File.
%%
%% See http://www.rabbitmq.com/configure.html for details.
%% ----------------------------------------------------------------------------
[
{rabbit,
[
{cluster_nodes, {[' rabbit@rabbitmq-node1', ' rabbit@rabbitmq-node2', ' rabbit@rabbitmq-node3'], disc}}
]},
%% ----------------------------------------------------------------------------
%% Advanced Erlang Networking/Clustering Options.
%%
%% See http://www.rabbitmq.com/clustering.html for details
%% ----------------------------------------------------------------------------
{kernel,
[%% Sets the net_kernel tick time.
%% Please see http://erlang.org/doc/man/kernel_app.html and
%% http://www.rabbitmq.com/nettick.html for further details.
%%
%% {net_ticktime, 60}
]},
%% ----------------------------------------------------------------------------
%% RabbitMQ Management Plugin
%%
%% See http://www.rabbitmq.com/management.html for details
%% ----------------------------------------------------------------------------
{rabbitmq_management,
[
{listener, [{port, 8080},
{ip, "0.0.0.0"},
{ssl, false}]}
]},
%% ----------------------------------------------------------------------------
%% RabbitMQ Shovel Plugin
%%
%% See http://www.rabbitmq.com/shovel.html for details
%% ----------------------------------------------------------------------------
{rabbitmq_shovel,
[{shovels,
[
]}
%% Rather than specifying some values per-shovel, you can specify
%% them for all shovels here.
%%
%% {defaults, [{prefetch_count, 0},
%% {ack_mode, on_confirm},
%% {publish_fields, []},
%% {publish_properties, [{delivery_mode, 2}]},
%% {reconnect_delay, 2.5}]}
]},
%% ----------------------------------------------------------------------------
%% RabbitMQ Stomp Adapter
%%
%% See http://www.rabbitmq.com/stomp.html for details
%% ----------------------------------------------------------------------------
{rabbitmq_stomp,
[
]},
%% ----------------------------------------------------------------------------
%% RabbitMQ MQTT Adapter
%%
%% See https://github.com/rabbitmq/rabbitmq-mqtt/blob/stable/README.md
%% for details
%% ----------------------------------------------------------------------------
{rabbitmq_mqtt,
[
]},
%% ----------------------------------------------------------------------------
%% RabbitMQ AMQP 1.0 Support
%%
%% See https://github.com/rabbitmq/rabbitmq-amqp1.0/blob/stable/README.md
%% for details
%% ----------------------------------------------------------------------------
{rabbitmq_amqp1_0,
[
]},
%% ----------------------------------------------------------------------------
%% RabbitMQ LDAP Plugin
%%
%% See http://www.rabbitmq.com/ldap.html for details.
%%
%% ----------------------------------------------------------------------------
{rabbitmq_auth_backend_ldap,
[
]}
].
我也借鉴了一些大神的博客。也看了官方文档。还在继续提高中~~~
版权声明：本文为博主原创文章，未经博主允许不得转载。