当前位置: article > 正文

kafka监听机制的实现_分布式下使用kafka实现事件监听器的方式

作者：天景科技苑 | 2024-07-31 01:28:23

踩

分布式下使用kafka实现事件监听器的方式

kafka监听机制的实现

实际是开启一个线程池ThreadPoolExecutor，for循环建立一个长连接，每200毫秒去kafka服务器拉取消息，每拉到一个消息，就分配给一个线程类ConsumerWorker去处理这个消息

说是监听，其实就是一直不停的拉取消息，在实际的业务场景中可能解释不同，但其实就是以某一个特定的指标或者是什么东西做为一个基础，然后每200ms去和200ms前的状态去做比较，把差异部分取出来，也可以称为增量数据拉取，只不过是间隔时间缩短了而已。所以在这一块解释应该和kafka一样，引入状态量这个词，状态量也相当于是一个指标，如果指标有变化，则把消息实时拉取过来并发送给订阅的消费者，由消费者进行消费即可。

在kafka中把握住几个关键点就行：

生产者、消息分发、消费者

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/天景科技苑/article/detail/906318