文件名称：kafka-notify-system:一个基于Kafka的演示通知系统，生产者将通知发布到Kafka，消费者订阅通知并发送给用户
文件大小：25KB
文件格式：ZIP
更新时间：2024-05-22 04:02:41
Java
通知生产者 该模块使用Apache Kafka客户端将通知发布到Kafka。 SimpleBatchProducer是一个单线程生成器，默认情况下发布通知分区程序（键：receiverId + serviceName）。 这样可以保证每个分区上消息的本地顺序。 处理消息发送结果的3种方法： 火与忘了 等待结果（通过Future.get() ） 回调处理程序 通知消费者 该模块订阅通知并发送给用户。 最大并行度受分区数限制。 消息的轮询和处理应该是同步的，以确保接收通知的顺序。 SimpleConsumer将订阅该主题，并将接收到的消息放入阻止队列。 NotificationProcessor将清空队列中的消息并进行处理（通过打印到日志进行简化）。 使用单线程来确保流程顺序。 对于多个使用者，可以使用多线程，请参阅
【文件预览】：
kafka-notify-system-master
----.gitignore(32B)
----notify-producer()
--------src()
--------pom.xml(762B)
----common-util()
--------src()
--------pom.xml(543B)
----notify-consumer()
--------src()
--------pom.xml(761B)
----pom.xml(4KB)
----Readme.md(1KB)