zoukankan      html  css  js  c++  java
  • 初始MQ

    同步通讯

    同步通讯相当于打电话,两个人建立通话连接后,可以实时获取信息,并且别人无法介入此次通话。

    同步调用的问题

    微服务间基于Feign的调用就属于同步方式

    耦合度高:每次加入新的需求,都要修改原来的代码

    性能下降:调用者需要等待服务提供者响应,如果调用链过长则响应时间等于每次调用的时间之和。

    资源浪费:调用链中的每个服务在等待响应过程中,不能释放请求占用的资源,高并发场景下会极度浪费系统资源

    级联失败:如果服务提供者出现问题,所有调用方都会跟着出问题,如同多米诺骨牌一样,迅速导致整个微服务群故障

    异步通讯

    异步通讯相当于微信,微信特点发送信息后,不需要等待对方回复,可以多人聊天

    异步调用的问题

    异步调用常见实现就是事件驱动模式

    事件驱动优势

    服务解耦:在上线的项目中增加新的功能不用修改现有代码,只需要服务订阅Broker即可,包括要减少一些服务,取消订阅Broker即可。

    性能提升,吞吐量提高:支付服务(50ms)+ 发布事件(10ms)=60ms

    服务没有强依赖,不担心级联失败问题:仓储服务停止,不会影响支付服务,重启仓储服务即可

    流量削峰:请求过多时,Broker会根据服务的处理能力来分发请求,Broker相当于缓存的作用

    异步通信的缺点:

    • 依赖于Broker的可靠性、安全性、吞吐能力
    • 架构复杂了,业务没有明显的流程线,不好追踪管理

    MQ

    MQ (MessageQueue)消息队列,存放消息的队列。也就是事件驱动架构中的Broker。

     

    RabbitMQ

    ActiveMQ

    RocketMQ

    Kafka

    公司/社区

    Rabbit

    Apache

    阿里

    Apache

    开发语言

    Erlang

    Java

    Java

    Scala&Java

    协议支持

    AMQP,XMPP,SMTP,STOMP

    OpenWire,STOMP,REST,XMPP,AMQP

    自定义协议

    自定义协议

    可用性

    一般

    单机吞吐量

    一般

    非常高

    消息延迟

    微秒级

    毫秒级

    毫秒级

    毫秒以内

    消息可靠性

    一般

    一般

  • 相关阅读:
    mybatis 枚举的支持
    windows系统下Disconf web安装-分布式配置管理平台
    Tomcat启动报Error listenerStart错误
    Java并发编程:volatile关键字解析
    深入理解java异常处理机制
    Java 常见异常种类
    Java RMI与RPC的区别
    Java的快速失败和安全失败
    mysql数据类型介绍(含text,longtext,mediumtext说明)
    DTO – 服务实现中的核心数据
  • 原文地址:https://www.cnblogs.com/WarBlog/p/15474253.html
Copyright © 2011-2022 走看看