消息中间件

使用中间件前的系统之间调用关系

异步解耦合

原本可能是 登录后,你需要若干操作, 那么你就一样一样做, 做完之后才返回登录成功。(阻塞,高耦合)
而后来, 你把信息发送到一个中间件, 其它服务来接收中间件信息, 你登录后再慢慢做那些事情(非阻塞,解耦合)


中间件概述

消息中间件

图示

JMS

JMS 和 AMQP

KAFKA

JMS编码接口1

JMS编码接口2

JMS编码和接口规范
  • 队列模式: 生产者不断向中间件中添加消息, 消费者从队列中逐个获取消息进行消费(只能有一个消费者获取到消息)

  • 主题模式: 生产者不断向中间件中添加消息, 消费者从主题中逐个获取消息进行消费(先订阅了才能获取,且每个消费者都能获取到)

  • 集群的意义
  • 集群方式
  • Master/Slave

    (每个Node对应自己的存储地址,zookeeper选举一个为Master, 其它为Slave。只有一个Master能被访问,当Master收到信息后,通过Zookeeper把信息同步给NodeB和NodeC。当一个挂掉后,选举其它的为Master)

  • 分布式系统应用消息中间件

    (各个系统之间通过主题方式来消费别的系统的信息, 而一个系统的集群又通过队列来消费信息。)

  • 实际业务场景需求
  • Kafka
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容