你好,我是kafka 今天带大家初步认识一下中间件kafka.
首先问一下,什么是中间件呢?
中间件意思就是介于操作系统和应用程序的软件,可以进行复用,不依赖域第三方的应用,可独立运行
kafka就是这么一个中间件,一起来了解一下它吧
kafka 是一个消息订阅型中间件,主要采取订阅 发布的模式进行运行.
那么 啥是订阅发布呢? 举例来说就是 你下单点个外卖, 手机下完单就可以了, 不需要等待商家回复,也无需站在门口等,静静等待外卖骑手给你送过来就行了,这里就是很经典的发布订阅模型, 你发布一个订单, 商家进行接单 骑手进行派单, 你在进行接收外卖, 过程中没有直接的交互 , 也不需要一直等待商家的回复确认 这个过程也叫解耦 ,意思就是我不和你强绑定关系 我可以点A商家的外卖 也可以点B商家的外卖 互相没有强依赖关系
那么除了上述说的 发布订阅模型可以互相解耦外, 还有什么优点呢?
其实啊 解耦带来的好处就是不需要强依赖,还是外卖的例子, 我下单就行了, 我该拖地拖地 该上班上班 无需进行等待,这也就是异步的概念, 通知你就行了,我不需要你的回应.这个可以带来程序更高的效率和性能.
那这个发布/订阅 怎么玩的? 这个模型到底是个啥?
首先先引入一个概念 topic 也就是主题 例如: 你喜欢流行音乐频道, 所以你在网易云上订阅了这个频道,
那么这个频道就是对应的topic ,你订阅了此频道, 有新出的音乐我们后续通知你.
所以在kafka中呢 一般是以topic作为消息订阅的队列,你可以往里面推送消息, 也可以从里面消费消息。
好啦，这就是大概的模型。
那么为什么kafka需要用发布订阅模型呢? 有什么好处? 那么使用这种模型具体使用pull 还是push?
那么请留意后期的推文，或者关注我集中更新哦~
