消息队列之RabbitMQ的安装配置

这篇具有很好参考价值的文章主要介绍了消息队列之RabbitMQ的安装配置。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

一,前言

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

RabbitMQ提供了6种模式:

简单模式,work模式 ,Publish/Subscribe发布与订阅模式,Routing路由模式,Topics主题模式,RPC远程调用模式(远程调用,不太算MQ;暂不作介绍)
点击跳转官网对应模式介绍
消息队列之RabbitMQ的安装配置,MQ,rabbitmq,分布式,java-rabbitmq
2007年,Rabbit 技术公司基于 AMQP 标准开发的 RabbitMQ 1.0 发布。RabbitMQ 采用 Erlang 语言开发。Erlang 语言由 Ericson 设计,专门为开发高并发和分布式系统的一种语言,在电信领域使用广泛。

RabbitMQ 基础架构如下图:

消息队列之RabbitMQ的安装配置,MQ,rabbitmq,分布式,java-rabbitmq

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

下载

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

安装配置

  1. 安装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

  2. 启用管理插件
    /usr/lib/rabbitmq/bin/
    rabbitmq-plugins enable rabbitmq_management

  3. 修改主机名
    (1)vim /etc/hostname
    消息队列之RabbitMQ的安装配置,MQ,rabbitmq,分布式,java-rabbitmq
    (2)vim /etc/hosts
    消息队列之RabbitMQ的安装配置,MQ,rabbitmq,分布式,java-rabbitmq

  4. 启动RabbitMQ
    启动:systemctl start rabbitmq-server.service
    查看状态systemctl status rabbitmq-server.service
    重启:systemctl restart rabbitmq-server.service
    关闭:systemctl stop rabbitmq-server.service

  5. 查看进程
    ps -ef | grep rabbitmq

测试
  • 关闭防火墙:systemctl stop firewalld.service
  • 在web浏览器中输入地址:http://虚拟机ip:15672/
  • 输入默认账号密码: guestguest,guest用户默认不允许远程连接。

增加自定义账号
l 添加管理员账号密码:rabbitmqctl add_user admin admin
l 分配账号角色:rabbitmqctl set_user_tags admin administrator
l 修改密码:rabbitmqctl change_password admin 123456
l 查看用户列表:rabbitmqctl list_users
使用新账号登录,成功界面
消息队列之RabbitMQ的安装配置,MQ,rabbitmq,分布式,java-rabbitmq

管理界面标签页介绍
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

三,管理界面

  1. 添加用户
    如果不使用guest,我们也可以自己创建一个用户:
    消息队列之RabbitMQ的安装配置,MQ,rabbitmq,分布式,java-rabbitmq
  • 超级管理员(administrator)
    可登录管理控制台,可查看所有的信息,并且可以对用户,策略(policy)进行操作。
  • 监控者(monitoring)
    可登录管理控制台,同时可以查看rabbitmq节点的相关信息(进程数,内存使用情况,磁盘使用情况等)
  • 策略制定者(policymaker)
    可登录管理控制台,同时可以对policy进行管理。但无法查看节点的相关信息。
  • 普通管理者(management)
    仅可登录管理控制台,无法看到节点信息,也无法对策略进行管理。
  • 其他
    无法登录管理控制台,通常就是普通的生产者和消费者。
  1. 创建Virtual Hosts
    虚拟主机:类似于mysql中的database。他们都是以“/”开头
    消息队列之RabbitMQ的安装配置,MQ,rabbitmq,分布式,java-rabbitmq

  2. 设置权限

消息队列之RabbitMQ的安装配置,MQ,rabbitmq,分布式,java-rabbitmq
消息队列之RabbitMQ的安装配置,MQ,rabbitmq,分布式,java-rabbitmq文章来源地址https://www.toymoban.com/news/detail-857874.html

到了这里,关于消息队列之RabbitMQ的安装配置的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • MQ消息队列(主要介绍RabbitMQ)

    消息队列概念:是在消息的传输过程中保存消息的容器。 作用:异步处理、应用解耦、流量控制..... RabbitMQ:     SpringBoot继承RabbitMQ步骤:         1.加入依赖          2.配置         3.开启(如果不需要监听消息也就是不消费就不需要该注解开启)         4.创建队列、

    2024年02月11日
    浏览(50)
  • 消息队列-RabbitMQ:MQ作用分类、RabbitMQ核心概念及消息生产消费调试

    1)什么是 MQ MQ (message queue),从字面意思上看, 本质是个队列,FIFO 先入先出 ,只不过队列中存放的内容是 message 而已,还是一种 跨进程的通信机制 , 用于上下游传递消息 。在互联网架构中,MQ 是一种非常常见的上下游 “ 逻辑解耦 + 物理解耦” 的消息通信服务 。 使用了

    2024年02月20日
    浏览(42)
  • MQ消息队列,以及RabbitMQ详细(中1)五种rabbitMQ实用模型

    书接上文,展示一下五种模型我使用的是spring could 微服务的框架 文章说明:         本文章我会分享总结5种实用的rabbitMQ的实用模型 1、hello world简单模型 2、work queues工作队列 3、Publish/Subscribe发布订阅模型 4、Routing路由模型 5、Topics 主题模型 (赠送) 6、消息转换器 Rabbi

    2024年02月05日
    浏览(52)
  • 分布式消息队列RabbitMQ-Linux下服务搭建,面试完腾讯我才发现这些知识点竟然没掌握全

    vim /usr/lib/rabbitmq/lib/rabbitmq_server-3.6.5/ebin/rabbit.app 5.修改配置文件 这里面修改{loopback_users, [“guest”]}改为{loopback_users, []} {application, rabbit, %% - - erlang - - [{description, “RabbitMQ”}, {id, “RabbitMQ”}, {vsn, “3.6.5”}, {modules, [‘background_gc’,‘delegate’,‘delegate_sup’,‘dtree’,‘file_han

    2024年04月14日
    浏览(53)
  • RaabitMQ(三) - RabbitMQ队列类型、死信消息与死信队列、懒队列、集群模式、MQ常见消息问题

    这是RabbitMQ最为经典的队列类型。在单机环境中,拥有比较高的消息可靠性。 经典队列可以选择是否持久化(Durability)以及是否自动删除(Auto delete)两个属性。 Durability有两个选项,Durable和Transient。 Durable表示队列会将消息保存到硬盘,这样消息的安全性更高。但是同时,由于需

    2024年02月14日
    浏览(168)
  • mq 消息队列 mqtt emqx ActiveMQ RabbitMQ RocketMQ

    十几年前,淘宝的notify,借鉴ActiveMQ。京东的ActiveMQ集群几百台,后面改成JMQ。 Linkedin的kafka,因为是scala,国内很多人不熟。淘宝的人把kafka用java写了一遍,取名metaq,后来再改名RocketMQ。 总的来说,三大原因,语言、潮流、生态。 MQ这种东西,当你的消息量不大的时候,用啥

    2024年02月12日
    浏览(49)
  • 消息队列之RabbitMQ的安装配置

    RabbitMQ是由erlang语言开发,基于AMQP(Advanced Message Queue 高级消息队列协议)协议实现的消息队列,它是一种应用程序之间的通信方法,消息队列在分布式系统开发中应用非常广泛。点击跳转RabbitMQ官方地址 简单模式,work模式 ,Publish/Subscribe发布与订阅模式,Routing路由模式,

    2024年04月25日
    浏览(37)
  • .NetCore 使用 RabbitMQ (交换机/队列/消息持久化+mq高级特性+死信队列+延迟队列)

    目录 一、安装mq 二、实操 1、简单模式 2、工作模式 3、fanout扇形模式(发布订阅) 4、direct路由模式也叫定向模式 5、topic主题模式也叫通配符模式(路由模式的一种) 6、header 参数匹配模式 7、延时队列(插件方式实现) 参考资料: 1、我的环境是使用VMware安装的Centos7系统。MQ部署

    2023年04月09日
    浏览(99)
  • 【学习日记2023.6.19】 之 RabbitMQ服务异步通信_消息可靠性_死信交换机_惰性队列_MQ集群

    消息队列在使用过程中,面临着很多实际问题需要思考: 消息从发送,到消费者接收,会经历多个过程: 其中的每一步都可能导致消息丢失,常见的丢失原因包括: 发送时丢失: 生产者发送的消息未送达exchange 消息到达exchange后未到达queue MQ宕机,queue将消息丢失 consumer接收

    2024年02月11日
    浏览(54)
  • RabbitMQ:高效传递消息的魔法棒,一篇带你助力构建可靠的分布式系统(上篇)

    MQ是消息队列( Message Queue )的缩写,是一种在应用程序之间传递消息的技术。通常用于 分布式系统 或 异步通信 中,其中 发送者 将消息放入队列,而 接收者 从队列中获取消息。 这种异步通信模式允许发送者和接收者在不需要实时连接的情况下进行通信,从而提高了应用

    2024年02月15日
    浏览(46)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包