【仿牛客网笔记】 Kafka，构建TB级异步消息系统——发送系统通知、显示系统通知

定义时间主题


判断消息内容是否为空，消息格式是否错误。

系统通知是后台发给用户
发送站内通知
构造一个Message对象


设置站内的值
判断是否有数据，然后放入到message中

对CommentController、LikeController、FollowController进行处理。
需要注入EventProduce



CommentController实现触发评论事件

实现findCommentById



出发点赞事件，点一下是赞，一下是取消赞

重构一下方法，多加一个参数

触发关注事件

在discuss.js中加入传入的参数

前提是准备好Kafka和Zookeeper准备好。
Kafka的windows报错会由于某些原因崩溃，看它的报错日志经常会因为某一条数据锁死有冲突。window客户端不稳定。
将日志删除就会解决这个问题。

---

显示系统通知


status为2表示是私信删除的状态
from_id：通知一定是系统用户所以from_id一定是为1的，为了避免和访问的私信混淆
userId是接受者
主题放入到conversation_id中

查询数量

查询未读的通知数量

编写业务层

实现评论类通知、点赞类通知、查询关注类通知。

将数据放入data中
还要查询这一类的的数量和未读的数量

查询点赞类通知

查询关注类的通知

查询未读消息数量
私信的未读数量
conversationid为空，是因为不是要会话的，而是要整个的

为开发的私信添加通知功能



处理通知的模板



通知列表中有三类通知：评论类通知、点赞类通知、关注类通知

关注类通知






获取已读的数据，后返回模板