Elasticsearch 简介1234- 一个分布式的、Restful 风格的搜索引擎。- 支持对各种类型的数据的检索。- 搜索速度快，可以提供实时的搜索服务。- 便于水平扩展，每秒可以处理PB级海量数据。 Elasticsearch 术语12- 索引（对应数据库中的表）、类型（6.0以上废弃）、文档（行，JSON）、字段（列）。- 集群、节点、分片、副本。 Elasticsearch 配置

示意图 通知列表1- 显示评论、点赞、关注三种类型的通知 通知详情1- 分页显示某一类主题所包含的通知 未读消息1- 在页面头部显示所有的未读消息数量 数据访问层 MessageMapper: 添加内容12345678910111213// MessageMapper.java// 查询某个主题下最新的通知Message selectLatestNotice(int userId, String

问题背景 12在项目中，有一些不需要实时执行但是非常频繁的操作。为了提升网站的性能，可以使用异步消息的形式进行发送，使用消息队列服务器 kafka 来实现。 发送系统通知评论，点赞，关注等事件频繁发生，但是发送系统通知不需要立刻执行。 触发事件 评论后，发布通知1234567891011121314151617181920212223242526272829303132// CommentCon

引入依赖1234<dependency> <groupId>org.springframework.kafka</groupId> <artifactId>spring-kafka</artifactId></dependency> 配置 Kafka 配置server、consumer12345# KafkaPr

系统环境Ubuntu16.04 安装Docker12apt install dockerapt-get install docker.io 下载镜像1docker pull ubuntu:16.04 运行容器1docker run -ti ubuntu:16.04 不要关闭这个终端 安装JDK1tar -zxvf jdk-8u11-linux-x64.tar.gz -C /opt 配置Java

Kafka 简介 12- Kafka 是一个分布式的流媒体平台。- 应用：消息系统、日志收集、用户行为追踪、流式处理。 Kafka 特点1234- 消息持久化：把数据存到硬盘上，而不是简单地存到内存。- 高吞吐量：硬盘价格低、存储量大，是存储海量数据的前提。硬盘的顺序读取甚至高于对内存的随机读取，Kafka对硬盘的读取都是顺序进行的，所以对硬盘进行IO不一定性能低。- 高可靠性：分布式环境，可以

阻塞队列 123456不使用阻塞队列：- 如果生产者生产速度快、消费者消费速度慢的话，很快就会达到性能瓶颈。如：线程2没处理完数据，线程1依旧在不停的生产数据、没有被阻塞，则会占用CPU资源。- 如果消费者消费速度快、生产者生产速度慢的话，占用系统CPU资源。使用阻塞队列：- 队列满，生产者线程被阻塞，不占用系统资源。- 队列空相反。 BlockingQueue12- 解决线程通信的一个接口。在生

Redis 存储验证码123- 验证码需要频繁地访问与刷新，对性能要求较高。- 验证码不需要永久保存，通常在很短的时间后就会失效。- 分布式部署时，存在 Session 共享的问题。 工具类 RedisKeyUtil：增加内容123456private static final String PREFIX_KAPTCHA = "kaptcha";// 登录验证码public s

业务层12- 查询某个用户关注的人（支持分页）。- 查询某个用户的粉丝（支持分页）。 FollowService：增加内容12345678910111213141516171819202122232425262728293031323334353637383940414243// 查询某个用户关注的人public List<Map<String, Object>> fin

需求12- 开发关注、取消关注功能。- 统计用户的关注数、粉丝数。 关键12- 若A关注了B，则A是B的Follower(粉丝、关注者)，B是A的Followee(目标、被关注者)。- 关注的目标可以是用户、帖子等，实现时将这些目标抽象为实体。 工具类 RedisKeyUtil：增加内容1234567891011121314private static final String PREFIX_