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 小米 华为 单反 装机 图拉丁
 
   -> 大数据 -> MQ相关基础知识 -> 正文阅读

[大数据]MQ相关基础知识

MQ

1、AMQP和rabbitMq:

amqp是一种网络协议,支持符合条件的客户端和消息代理中间件进行通讯。rabbitmq是amqp的实现,所以rabbitmq可以使用amqp的所有概念和准则。

2、消息流向:

生产者(publisher/producer)生产具有指定路由键(routing key)的消息将其发布给消息代理(broker 即rabbitmq)中的交换机(exchange),交换机将消息中的路由键与队列(queue)绑定信息(binding)中存储的路由键对比,将消息路由到匹配的队列中。队列再将信息通过连接(connection)中的通道(channel)推送给订阅了消息的消费者(consumer)。

3、交换机的种类:

a、直连交换机:类似于键值对,通过匹配键值将消息发送到对应的队列。

b、主题交换机:类似于模糊匹配,*代表一个单词。#代表0或者多个单词。

c、扇形交换机:将消息发送给连接到交换机上的所有队列中。

d、头交换机:有时消息的路由操作会涉及到多个属性,此时使用消息头就比用路由键更容易表达,头交换机(headers exchange)就是为此而生的。头交换机使用多个消息属性来代替路由键建立路由规则。通过判断消息头的值能否与指定的绑定相匹配来确立路由规则。

e、默认交换机:默认交换机是一种特殊的直连交换机(direct exchange)。它是由消息代理默认声明的,该交换机有一个特性,所有新建的队列都会默认绑定到默认交换机上,并且绑定的routing ke就是队列的名字。

4、安装:

准备:

阿里云服务器一台(Centos7.5)、Xshell、ftp文件传输工具(我用的是FileZilla)、压缩包(rabbitmq-server-generic-unix-3.7.4.tar).

a、安装依赖文件:

yum -y install gcc glibc-devel make ncurses-devel openssl-devel xmlto perl wget

b、安装erlang语言环境:

wget http://www.erlang.org/download/otp_src_20.3.tar.gz #下载erlang包

tar -xvf otp_src_20.3.tar.gz  #解压

cd otp_src_20.3/ #切换到安装路径

./configure --prefix=/usr/local/erlang  #生产安装配置

make && make install  #编译安装

c、配置erlang环境变量:

vi /etc/profile  #在底部添加以下内容

#set erlang environment
ERL_HOME=/usr/local/erlang
PATH=$ERL_HOME/bin:$PATH
export ERL_HOME PATH

source /etc/profile #使以上配置生效

测试是否安装成功:

在终端输入erl,看是否进入erlang的shell。

在这里插入图片描述

d、安装RabbitMq:

切换路径: cd /usr/local     ------需要安装的位置
下载安装包:wget https://dl.bintray.com/rabbitmq/all/rabbitmq-server/3.7.4/rabbitmq-server-generic-unix-3.7.4.tar.xz

解压:
xz -d rabbitmq-server-generic-unix-3.7.4.tar.xz
tar -xvf rabbitmq-server-generic-unix-3.7.4.tar

mv rabbitmq_server-3.7.4/ rabbitmq

注意:下载安装包时链接可能会出现forbidden。所以我是直接将安装包到本地,然后上传给服务器:

地址:放在tools目录下。

e、配置rabbitMq环境变量:

vi /etc/profile

#set rabbitmq environment
export PATH=$PATH:/usr/local/rabbitmq/sbin

source /etc/profile

d、启动服务:

rabbitmq-server -detached //启动rabbitmq,-detached代表后台守护进程方式启动。

f、查看状态:

rabbitmqctl status

在这里插入图片描述

g、配合网页插件:

mkdir /etc/rabbitmq

rabbitmq-plugins enable rabbitmq_management  //启用插件

阿里云控制台配置安全组:15672和5672端口

h、添加用户:

rabbitmqctl add_user admin admin  #添加用户

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

rabbitmqctl set_user_tags admin administrator #修改用户角色

i、访问:

ip:5672

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

//TODO

测试案例传送门:
  大数据 最新文章
实现Kafka至少消费一次
亚马逊云科技:还在苦于ETL?Zero ETL的时代
初探MapReduce
【SpringBoot框架篇】32.基于注解+redis实现
Elasticsearch:如何减少 Elasticsearch 集
Go redis操作
Redis面试题
专题五 Redis高并发场景
基于GBase8s和Calcite的多数据源查询
Redis——底层数据结构原理
上一篇文章      下一篇文章      查看所有文章
加:2021-08-12 16:40:01  更:2021-08-12 16:40:23 
 
开发: 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 9:40:30-

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