node-rdkafka的高级封装,在消息队列的基础上现实了类RPC远程调用.
特性
- 消息队列
- 远程调用
- 推送回调.
- 通用组件.
- 拓展服务.
- 中间件.
关于
该系统构建的目的在于解决Jessehealth公司的内部高并发集群架构问题.
用法
快速入门
const pandakafka = // 消费const consumer = type: "consumer" configure: name: "test" host: "localhost:9092" topic: "test" { console // "我的名字?" } // 生产const producer = type: "producer" configure: name: "test" host: "localhost:9092" topic: "test" // 生产测试消息并等待回调producer
配置
type: "consumer" // 模式 (consumer or producer)configure: name: "test" // 组ID host: "localhost:9092" // 服务器 topic: "test" // 主题 timeout: // 默认值为下面的示例 loop: 600000 // 消息回调清扫的周期 max: 1200000 // 消息回调的保留时间
异步处理请求并返回回调
// 消费const consumer = type: "consumer" configure: name: "test" host: "localhost:9092" topic: "test" { console // "我的名字?" return "panda" }
直接推送消息不要求回调
producer
消息类型(send and request) 这里只举例send
producerproducerproducer
全局的API
许可
Copyright (c) 2018 Mr.Panda.