微信亿级在线点赞系统，用Redis如何实现？

gtxyzz 运维技术 2022-11-19 435浏览 0

点赞功能大家都不会陌生，像微信这样的社交产品中都有，但别看功能小，想要做好需要考虑的东西还挺多的，如海量数据的分布式存储、分布式缓存、多 IDC 的数据一致性、访问路由到机房的算法等等。

微信亿级在线点赞系统，用Redis如何实现？图片来 Pexels

本文介绍大型社交平台点赞系统的设计思路，基于 Spring Cloud，用户发起点赞、取消点赞后先存入 Redis 中，再每隔两小时从 Redis 读取点赞数据写入数据库中做持久化存储。

点赞、取消点赞是高频次的操作，若每次都读写数据库，大量的操作会影响数据库性能，所以需要做缓存。

至于多久从 Redis 取一次数据存到数据库中，根据项目的实际情况定吧，我是暂时设了两个小时。

项目需求需要查看都谁点赞了，所以要存储每个点赞的点赞人、被点赞人，不能简单的做计数。

文章分四部分介绍：

Redis 缓存设计及实现
数据库设计
数据库操作
开启定时任务持久化存储到数据库

Redis 缓存设计及实现

Redis 安装及运行

Redis 安装请自行查阅相关教程。

说下Docker 安装运行 Redis：

dockerrun-d-p6379:6379redis:4.0.8

如果已经安装了 Redis，打开命令行，输入启动 Redis 的命令：

redis-server

Redis 与 Spring Boot 项目的整合

①在 pom.xml 中引入依赖：

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

②在启动类上添加注释 @EnableCaching：

@SpringBootApplication
@EnableDiscoveryClient
@EnableSwagger2
@EnableFeignClients(basePackages="com.solo.coderiver.project.client")
@EnableCaching
publicclassUserApplication{

publicstaticvoidmain(String[]args){
SpringApplication.run(UserApplication.class,args);
}
}

③编写 Redis 配置类 RedisConfig：

importcom.fasterxml.jackson.annotation.JsonAutoDetect;
importcom.fasterxml.jackson.annotation.PropertyAccessor;
importcom.fasterxml.jackson.databind.ObjectMapper;
importorg.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
importorg.springframework.context.annotation.Bean;
importorg.springframework.context.annotation.Configuration;
importorg.springframework.data.redis.connection.RedisConnectionFactory;
importorg.springframework.data.redis.core.RedisTemplate;
importorg.springframework.data.redis.core.StringRedisTemplate;
importorg.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;

importjava.net.UnknownHostException;


@Configuration
publicclassRedisConfig{

@Bean
@ConditionalOnMissingBean(name="redisTemplate")
publicRedisTemplate<String,Object>redisTemplate(
RedisConnectionFactoryredisConnectionFactory)
throwsUnknownHostException{

Jackson2JsonRedisSerializer<Object>jackson2JsonRedisSerializer=newJackson2JsonRedisSerializer<Object>(Object.class);
ObjectMapperom=newObjectMapper();
om.setVisibility(PropertyAccessor.ALL,JsonAutoDetect.Visibility.ANY);
om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
jackson2JsonRedisSerializer.setObjectMapper(om);

RedisTemplate<String,Object>template=newRedisTemplate<String,Object>();
template.setConnectionFactory(redisConnectionFactory);
template.setKeySerializer(jackson2JsonRedisSerializer);
template.setValueSerializer(jackson2JsonRedisSerializer);
template.setHashKeySerializer(jackson2JsonRedisSerializer);
template.setHashValueSerializer(jackson2JsonRedisSerializer);
template.afterPropertiesSet();
returntemplate;
}


@Bean
@ConditionalOnMissingBean(StringRedisTemplate.class)
publicStringRedisTemplatestringRedisTemplate(
RedisConnectionFactoryredisConnectionFactory)
throwsUnknownHostException{
StringRedisTemplatetemplate=newStringRedisTemplate();
template.setConnectionFactory(redisConnectionFactory);
returntemplate;
}
}

至此 Redis 在 Spring Boot 项目中的配置已经完成，可以愉快的使用了。

Redis 的数据结构类型

Redis 可以存储键与 5 种不同数据结构类型之间的映射，这5种数据结构类型分别为 String(字符串)、List(列表)、Set(集合)、Hash(散列)和 Zset(有序集合)。