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