image.png
5.1 阻塞队列
image.png
put和take这两个方法都是阻塞的方法。
阻塞的时候不会占用系统资源。
image.png
image.png
一个生产者三个消费者：
image.png
5.5 kafka入门
image.png
kafka高吞吐量的一个原因就是他的消息持久化，它将消息存在了硬盘中。但是对硬盘的顺序读取效率很高，甚至高于对内存的随机读取，因此kafka利用了这一点。这是一个分布式的服务器，因此具备高可靠性。
broker:kafka的服务器，kafka集群中每一台服务器都是一个broker。
zookeeper:管理集群的工具
kafka内置了zookeeper。
消息队列实现的方式大概有两种：
- 点对点：每个数据只被一个消费者消费 。
- 发布订阅模式：
可以有很多消费者先后读到。kafka是这种模式：
生产者将数据发布到的空间就是topic，主题。可以理解成是用来存放消息的一个位置。
offset表示消息再分区内存放的索引。
Leader Replica:分布式消息引擎，通过副本模式将消息存储多份。主副本可以负责做出响应，当有请求发过来的时候
Follower Replica:不负责进行响应，只是单纯的副本。主副本挂掉之后，会有一个从副本被选出作为主副本。
partition:
对主题的分区。
修改属性：
image.png
image.png
访问路径：bin/window/这个目录下面。
image.png
image.png
cd d
cd java/kafka
bin\window\zookeeper-server-start.bat config\zookeeper.properties
//表示使用某个配置文件来启动某个命令。
//然后就启动完成了
//再打开一个命令终端
cd d\work\kafka
bin\windows\kafka-server-start.bat config\server.prroperties
//启动完成了，下面这个文件也新建完成了。
image.png
现在两个都已经启动了，我们需要再次启动一个cmd窗口。使用kafka的命令。直接进入到包含命令行工具的目录下面。
image.png
kafka采用的发布订阅模式，因此要先将消息发布到某个主题下面。得先创建主题，他代表了消息的类别，比如说是点赞消息，还是回复消息。同时代表了消息的位置。
创建主题：
kafka-topics.bat --create --bootstrap-server localhost:9092[哪个服务器上创建主题] --replication-factor 1[创建一个副本] -partitions 1[有一个分区] --topic test[主题的名称]
//创建完成
image.png
//查看创建好的主题
image.png
//然后开始发送消息
//先选服务器列表，再选主题
image.png
生产者这边发了两个消息：
image.png
//再启动一个消费者窗口，读消息
image.png
左边只要一写，右边就能够收到。
5.9 spring整合kafka
image.png
image.png
将版本去掉。
image.png
3000ms自动提交一次。
自动提交消费者的消息偏移量。
测试：生产者生产一个消息，看看消费者能否得到并将其打印出来。
写的时候一般会将生产者和消费者进行各自的封装。
生产者发消息是依靠类kafkaTemplate。
image.png
image.png
image.png
我们主动调用生产者使其发送消息，但是消费者是被动收到消息的。不需要进行任何形式的调用。
5.11 发送系统通知
image.png
image.png
为了能够进行链式编程，我们对set操作稍作修改。
image.png
对所有的Set方法做相同的操作。
image.png
等后来就可以体现出来这样设计的便捷之处。
image.png
image.png
增加三个主题常量：
image.png
我们定义一个方法消费三个主题，方法和主题之间是多对多的关系。
image.png
接下来，如果都没问题，我们就可以利用恢复回来的消息发送一个站内通知。也就是构造一个message存在表中。
image.png
image.png
image.png
image.png
content里面还有可能会存在一些其他的额外数据，也都存起来。
image.png
image.png
接下来开始研究什么时候调用这个producer，因为消费者是被动调用的。只要队列中有数据，就会被调用。根据前面的讲解，我们应该在评论，点赞或者关注的时候调用。关注于commentControler, LikeController, FollowController。
红色部分是map中添加的，因为我们没有专门针对于此的属性。
image.png
方法补充：
image.png
image.png
image.png
这两个部分是并行的。
点赞事件：
只发点赞的通知，不发取消赞的通知。
image.png
image.png
image.png
在最后启动服务之前，首先一定要打开kafka和zookeeper。
这里有个逻辑问题，因为没有经过controller，明天再看具体是因为啥，不明白。
image.png
5.13 显示系统通知
将上一节课存储在数据库中的数据显示在页面上面。
image.png
image.png
image.png
我一直在想只是有这一个方法是不够的，还得再补充一个查所有主题未读消息的方法，这是太笨了，把第二个参数设置成可变的就可以啦。
image.png
image.png
image.png
显示通知列表：
Htmlescape表示转义，Htmlunescape表示反转义，转成特殊字符。
image.png
image.png
image.png
image.png
同时页面上还要显示私信的数量以及未读的数量，进行显示。
在私信列表上应该将这个补充完整。
image.png
image.png
image.png
image.png
- 接着开发通知详情
image.png
image.png
image.png
image.png
image.png
image.png
image.png
评论：
image.png
image.png
image.png
总的消息条数需要拦截器：因为每个消息都需要这个。
image.png
image.png
配置拦截器：
image.png
index页面的消息需要显示一下
网友评论