java
mall-parent
├── mall-common          // 全局公共依赖
│   ├── mall-common-core // 核心工具、统一返回、异常、常量、工具类
│   ├── mall-common-redis// Redis缓存封装、分布式锁工具
│   ├── mall-common-es   // Elasticsearch检索封装
│   ├── mall-common-mq   // RocketMQ消息封装、生产者/消费者模板
│   ├── mall-common-security // 鉴权、Token、权限工具
│   └── mall-common-storage  // 对象存储、文件上传工具
├── mall-gateway         // 网关服务（独立工程）
├── mall-user            // 用户微服务
├── mall-goods           // 商品微服务
├── mall-order           // 订单微服务
├── mall-pay             // 支付微服务
├── mall-aftersale       // 售后微服务
└── mall-config          // 统一配置中心

java
mall-goods
├── controller       // 接口接入层，接收前端请求、参数校验、返回结果
├── service          // 业务接口层
│   └── impl         // 业务实现层，核心业务逻辑、事务控制
├── manager          // 通用组件层，封装缓存、MQ、ES、第三方调用
├── dao              // 数据访问层
│   ├── mapper       // Mybatis Mapper接口
│   └── xml          // SQL映射文件
├── entity           // 实体类
│   ├── po           // 数据库持久化对象
│   ├── dto          // 业务传输对象（服务间调用）
│   ├── vo           // 前端返回视图对象
│   └── query        // 分页、查询参数对象
├── config           // 配置类（ES、Redis、MQ、线程池配置）
├── exception        // 自定义业务异常、异常处理器
├── util             // 服务内专属工具类
└── resource         // 配置文件（yml、mybatis配置）

go
mall-goods-go
├── api        // 接口层
├── service    // 业务逻辑层
├── dao        // 数据层
├── model      // 数据模型、请求响应结构体
├── config     // 全局配置
├── pkg        // 公共工具、缓存、MQ、ES封装
└── main.go    // 服务入口

java
@RestController
@RequestMapping("/api/goods")
public class GoodsController {

    @Autowired
    private GoodsService goodsService;

    // 商品全文搜索接口
    @GetMapping("/search")
    public Result<PageVO<GoodsVO>> searchGoods(GoodsQuery query) {
        // 基础参数校验
        QueryUtil.checkPage(query);
        // 调用业务层
        PageVO<GoodsVO> pageVO = goodsService.searchGoods(query);
        return Result.success(pageVO);
    }
}

java
@Service
public class GoodsServiceImpl implements GoodsService {

    @Autowired
    private GoodsManager goodsManager;

    @Override
    public PageVO<GoodsVO> searchGoods(GoodsQuery query) {
        // 1.优先查询Redis热点缓存
        PageVO<GoodsVO> cachePage = goodsManager.getGoodsSearchCache(query);
        if (Objects.nonNull(cachePage)) {
            return cachePage;
        }
        // 2.缓存未命中，查询ES全文检索
        PageVO<GoodsVO> esPage = goodsManager.searchGoodsByES(query);
        // 3.写入缓存，设置过期时间
        goodsManager.setGoodsSearchCache(query, esPage);
        return esPage;
    }
}

java
@Service
public class GoodsManager {

    @Autowired
    private ElasticsearchRestTemplate esTemplate;
    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    // ES商品检索封装
    public PageVO<GoodsVO> searchGoodsByES(GoodsQuery query) {
        // 构建ES分词查询、筛选、排序条件
        NativeSearchQueryBuilder queryBuilder = new NativeSearchQueryBuilder();
        queryBuilder.withQuery(QueryBuilders.matchQuery("title", query.getKeyword()));
        // 分页、排序、过滤逻辑
        // ...省略通用检索逻辑
        return new PageVO<>();
    }

    // Redis缓存查询与更新封装
    public PageVO<GoodsVO> getGoodsSearchCache(GoodsQuery query) {
        String cacheKey = CacheKeyUtil.getGoodsSearchKey(query);
        return (PageVO<GoodsVO>) redisTemplate.opsForValue().get(cacheKey);
    }
}

java
@Mapper
public interface GoodsMapper extends BaseMapper<GoodsPO> {
    // 自定义复杂商品查询SQL
    List<GoodsPO> listHotGoods();
}

java
// 订单生产者：创建订单发送15分钟延时消息
@Component
public class OrderMqProducer {
    @Autowired
    private RocketMQTemplate rocketMQTemplate;

    public void sendOrderDelayMsg(String orderNo) {
        // 延时等级：15分钟
        rocketMQTemplate.syncSend("order-delay-topic",
                MessageBuilder.withPayload(orderNo).build(),
                3000, 16);
    }
}

// 订单消费者：超时取消订单
@Component
@RocketMQMessageListener(topic = "order-delay-topic", consumerGroup = "order-delay-consumer")
public class OrderDelayConsumer implements RocketMQListener<String> {

    @Autowired
    private OrderService orderService;

    @Override
    public void onMessage(String orderNo) {
        // 幂等判断：避免重复消费
        if (orderService.isOrderClosed(orderNo)) {
            return;
        }
        // 关闭订单、释放库存
        orderService.closeTimeoutOrder(orderNo);
    }
}

java
@Service
public class OrderServiceImpl implements OrderService {

    @Autowired
    private RedisLockUtil redisLockUtil;

    @Override
    public void createOrder(OrderDTO orderDTO) {
        String lockKey = "stock:lock:" + orderDTO.getSkuId();
        // 尝试获取分布式锁
        boolean lock = redisLockUtil.tryLock(lockKey, 30, 3);
        if (!lock) {
            throw new BusinessException("库存繁忙，请稍后重试");
        }
        try {
            // 校验库存、创建订单、锁定库存
            // ...核心下单逻辑
        } finally {
            // 释放锁
            redisLockUtil.unLock(lockKey);
        }
    }
}

vue
mall-vue
├── public         // 静态资源
├── src
│   ├── api        // 统一接口请求（按服务拆分：user、goods、order、pay）
│   ├── assets     // 图片、样式、字体
│   ├── components // 公共组件、业务组件
│   ├── router     // 双端路由、权限路由
│   ├── store      // Pinia状态管理
│   ├── utils      // 请求封装、工具方法、权限校验
│   ├── views      // 页面视图（PC页面、H5页面分开目录）
│   └── App.vue
├── vite.config.js // 打包配置、CDN配置
└── .env           // 环境变量

js
mall-react
├── src
│   ├── api        // 服务接口统一封装
│   ├── components // 通用组件、业务组件
│   ├── pages      // 页面组件
│   ├── router     // 路由配置
│   ├── store      // 状态管理
│   ├── utils      // 全局工具、请求拦截
│   └── styles     // 全局样式
└── config         // 打包、环境配置

dockerfile
# 通用Java服务Dockerfile
FROM openjdk:11-jre-slim
WORKDIR /mall
COPY target/*.jar app.jar
EXPOSE 8080
ENTRYPOINT ["java","-jar","app.jar"]