Redis实现朋友圈，微博等Feed流功能,实现Feed流微服务(业务场景、实现思路和环境搭建)-恋恋不舍网

Redis实现朋友圈，微博等Feed流功能,实现Feed流微服务(业务场景、实现思路和环境搭建)

文章目录

- 业务场景
- Feed流相关概念
- Feed流特征
- Feed流分类
- 实现思路
- 环境搭建
- - 数据库表结构
  - 新建Feeds功能微服务ms-feeds
  - 配置类 RedisTemplateConfiguration
  - REST配置类 RestTemplateConfiguration
  - Feeds 实体类
  - FeedsVO 响应类

业务场景

在互联网领域，实实现实现思路尤其现在的现朋移动互联网时代，Feed流产品是友圈业务非常常见的，比如我们每天都会用到的微博朋友圈，微博，流流微就是服务一种非常典型的Feed流产品，还有图片分享网站Pinterest，场景花瓣网等又是和环另一种形式的Feed流产品。除此之外，境搭建很多App的实实现实现思路都会有一个模块，要么叫动态，现朋要么叫消息广场，友圈业务这些也是微博Feed流产品，可以说，流流微Feed流产品是服务遍布天下所有的App中。
在这里插入图片描述

Feed流相关概念

我们在讲如何设计Feed流系统之前，先来看一下Feed流中的一些概念：

Feed：Feed流中的每一条状态或者消息都是Feed，比如朋友圈中的一个状态就是一个Feed，微博中的一条微博就是一个Feed。
Feed流：持续更新并呈现给用户内容的信息流。每个人的朋友圈，微博关注页等等都是一个Feed流。
Timeline：Timeline其实是一种Feed流的类型，微博，朋友圈都是Timeline类型的Feed流，但是由于Timeline类型出现最早，使用最广泛，最为人熟知，有时候也用Timeline来表示Feed流。
关注页Timeline：展示其他人Feed消息的页面，比如朋友圈，微博的首页等。
个人页Timeline：展示自己发送过的Feed消息的页面，比如微信中的相册，微博的个人页等。
总结来说，Feed是将用户主动订阅的若干消息源组合在一起形成内容聚合器，帮助用户持续地获取最新的订阅源内容。Feed流即持续更新并呈现给用户内容的信息流。

Feed流特征

Feed流系统有一些非常典型的特点，比如：

多账号内容流：Feed流系统中肯定会存在成千上万的账号，账号之间可以关注，取关，加好友和拉黑等操作。只要满足这一条，那么就可以当做Feed流系统来设计。
非稳定的账号关系：由于存在关注，取关等操作，所以系统中的用户之间的关系就会一直在变化，是一种非稳定的状态。
读写比例100:1：读写严重不平衡，读多写少，一般读写比例在10：1，甚至100：1以上。
消息必达性要求高：比如发送了一条朋友圈后，结果部分朋友看到了，部分朋友没看到，这就很有问题，如果偏偏女朋友没看到，那么可能会产生很严重的感情矛盾，后果很严重。

Feed流分类

Feed流的分类有很多种，但最常见的分类有两种：

Timeline：按发布的时间顺序排序，先发布的先看到，后发布的排列在最顶端，类似于微信朋友圈，微博等。这也是一种最常见的形式。产品如果选择Timeline类型，那么就是认为Feed流中的Feed不多，但是每个Feed都很重要，都需要用户看到。
Rank：按某个非时间的因子排序，一般是按照用户的喜好度排序，用户最喜欢的排在最前面，次喜欢的排在后面。这种一般假定用户可能看到的Feed非常多，而用户花费在这里的时间有限，那么就为用户选择出用户最想看的Top N结果，场景的应用场景有图片分享、新闻推荐类、商品推荐等。

实现思路

解决Feed流最核心的两个问题：一个是存储，另一个是推送
① 存储
因为该项目中Feed比较简单，就类比于空间说说，因此可以使用MySQL关系型数据库存储，如果对于数据结构比较复杂的Feed流就要使用NoSQL数据库，这样存储更方便与高效，比如MongoDB或者HBase。
② 推送，在推送方案里面的，有三种方案，分别是：

拉方案：也称为读扩散，用户主动去拉取关注人的Feed内容
推方案：也成为写扩散，当用户添加Feed时，会自动将Feed通知给关注的人（优选）。使用Redis Sorted Sets（方便按时间排序Timeline）维护粉丝的Feed集合，当博主添加Feed时，主动将内容推送到粉丝的Feed集合中，这样用户可以很方便快速从集合中读取
推拉结合：比如微博，大部分用户的账号关系都是几百个，但是有个别用户是1000万以上。

环境搭建

数据库表结构

CREATE TABLE `t_feeds` (	`id` INT ( 11 ) NOT NULL AUTO_INCREMENT,	`content` VARCHAR ( 500 ) CHARACTER 	SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '内容',	`fk_user_id` INT ( 11 ) NULL DEFAULT NULL,	`praise_amount` INT ( 11 ) NULL DEFAULT NULL COMMENT '点赞数量',	`comment_amount` INT ( 11 ) NULL DEFAULT NULL COMMENT '评论数量',	`fk_restaurant_id` INT ( 11 ) NULL DEFAULT NULL  COMMENT '餐厅外键',	`create_date` datetime NULL DEFAULT NULL,	`update_date` datetime NULL DEFAULT NULL,	`is_valid` TINYINT ( 1 ) NULL DEFAULT NULL,	PRIMARY KEY ( `id` ) ) ENGINE = INNODB DEFAULT CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci AUTO_INCREMENT = 14 ROW_FORMAT = COMPACT;

新建Feeds功能微服务ms-feeds

pom依赖：

redis-seckill        com.zjq1.0-SNAPSHOT4.0.0ms-feeds    org.springframework.cloudspring-cloud-starter-netflix-eureka-client        org.springframework.bootspring-boot-starter-web        mysqlmysql-connector-java        org.springframework.bootspring-boot-starter-data-redis        org.mybatis.spring.bootmybatis-spring-boot-starter        com.zjqcommons            1.0-SNAPSHOTcom.battcnswagger-spring-boot-starter

SpringBoot配置文件：

server:  port: 7005 # 端口spring:  application:    name: ms-feeds # 应用名  # 数据库  datasource:    driver-class-name: com.mysql.cj.jdbc.Driver    username: root    password: root    url: jdbc:mysql://127.0.0.1:3306/seckill?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useUnicode=true&useSSL=false  # Redis  redis:    port: 6379    host: localhost    timeout: 3000    password: 123456    database: 2  # Swagger  swagger:    base-package: com.zjq.feeds    title: Feed功能微服务API接口文档# 配置 Eureka Server 注册中心eureka:  instance:    prefer-ip-address: true    instance-id: ${ server.port}  client:    service-url:      defaultZone: http://localhost:7000/eureka/service:  name:    ms-oauth-server: http://ms-oauth2-server/    ms-users-server: http://ms-users/mybatis:  configuration:    map-underscore-to-camel-case: true # 开启驼峰映射logging:  pattern:    console: '%d{ HH:mm:ss} [%thread] %-5level %logger{ 50} - %msg%n'

启动类：

package com.zjq.feeds;import org.mybatis.spring.annotation.MapperScan;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;/** * Feeds功能微服务 * @author zjq */@MapperScan("com.zjq.feeds.mapper")@SpringBootApplicationpublic class FeedsApplication {     public static void main(String[] args) {         SpringApplication.run(FeedsApplication.class);    }}

配置类 RedisTemplateConfiguration

/** * RedisTemplate配置类 * * @author zjq */@Configurationpublic class RedisTemplateConfiguration {     /**     * redisTemplate 序列化使用的jdkSerializeable, 存储二进制字节码, 所以自定义序列化类     *     * @param redisConnectionFactory     * @return     */    @Bean    public RedisTemplateredisTemplate(RedisConnectionFactory redisConnectionFactory) {         RedisTemplateredisTemplate = new RedisTemplate<>();        redisTemplate.setConnectionFactory(redisConnectionFactory);        // 使用Jackson2JsonRedisSerialize 替换默认序列化        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);        ObjectMapper objectMapper = new ObjectMapper();        objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);        jackson2JsonRedisSerializer.setObjectMapper(objectMapper);        // 设置key和value的序列化规则        redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);        redisTemplate.setKeySerializer(new StringRedisSerializer());        redisTemplate.setHashKeySerializer(new StringRedisSerializer());        redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);        redisTemplate.afterPropertiesSet();        return redisTemplate;    }}

REST配置类 RestTemplateConfiguration

/** * RestTemplate 配置类 * @author zjq */@Configurationpublic class RestTemplateConfiguration {     @LoadBalanced    @Bean    public RestTemplate restTemplate() {         RestTemplate restTemplate = new RestTemplate();        MappingJackson2HttpMessageConverter converter = new MappingJackson2HttpMessageConverter();        converter.setSupportedMediaTypes(Collections.singletonList(MediaType.TEXT_PLAIN));        restTemplate.getMessageConverters().add(converter);        return restTemplate;    }}

Feeds 实体类

/** * Feed信息类 * @author zjq */@Getter@Setter@ApiModel(description = "Feed信息类")public class Feeds extends BaseModel {     @ApiModelProperty("内容")    private String content;    @ApiModelProperty("用户id")    private Integer fkUserId;    @ApiModelProperty("点赞")    private int praiseAmount;    @ApiModelProperty("评论")    private int commentAmount;    @ApiModelProperty("关联的餐厅")    private Integer fkRestaurantId;}