西安网站seo推广厂家,网站代理建设,什么专业学网页设计制作,做公司网站软件一、阻塞队列 创建了一个生产者线程和一个消费者线程。生产者线程向队列中放入元素#xff0c;消费者线程从队列中取出元素。我们可以看到#xff0c;当队列为空时#xff0c;消费者线程会被阻塞#xff0c;直到生产者线程向队列中放入新的元素。
二、Kafka入门 发布、订阅…一、阻塞队列 创建了一个生产者线程和一个消费者线程。生产者线程向队列中放入元素消费者线程从队列中取出元素。我们可以看到当队列为空时消费者线程会被阻塞直到生产者线程向队列中放入新的元素。
二、Kafka入门 发布、订阅
三、spring整合Kafka
首先需要在项目的pom.xml中添加对Spring Kafka的依赖。然后可以通过配置类或application.properties来配置Kafka生产者和消费者。接着使用KafkaTemplate发送消息和使用KafkaListener注解来监听和接收消息。
四、发送系统通知
功能拆解
具体实现
构造生产者与消费者
生产者将得到的event发给指定主题
消费者将event转换为message对象再将message存入数据库
调用producer
comment controller生成event调用生产者的fire event方法。有人点赞时就会将event发出到消息队列里消费者监听到后会将event转换为message对象再将message存入数据库。
like controller生成event调用生产者的fire event方法。
follow controller:生成event调用生产者的fire event方法。
五、显示系统通知 message表里有新的点赞、评论、关注。现在增加将这些数据显示在系统通知页面的功能。
service增加查询message通知的方法
controller将查到的message放入页面
