博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
RabbitMQ安装与配置
阅读量:6186 次
发布时间:2019-06-21

本文共 5619 字,大约阅读时间需要 18 分钟。

RabbitMQ

RabbitMQ 是一个由 Erlang 语言开发的 AMQP 的开源实现。AMQP :Advanced Message Queue,高级消息队列协议。它是应用层协议的一个开放标准,为面向消息的中间件设计,基于此协议的客户端与消息中间件可传递消息,并不受产品、开发语言等条件的限制。

消息队列是什么

消息(Message)是指在应用间传送的数据。消息可以非常简单,比如只包含文本字符串,也可以更复杂,可能包含嵌入对象。消息队列(Message Queue)是一种应用间的通信方式,消息发送后可以立即返回,由消息系统来确保消息的可靠传递。消息发布者只管把消息发布到 MQ 中而不用管谁来取,消息使用者只管从 MQ 中取消息而不管是谁发布的。这样发布者和使用者都不用知道对方的存在。

为何用消息队列

从上面的描述中可以看出消息队列是一种应用间的异步协作机制,那什么时候需要使用 MQ 呢?以常见的订单系统为例,用户点击【下单】按钮之后的业务逻辑可能包括:扣减库存、生成相应单据、发红包、发短信通知。在业务发展初期这些逻辑可能放在一起同步执行,随着业务的发展订单量增长,需要提升系统服务的性能,这时可以将一些不需要立即生效的操作拆分出来异步执行,比如发放红包、发短信通知等。这种场景下就可以用 MQ ,在下单的主流程(比如扣减库存、生成相应单据)完成之后发送一条消息到 MQ 让主流程快速完结,而由另外的单独线程拉取MQ的消息(或者由 MQ 推送消息),当发现 MQ 中有发红包或发短信之类的消息时,执行相应的业务逻辑。以上是用于业务解耦的情况,其它常见场景包括最终一致性、广播、错峰流控等等。

RabbitMQ特点

RabbitMQ 是一个由 Erlang 语言开发的 AMQP 的开源实现。AMQP :Advanced Message Queue,高级消息队列协议。它是应用层协议的一个开放标准,为面向消息的中间件设计,基于此协议的客户端与消息中间件可传递消息,并不受产品、开发语言等条件的限制。RabbitMQ 最初起源于金融系统,用于在分布式系统中存储转发消息,在易用性、扩展性、高可用性等方面表现不俗。具体特点包括:

  1. 可靠性(Reliability)
    RabbitMQ 使用一些机制来保证可靠性,如持久化、传输确认、发布确认。
  2. 灵活的路由(Flexible Routing)
    在消息进入队列之前,通过 Exchange 来路由消息的。对于典型的路由功能,RabbitMQ 已经提供了一些内置的 Exchange 来实现。针对更复杂的路由功能,可以将多个 Exchange 绑定在一起,也通过插件机制实现自己的 Exchange 。
  3. 消息集群(Clustering)
    多个 RabbitMQ 服务器可以组成一个集群,形成一个逻辑 Broker 。
  4. 高可用(Highly Available Queues)
    队列可以在集群中的机器上进行镜像,使得在部分节点出问题的情况下队列仍然可用。
  5. 多种协议(Multi-protocol)
    RabbitMQ 支持多种消息队列协议,比如 STOMP、MQTT 等等。
  6. 多语言客户端(Many Clients)
    RabbitMQ 几乎支持所有常用语言,比如 Java、.NET、Ruby 等等。
  7. 管理界面(Management UI)
    RabbitMQ 提供了一个易用的用户界面,使得用户可以监控和管理消息 Broker 的许多方面。
  8. 跟踪机制(Tracing)
    如果消息异常,RabbitMQ 提供了消息跟踪机制,使用者可以找出发生了什么。
  9. 插件机制(Plugin System)
    RabbitMQ 提供了许多插件,来从多方面进行扩展,也可以编写自己的插件。

安装RabbitMQ

通过yum等软件仓库都可以直接安装RabbitMQ,但版本一般都较为保守。RabbitMQ官网提供了新版的rpm包(),但是安装的时候会提示需要erlang版本>=19.3,然而默认yum仓库中的版本较低。其实RabbitMQ在github上有提供新的erlang包()也可以直接加到yum源中

#cat /etc/yum.repos.d/rabbitmq-erlang.repo[rabbitmq-erlang]name=rabbitmq-erlangbaseurl=https://dl.bintray.com/rabbitmq/rpm/erlang/20/el/7gpgcheck=1gpgkey=https://dl.bintray.com/rabbitmq/Keys/rabbitmq-release-signing-key.ascrepo_gpgcheck=0enabled=1#yum clean all#yum makecache

然后下载RabbitMQ的RPM包()

这里是centos7的版本#wget https://dl.bintray.com/rabbitmq/all/rabbitmq-server/3.7.4/rabbitmq-server-3.7.4-1.el7.noarch.rpm#yum install rabbitmq-server-3.7.4-1.el7.noarch.rpmyum会自动去源里安装依赖包

安装到这里就完成了

基本操作

$ sudo chkconfig rabbitmq-server on  # 添加开机启动RabbitMQ服务$ sudo /sbin/service rabbitmq-server start # 启动服务$ sudo /sbin/service rabbitmq-server status  # 查看服务状态$ sudo /sbin/service rabbitmq-server stop   # 停止服务 # 查看当前所有用户$ sudo rabbitmqctl list_users # 查看默认guest用户的权限$ sudo rabbitmqctl list_user_permissions guest # 由于RabbitMQ默认的账号用户名和密码都是guest。为了安全起见, 先删掉默认用户$ sudo rabbitmqctl delete_user guest # 添加新用户$ sudo rabbitmqctl add_user username password # 设置用户tag$ sudo rabbitmqctl set_user_tags username administrator # 赋予用户默认vhost的全部操作权限$ sudo rabbitmqctl set_permissions -p / username ".*" ".*" ".*" # 查看用户的权限$ sudo rabbitmqctl list_user_permissions username

更多关于rabbitmqctl的使用,可以参考。

开启Web管理接口

如果只从命令行操作RabbitMQ,多少有点不方便。幸好RabbitMQ自带了web管理界面,只需要启动插件便可以使用。

$ sudo rabbitmq-plugins enable rabbitmq_management

然后通过浏览器访问:IP:15672

输入用户名和密码访问web管理界面了。

配置RabbitMQ

关于RabbitMQ的配置,可以下载RabbitMQ的到/etc/rabbitmq/rabbitmq.config, 然后按照需求更改即可。关于每个配置项的具体作用,可以参考。更新配置后,别忘了重启服务

#!/bin/bashrpm -vih epel-release-latest-6.noarch.rpmyum install -y erlangrpm -vih rabbitmq-server-3.3.4-1.noarch.rpmmkdir -p /data/rabbitmqmkdir -p /data/weblogs/rabbitmqchown -R rabbitmq:rabbitmq /data/weblogs/rabbitmq/chown -R rabbitmq:rabbitmq /data/rabbitmq/cat >> /etc/rabbitmq/rabbitmq-env.conf<

开启用户远程访问

默认情况下,RabbitMQ的默认的guest用户只允许本机访问, 如果想让guest用户能够远程访问的话,只需要将配置文件中的loopback_users列表置为空即可,如下:

{loopback_users, []}

另外关于新添加的用户,直接就可以从远程访问的,如果想让新添加的用户只能本地访问,可以将用户名添加到上面的列表, 如只允许admin用户本机访问。

{loopback_users, ["admin"]}

更新配置,需要重启

[root@localhost access]# systemctl status rabbitmq-server● rabbitmq-server.service - RabbitMQ broker   Loaded: loaded (/usr/lib/systemd/system/rabbitmq-server.service; enabled; vendor preset: disabled)   Active: active (running) since Wed 2018-10-31 21:50:01 CST; 13h ago Main PID: 30926 (beam.smp)   Status: "Initialized"   CGroup: /system.slice/rabbitmq-server.service           ├─30926 /usr/lib64/erlang/erts-9.3.3.4/bin/beam.smp -W w -A 128 -P 1048576 -t 5000000 -stbt db -zdbbl 1280000 -K true -- -root /usr/lib64/erlang -progname erl -- -home /var/...           ├─31097 /usr/lib64/erlang/erts-9.3.3.4/bin/epmd -daemon           ├─31322 erl_child_setup 1024           ├─31358 inet_gethost 4           └─31359 inet_gethost 4Oct 31 21:50:00 localhost.localdomain rabbitmq-server[30926]: ##  ##Oct 31 21:50:00 localhost.localdomain rabbitmq-server[30926]: ##  ##      RabbitMQ 3.7.4. Copyright (C) 2007-2018 Pivotal Software, Inc.Oct 31 21:50:00 localhost.localdomain rabbitmq-server[30926]: ##########  Licensed under the MPL.  See http://www.rabbitmq.com/Oct 31 21:50:00 localhost.localdomain rabbitmq-server[30926]: ######  ##Oct 31 21:50:00 localhost.localdomain rabbitmq-server[30926]: ##########  Logs: /data/weblogs/rabbitmq/rabbit@localhost.logOct 31 21:50:00 localhost.localdomain rabbitmq-server[30926]: /data/weblogs/rabbitmq/rabbit@localhost_upgrade.logOct 31 21:50:00 localhost.localdomain rabbitmq-server[30926]: Starting broker...Oct 31 21:50:01 localhost.localdomain rabbitmq-server[30926]: systemd unit for activation check: "rabbitmq-server.service"Oct 31 21:50:01 localhost.localdomain systemd[1]: Started RabbitMQ broker.Oct 31 21:50:01 localhost.localdomain rabbitmq-server[30926]: completed with 0 plugins.这里可以看到log文件的位置,转到文件位置,打开文件:

防火墙配置:

/sbin/iptables -I INPUT -p tcp --dport 5672 -j ACCEPT/sbin/iptables -I INPUT -p tcp --dport 15672 -j ACCEPT

转载于:https://www.cnblogs.com/Template/p/9888999.html

你可能感兴趣的文章
Spring - Configuration Metadata
查看>>
利用Python调用HBASE
查看>>
python socket编程之基本流程
查看>>
mysql字符乱码
查看>>
Mysql之一:mysqldump和LVM逻辑卷快照
查看>>
JAVA之带转义字符的json字符串解析
查看>>
Mac上搭建Xcode9.0+appium1.6.5过程及链接模拟器测试app
查看>>
centos7配置haproxy
查看>>
MongoDB 3.0(1):CentOS7 安装MongoDB 3.0服务
查看>>
Android开发者指南(20) —— Testing
查看>>
Linux多线程实践(4) --线程特定数据
查看>>
guardian keytab生成不了
查看>>
08:特殊日历计算
查看>>
mongodb数据结构学习1--增删改查
查看>>
android中文api(80)——Gallery.LayoutParams
查看>>
Windows Embedded Compact 7加速生活化IT产品创新
查看>>
安装LSMS前需关闭MediaSense
查看>>
QTP引用外部脚本路径的设定(三)Instr函数的使用
查看>>
Linux 监控工具之Cacti使用详解(四)
查看>>
机房管理系列之共享打印服务器
查看>>