王海鱼 发表于 2024-8-6 16:50:34

消息队列之RabbitMQ的安装配置

一,前言

RabbitMQ是由erlang语言开发,基于AMQP(Advanced Message Queue 高级消息队列协议)协议实现的消息队列,它是一种应用步伐之间的通信方法,消息队列在分布式系统开发中应用非常广泛。点击跳转RabbitMQ官方地址
RabbitMQ提供了6种模式:

简单模式,work模式 ,Publish/Subscribe发布与订阅模式,Routing路由模式,Topics主题模式,RPC远程调用模式(远程调用,不太算MQ;暂不作先容)
点击跳转官网对应模式先容
https://i-blog.csdnimg.cn/blog_migrate/7184952edbdd1fb1809612f0c896a320.png
2007年,Rabbit 技能公司基于 AMQP 尺度开发的 RabbitMQ 1.0 发布。RabbitMQ 接纳 Erlang 语言开发。Erlang 语言由 Ericson 计划,专门为开发高并发和分布式系统的一种语言,在电信领域使用广泛。
RabbitMQ 基础架构如下图:

https://i-blog.csdnimg.cn/blog_migrate/47427920fd1263fc2d86e81158ab20ac.png
RabbitMQ 中的相干概念

Broker:吸取和分发消息的应用,RabbitMQ Server就是 Message Broker
Virtual host:出于多租户和安全因素计划的,把 AMQP 的根本组件分别到一个虚拟的分组中,类似于网络中的 namespace 概念。当多个不同的用户使用同一个 RabbitMQ server 提供的服务时,可以分别出多个vhost,每个用户在本身的 vhost 创建exchange/queue 等。
Connection:publisher/consumer 和 broker 之间的 TCP 连接。
Channel:如果每一次访问 RabbitMQ 都创建一个 Connection,在消息量大的时候创建 TCP Connection的开销将是巨大的,效率也较低。Channel 是在 connection 内部创建的逻辑连接,如果应用步伐支持多线程,通常每个thread创建单独的 channel 举行通讯,AMQP method 包含了channel id 帮助客户端和message broker 辨认 channel,所以 channel 之间是完全隔离的。Channel 作为轻量级的 Connection 极大减少了操作系统创建 TCP connection 的开销。
Exchange:message 到达 broker 的第一站,根据分发规则,匹配查询表中的 routing key,分发消息到queue 中去。常用的类型有:direct (point-to-point),topic (publish-subscribe) and fanout (multicast)。
Queue:存储消息的容器,消息终极被送到这里,等候 consumer 取走。
Binding:exchange 和 queue 之间的虚拟连接,binding 中可以包含 routing key。Binding 信息被生存到 exchange 中的查询表中,用于 message 的分发依据。
二,下载安装和配置RabbitMQ

下载


[*]下载Erlang的rpm包
RabbitMQ是Erlang语言编写,所以Erlang情况必须要有,注:Erlang情况一定要与RabbitMQ版本匹配:点击查看版本匹配关系
[*]下载socat的rpm包
rabbitmq安装依赖于socat,所以需要下载socat。
点击下载:socat下载地址
[*]下载RabbitMQ的rpm包
RabbitMQ下载地址:下载(根据自身需求及匹配关系,下载对应rpm包)比方:rabbitmq-server-3.8.1-1.el7.noarch.rpm
也可从github等网站下载。
安装配置


[*] 安装Erlang、Socat、RabbitMQ
①rpm -ivh erlang-21.3.8.9-1.el7.x86_64.rpm
②rpm -ivh socat-1.7.3.2-1.el6.lux.x86_64.rpm
在安装rabbitmq之前需要先安装socat,否则,报错。
可以接纳yum安装方式:yum install socat,我们这里接纳rpm安装方式
③rpm -ivh rabbitmq-server-3.8.1-1.el7.noarch.rpm
[*] 启用管理插件
/usr/lib/rabbitmq/bin/
rabbitmq-plugins enable rabbitmq_management
[*] 修改主机名
(1)vim /etc/hostname
https://i-blog.csdnimg.cn/blog_migrate/7381d0a32b3d05fc94c41df1d1469348.png
(2)vim /etc/hosts
https://i-blog.csdnimg.cn/blog_migrate/c6739a8d072aac50d274a7d190aad827.png
[*] 启动RabbitMQ
启动:systemctl start rabbitmq-server.service
查看状态systemctl status rabbitmq-server.service
重启:systemctl restart rabbitmq-server.service
关闭:systemctl stop rabbitmq-server.service
[*] 查看进程
ps -ef | grep rabbitmq
测试



[*]关闭防火墙:systemctl stop firewalld.service
[*]在web浏览器中输入地址:http://虚拟机ip:15672/
[*]输入默认账号密码: guest : guest,guest用户默认不答应远程连接。
增加自界说账号
l 添加管理员账号密码:rabbitmqctl add_user admin admin
l 分配账军号色:rabbitmqctl set_user_tags admin administrator
l 修改密码:rabbitmqctl change_password admin 123456
l 查看用户列表:rabbitmqctl list_users
使用新账号登录,乐成界面
https://i-blog.csdnimg.cn/blog_migrate/934a84c2f7d926cd833f7b2ecf5cf596.png
管理界面标签页先容
l overview:概览
l connections:无论生产者照旧消费者,都需要与RabbitMQ创建连接后才可以完成消息的生产和消费,在这里可以查看连接情况
l channels:通道,创建连接后,会形成通道,消息的投递获取依赖通道。
l Exchanges:互换机,用来实现消息的路由
l Queues:队列,即消息队列,消息存放在队列中,等候消费,消费后被移除队列。
端口:
l 5672:rabbitMq的编程语言客户端连接端口
l 15672:rabbitMq管理界面端口
l 25672:rabbitMq集群的端口
卸载

l rpm -qa | grep rabbitmq
l rpm -e rabbitmq-server
三,管理界面


[*]添加用户
如果不使用guest,我们也可以本身创建一个用户:
https://i-blog.csdnimg.cn/blog_migrate/976551bb01305bbd7c3d14f196670af7.png


[*]超级管理员(administrator)
可登录管理控制台,可查看全部的信息,并且可以对用户,策略(policy)举行操作。
[*]监控者(monitoring)
可登录管理控制台,同时可以查看rabbitmq节点的相干信息(进程数,内存使用情况,磁盘使用情况等)
[*]策略订定者(policymaker)
可登录管理控制台,同时可以对policy举行管理。但无法查看节点的相干信息。
[*]平凡管理者(management)
仅可登录管理控制台,无法看到节点信息,也无法对策略举行管理。
[*]其他
无法登录管理控制台,通常就是平凡的生产者和消费者。

[*] 创建Virtual Hosts
虚拟主机:类似于mysql中的database。他们都是以“/”开头
https://i-blog.csdnimg.cn/blog_migrate/ad2f1373b9f9e2b2ef1ab0036a8328aa.png
[*] 设置权限
https://i-blog.csdnimg.cn/blog_migrate/c7dd534ef6c99a60584b407c45e7e48b.png
https://i-blog.csdnimg.cn/blog_migrate/7d6399d8ae6265c87466c4aee4afc739.png

免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。
页: [1]
查看完整版本: 消息队列之RabbitMQ的安装配置