选择使用Kafka是因为Kafka作为中间件他的吞吐量比较高 , 我们的系统中主要使用Kafka来处理一些用户的行为数据 , 用户行为数据用户操作成本低 , 数据量比较大 , 需要有更高的吞吐量支持 , 并且我们在项目中需要实现根据用户行为的实时推荐 , 运营端后台管理系统首页看板数据的实体展示 !
使用Kafka有很多好处:
● 吞吐量提升:无需等待订阅者处理完成,响应更快速
● 故障隔离:服务没有直接调用,不存在级联失败问题
● 调用间没有阻塞,不会造成无效的资源占用
● 耦合度极低,每个服务都可以灵活插拔,可替换
● 流量削峰:不管发布事件的流量波动多大,都由Broker接收,订阅者可以按照自己的速度去处理事件
使用Kafka也有很多缺点:
● 架构复杂了,业务没有明显的流程线,不好管理
● 需要依赖于Broker的可靠、安全、性能