Fork me on GitHub

RabbitMQ原理与单机部署

字数统计: 1.7k字   |   阅读时长≈ 7分

RabbitMQ能做什么

1
2
3
RabbitMQ是一个消息代理 - 一个消息系统的媒介。它可以为你的应用提供一个通用的消息发送和接收平台，并且保证消息在传输过程中的安全。

消息系统允许软件、应用相互连接和扩展．这些应用可以相互链接起来组成一个更大的应用，或者将用户设备和数据进行连接．消息系统通过将消息的发送和接收分离来实现应用程序的异步和解偶。

技术亮点

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
可靠性
RabbitMQ提供了多种技术可以让你在性能和可靠性之间进行权衡。这些技术包括持久性机制、投递确认、发布者证实和高可用性机制。

灵活的路由
消息在到达队列前是通过交换机进行路由的。RabbitMQ为典型的路由逻辑提供了多种内置交换机类型。如果你有更复杂的路由需求，可以将这些交换机组合起来使用，你甚至可以实现自己的交换机类型，并且当做RabbitMQ的插件来使用。

集群
在相同局域网中的多个RabbitMQ服务器可以聚合在一起，作为一个独立的逻辑代理来使用。

联合
对于服务器来说，它比集群需要更多的松散和非可靠链接。为此RabbitMQ提供了联合模型。

高可用的队列
在同一个集群里，队列可以被镜像到多个机器中，以确保当其中某些硬件出现故障后，你的消息仍然安全。

多协议
RabbitMQ 支持多种消息协议的消息传递。

广泛的客户端
只要是你能想到的编程语言几乎都有与其相适配的RabbitMQ客户端。

可视化管理工具
RabbitMQ附带了一个易于使用的可视化管理工具，它可以帮助你监控消息代理的每一个环节。

追踪
如果你的消息系统有异常行为，RabbitMQ还提供了追踪的支持，让你能够发现问题所在。

插件系统
RabbitMQ附带了各种各样的插件来对自己进行扩展。你甚至也可以写自己的插件来使用。

注：官方列举了哪些版本的RabbitMQ兼容固定版本的Erlang。所以为了避免出现兼容性问题，强烈建议下载对应版本。参考：RabbitMQ Erlang Version Requirements

单机部署RabbitMQ

1
RabbitMQ是使用Erlang语言编写的一个高可靠消息队列。所以在安装之前，需要下载最新版本的Erlang。
  • 编译安装Erlang

配置Erlang支持SSL

1
2
3
4
5
6
7
8
编译升级openssl
wget https://www.openssl.org/source/openssl-1.1.0g.tar.gz
tar zxvf openssl-1.1.0g.tar.gz
yum groupinstall "Development tools"
cd openssl-1.1.0g
./config --prefix=/usr/local/openssl
编译安装
make && make install

编译报错-解决

1
2
3
4
5
6
7
编译安装openssl报错：
POD document had syntax errors at /usr/bin/pod2man line 69. make: *** [install_docs]

解决方法：
rm -f /usr/bin/pod2man 

重新编译

增加openssl的lib目录到系统里并生效

1
2
echo '/usr/local/openssl/lib' >> /etc/ld.so.conf.d/server.conf
ldconfig
1
2
3
4
5
6
配置环境变量
cat >>/etc/profile<<EOF
export PATH=$PATH:/usr/local/openssl/bin
EOF

source /etc/profile

软链

1
2
mv /usr/bin/openssl /usr/bin/openssl.bak
ln -s /usr/local/openssl/bin/openssl /usr/bin/openssl

验证

1
2
[root@localhost ~]# openssl version
OpenSSL 1.1.0g  2 Nov 2017
1
2
3
4
5
6
wget http://erlang.org/download/otp_src_20.2.tar.gz
tar -zxvf  otp_src_20.2.tar.gz
cd  otp_src_20.2
yum install -y ncurses-devel
./configure --with-ssl=/usr/local/openssl --prefix=/usr/local/erlang
make && make install

解决编译错误

1
2
3
4
5
6
7
8
9
10
11
12
13
14
********************************************************************
**********************  APPLICATIONS DISABLED  **********************
*********************************************************************

jinterface     : No Java compiler found
odbc           : ODBC library - link check failed


这里只需关注“ APPLICATIONS DISABLED 部分”,其他两部分是INFO信息不影响编译。

(1)"jinterface: No Java compiler found" 添加参数“--without-javac”

(2)odbc:ODBC library - link check failed    #没有,那就安装
   yum install -y unixODBC-devel

重新编译Erlang

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
重新编译Erlang
./configure --with-ssl=/usr/local/openssl  --prefix=/usr/local/erlang  --without-javac

->->->->->->->->->->->->->->->->->->->->->->->->->->->->->->->->->->->->->->->
正常配置完成后会显示如下

*********************************************************************
**********************  APPLICATIONS DISABLED  **********************
*********************************************************************

jinterface     : Java compiler disabled by user
->->->->->->->->->->->->->->->->->->->->->->->->->->->->->->->->->->->->->->->

编译安装
make && make install

配置环境变量

1
2
3
4
5
6
cat >>/etc/profile<<EOF
export PATH=$PATH:/usr/local/erlang/bin
EOF

让环境变量生效
source /etc/profile

测试Erlang

1
2
3
4
5
6
Eshell V5.10.3  (abort with ^G)
1> crypto:start().
ok
2>

Erlang退出信号： halt().
  • 安装simpleJson

下载地址：https://pypi.python.org/pypi/simplejson/ 

1
2
3
tar  -zxvf simplejson-3.13.2.tar.gz
cd simplejson-3.13.2
python setup.py install
  • 部署RabbitMQ

下载地址：http://www.rabbitmq.com/releases/rabbitmq-server/ 

1
2
3
4
5
6
7
推荐用：rabbitmq-server-generic-unix-..*.tar.xz版本
wget https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.7.2/rabbitmq-server-generic-unix-3.7.2.tar.xz

xz -d rabbitmq-server-generic-unix-3.7.2.tar.xz
tar -xvf rabbitmq-server-generic-unix-3.7.2.tar
mv rabbitmq_server-3.7.2 /usr/local/
ln -s /usr/local/rabbitmq_server-3.7.2 /usr/local/rabbitmq    #配置文件软链

配置rabbitmq的环境变量

1
2
3
4
5
6
cat >>/etc/profile <<EOF
export PATH=$PATH:/usr/local/rabbitmq/sbin
EOF

环境变量生效
source /etc/profile

正常启动RabbitMQ

1
2
3
4
5
6
7
rabbitmq-server -datached  #启动rabbitmq

启动报错: ERROR: epmd error for host controler: address (cannot connect to host/port)
故障解决： 查看当前hostname，假设是controller，然后修改/etc/hosts文件，添加一行如下：
vim /etc/hosts

127.0.0.1  controller
1
2
3
4
5
启动验证
rabbitmqctl status   #查看启动状态
ps -ef |grep rabbitmq  #查看进程

RabbitMQ端口:5672

日志软链

1
ln -s /usr/local/rabbitmq/var/log/rabbitmq /var/log/rabbitmq  #日志目录软链

管理命令详解

参考: RabbitMQ管理命令详解

配置网页插件

1
2
3
4
mkdir -p /etc/rabbitmq   #防报错
rabbitmq-plugins enable rabbitmq_management   #启用网页管理插件,网页管理端口:15672

访问http://localhost:15672即可, 默认用户guest 密码guest

远程访问配置

1
2
3
4
5
6
7
8
9
10
11
12
默认网页是不允许访问的，需要增加一个用户修改一下权限，代码如下：

添加用户openstack
rabbitmqctl add_user openstack password

添加权限
rabbitmqctl set_permissions -p "/" openstack ".*" ".*" ".*"

修改用户角色
rabbitmqctl set_user_tags openstack administrator

然后就可以远程访问了，然后可直接配置用户权限等信息。

扫一扫，分享到微信

tag:

    缺失模块。
    1、请确保node版本大于6.2
    2、在博客根目录（注意不是yilia-plus根目录）执行以下命令：
    npm i hexo-generator-json-content --save

    3、在根目录_config.yml里添加配置： 

      jsonContent:
    meta: false
    pages: false
    posts:
      title: true
      date: true
      path: true
      text: false
      raw: false
      content: false
      slug: false
      updated: false
      comments: false
      link: false
      permalink: false
      excerpt: false
      categories: false
      tags: true


不论我写了什么...
其实都是错的......