Kafka消息队列初识 (4)

  

Kafka消息队列初识

   以上就是Kafka的搭建和使用,也不是那么的复杂。我们在开发中肯定使用的是各类语言封装过的驱动,java、.net的都差不多,先理解了原理,用起来就方便多了。

三、Kafka客户端驱动的使用

   下面我们使用.net的Kafka驱动Confluent.Kafka,来看看是如果使用Kafka的,其他语言的小伙伴可以自行搜索相关的驱动。

  3.1 创建应用

   如下图,创建一个解决方案,添加两个控制台项目,一个作为生产者,一个作为消费者。

  

Kafka消息队列初识

  3.2 添加Producer和Consumer类

  添加Producer类和Consumer类,配置中的server写死为默认的Kafka服务器的地址,如下图所示:

  

Kafka消息队列初识

  

Kafka消息队列初识

     3.3 添加Program.cs中的启动代码

   添加Producer的代码:

   

Kafka消息队列初识

  添加Consumer的代码:

  

Kafka消息队列初识

  3.4 启动Kafka服务

  按照步骤2.2.1和2.2.2 启动Zookeeper和Kafka,消费者和生产者就不用启动了,我们用控制台代替。

  3.4 启动实例

  分别启动Producer实例和Consumer实例,在Producer控制台下输入消息,可以发现Consumer控制台下显示消息,和前边我们所做的是一致的。

  

Kafka消息队列初识

  好了,以上就是Kafka的初步使用,有了这些基础,我们就可以搭建一个消息队列开始处理消息了。

  代码托管到github,地址:https://github.com/EmmaCCC/KafkaStudy.git

四、总结

  到此为止,我们已经基本掌握了Kafka的使用,至于详细的配置啥的等到我们用的时候再去研究,假如没机会用到,那就不用去学了,不过用到用不到学了总是有用的,因为到时候简历上又可以写上一项技能了:熟练使用Kafka搭建高并发分布式消息队列系统,承载千万级别的消息并发,之后的怎么喷就看你自己了。

Kafka消息队列初识

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/zydspw.html