尧图网站建设 
最近在开发一个社区活动投票系统时遇到了一个典型的技术挑战如何在后端高效、安全地处理来自前端的复杂投票数据并确保实时排名和结果展示的准确性。这不仅仅是简单的增删改查更涉及到数据校验、并发控制、实时计算和结果缓存等多个技术点的综合运用。本文将围绕一个模拟的社区才艺竞演活动我们暂且称之为“社区星光赛”的后台系统构建完整拆解从数据库设计、Spring Boot接口开发到结果实时展示的全流程。无论你是正在学习Spring Boot和MyBatis的在校学生还是需要处理类似投票、评分业务的后端开发者都能从本文中获得一套可直接复用的实战方案。1. 项目背景与核心需求分析我们的目标是构建一个“社区星光赛”活动的后台管理系统。该活动有多个参赛者英才观众可以为他们支持的英才投票。每次投票行为我们称之为一次“竞斗”。系统需要实时统计每个英才的票数并动态更新排名。核心业务需求如下英才管理支持录入、查询、修改参赛英才的基本信息如编号、姓名、所属阵营/“邻居”。投票竞斗处理接收投票请求记录投票人、被投票英才、投票时间等信息。实时统计与排名根据投票数据实时计算每个英才的总票数并按照票数进行排名。数据查询与展示提供接口查询英才列表带排名、单个英才详情、投票记录等。数据安全与校验防止重复投票、刷票等恶意行为保证数据一致性。技术栈选型后端框架Spring Boot 2.7.x稳定且生态丰富数据持久层MyBatis-Plus 3.5.x简化CRUD提高开发效率数据库MySQL 8.0关系型数据库适合事务性操作缓存Redis用于存放实时排名减轻数据库压力项目管理Maven2. 开发环境与项目初始化在开始编码前请确保你的本地开发环境已就绪。2.1 环境准备清单JDK版本 8 或 11本文使用 JDK 11IDEIntelliJ IDEA 或 Eclipse推荐IDEAMySQL版本 5.7已启动并创建好数据库如community_show_dbRedis版本 5.0已启动Maven版本 3.62.2 创建Spring Boot项目使用 Spring Initializr https://start.spring.io 或 IDEA 内置的 Spring Initializr 创建项目。依赖选择Spring WebMyBatis FrameworkMySQL DriverLombok简化实体类代码Spring Boot DevTools热部署创建完成后pom.xml文件会包含这些基础依赖。我们还需要手动添加mybatis-plus-boot-starter和redis的依赖。!-- pom.xml 中添加 -- dependency groupIdcom.baomidou/groupId artifactIdmybatis-plus-boot-starter/artifactId version3.5.3.1/version /dependency dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-data-redis/artifactId /dependency2.3 项目基础配置在application.yml或application.properties中配置数据库和Redis连接。这里以application.yml为例。# src/main/resources/application.yml server: port: 8080 spring: datasource: driver-class-name: com.mysql.cj.jdbc.Driver url: jdbc:mysql://localhost:3306/community_show_db?useUnicodetruecharacterEncodingutf-8serverTimezoneAsia/Shanghai username: root password: yourpassword redis: host: localhost port: 6379 # password: 如果Redis有密码则配置 database: 0 timeout: 3000ms lettuce: pool: max-active: 8 max-wait: -1ms max-idle: 8 min-idle: 0 # MyBatis-Plus 配置 mybatis-plus: configuration: log-impl: org.apache.ibatis.logging.stdout.StdOutImpl # 控制台打印SQL生产环境建议关闭 global-config: db-config: logic-delete-field: isDeleted # 全局逻辑删除字段名若有 logic-delete-value: 1 # 逻辑已删除值 logic-not-delete-value: 0 # 逻辑未删除值3. 数据库设计与实体类映射良好的数据库设计是系统的基石。根据需求我们设计三张核心表。3.1 数据表设计-- 英才表 (talent) CREATE TABLE talent ( id bigint NOT NULL AUTO_INCREMENT COMMENT 主键ID, talent_no varchar(20) NOT NULL COMMENT 英才编号如TC001, name varchar(50) NOT NULL COMMENT 英才姓名, neighborhood varchar(50) DEFAULT NULL COMMENT 所属阵营/邻居, description text COMMENT 描述, create_time datetime DEFAULT CURRENT_TIMESTAMP COMMENT 创建时间, update_time datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT 更新时间, is_deleted tinyint DEFAULT 0 COMMENT 逻辑删除0-未删1-已删, PRIMARY KEY (id), UNIQUE KEY uk_talent_no (talent_no) ) ENGINEInnoDB DEFAULT CHARSETutf8mb4 COMMENT英才信息表; -- 投票记录表 (vote_record) CREATE TABLE vote_record ( id bigint NOT NULL AUTO_INCREMENT COMMENT 主键ID, voter_id varchar(64) NOT NULL COMMENT 投票人标识可为用户ID、IP、设备指纹等, talent_id bigint NOT NULL COMMENT 被投票英才ID, vote_time datetime DEFAULT CURRENT_TIMESTAMP COMMENT 投票时间, channel varchar(20) DEFAULT WEB COMMENT 投票渠道WEB, APP, WX等, create_time datetime DEFAULT CURRENT_TIMESTAMP COMMENT 创建时间, PRIMARY KEY (id), KEY idx_voter_talent (voter_id,talent_id) COMMENT 防止同一投票人对同一英才重复投票, KEY idx_talent_time (talent_id,vote_time) COMMENT 按英才和时间查询, CONSTRAINT fk_vote_talent FOREIGN KEY (talent_id) REFERENCES talent (id) ) ENGINEInnoDB DEFAULT CHARSETutf8mb4 COMMENT投票记录表; -- 英才票数统计表 (talent_vote_summary) - 可做物化视图或定时更新 CREATE TABLE talent_vote_summary ( talent_id bigint NOT NULL COMMENT 英才ID, total_votes bigint DEFAULT 0 COMMENT 总票数, update_time datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT 统计更新时间, PRIMARY KEY (talent_id), CONSTRAINT fk_summary_talent FOREIGN KEY (talent_id) REFERENCES talent (id) ) ENGINEInnoDB DEFAULT CHARSETutf8mb4 COMMENT英才票数统计表冗余用于快速查询;设计要点说明talent_no设置唯一索引确保编号不重复。vote_record表建立了(voter_id, talent_id)的联合索引可以高效判断同一用户是否对同一英才重复投票。创建了talent_vote_summary表作为统计冗余表。实时更新排名对数据库压力大通常我们会用缓存Redis来存实时排名此表可用于每日定时汇总或作为缓存击穿后的备份数据源。3.2 实体类创建使用 Lombok 注解简化代码。// src/main/java/com/example/communityshow/entity/Talent.java package com.example.communityshow.entity; import com.baomidou.mybatisplus.annotation.*; import lombok.Data; import java.time.LocalDateTime; Data TableName(talent) public class Talent { TableId(type IdType.AUTO) private Long id; private String talentNo; private String name; private String neighborhood; private String description; TableField(fill FieldFill.INSERT) private LocalDateTime createTime; TableField(fill FieldFill.INSERT_UPDATE) private LocalDateTime updateTime; TableLogic private Integer isDeleted; }// src/main/java/com/example/communityshow/entity/VoteRecord.java package com.example.communityshow.entity; import com.baomidou.mybatisplus.annotation.*; import lombok.Data; import java.time.LocalDateTime; Data TableName(vote_record) public class VoteRecord { TableId(type IdType.AUTO) private Long id; private String voterId; // 实际项目中可能需要更复杂的用户标识 private Long talentId; private LocalDateTime voteTime; private String channel; TableField(fill FieldFill.INSERT) private LocalDateTime createTime; }// src/main/java/com/example/communityshow/entity/TalentVoteSummary.java package com.example.communityshow.entity; import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; import lombok.Data; import java.time.LocalDateTime; Data TableName(talent_vote_summary) public class TalentVoteSummary { TableId(type IdType.INPUT) // 注意这里主键是 talent_id不是自增 private Long talentId; private Long totalVotes; private LocalDateTime updateTime; }4. MyBatis-Plus 与 Service 层开发我们将利用 MyBatis-Plus 的通用 Mapper 和 Service 快速实现基础数据操作。4.1 创建 Mapper 接口// src/main/java/com/example/communityshow/mapper/TalentMapper.java package com.example.communityshow.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.example.communityshow.entity.Talent; import org.apache.ibatis.annotations.Mapper; Mapper public interface TalentMapper extends BaseMapperTalent { // 可以在此定义自定义的复杂SQL方法 // 例如ListTalent selectWithRank(); }同理创建VoteRecordMapper和TalentVoteSummaryMapper它们都继承BaseMapper。4.2 创建 Service 接口及实现我们以TalentService为例。// src/main/java/com/example/communityshow/service/TalentService.java package com.example.communityshow.service; import com.baomidou.mybatisplus.extension.service.IService; import com.example.communityshow.entity.Talent; import com.example.communityshow.vo.TalentRankVO; import java.util.List; public interface TalentService extends IServiceTalent { /** * 获取英才列表并附带实时排名信息 */ ListTalentRankVO getTalentListWithRank(); /** * 根据ID获取英才详情及当前排名 */ TalentRankVO getTalentDetailWithRank(Long talentId); }// src/main/java/com/example/communityshow/service/impl/TalentServiceImpl.java package com.example.communityshow.service.impl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.example.communityshow.entity.Talent; import com.example.communityshow.mapper.TalentMapper; import com.example.communityshow.service.TalentService; import com.example.communityshow.vo.TalentRankVO; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.ZSetOperations; import org.springframework.stereotype.Service; import java.util.List; import java.util.Set; import java.util.stream.Collectors; Slf4j Service RequiredArgsConstructor // Lombok注解自动注入final字段 public class TalentServiceImpl extends ServiceImplTalentMapper, Talent implements TalentService { private final RedisTemplateString, String redisTemplate; // Redis Key 设计 private static final String RANK_KEY community_show:talent_rank; Override public ListTalentRankVO getTalentListWithRank() { // 1. 从数据库查询所有有效英才 ListTalent talentList this.lambdaQuery() .eq(Talent::getIsDeleted, 0) .list(); // 2. 从Redis获取实时排名ZSETscore为票数member为talentId ZSetOperationsString, String zSetOps redisTemplate.opsForZSet(); SetZSetOperations.TypedTupleString rankTuples zSetOps.reverseRangeWithScores(RANK_KEY, 0, -1); // 3. 将排名信息映射到Map中便于查找 MapLong, Long rankMap new HashMap(); if (rankTuples ! null) { long currentRank 1L; for (ZSetOperations.TypedTupleString tuple : rankTuples) { Long talentId Long.valueOf(tuple.getValue()); Long score tuple.getScore().longValue(); // 票数 rankMap.put(talentId, currentRank); } } // 4. 组装VO return talentList.stream().map(talent - { TalentRankVO vo new TalentRankVO(); vo.setId(talent.getId()); vo.setTalentNo(talent.getTalentNo()); vo.setName(talent.getName()); vo.setNeighborhood(talent.getNeighborhood()); vo.setDescription(talent.getDescription()); // 从Redis ZSET获取该英才的票数 Double score zSetOps.score(RANK_KEY, String.valueOf(talent.getId())); vo.setVoteCount(score null ? 0L : score.longValue()); // 从Map中获取排名 vo.setRank(rankMap.getOrDefault(talent.getId(), -1L)); // -1表示未上榜 return vo; }).collect(Collectors.toList()); } Override public TalentRankVO getTalentDetailWithRank(Long talentId) { Talent talent this.getById(talentId); if (talent null || talent.getIsDeleted() 1) { throw new RuntimeException(英才不存在或已被删除); } TalentRankVO vo new TalentRankVO(); vo.setId(talent.getId()); vo.setTalentNo(talent.getTalentNo()); vo.setName(talent.getName()); vo.setNeighborhood(talent.getNeighborhood()); vo.setDescription(talent.getDescription()); ZSetOperationsString, String zSetOps redisTemplate.opsForZSet(); Double score zSetOps.score(RANK_KEY, String.valueOf(talentId)); vo.setVoteCount(score null ? 0L : score.longValue()); // 获取排名reverseRank 返回的是从高到低的排名0-based Long rank zSetOps.reverseRank(RANK_KEY, String.valueOf(talentId)); vo.setRank(rank null ? -1L : rank 1); // 转换为1-based排名 return vo; } }4.3 视图对象VO定义TalentRankVO用于接口返回包含排名信息。// src/main/java/com/example/communityshow/vo/TalentRankVO.java package com.example.communityshow.vo; import lombok.Data; import java.io.Serializable; Data public class TalentRankVO implements Serializable { private Long id; private String talentNo; private String name; private String neighborhood; private String description; private Long voteCount; // 票数 private Long rank; // 排名1-based }5. 投票业务核心逻辑实现投票是核心业务需要保证原子性和防止刷票。5.1 投票服务接口与实现// src/main/java/com/example/communityshow/service/VoteService.java package com.example.communityshow.service; public interface VoteService { /** * 执行投票 * param voterId 投票人标识 * param talentId 英才ID * param channel 投票渠道 * return 是否投票成功 */ boolean vote(String voterId, Long talentId, String channel); }// src/main/java/com/example/communityshow/service/impl/VoteServiceImpl.java package com.example.communityshow.service.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.example.communityshow.entity.VoteRecord; import com.example.communityshow.mapper.VoteRecordMapper; import com.example.communityshow.service.VoteService; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.dao.DataIntegrityViolationException; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.script.DefaultRedisScript; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.time.LocalDateTime; import java.util.Arrays; import java.util.Collections; Slf4j Service RequiredArgsConstructor public class VoteServiceImpl implements VoteService { private final VoteRecordMapper voteRecordMapper; private final RedisTemplateString, String redisTemplate; private static final String RANK_KEY community_show:talent_rank; // 同一投票人对同一英才的投票锁Key前缀 private static final String VOTE_LOCK_KEY_PREFIX vote_lock:; Override Transactional(rollbackFor Exception.class) public boolean vote(String voterId, Long talentId, String channel) { // 1. 基础校验实际项目中talentId需要查库校验是否存在且有效 if (voterId null || voterId.trim().isEmpty() || talentId null) { log.warn(投票参数错误: voterId{}, talentId{}, voterId, talentId); return false; } // 2. 防重复投票使用数据库唯一索引voterIdtalentId作为最终保障 // 但为了提升性能可以先在应用层用Redis做一层校验 String lockKey VOTE_LOCK_KEY_PREFIX voterId : talentId; Boolean lockAcquired redisTemplate.opsForValue().setIfAbsent(lockKey, 1, java.time.Duration.ofSeconds(5)); if (Boolean.FALSE.equals(lockAcquired)) { log.info(投票过于频繁或重复投票被拦截: voterId{}, talentId{}, voterId, talentId); return false; // 短时间内重复请求 } try { // 3. 检查是否已投过票数据库层面最终检查 Long count voteRecordMapper.selectCount(new LambdaQueryWrapperVoteRecord() .eq(VoteRecord::getVoterId, voterId) .eq(VoteRecord::getTalentId, talentId)); if (count 0) { log.info(该用户已为此英才投过票: voterId{}, talentId{}, voterId, talentId); return false; } // 4. 插入投票记录 VoteRecord record new VoteRecord(); record.setVoterId(voterId); record.setTalentId(talentId); record.setChannel(channel); record.setVoteTime(LocalDateTime.now()); int insertResult voteRecordMapper.insert(record); if (insertResult ! 1) { throw new RuntimeException(插入投票记录失败); } // 5. 更新Redis中的实时票数排名原子操作 // 使用Lua脚本保证原子性 String luaScript local rankKey KEYS[1] local talentId ARGV[1] return redis.call(ZINCRBY, rankKey, 1, talentId); DefaultRedisScriptLong script new DefaultRedisScript(luaScript, Long.class); Long newScore redisTemplate.execute(script, Collections.singletonList(RANK_KEY), String.valueOf(talentId)); log.info(投票成功: voterId{}, talentId{}, newScore{}, voterId, talentId, newScore); return true; } catch (DataIntegrityViolationException e) { // 捕获数据库唯一约束冲突异常防止极端并发情况 log.error(投票违反唯一约束可能为并发重复投票: voterId{}, talentId{}, voterId, talentId, e); return false; } catch (Exception e) { log.error(投票过程发生异常: voterId{}, talentId{}, voterId, talentId, e); throw e; // 触发事务回滚 } finally { // 释放锁 redisTemplate.delete(lockKey); } } }关键点解析防重复投票采用“Redis分布式锁 数据库唯一索引”双重保障。Redis锁防止短时间内高频重复请求穿透到数据库数据库唯一索引是最终防线确保数据一致性。原子性更新排名使用 Redis Lua 脚本执行ZINCRBY命令确保“读取-增加-写回”的原子性避免并发投票导致票数错误。事务管理Transactional确保投票记录插入和后续业务如果有的原子性。虽然Redis操作不在数据库事务内但通过Lua脚本保证了自身原子性。6. 控制器Controller与接口定义提供 RESTful API 给前端调用。6.1 英才相关接口// src/main/java/com/example/communityshow/controller/TalentController.java package com.example.communityshow.controller; import com.example.communityshow.service.TalentService; import com.example.communityshow.vo.TalentRankVO; import lombok.RequiredArgsConstructor; import org.springframework.web.bind.annotation.*; import java.util.List; RestController RequestMapping(/api/talent) RequiredArgsConstructor public class TalentController { private final TalentService talentService; GetMapping(/list) public ResultListTalentRankVO getTalentListWithRank() { ListTalentRankVO list talentService.getTalentListWithRank(); return Result.success(list); } GetMapping(/{id}) public ResultTalentRankVO getTalentDetail(PathVariable Long id) { TalentRankVO detail talentService.getTalentDetailWithRank(id); return Result.success(detail); } }6.2 投票接口// src/main/java/com/example/communityshow/controller/VoteController.java package com.example.communityshow.controller; import com.example.communityshow.service.VoteService; import lombok.RequiredArgsConstructor; import org.springframework.web.bind.annotation.*; import javax.servlet.http.HttpServletRequest; RestController RequestMapping(/api/vote) RequiredArgsConstructor public class VoteController { private final VoteService voteService; PostMapping public ResultBoolean vote(RequestParam Long talentId, RequestParam(required false, defaultValue WEB) String channel, HttpServletRequest request) { // 实际项目中voterId应从用户登录态或通过风控策略生成如IPUserAgent的哈希 // 此处简化为从请求中获取IP作为标识仅作演示生产环境需要更严谨的方案 String voterId getVoterId(request); boolean success voteService.vote(voterId, talentId, channel); if (success) { return Result.success(true, 投票成功); } else { return Result.error(投票失败可能已投过票或参数错误); } } private String getVoterId(HttpServletRequest request) { // 简易版使用IP地址。注意局域网或代理情况下需要获取真实IPX-Forwarded-For String ip request.getRemoteAddr(); // 可以加上User-Agent等生成一个更唯一的指纹这里简单返回IP return IP_ ip; } }6.3 统一返回结果封装// src/main/java/com/example/communityshow/common/Result.java package com.example.communityshow.common; import lombok.Data; import java.io.Serializable; Data public class ResultT implements Serializable { private Integer code; private String msg; private T data; public static T ResultT success(T data) { ResultT result new Result(); result.setCode(200); result.setMsg(success); result.setData(data); return result; } public static T ResultT success(T data, String msg) { ResultT result new Result(); result.setCode(200); result.setMsg(msg); result.setData(data); return result; } public static T ResultT error(String msg) { ResultT result new Result(); result.setCode(500); result.setMsg(msg); return result; } // 可以定义更多状态码如 400参数错误401未授权等 }7. 系统测试与验证7.1 初始化测试数据在MySQL中插入一些英才数据。INSERT INTO talent (talent_no, name, neighborhood, description) VALUES (TC001, 张三, 星光社区, 歌唱达人), (TC002, 李四, 晨曦社区, 舞蹈高手), (TC003, 王五, 彩虹社区, 乐器大师);7.2 启动项目并测试接口启动 Redis 和 MySQL。运行 Spring Boot 主类CommunityShowApplication。使用 Postman 或 curl 进行测试。测试获取英才列表GET http://localhost:8080/api/talent/list预期返回包含英才信息和初始排名票数为0排名为-1的列表。测试投票POST http://localhost:8080/api/vote?talentId1channelWEB重复执行此请求由于voterId基于IP相同只有第一次会成功。再次获取列表再次调用GET /api/talent/list可以看到TC001的票数增加排名变为第1名。7.3 验证Redis数据通过 Redis 客户端连接查看排名数据。redis-cli ZRANGE community_show:talent_rank 0 -1 WITHSCORES此命令会列出所有英才ID及其票数score按分数从低到高。可以使用ZREVRANGE查看从高到低的排名。8. 常见问题与排查思路在实际开发和部署中你可能会遇到以下问题问题现象可能原因排查思路与解决方案投票接口返回“投票失败”1. 参数talentId不存在。2. 同一voterId对同一英才已投过票。3. Redis锁获取失败5秒内重复请求。1. 检查数据库talent表是否存在该ID且未删除。2. 检查vote_record表是否存在对应记录。3. 检查Redis服务是否正常并适当调整锁的过期时间。票数增加但排名未实时更新1. 前端未重新调用排名接口。2. RedisZINCRBY命令执行失败但未抛异常。3. Redis连接异常命令未生效。1. 确认前端在投票成功后调用了获取最新排名的接口。2. 查看应用日志确认Lua脚本执行是否有错误。3. 检查Redis连接配置和网络。高并发下出现重复投票1. Redis锁在极端高并发下失效如锁过期时间设置不当。2. 数据库唯一索引冲突。1. 确保锁的过期时间略大于业务处理时间并考虑使用Redlock等更严格的分布式锁。2.数据库唯一索引是最终保障即使出现重复请求数据库也会拦截并抛出DataIntegrityViolationException业务层捕获后返回失败即可数据不会错。获取排名列表缓慢1. 英才数量巨大如十万级。2. 网络延迟或Redis性能瓶颈。1. 分页获取排名如ZREVRANGE rankKey (page-1)*size page*size-1 WITHSCORES。2. 对排名结果进行本地缓存如Caffeine设置短时间如5秒过期减少Redis访问。Redis重启后排名数据丢失Redis数据未持久化重启后内存数据清空。1.方案一推荐开启Redis RDB或AOF持久化。2.方案二定时如每分钟将Redis排名数据同步到talent_vote_summary表。系统启动时从该表或vote_record表重新计算并加载到Redis。9. 最佳实践与进阶优化建议一个基础的投票系统已经完成但要用于生产环境还需要考虑更多。风控策略voterId生成策略需要更健壮防止简单换IP刷票。可结合用户登录ID、设备指纹、行为分析等。增加投票频率限制如每小时/每天对同一英才或全局的投票次数限制。引入验证码CAPTCHA或人机验证对抗自动化脚本。性能优化缓存策略英才基本信息可以放入本地缓存如Caffeine或Redis缓存减少数据库查询。异步处理对于投票成功后的非核心操作如发送通知、更新其他统计可以放入消息队列如RabbitMQ, Kafka异步处理提升接口响应速度。数据库优化vote_record表会快速增长需考虑历史数据归档或分表策略。建立合适的索引我们已建立。高可用与数据一致性Redis高可用使用Redis哨兵或集群模式避免单点故障。最终一致性我们的设计是“先写数据库再更新Redis”。如果更新Redis失败会导致数据不一致。可以考虑将“更新Redis”也放入数据库事务后的异步消息中由消费者保证最终更新。使用定时任务定期从vote_record表同步票数到Redis作为补偿机制。监控与告警监控投票接口的QPS、响应时间、错误率。监控Redis内存使用率、连接数。设置告警当票数异常暴增可能被刷或Redis宕机时及时通知。API设计添加API版本号如/api/v1/vote。使用Swagger或Knife4j生成API文档。对敏感接口如投票实施限流如使用Spring Cloud Gateway或Sentinel。通过以上步骤我们不仅实现了一个功能完整的社区活动投票后台更深入探讨了在实现过程中可能遇到的技术难点和解决方案。从数据库设计、业务逻辑开发到系统优化每个环节都需要根据实际业务规模和场景进行权衡和深化。 Spring Boot+MyBatis+Redis构建高并发投票系统实战
最近在开发一个社区活动投票系统时遇到了一个典型的技术挑战如何在后端高效、安全地处理来自前端的复杂投票数据并确保实时排名和结果展示的准确性。这不仅仅是简单的增删改查更涉及到数据校验、并发控制、实时计算和结果缓存等多个技术点的综合运用。本文将围绕一个模拟的社区才艺竞演活动我们暂且称之为“社区星光赛”的后台系统构建完整拆解从数据库设计、Spring Boot接口开发到结果实时展示的全流程。无论你是正在学习Spring Boot和MyBatis的在校学生还是需要处理类似投票、评分业务的后端开发者都能从本文中获得一套可直接复用的实战方案。1. 项目背景与核心需求分析我们的目标是构建一个“社区星光赛”活动的后台管理系统。该活动有多个参赛者英才观众可以为他们支持的英才投票。每次投票行为我们称之为一次“竞斗”。系统需要实时统计每个英才的票数并动态更新排名。核心业务需求如下英才管理支持录入、查询、修改参赛英才的基本信息如编号、姓名、所属阵营/“邻居”。投票竞斗处理接收投票请求记录投票人、被投票英才、投票时间等信息。实时统计与排名根据投票数据实时计算每个英才的总票数并按照票数进行排名。数据查询与展示提供接口查询英才列表带排名、单个英才详情、投票记录等。数据安全与校验防止重复投票、刷票等恶意行为保证数据一致性。技术栈选型后端框架Spring Boot 2.7.x稳定且生态丰富数据持久层MyBatis-Plus 3.5.x简化CRUD提高开发效率数据库MySQL 8.0关系型数据库适合事务性操作缓存Redis用于存放实时排名减轻数据库压力项目管理Maven2. 开发环境与项目初始化在开始编码前请确保你的本地开发环境已就绪。2.1 环境准备清单JDK版本 8 或 11本文使用 JDK 11IDEIntelliJ IDEA 或 Eclipse推荐IDEAMySQL版本 5.7已启动并创建好数据库如community_show_dbRedis版本 5.0已启动Maven版本 3.62.2 创建Spring Boot项目使用 Spring Initializr https://start.spring.io 或 IDEA 内置的 Spring Initializr 创建项目。依赖选择Spring WebMyBatis FrameworkMySQL DriverLombok简化实体类代码Spring Boot DevTools热部署创建完成后pom.xml文件会包含这些基础依赖。我们还需要手动添加mybatis-plus-boot-starter和redis的依赖。!-- pom.xml 中添加 -- dependency groupIdcom.baomidou/groupId artifactIdmybatis-plus-boot-starter/artifactId version3.5.3.1/version /dependency dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-data-redis/artifactId /dependency2.3 项目基础配置在application.yml或application.properties中配置数据库和Redis连接。这里以application.yml为例。# src/main/resources/application.yml server: port: 8080 spring: datasource: driver-class-name: com.mysql.cj.jdbc.Driver url: jdbc:mysql://localhost:3306/community_show_db?useUnicodetruecharacterEncodingutf-8serverTimezoneAsia/Shanghai username: root password: yourpassword redis: host: localhost port: 6379 # password: 如果Redis有密码则配置 database: 0 timeout: 3000ms lettuce: pool: max-active: 8 max-wait: -1ms max-idle: 8 min-idle: 0 # MyBatis-Plus 配置 mybatis-plus: configuration: log-impl: org.apache.ibatis.logging.stdout.StdOutImpl # 控制台打印SQL生产环境建议关闭 global-config: db-config: logic-delete-field: isDeleted # 全局逻辑删除字段名若有 logic-delete-value: 1 # 逻辑已删除值 logic-not-delete-value: 0 # 逻辑未删除值3. 数据库设计与实体类映射良好的数据库设计是系统的基石。根据需求我们设计三张核心表。3.1 数据表设计-- 英才表 (talent) CREATE TABLE talent ( id bigint NOT NULL AUTO_INCREMENT COMMENT 主键ID, talent_no varchar(20) NOT NULL COMMENT 英才编号如TC001, name varchar(50) NOT NULL COMMENT 英才姓名, neighborhood varchar(50) DEFAULT NULL COMMENT 所属阵营/邻居, description text COMMENT 描述, create_time datetime DEFAULT CURRENT_TIMESTAMP COMMENT 创建时间, update_time datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT 更新时间, is_deleted tinyint DEFAULT 0 COMMENT 逻辑删除0-未删1-已删, PRIMARY KEY (id), UNIQUE KEY uk_talent_no (talent_no) ) ENGINEInnoDB DEFAULT CHARSETutf8mb4 COMMENT英才信息表; -- 投票记录表 (vote_record) CREATE TABLE vote_record ( id bigint NOT NULL AUTO_INCREMENT COMMENT 主键ID, voter_id varchar(64) NOT NULL COMMENT 投票人标识可为用户ID、IP、设备指纹等, talent_id bigint NOT NULL COMMENT 被投票英才ID, vote_time datetime DEFAULT CURRENT_TIMESTAMP COMMENT 投票时间, channel varchar(20) DEFAULT WEB COMMENT 投票渠道WEB, APP, WX等, create_time datetime DEFAULT CURRENT_TIMESTAMP COMMENT 创建时间, PRIMARY KEY (id), KEY idx_voter_talent (voter_id,talent_id) COMMENT 防止同一投票人对同一英才重复投票, KEY idx_talent_time (talent_id,vote_time) COMMENT 按英才和时间查询, CONSTRAINT fk_vote_talent FOREIGN KEY (talent_id) REFERENCES talent (id) ) ENGINEInnoDB DEFAULT CHARSETutf8mb4 COMMENT投票记录表; -- 英才票数统计表 (talent_vote_summary) - 可做物化视图或定时更新 CREATE TABLE talent_vote_summary ( talent_id bigint NOT NULL COMMENT 英才ID, total_votes bigint DEFAULT 0 COMMENT 总票数, update_time datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT 统计更新时间, PRIMARY KEY (talent_id), CONSTRAINT fk_summary_talent FOREIGN KEY (talent_id) REFERENCES talent (id) ) ENGINEInnoDB DEFAULT CHARSETutf8mb4 COMMENT英才票数统计表冗余用于快速查询;设计要点说明talent_no设置唯一索引确保编号不重复。vote_record表建立了(voter_id, talent_id)的联合索引可以高效判断同一用户是否对同一英才重复投票。创建了talent_vote_summary表作为统计冗余表。实时更新排名对数据库压力大通常我们会用缓存Redis来存实时排名此表可用于每日定时汇总或作为缓存击穿后的备份数据源。3.2 实体类创建使用 Lombok 注解简化代码。// src/main/java/com/example/communityshow/entity/Talent.java package com.example.communityshow.entity; import com.baomidou.mybatisplus.annotation.*; import lombok.Data; import java.time.LocalDateTime; Data TableName(talent) public class Talent { TableId(type IdType.AUTO) private Long id; private String talentNo; private String name; private String neighborhood; private String description; TableField(fill FieldFill.INSERT) private LocalDateTime createTime; TableField(fill FieldFill.INSERT_UPDATE) private LocalDateTime updateTime; TableLogic private Integer isDeleted; }// src/main/java/com/example/communityshow/entity/VoteRecord.java package com.example.communityshow.entity; import com.baomidou.mybatisplus.annotation.*; import lombok.Data; import java.time.LocalDateTime; Data TableName(vote_record) public class VoteRecord { TableId(type IdType.AUTO) private Long id; private String voterId; // 实际项目中可能需要更复杂的用户标识 private Long talentId; private LocalDateTime voteTime; private String channel; TableField(fill FieldFill.INSERT) private LocalDateTime createTime; }// src/main/java/com/example/communityshow/entity/TalentVoteSummary.java package com.example.communityshow.entity; import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; import lombok.Data; import java.time.LocalDateTime; Data TableName(talent_vote_summary) public class TalentVoteSummary { TableId(type IdType.INPUT) // 注意这里主键是 talent_id不是自增 private Long talentId; private Long totalVotes; private LocalDateTime updateTime; }4. MyBatis-Plus 与 Service 层开发我们将利用 MyBatis-Plus 的通用 Mapper 和 Service 快速实现基础数据操作。4.1 创建 Mapper 接口// src/main/java/com/example/communityshow/mapper/TalentMapper.java package com.example.communityshow.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.example.communityshow.entity.Talent; import org.apache.ibatis.annotations.Mapper; Mapper public interface TalentMapper extends BaseMapperTalent { // 可以在此定义自定义的复杂SQL方法 // 例如ListTalent selectWithRank(); }同理创建VoteRecordMapper和TalentVoteSummaryMapper它们都继承BaseMapper。4.2 创建 Service 接口及实现我们以TalentService为例。// src/main/java/com/example/communityshow/service/TalentService.java package com.example.communityshow.service; import com.baomidou.mybatisplus.extension.service.IService; import com.example.communityshow.entity.Talent; import com.example.communityshow.vo.TalentRankVO; import java.util.List; public interface TalentService extends IServiceTalent { /** * 获取英才列表并附带实时排名信息 */ ListTalentRankVO getTalentListWithRank(); /** * 根据ID获取英才详情及当前排名 */ TalentRankVO getTalentDetailWithRank(Long talentId); }// src/main/java/com/example/communityshow/service/impl/TalentServiceImpl.java package com.example.communityshow.service.impl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.example.communityshow.entity.Talent; import com.example.communityshow.mapper.TalentMapper; import com.example.communityshow.service.TalentService; import com.example.communityshow.vo.TalentRankVO; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.ZSetOperations; import org.springframework.stereotype.Service; import java.util.List; import java.util.Set; import java.util.stream.Collectors; Slf4j Service RequiredArgsConstructor // Lombok注解自动注入final字段 public class TalentServiceImpl extends ServiceImplTalentMapper, Talent implements TalentService { private final RedisTemplateString, String redisTemplate; // Redis Key 设计 private static final String RANK_KEY community_show:talent_rank; Override public ListTalentRankVO getTalentListWithRank() { // 1. 从数据库查询所有有效英才 ListTalent talentList this.lambdaQuery() .eq(Talent::getIsDeleted, 0) .list(); // 2. 从Redis获取实时排名ZSETscore为票数member为talentId ZSetOperationsString, String zSetOps redisTemplate.opsForZSet(); SetZSetOperations.TypedTupleString rankTuples zSetOps.reverseRangeWithScores(RANK_KEY, 0, -1); // 3. 将排名信息映射到Map中便于查找 MapLong, Long rankMap new HashMap(); if (rankTuples ! null) { long currentRank 1L; for (ZSetOperations.TypedTupleString tuple : rankTuples) { Long talentId Long.valueOf(tuple.getValue()); Long score tuple.getScore().longValue(); // 票数 rankMap.put(talentId, currentRank); } } // 4. 组装VO return talentList.stream().map(talent - { TalentRankVO vo new TalentRankVO(); vo.setId(talent.getId()); vo.setTalentNo(talent.getTalentNo()); vo.setName(talent.getName()); vo.setNeighborhood(talent.getNeighborhood()); vo.setDescription(talent.getDescription()); // 从Redis ZSET获取该英才的票数 Double score zSetOps.score(RANK_KEY, String.valueOf(talent.getId())); vo.setVoteCount(score null ? 0L : score.longValue()); // 从Map中获取排名 vo.setRank(rankMap.getOrDefault(talent.getId(), -1L)); // -1表示未上榜 return vo; }).collect(Collectors.toList()); } Override public TalentRankVO getTalentDetailWithRank(Long talentId) { Talent talent this.getById(talentId); if (talent null || talent.getIsDeleted() 1) { throw new RuntimeException(英才不存在或已被删除); } TalentRankVO vo new TalentRankVO(); vo.setId(talent.getId()); vo.setTalentNo(talent.getTalentNo()); vo.setName(talent.getName()); vo.setNeighborhood(talent.getNeighborhood()); vo.setDescription(talent.getDescription()); ZSetOperationsString, String zSetOps redisTemplate.opsForZSet(); Double score zSetOps.score(RANK_KEY, String.valueOf(talentId)); vo.setVoteCount(score null ? 0L : score.longValue()); // 获取排名reverseRank 返回的是从高到低的排名0-based Long rank zSetOps.reverseRank(RANK_KEY, String.valueOf(talentId)); vo.setRank(rank null ? -1L : rank 1); // 转换为1-based排名 return vo; } }4.3 视图对象VO定义TalentRankVO用于接口返回包含排名信息。// src/main/java/com/example/communityshow/vo/TalentRankVO.java package com.example.communityshow.vo; import lombok.Data; import java.io.Serializable; Data public class TalentRankVO implements Serializable { private Long id; private String talentNo; private String name; private String neighborhood; private String description; private Long voteCount; // 票数 private Long rank; // 排名1-based }5. 投票业务核心逻辑实现投票是核心业务需要保证原子性和防止刷票。5.1 投票服务接口与实现// src/main/java/com/example/communityshow/service/VoteService.java package com.example.communityshow.service; public interface VoteService { /** * 执行投票 * param voterId 投票人标识 * param talentId 英才ID * param channel 投票渠道 * return 是否投票成功 */ boolean vote(String voterId, Long talentId, String channel); }// src/main/java/com/example/communityshow/service/impl/VoteServiceImpl.java package com.example.communityshow.service.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.example.communityshow.entity.VoteRecord; import com.example.communityshow.mapper.VoteRecordMapper; import com.example.communityshow.service.VoteService; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.dao.DataIntegrityViolationException; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.script.DefaultRedisScript; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.time.LocalDateTime; import java.util.Arrays; import java.util.Collections; Slf4j Service RequiredArgsConstructor public class VoteServiceImpl implements VoteService { private final VoteRecordMapper voteRecordMapper; private final RedisTemplateString, String redisTemplate; private static final String RANK_KEY community_show:talent_rank; // 同一投票人对同一英才的投票锁Key前缀 private static final String VOTE_LOCK_KEY_PREFIX vote_lock:; Override Transactional(rollbackFor Exception.class) public boolean vote(String voterId, Long talentId, String channel) { // 1. 基础校验实际项目中talentId需要查库校验是否存在且有效 if (voterId null || voterId.trim().isEmpty() || talentId null) { log.warn(投票参数错误: voterId{}, talentId{}, voterId, talentId); return false; } // 2. 防重复投票使用数据库唯一索引voterIdtalentId作为最终保障 // 但为了提升性能可以先在应用层用Redis做一层校验 String lockKey VOTE_LOCK_KEY_PREFIX voterId : talentId; Boolean lockAcquired redisTemplate.opsForValue().setIfAbsent(lockKey, 1, java.time.Duration.ofSeconds(5)); if (Boolean.FALSE.equals(lockAcquired)) { log.info(投票过于频繁或重复投票被拦截: voterId{}, talentId{}, voterId, talentId); return false; // 短时间内重复请求 } try { // 3. 检查是否已投过票数据库层面最终检查 Long count voteRecordMapper.selectCount(new LambdaQueryWrapperVoteRecord() .eq(VoteRecord::getVoterId, voterId) .eq(VoteRecord::getTalentId, talentId)); if (count 0) { log.info(该用户已为此英才投过票: voterId{}, talentId{}, voterId, talentId); return false; } // 4. 插入投票记录 VoteRecord record new VoteRecord(); record.setVoterId(voterId); record.setTalentId(talentId); record.setChannel(channel); record.setVoteTime(LocalDateTime.now()); int insertResult voteRecordMapper.insert(record); if (insertResult ! 1) { throw new RuntimeException(插入投票记录失败); } // 5. 更新Redis中的实时票数排名原子操作 // 使用Lua脚本保证原子性 String luaScript local rankKey KEYS[1] local talentId ARGV[1] return redis.call(ZINCRBY, rankKey, 1, talentId); DefaultRedisScriptLong script new DefaultRedisScript(luaScript, Long.class); Long newScore redisTemplate.execute(script, Collections.singletonList(RANK_KEY), String.valueOf(talentId)); log.info(投票成功: voterId{}, talentId{}, newScore{}, voterId, talentId, newScore); return true; } catch (DataIntegrityViolationException e) { // 捕获数据库唯一约束冲突异常防止极端并发情况 log.error(投票违反唯一约束可能为并发重复投票: voterId{}, talentId{}, voterId, talentId, e); return false; } catch (Exception e) { log.error(投票过程发生异常: voterId{}, talentId{}, voterId, talentId, e); throw e; // 触发事务回滚 } finally { // 释放锁 redisTemplate.delete(lockKey); } } }关键点解析防重复投票采用“Redis分布式锁 数据库唯一索引”双重保障。Redis锁防止短时间内高频重复请求穿透到数据库数据库唯一索引是最终防线确保数据一致性。原子性更新排名使用 Redis Lua 脚本执行ZINCRBY命令确保“读取-增加-写回”的原子性避免并发投票导致票数错误。事务管理Transactional确保投票记录插入和后续业务如果有的原子性。虽然Redis操作不在数据库事务内但通过Lua脚本保证了自身原子性。6. 控制器Controller与接口定义提供 RESTful API 给前端调用。6.1 英才相关接口// src/main/java/com/example/communityshow/controller/TalentController.java package com.example.communityshow.controller; import com.example.communityshow.service.TalentService; import com.example.communityshow.vo.TalentRankVO; import lombok.RequiredArgsConstructor; import org.springframework.web.bind.annotation.*; import java.util.List; RestController RequestMapping(/api/talent) RequiredArgsConstructor public class TalentController { private final TalentService talentService; GetMapping(/list) public ResultListTalentRankVO getTalentListWithRank() { ListTalentRankVO list talentService.getTalentListWithRank(); return Result.success(list); } GetMapping(/{id}) public ResultTalentRankVO getTalentDetail(PathVariable Long id) { TalentRankVO detail talentService.getTalentDetailWithRank(id); return Result.success(detail); } }6.2 投票接口// src/main/java/com/example/communityshow/controller/VoteController.java package com.example.communityshow.controller; import com.example.communityshow.service.VoteService; import lombok.RequiredArgsConstructor; import org.springframework.web.bind.annotation.*; import javax.servlet.http.HttpServletRequest; RestController RequestMapping(/api/vote) RequiredArgsConstructor public class VoteController { private final VoteService voteService; PostMapping public ResultBoolean vote(RequestParam Long talentId, RequestParam(required false, defaultValue WEB) String channel, HttpServletRequest request) { // 实际项目中voterId应从用户登录态或通过风控策略生成如IPUserAgent的哈希 // 此处简化为从请求中获取IP作为标识仅作演示生产环境需要更严谨的方案 String voterId getVoterId(request); boolean success voteService.vote(voterId, talentId, channel); if (success) { return Result.success(true, 投票成功); } else { return Result.error(投票失败可能已投过票或参数错误); } } private String getVoterId(HttpServletRequest request) { // 简易版使用IP地址。注意局域网或代理情况下需要获取真实IPX-Forwarded-For String ip request.getRemoteAddr(); // 可以加上User-Agent等生成一个更唯一的指纹这里简单返回IP return IP_ ip; } }6.3 统一返回结果封装// src/main/java/com/example/communityshow/common/Result.java package com.example.communityshow.common; import lombok.Data; import java.io.Serializable; Data public class ResultT implements Serializable { private Integer code; private String msg; private T data; public static T ResultT success(T data) { ResultT result new Result(); result.setCode(200); result.setMsg(success); result.setData(data); return result; } public static T ResultT success(T data, String msg) { ResultT result new Result(); result.setCode(200); result.setMsg(msg); result.setData(data); return result; } public static T ResultT error(String msg) { ResultT result new Result(); result.setCode(500); result.setMsg(msg); return result; } // 可以定义更多状态码如 400参数错误401未授权等 }7. 系统测试与验证7.1 初始化测试数据在MySQL中插入一些英才数据。INSERT INTO talent (talent_no, name, neighborhood, description) VALUES (TC001, 张三, 星光社区, 歌唱达人), (TC002, 李四, 晨曦社区, 舞蹈高手), (TC003, 王五, 彩虹社区, 乐器大师);7.2 启动项目并测试接口启动 Redis 和 MySQL。运行 Spring Boot 主类CommunityShowApplication。使用 Postman 或 curl 进行测试。测试获取英才列表GET http://localhost:8080/api/talent/list预期返回包含英才信息和初始排名票数为0排名为-1的列表。测试投票POST http://localhost:8080/api/vote?talentId1channelWEB重复执行此请求由于voterId基于IP相同只有第一次会成功。再次获取列表再次调用GET /api/talent/list可以看到TC001的票数增加排名变为第1名。7.3 验证Redis数据通过 Redis 客户端连接查看排名数据。redis-cli ZRANGE community_show:talent_rank 0 -1 WITHSCORES此命令会列出所有英才ID及其票数score按分数从低到高。可以使用ZREVRANGE查看从高到低的排名。8. 常见问题与排查思路在实际开发和部署中你可能会遇到以下问题问题现象可能原因排查思路与解决方案投票接口返回“投票失败”1. 参数talentId不存在。2. 同一voterId对同一英才已投过票。3. Redis锁获取失败5秒内重复请求。1. 检查数据库talent表是否存在该ID且未删除。2. 检查vote_record表是否存在对应记录。3. 检查Redis服务是否正常并适当调整锁的过期时间。票数增加但排名未实时更新1. 前端未重新调用排名接口。2. RedisZINCRBY命令执行失败但未抛异常。3. Redis连接异常命令未生效。1. 确认前端在投票成功后调用了获取最新排名的接口。2. 查看应用日志确认Lua脚本执行是否有错误。3. 检查Redis连接配置和网络。高并发下出现重复投票1. Redis锁在极端高并发下失效如锁过期时间设置不当。2. 数据库唯一索引冲突。1. 确保锁的过期时间略大于业务处理时间并考虑使用Redlock等更严格的分布式锁。2.数据库唯一索引是最终保障即使出现重复请求数据库也会拦截并抛出DataIntegrityViolationException业务层捕获后返回失败即可数据不会错。获取排名列表缓慢1. 英才数量巨大如十万级。2. 网络延迟或Redis性能瓶颈。1. 分页获取排名如ZREVRANGE rankKey (page-1)*size page*size-1 WITHSCORES。2. 对排名结果进行本地缓存如Caffeine设置短时间如5秒过期减少Redis访问。Redis重启后排名数据丢失Redis数据未持久化重启后内存数据清空。1.方案一推荐开启Redis RDB或AOF持久化。2.方案二定时如每分钟将Redis排名数据同步到talent_vote_summary表。系统启动时从该表或vote_record表重新计算并加载到Redis。9. 最佳实践与进阶优化建议一个基础的投票系统已经完成但要用于生产环境还需要考虑更多。风控策略voterId生成策略需要更健壮防止简单换IP刷票。可结合用户登录ID、设备指纹、行为分析等。增加投票频率限制如每小时/每天对同一英才或全局的投票次数限制。引入验证码CAPTCHA或人机验证对抗自动化脚本。性能优化缓存策略英才基本信息可以放入本地缓存如Caffeine或Redis缓存减少数据库查询。异步处理对于投票成功后的非核心操作如发送通知、更新其他统计可以放入消息队列如RabbitMQ, Kafka异步处理提升接口响应速度。数据库优化vote_record表会快速增长需考虑历史数据归档或分表策略。建立合适的索引我们已建立。高可用与数据一致性Redis高可用使用Redis哨兵或集群模式避免单点故障。最终一致性我们的设计是“先写数据库再更新Redis”。如果更新Redis失败会导致数据不一致。可以考虑将“更新Redis”也放入数据库事务后的异步消息中由消费者保证最终更新。使用定时任务定期从vote_record表同步票数到Redis作为补偿机制。监控与告警监控投票接口的QPS、响应时间、错误率。监控Redis内存使用率、连接数。设置告警当票数异常暴增可能被刷或Redis宕机时及时通知。API设计添加API版本号如/api/v1/vote。使用Swagger或Knife4j生成API文档。对敏感接口如投票实施限流如使用Spring Cloud Gateway或Sentinel。通过以上步骤我们不仅实现了一个功能完整的社区活动投票后台更深入探讨了在实现过程中可能遇到的技术难点和解决方案。从数据库设计、业务逻辑开发到系统优化每个环节都需要根据实际业务规模和场景进行权衡和深化。