最近维护的一个系统并发有点高，所以想引入一个消息队列来进行削峰。考察了一些产品，最终决定使用kafka来当做消息队列。kafkakafka 是分布式流式平台。它由linkedin开发，后贡献给了Apache开源组织并成为顶级开源项目。流处理平台有以下三种特性:. topickafka中的topic是一个分类的概念，表示一类消息。消费者消费者的演示代码同样很简单。我们需要指定groupId，然后订阅topic。运行一下我们运行一个生产者进程，按照500ms的速度生产消息。运行三个consumer进行消费，可以看到消息被均匀的推送到三个consumer上去。总结以上简单的介绍了kafka的背景、安装方法、使用场景。它当前非常流行，网上的资料也多如牛毛。官方也提供了简单易用的.net sdk ，为.net 平台集成kafka提供了便利。
暂无评论