东莞网上商城网站建设,nginx wordpress 安全,360网站怎么做网址链接,网站数据分析视频一#xff0c;前言
RabbitMQ是由erlang语言开发#xff0c;基于AMQP#xff08;Advanced Message Queue 高级消息队列协议#xff09;协议实现的消息队列#xff0c;它是一种应用程序之间的通信方法#xff0c;消息队列在分布式系统开发中应用非常广泛。点击跳转RabbitM…一前言
RabbitMQ是由erlang语言开发基于AMQPAdvanced Message Queue 高级消息队列协议协议实现的消息队列它是一种应用程序之间的通信方法消息队列在分布式系统开发中应用非常广泛。点击跳转RabbitMQ官方地址
RabbitMQ提供了6种模式
简单模式work模式 Publish/Subscribe发布与订阅模式Routing路由模式Topics主题模式RPC远程调用模式远程调用不太算MQ暂不作介绍 点击跳转官网对应模式介绍 2007年Rabbit 技术公司基于 AMQP 标准开发的 RabbitMQ 1.0 发布。RabbitMQ 采用 Erlang 语言开发。Erlang 语言由 Ericson 设计专门为开发高并发和分布式系统的一种语言在电信领域使用广泛。
RabbitMQ 基础架构如下图 RabbitMQ 中的相关概念
Broker接收和分发消息的应用RabbitMQ Server就是 Message Broker Virtual host:出于多租户和安全因素设计的把 AMQP 的基本组件划分到一个虚拟的分组中类似于网络中的 namespace 概念。当多个不同的用户使用同一个 RabbitMQ server 提供的服务时可以划分出多个vhost每个用户在自己的 vhost 创建exchangequeue 等。 Connectionpublisherconsumer 和 broker 之间的 TCP 连接。 Channel如果每一次访问 RabbitMQ 都建立一个 Connection在消息量大的时候建立 TCP Connection的开销将是巨大的效率也较低。Channel 是在 connection 内部建立的逻辑连接如果应用程序支持多线程通常每个thread创建单独的 channel 进行通讯AMQP method 包含了channel id 帮助客户端和message broker 识别 channel所以 channel 之间是完全隔离的。Channel 作为轻量级的 Connection 极大减少了操作系统建立 TCP connection 的开销。 Exchangemessage 到达 broker 的第一站根据分发规则匹配查询表中的 routing key分发消息到queue 中去。常用的类型有direct (point-to-point)topic (publish-subscribe) and fanout (multicast)。 Queue存储消息的容器消息最终被送到这里等待 consumer 取走。 Bindingexchange 和 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 修改主机名 1vim /etc/hostname 2vim /etc/hosts 启动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 guestguest用户默认不允许远程连接。
增加自定义账号 l 添加管理员账号密码rabbitmqctl add_user admin admin l 分配账号角色rabbitmqctl set_user_tags admin administrator l 修改密码rabbitmqctl change_password admin 123456 l 查看用户列表rabbitmqctl list_users 使用新账号登录成功界面
管理界面标签页介绍 l overview概览 l connections无论生产者还是消费者都需要与RabbitMQ建立连接后才可以完成消息的生产和消费在这里可以查看连接情况 l channels通道建立连接后会形成通道消息的投递获取依赖通道。 l Exchanges交换机用来实现消息的路由 l Queues队列即消息队列消息存放在队列中等待消费消费后被移除队列。 端口 l 5672rabbitMq的编程语言客户端连接端口 l 15672rabbitMq管理界面端口 l 25672rabbitMq集群的端口
卸载
l rpm -qa | grep rabbitmq l rpm -e rabbitmq-server
三管理界面
添加用户 如果不使用guest我们也可以自己创建一个用户
超级管理员(administrator) 可登录管理控制台可查看所有的信息并且可以对用户策略(policy)进行操作。监控者(monitoring) 可登录管理控制台同时可以查看rabbitmq节点的相关信息(进程数内存使用情况磁盘使用情况等)策略制定者(policymaker) 可登录管理控制台同时可以对policy进行管理。但无法查看节点的相关信息。普通管理者(management) 仅可登录管理控制台无法看到节点信息也无法对策略进行管理。其他 无法登录管理控制台通常就是普通的生产者和消费者。 创建Virtual Hosts 虚拟主机类似于mysql中的database。他们都是以“/”开头 设置权限
