1. 项目概述去年接手了一个校园二手交易平台的重构项目用SpringBoot从零搭建了一套完整的系统。这个看似简单的需求背后其实藏着不少技术门道。今天就把整个设计过程和实现细节完整分享出来特别适合需要快速搭建交易类系统的开发者参考。二手交易平台本质上是个典型的C2C电商系统但相比传统电商更注重即时性和社区属性。我们采用SpringBootMyBatis技术栈前端Vue.js整体开发周期控制在6周内完成。系统日均稳定处理3000交易请求峰值QPS达到150数据库单表数据量突破50万行后查询性能依然稳定。2. 核心架构设计2.1 技术选型决策选择SpringBoot主要基于三个考量快速迭代starter依赖和自动配置让项目搭建时间缩短60%以上生态完整整合Redis、RabbitMQ等中间件只需添加依赖和简单配置运维友好内置Actuator端点方便监控与Jenkins部署流程天然契合数据库选用MySQL 8.0主要考虑事务完整性和对JSON字段的良好支持。商品详情这类半结构化数据直接用JSON类型存储比传统的EAV模型节省40%存储空间。2.2 微服务拆分策略虽然单体架构也能满足需求但我们仍做了适度拆分用户服务独立处理认证授权商品服务核心交易业务消息服务站内信和实时通知支付服务对接第三方支付渠道服务间通信采用FeignJackson通过自定义编解码器将传输数据压缩30%。特别注意了服务划分的粒度控制避免过度拆分带来的运维复杂度。3. 关键功能实现3.1 商品发布流程核心难点在于富文本内容和多图上传的处理Transactional public Long publishItem(ItemDTO dto) { // 1. 校验用户状态 User seller userService.checkUserStatus(dto.getUserId()); // 2. 处理图片上传 ListString imageUrls imageService.upload(dto.getImages()); // 3. 构建商品实体 Item item Item.builder() .title(dto.getTitle()) .content(HtmlUtils.htmlEscape(dto.getContent())) // 防XSS .images(JSON.toJSONString(imageUrls)) .price(dto.getPrice()) .categoryId(dto.getCategoryId()) .sellerId(seller.getId()) .status(ItemStatus.ON_SALE) .build(); // 4. 持久化 itemMapper.insert(item); // 5. 发送商品创建事件 eventPublisher.publishEvent(new ItemCreateEvent(item.getId())); return item.getId(); }重要提示图片存储一定要做内容校验我们曾遭遇过攻击者上传伪装成图片的脚本文件3.2 交易状态机设计采用状态模式避免复杂的if-else判断public interface TradeState { void pay(Trade trade); void cancel(Trade trade); void confirm(Trade trade); } Component Scope(prototype) public class WaitingPayState implements TradeState { Override public void pay(Trade trade) { // 支付逻辑 trade.setState(TradeStateEnum.WAITING_SHIP); // 发送支付成功通知 } // 其他方法实现... }状态转换通过Spring StateMachine实现配置化定义让业务流程变更只需修改YAML文件。4. 性能优化实践4.1 缓存策略采用多级缓存架构本地缓存Caffeine处理热点数据分布式缓存Redis集群缓存商品详情浏览器缓存ETag协商缓存静态资源关键配置示例# Caffeine配置 spring.cache.caffeine.specmaximumSize1000,expireAfterWrite5m # Redis缓存商品详情 Cacheable(value item, key #id, unless #result null) public Item getItemById(Long id) { return itemMapper.selectById(id); }4.2 数据库优化针对商品列表页的典型慢查询-- 优化前 SELECT * FROM items WHERE category_id ? ORDER BY create_time DESC; -- 优化后 CREATE INDEX idx_category_create ON items(category_id, create_time DESC); -- 分页查询改进 SELECT * FROM items WHERE category_id ? AND create_time ? ORDER BY create_time DESC LIMIT 20;配合MyBatis的PageHelper插件百万级数据下分页响应时间从1200ms降至200ms以内。5. 安全防护措施5.1 防刷机制采用令牌桶算法限制关键接口RateLimiter(value 10, key #userId) public boolean createOrder(Long userId, Long itemId) { // 下单逻辑 }配合Redis实现分布式限流-- rate_limiter.lua local key KEYS[1] local limit tonumber(ARGV[1]) local current tonumber(redis.call(get, key) or 0) if current 1 limit then return 0 else redis.call(INCR, key) redis.call(EXPIRE, key, 60) return 1 end5.2 敏感数据保护采用ShardingSphere实现字段级加密spring: shardingsphere: encrypt: encryptors: mobile_encryptor: type: AES props: aes.key.value: ${encrypt.key} tables: users: columns: phone: plainColumn: phone_plain cipherColumn: phone_cipher encryptor: mobile_encryptor6. 运维监控体系6.1 健康检查配置通过Actuator暴露关键指标management: endpoints: web: exposure: include: health,info,metrics,prometheus endpoint: health: show-details: always probes: enabled: true自定义健康检查指标Component public class RedisHealthIndicator implements HealthIndicator { Override public Health health() { try { String result redisTemplate.execute(PING); return PONG.equals(result) ? Health.up().build() : Health.down().build(); } catch (Exception e) { return Health.down(e).build(); } } }6.2 日志收集方案采用ELK栈处理日志!-- logback-spring.xml -- appender nameLOGSTASH classnet.logstash.logback.appender.LogstashTcpSocketAppender destination${LOGSTASH_HOST}:5000/destination encoder classnet.logstash.logback.encoder.LogstashEncoder customFields{app:second-hand,env:${spring.profiles.active}}/customFields /encoder /appender关键日志字段包括traceId全链路追踪userId用户行为分析elapsed接口耗时监控7. 典型问题排查7.1 事务失效场景我们遇到过最隐蔽的问题是Transactional失效主要几种情况同类方法调用A方法调用本类B方法B的事务注解不生效异常类型不匹配默认只回滚RuntimeException数据库引擎不支持MyISAM引擎不支持事务解决方案// 正确用法示例 Service public class OrderService { Transactional(rollbackFor Exception.class) public void createOrder() { // 业务逻辑 } } // 自调用问题解决 Service public class OrderService { Autowired private ApplicationContext context; public void outerMethod() { context.getBean(OrderService.class).innerMethod(); } Transactional public void innerMethod() { // 业务逻辑 } }7.2 缓存一致性难题商品信息更新时的缓存策略选择先更新数据库再删除缓存推荐采用Canel监听binlog异步更新缓存设置较短的缓存过期时间作为兜底我们最终采用的方案public void updateItem(Item item) { // 1. 更新DB itemMapper.updateById(item); // 2. 删除缓存 redisTemplate.delete(item:: item.getId()); // 3. 发送MQ消息 rabbitTemplate.convertAndSend(item.update, item.getId()); } // 消费者处理缓存重建 RabbitListener(queues item.update.queue) public void handleItemUpdate(Long itemId) { Item item itemMapper.selectById(itemId); redisTemplate.opsForValue().set( item:: itemId, JSON.toJSONString(item), 30, TimeUnit.MINUTES); }8. 部署实践8.1 容器化部署Dockerfile最佳实践FROM openjdk:11-jre-slim VOLUME /tmp ARG JAR_FILEtarget/*.jar COPY ${JAR_FILE} app.jar ENTRYPOINT [java,-Djava.security.egdfile:/dev/./urandom,-jar,/app.jar]关键优化点使用slim镜像减少体积从300MB降到90MB设置/dev/urandom避免熵池阻塞分离构建层和运行层8.2 灰度发布方案通过NginxJenkins实现# 蓝绿部署脚本示例 #!/bin/bash OLD_POD$(kubectl get pods -l appuser-service -o jsonpath{.items[0].metadata.name}) kubectl rollout status deployment/user-service NEW_POD$(kubectl get pods -l appuser-service -o jsonpath{.items[0].metadata.name}) if [ $OLD_POD ! $NEW_POD ]; then # 新Pod健康检查 if curl -s http://$NEW_POD:8080/actuator/health | grep -q UP; then # 流量切换 kubectl patch svc user-service -p {spec:{selector:{version:v2}}} fi fi9. 扩展思考系统上线后我们还做了几个有价值的扩展推荐系统基于用户行为实现协同过滤推荐风控系统实时检测异常交易数据分析用户画像和商品热度分析其中推荐系统采用Redis的SortedSet实现简单版本public ListLong recommendItems(Long userId) { // 1. 获取用户最近浏览的10个商品 String key user:view: userId; ListLong recentItems redisTemplate.opsForList() .range(key, 0, 9); // 2. 计算相似商品 return recentItems.stream() .flatMap(itemId - { String similarKey item:similar: itemId; return redisTemplate.opsForZSet() .reverseRange(similarKey, 0, 2).stream(); }) .distinct() .limit(10) .collect(Collectors.toList()); }