bigpipe:以Kafka为存储介质提供异步HTTP RPC的中间件 源码

大烟斗 一个基于Kafka的中间件,预测简化服务间初始Http调用的复杂度 功能更新 2018-04-04:增加了消费者粒度的熔断器,防止下游不可用导致大量流量持续损失,这是一个可选功能 环境要求 卡夫卡> = 0.9 转到> = 1.8 特性 横向扩展:完全支持rebalanced-consumer-group,多进程部署即可实现分区自动负载均衡 配置热加载:在线服务无需重启即可立即加载配置,流量0损失 优雅退出:处理完剩余任务后退出,流量0损失 超强性能:无锁,协程并发,单进程即可充分利用多核,满足一般流量需求 容错机制:对下游实施限速,限并发,熔断三种保护机制 安装依赖 GO包依赖 编