以上就是Kafka的搭建和使用,也不是那么的复杂。我们在开发中肯定使用的是各类语言封装过的驱动,java、.net的都差不多,先理解了原理,用起来就方便多了。
三、Kafka客户端驱动的使用
下面我们使用.net的Kafka驱动Confluent.Kafka,来看看是如果使用Kafka的,其他语言的小伙伴可以自行搜索相关的驱动。
3.1 创建应用
如下图,创建一个解决方案,添加两个控制台项目,一个作为生产者,一个作为消费者。
3.2 添加Producer和Consumer类
添加Producer类和Consumer类,配置中的server写死为默认的Kafka服务器的地址,如下图所示:
3.3 添加Program.cs中的启动代码
添加Producer的代码:
添加Consumer的代码:
3.4 启动Kafka服务
按照步骤2.2.1和2.2.2 启动Zookeeper和Kafka,消费者和生产者就不用启动了,我们用控制台代替。
3.4 启动实例
分别启动Producer实例和Consumer实例,在Producer控制台下输入消息,可以发现Consumer控制台下显示消息,和前边我们所做的是一致的。
好了,以上就是Kafka的初步使用,有了这些基础,我们就可以搭建一个消息队列开始处理消息了。
代码托管到github,地址:https://github.com/EmmaCCC/KafkaStudy.git
四、总结
到此为止,我们已经基本掌握了Kafka的使用,至于详细的配置啥的等到我们用的时候再去研究,假如没机会用到,那就不用去学了,不过用到用不到学了总是有用的,因为到时候简历上又可以写上一项技能了:熟练使用Kafka搭建高并发分布式消息队列系统,承载千万级别的消息并发,之后的怎么喷就看你自己了。