IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 大数据 -> RabbitMQ安装(Linux) -> 正文阅读

[大数据]RabbitMQ安装(Linux)

MQ:

????????消息队列,通过典型的生产者和消费者模型,生产者不断向消息队列中生产消息,消费者不断地从队列中获取消息。

主流MQ:

????????ActiveMQ:它是一个完全支持JMS规范的的消息中间件。丰富的API,多种集群架构模式让ActiveMQ在业界成为老牌的消息中间件

????????RocketMQ:纯Java开发,具有高吞吐量、高可用性、适合大规模分布式系统应用的特点,RocketMQ思路起源于Kafka,但并不是Kafka的一个Copy,它对消息的可靠传输及事务性做了优化,目前在阿里集团被广泛应用于交 易、充值、流计算、消息推送、日志流式处理、binglog分发等场

????????kafka:Kafka主要特点是基于Pull的模式来处理消息消费,追求高吞吐量,一开始的目的就是用于日志收集和传输

????????RabbitMQ:整体是一个与其他中间件相同的模型,主要是负责接收、存储和转发消息。可以把消息传递的过程想想成快递:将一个快递送到快递公司,快递公司由快递员送到收件人的人中,RabbitMQ就类似于一个快递公司,也就是RabbitMQ的交换机模型。

RabbitMQ比Kafka可靠,Kafka更适合IO高吞吐的处理,一般应用在大数据日志处理或对实时性(少量延迟),可靠性(少量丢数据)要求稍低的场景使用,比如ELK日志收集。

AMQP:

AMQP是一种协议,更准确的说是一种binary wire-level protocol(链接协议)。这是其和JMS的本质差别,AMQP不从API层进行限定,而是直接定义网络交换的数据格式。这使得实现了AMQP的provider天然性就是跨平台的。以下是AMQP协议模型:

?

安装RabbitMQ:

1.安装任何软件包之前,建议使用以下命令更新软件包和存储库

????????yum -y update

2.安装Erlang

????????安装EPEL存储库

????????????????yum -y install epel-release

????????????????yum -y update

????????安装Erlang

????????????????yum -y install erlang socat

????????查看版本:

????????????????erl -version

?

3.安装rabbitMQ

????????1.下载rpm包,然后上传至服务器

????????????????下载:https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.8.1/rabbitmq-server-3.8.1-1.el8.noarch.rpm

????????2.安装rabbitMQ

????????????????通过运行导入GPG密钥:rpm –import https://www.rabbitmq.com/rabbitmq-release-signing-key.asc

????????????????运行rpm包:rpm -Uvh rabbitmq-server-3.8.1-1.el8.noarch

4.使用rabbitMQ

运行:

????????systemctl start rabbitmq-server

开机自启:

????????systemctl enable rabbitmq-server

检查状态:

????????systemctl status rabbitmq-server

启动rabbitMQ web管理控制台:

????????rabbitmq-plugins enable rabbitmq_management

将文件所有权授权给rabbitMQ用户:

????????chown -R rabbitmq:rabbitmq /var/lib/rabbitmq/

5.创建用户:

????????rabbitmqctl add_user admin 111111

????????rabbitmqctl set_permissions -p / admin ".*" ".*" ".*"

????????rabbitmqctl set_user_tags admin administrator

6.访问登录:

http://192.168.111.130:15672

7.管理页介绍

主页:

?

  • connections:无论生产者还是消费者,都需要与RabbitMQ建立连接后才可以完成消息的生产和消费,在这里可以查看连接情况
  • channels:通道,建立连接后,会形成通道,消息的投递获取依赖通道。
  • Exchanges:交换机,用来实现消息的路由
  • Queues:队列,即消息队列,消息存放在队列中,等待消费,消费后被移除队列。

端口:

8.添加用户:

?Tags选项:

????????administrator(超级管理员):可登陆管理控制台,可查看所有的信息,并且可以对用户,策略(policy)进行操作

????????monitoring(监控者):可登陆管理控制台,同时可以查看rabbitmq节点的相关信息(进程数,内存使用情况,磁盘使用情况等)

????????policymaker(策略制定者):可登陆管理控制台, 同时可以对policy进行管理。但无法查看节点的相关信息

????????management(普通管理者):仅可登陆管理控制台,无法看到节点信息,也无法对策略进行管理。

????????none(其他):无法登陆管理控制台,通常就是普通的生产者和消费者

9.创建虚拟主机

????????为了让各个用户可以互不干扰的工作,RabbitMQ添加了虚拟主机(Virtual Hosts)的概念。其实就是一个独立的访问路径,不同用户使用不同路径,各自有自己的队列、交换机,互相不会影响。

?创建虚拟主机后,用户添加访问权限(点击添加好的虚拟主机):

?进入虚拟主机设置界面:

  大数据 最新文章
实现Kafka至少消费一次
亚马逊云科技:还在苦于ETL?Zero ETL的时代
初探MapReduce
【SpringBoot框架篇】32.基于注解+redis实现
Elasticsearch:如何减少 Elasticsearch 集
Go redis操作
Redis面试题
专题五 Redis高并发场景
基于GBase8s和Calcite的多数据源查询
Redis——底层数据结构原理
上一篇文章      下一篇文章      查看所有文章
加:2021-08-26 12:10:28  更:2021-08-26 12:12:37 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/23 16:53:20-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码