栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

初学rabbitMQ

初学rabbitMQ

1.先了解什么是同步通信和异步通信

按我的理解来说是

同步通信:实时对话传输

异步通信:得等对方回复了才能收到,时效性差

优缺点:同步通信只能同时对于一个人对话不能多线回复,而异步通信可以同时与几个人聊天

这就是实时的,得等待服务回应

当服务多了会性能下降,吞吐量也下降了

同步调用存在的问题

耦合度高(每次加入新需求都需要修改原来的代码)性能和吞吐能力下降(调用者需要等待服务提供者的响应,如果调用链过长则每次响应时间等于调用时间之和)有额外的资源消耗(调用链中每个服务在等待相应过程中不能释放资源,高并发下极度浪费系统资源)有级联失败问题(如果服务提供者出现问题,所有调用方都会出现问题,和多米诺骨牌一样迅速导致整个微服务群故障)

 引入了broker(事件代理者)

例如

在这个体系中一旦有人支付成功就是一个事件

异步调用好处:

吞吐量提升:无需等待订阅者处理完成,响应更快速故障隔离:服务没有直接调用,不存在级联失败问题调用间没有阻塞,不会造成无效的资源占用耦合度极低,每个服务都可以灵活插拔,可替换流量削峰:不管发布事件的流量波动多大,都由 Broker 接收,订阅者可以按照自己的速度去处理事件 异步调用缺点:

架构复杂了,业务没有明显的流程线,不好管理需要依赖于 Broker 的可靠、安全、性能 MQ消息队列

MQ,中文是消息队列(MessageQueue),字面来看就是存放消息的队列,也就是事件驱动架构中的 Broker

比较常见的 MQ 实现:

ActiveMQRabbitMQRocketMQKafka

几种常见MQ的对比:

RabbitMQActiveMQRocketMQKafka
公司/社区RabbitApache阿里Apache
开发语言ErlangJavaJavaScala&Java
协议支持AMQP、XMPP、SMTP、STOMPOpenWire、STOMP、REST、XMPP、AMQP自定义协议自定义协议
可用性一般
单机吞吐量一般非常高
消息延迟微秒级毫秒级毫秒级毫秒以内
消息可靠性一般一般
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/730635.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号