1. 多租户ERP仓储管理模块的设计挑战与应对最近在做一个多租户ERP系统的仓储管理模块设计发现这个看似常规的需求背后藏着不少坑。多租户架构下数据隔离、性能优化、权限控制等问题会以意想不到的方式影响仓储模块的设计。今天就来聊聊我在这个项目中遇到的典型问题和解法。仓储管理作为ERP的核心模块需要处理库存、入库、出库、调拨、盘点等核心业务。而在多租户环境下这些基础功能都要考虑租户隔离的问题。比如同一SKU在不同租户间的库存不能混淆但又要支持跨租户的数据汇总分析。这种既要隔离又要聚合的需求让仓储模块的设计变得尤为复杂。2. 多租户仓储模块的核心设计思路2.1 数据隔离方案选型在多租户系统中数据隔离通常有三种实现方式独立数据库每个租户使用单独的数据库实例共享数据库独立Schema同一数据库实例下不同租户使用不同Schema共享数据库共享Schema通过tenant_id字段区分不同租户数据对于仓储管理模块我们最终选择了第三种方案主要基于以下考虑成本因素仓储数据量大但价值密度低独立数据库成本过高运维复杂度上千个租户意味着上千个数据库实例运维压力大业务需求总部需要跨租户汇总库存数据共享Schema更易实现提示选择共享Schema方案时务必在所有SQL中显式添加tenant_id条件避免数据泄露。我们通过MyBatis拦截器自动注入tenant_id条件。2.2 仓储数据模型设计仓储核心表的设计需要特别考虑多租户特性。以下是我们的主要表结构CREATE TABLE wms_warehouse ( id BIGINT PRIMARY KEY, tenant_id VARCHAR(32) NOT NULL, -- 租户标识 code VARCHAR(64) NOT NULL, -- 仓库编码 name VARCHAR(128) NOT NULL, -- 仓库名称 type TINYINT NOT NULL, -- 仓库类型 status TINYINT NOT NULL, -- 状态 UNIQUE KEY uk_tenant_code (tenant_id, code) -- 租户内编码唯一 ); CREATE TABLE wms_stock ( id BIGINT PRIMARY KEY, tenant_id VARCHAR(32) NOT NULL, sku_id BIGINT NOT NULL, -- 商品SKU warehouse_id BIGINT NOT NULL, -- 仓库ID quantity DECIMAL(18,4) NOT NULL, -- 库存数量 locked_quantity DECIMAL(18,4) DEFAULT 0, -- 锁定数量 UNIQUE KEY uk_tenant_sku_warehouse (tenant_id, sku_id, warehouse_id) );关键设计点所有表都包含tenant_id字段唯一约束需要包含tenant_id如uk_tenant_code外键关联需要同时校验tenant_id一致性2.3 并发控制策略仓储管理面临严重的并发问题特别是库存扣减场景。我们采用以下策略乐观锁在库存表中增加version字段更新时校验UPDATE wms_stock SET quantity quantity - #{change}, version version 1 WHERE id #{id} AND version #{version}分布式锁对关键SKU仓库组合加锁// Redisson分布式锁示例 RLock lock redissonClient.getLock(stock:tenantId:skuId:warehouseId); try { lock.lock(); // 执行库存操作 } finally { lock.unlock(); }异步队列将高并发写操作放入MQ异步处理3. 多租户仓储的业务逻辑实现3.1 入库流程设计多租户下的入库流程需要特别注意权限控制和数据隔离入库单创建public class ReceiptService { Transactional public Receipt createReceipt(String tenantId, ReceiptDTO dto) { // 校验仓库是否属于当前租户 Warehouse warehouse warehouseService.getById(dto.getWarehouseId()); if(!warehouse.getTenantId().equals(tenantId)) { throw new BusinessException(仓库不属于当前租户); } // 创建入库单 Receipt receipt new Receipt(); receipt.setTenantId(tenantId); // 其他字段填充... receiptMapper.insert(receipt); // 创建入库明细 for(ReceiptItemDTO item : dto.getItems()) { ReceiptItem itemEntity new ReceiptItem(); itemEntity.setTenantId(tenantId); // 其他字段填充... receiptItemMapper.insert(itemEntity); } return receipt; } }入库确认public void confirmReceipt(String tenantId, Long receiptId) { // 校验入库单 Receipt receipt receiptMapper.selectById(receiptId); if(!receipt.getTenantId().equals(tenantId)) { throw new BusinessException(入库单不属于当前租户); } // 遍历明细增加库存 for(ReceiptItem item : receipt.getItems()) { stockService.increaseStock( tenantId, item.getSkuId(), item.getWarehouseId(), item.getQuantity() ); } // 更新入库单状态 receipt.setStatus(ReceiptStatus.CONFIRMED); receiptMapper.updateById(receipt); }3.2 出库策略优化多租户环境下出库策略需要考虑租户间的差异租户级出库策略配置public class OutboundPolicy { private String tenantId; private OutboundStrategy strategy; // FIFO/FEFO/LIFO等 private boolean allowNegativeStock; private boolean needQualityCheck; // 其他策略参数... }策略工厂模式实现public interface OutboundStrategy { ListStock allocate(OutboundRequest request); } public class OutboundStrategyFactory { public OutboundStrategy getStrategy(String tenantId) { OutboundPolicy policy policyService.getPolicy(tenantId); switch(policy.getStrategy()) { case FIFO: return new FIFOStrategy(); case FEFO: return new FEFOStrategy(); default: return new DefaultStrategy(); } } }3.3 库存盘点设计多租户库存盘点需要处理大量数据我们采用分片处理方案盘点任务创建public void createInventoryTask(String tenantId, Long warehouseId) { // 1. 创建盘点任务 InventoryTask task new InventoryTask(); task.setTenantId(tenantId); task.setWarehouseId(warehouseId); taskMapper.insert(task); // 2. 分片生成盘点明细 int shardSize 1000; int total stockMapper.countByWarehouse(tenantId, warehouseId); for(int i0; itotal; ishardSize) { ListStock stocks stockMapper.selectByWarehouse( tenantId, warehouseId, i, shardSize); inventoryDetailMapper.batchInsert( stocks.stream() .map(s - convertToDetail(task.getId(), s)) .collect(Collectors.toList()) ); } }盘点结果处理public void processInventoryResult(String tenantId, Long taskId, ListInventoryResult results) { // 校验任务所属租户 InventoryTask task taskMapper.selectById(taskId); if(!task.getTenantId().equals(tenantId)) { throw new BusinessException(盘点任务不属于当前租户); } // 处理差异 for(InventoryResult result : results) { if(result.getDiffQuantity() ! 0) { stockAdjustmentService.adjust( tenantId, result.getSkuId(), result.getWarehouseId(), result.getDiffQuantity(), INVENTORY_ADJUST, taskId ); } } // 更新任务状态 task.setStatus(InventoryStatus.COMPLETED); taskMapper.updateById(task); }4. 性能优化实战经验4.1 多租户数据查询优化仓储模块的查询往往需要跨多表关联且带有tenant_id条件我们采用以下优化手段索引设计-- 商品库存查询SQL SELECT s.* FROM wms_stock s JOIN wms_warehouse w ON s.warehouse_id w.id AND s.tenant_id w.tenant_id WHERE s.tenant_id tenant1 AND s.sku_id 123 AND w.status 1; -- 对应索引 CREATE INDEX idx_stock_tenant_sku ON wms_stock(tenant_id, sku_id); CREATE INDEX idx_warehouse_tenant_status ON wms_warehouse(tenant_id, status);分库分表策略按tenant_id哈希分库按时间范围分表如wms_stock_2023、wms_stock_2024缓存设计// 多租户缓存key设计 public String getStockCacheKey(String tenantId, Long skuId, Long warehouseId) { return String.format(stock:%s:%d:%d, tenantId, skuId, warehouseId); } // 使用租户隔离的缓存区域 Cacheable(cacheNames tenantStock, key #tenantId:#skuId:#warehouseId) public Stock getStock(String tenantId, Long skuId, Long warehouseId) { return stockMapper.selectOne(tenantId, skuId, warehouseId); }4.2 批量操作优化仓储管理涉及大量批量操作我们总结了以下最佳实践MyBatis批量插入public void batchInsertItems(String tenantId, ListItem items) { SqlSession session sqlSessionFactory.openSession(ExecutorType.BATCH); try { ItemMapper mapper session.getMapper(ItemMapper.class); for (Item item : items) { item.setTenantId(tenantId); mapper.insert(item); } session.commit(); } finally { session.close(); } }库存变更合并public void batchUpdateStock(String tenantId, ListStockChange changes) { // 按SKU仓库分组合并变更 MapStockKey, BigDecimal mergedChanges changes.stream() .collect(Collectors.groupingBy( c - new StockKey(c.getSkuId(), c.getWarehouseId()), Collectors.reducing(BigDecimal.ZERO, StockChange::getChange, BigDecimal::add) )); // 批量执行合并后的变更 mergedChanges.forEach((key, change) - { stockMapper.updateQuantity( tenantId, key.getSkuId(), key.getWarehouseId(), change ); }); }4.3 租户级限流设计为防止某个租户的异常操作影响整体系统我们实现了租户级限流限流配置ratelimit: tenant-default: 1000/60s # 默认60秒1000次 tenant-premium: 5000/60s # 高级租户配额更高限流拦截器public class TenantRateLimitInterceptor implements HandlerInterceptor { Override public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) { String tenantId TenantContext.getCurrentTenant(); RateLimiter limiter rateLimitService.getLimiter(tenantId); if(!limiter.tryAcquire()) { response.sendError(429, 请求过于频繁); return false; } return true; } }5. 多租户权限控制方案5.1 数据权限设计仓储管理需要精细化的数据权限控制权限模型public class DataPermission { private String tenantId; private ListLong warehouseIds; // 可访问的仓库 private boolean allowViewCost; // 是否可查看成本价 private boolean allowAdjust; // 是否可调整库存 }权限拦截Aspect Component public class DataPermissionAspect { Before(annotation(requirePermission)) public void checkPermission(RequirePermission requirePermission) { String tenantId TenantContext.getCurrentTenant(); DataPermission permission permissionService.getPermission( tenantId, UserContext.getCurrentUserId()); if(!permission.getWarehouseIds().contains(warehouseId)) { throw new BusinessException(无权访问该仓库数据); } } }5.2 功能权限设计基于RBAC模型实现租户级功能权限权限表设计CREATE TABLE tenant_role ( id BIGINT PRIMARY KEY, tenant_id VARCHAR(32) NOT NULL, name VARCHAR(64) NOT NULL, UNIQUE KEY uk_tenant_role (tenant_id, name) ); CREATE TABLE tenant_permission ( id BIGINT PRIMARY KEY, tenant_id VARCHAR(32) NOT NULL, resource VARCHAR(64) NOT NULL, -- 如wms:stock:query action VARCHAR(32) NOT NULL, -- read/write/admin UNIQUE KEY uk_tenant_resource_action (tenant_id, resource, action) );权限校验public void checkPermission(String tenantId, String userId, String resource, String action) { // 获取用户角色 ListRole roles roleMapper.selectByUser(tenantId, userId); // 检查角色是否有对应权限 boolean hasPerm permissionMapper.exists( tenantId, roles.stream().map(Role::getId).collect(Collectors.toList()), resource, action ); if(!hasPerm) { throw new BusinessException(无权执行此操作); } }6. 典型问题与解决方案6.1 租户数据交叉问题问题现象A租户用户能看到B租户的仓库数据排查过程检查SQL日志发现某些查询缺少tenant_id条件追查代码发现手动编写的SQL未添加租户过滤解决方案统一使用MyBatis拦截器自动注入tenant_idpublic class TenantInterceptor implements Interceptor { Override public Object intercept(Invocation invocation) { // 获取当前租户 String tenantId TenantContext.getCurrentTenant(); // 修改SQL添加tenant_id条件 BoundSql boundSql ((MappedStatement)invocation.getArgs()[0]) .getBoundSql(invocation.getArgs()[1]); String newSql addTenantCondition(boundSql.getSql(), tenantId); // 使用新SQL继续执行 resetSql(invocation, newSql); return invocation.proceed(); } }代码审查时重点关注手动SQL编写测试用例验证数据隔离6.2 库存超卖问题问题现象并发下单时出现库存超卖排查过程检查库存扣减逻辑发现先查后改存在竞态条件压力测试重现问题解决方案采用乐观锁重试机制Transactional(isolation Isolation.READ_COMMITTED) public void deductStock(String tenantId, Long skuId, Long warehouseId, BigDecimal quantity) { int retry 3; while(retry-- 0) { Stock stock stockMapper.selectForUpdate( tenantId, skuId, warehouseId); if(stock.getQuantity().compareTo(quantity) 0) { throw new BusinessException(库存不足); } int updated stockMapper.updateQuantity( stock.getId(), stock.getQuantity().subtract(quantity), stock.getVersion() ); if(updated 0) { return; // 更新成功 } } throw new BusinessException(库存扣减冲突请重试); }引入分布式锁作为补充关键操作添加审计日志6.3 跨租户报表性能问题问题现象总部查看所有租户库存汇总时响应缓慢排查过程发现直接UNION ALL查询所有租户数据缺少合适的索引解决方案采用物化视图预聚合数据CREATE MATERIALIZED VIEW mv_cross_tenant_stock REFRESH COMPLETE ON DEMAND AS SELECT sku_id, SUM(quantity) AS total_quantity, COUNT(DISTINCT tenant_id) AS tenant_count FROM wms_stock GROUP BY sku_id;建立跨租户查询专用副本实现分页查询和异步导出7. 监控与运维设计7.1 租户资源监控public class TenantMetrics { private String tenantId; private int dbQueryCount; private int apiCallCount; private int stockUpdateCount; // 其他指标... public void checkQuota() { TenantQuota quota quotaService.getQuota(tenantId); if(dbQueryCount quota.getMaxDbQuery()) { throw new QuotaExceededException(数据库查询配额不足); } // 其他配额检查... } }7.2 慢查询分析-- 租户慢查询日志表 CREATE TABLE tenant_slow_query ( id BIGINT PRIMARY KEY, tenant_id VARCHAR(32) NOT NULL, sql_text TEXT, execution_time INT, create_time DATETIME, INDEX idx_tenant_time (tenant_id, create_time) );7.3 自动化扩缩容# 租户资源分配策略 tenant-resource: default: db-connections: 50 thread-pool-size: 20 premium: db-connections: 200 thread-pool-size: 100在多租户ERP仓储系统的开发过程中最大的体会是隔离与共享的平衡艺术。过于严格的隔离会导致系统僵化和资源浪费而过度的共享又会带来安全和性能隐患。我们的经验是核心业务数据严格隔离统计分析数据适度共享系统资源按需分配。 
长河君 · 2026/10/28 21:52:59 · 阅读 1.2k 多租户ERP仓储管理模块的设计与优化实践
1. 多租户ERP仓储管理模块的设计挑战与应对最近在做一个多租户ERP系统的仓储管理模块设计发现这个看似常规的需求背后藏着不少坑。多租户架构下数据隔离、性能优化、权限控制等问题会以意想不到的方式影响仓储模块的设计。今天就来聊聊我在这个项目中遇到的典型问题和解法。仓储管理作为ERP的核心模块需要处理库存、入库、出库、调拨、盘点等核心业务。而在多租户环境下这些基础功能都要考虑租户隔离的问题。比如同一SKU在不同租户间的库存不能混淆但又要支持跨租户的数据汇总分析。这种既要隔离又要聚合的需求让仓储模块的设计变得尤为复杂。2. 多租户仓储模块的核心设计思路2.1 数据隔离方案选型在多租户系统中数据隔离通常有三种实现方式独立数据库每个租户使用单独的数据库实例共享数据库独立Schema同一数据库实例下不同租户使用不同Schema共享数据库共享Schema通过tenant_id字段区分不同租户数据对于仓储管理模块我们最终选择了第三种方案主要基于以下考虑成本因素仓储数据量大但价值密度低独立数据库成本过高运维复杂度上千个租户意味着上千个数据库实例运维压力大业务需求总部需要跨租户汇总库存数据共享Schema更易实现提示选择共享Schema方案时务必在所有SQL中显式添加tenant_id条件避免数据泄露。我们通过MyBatis拦截器自动注入tenant_id条件。2.2 仓储数据模型设计仓储核心表的设计需要特别考虑多租户特性。以下是我们的主要表结构CREATE TABLE wms_warehouse ( id BIGINT PRIMARY KEY, tenant_id VARCHAR(32) NOT NULL, -- 租户标识 code VARCHAR(64) NOT NULL, -- 仓库编码 name VARCHAR(128) NOT NULL, -- 仓库名称 type TINYINT NOT NULL, -- 仓库类型 status TINYINT NOT NULL, -- 状态 UNIQUE KEY uk_tenant_code (tenant_id, code) -- 租户内编码唯一 ); CREATE TABLE wms_stock ( id BIGINT PRIMARY KEY, tenant_id VARCHAR(32) NOT NULL, sku_id BIGINT NOT NULL, -- 商品SKU warehouse_id BIGINT NOT NULL, -- 仓库ID quantity DECIMAL(18,4) NOT NULL, -- 库存数量 locked_quantity DECIMAL(18,4) DEFAULT 0, -- 锁定数量 UNIQUE KEY uk_tenant_sku_warehouse (tenant_id, sku_id, warehouse_id) );关键设计点所有表都包含tenant_id字段唯一约束需要包含tenant_id如uk_tenant_code外键关联需要同时校验tenant_id一致性2.3 并发控制策略仓储管理面临严重的并发问题特别是库存扣减场景。我们采用以下策略乐观锁在库存表中增加version字段更新时校验UPDATE wms_stock SET quantity quantity - #{change}, version version 1 WHERE id #{id} AND version #{version}分布式锁对关键SKU仓库组合加锁// Redisson分布式锁示例 RLock lock redissonClient.getLock(stock:tenantId:skuId:warehouseId); try { lock.lock(); // 执行库存操作 } finally { lock.unlock(); }异步队列将高并发写操作放入MQ异步处理3. 多租户仓储的业务逻辑实现3.1 入库流程设计多租户下的入库流程需要特别注意权限控制和数据隔离入库单创建public class ReceiptService { Transactional public Receipt createReceipt(String tenantId, ReceiptDTO dto) { // 校验仓库是否属于当前租户 Warehouse warehouse warehouseService.getById(dto.getWarehouseId()); if(!warehouse.getTenantId().equals(tenantId)) { throw new BusinessException(仓库不属于当前租户); } // 创建入库单 Receipt receipt new Receipt(); receipt.setTenantId(tenantId); // 其他字段填充... receiptMapper.insert(receipt); // 创建入库明细 for(ReceiptItemDTO item : dto.getItems()) { ReceiptItem itemEntity new ReceiptItem(); itemEntity.setTenantId(tenantId); // 其他字段填充... receiptItemMapper.insert(itemEntity); } return receipt; } }入库确认public void confirmReceipt(String tenantId, Long receiptId) { // 校验入库单 Receipt receipt receiptMapper.selectById(receiptId); if(!receipt.getTenantId().equals(tenantId)) { throw new BusinessException(入库单不属于当前租户); } // 遍历明细增加库存 for(ReceiptItem item : receipt.getItems()) { stockService.increaseStock( tenantId, item.getSkuId(), item.getWarehouseId(), item.getQuantity() ); } // 更新入库单状态 receipt.setStatus(ReceiptStatus.CONFIRMED); receiptMapper.updateById(receipt); }3.2 出库策略优化多租户环境下出库策略需要考虑租户间的差异租户级出库策略配置public class OutboundPolicy { private String tenantId; private OutboundStrategy strategy; // FIFO/FEFO/LIFO等 private boolean allowNegativeStock; private boolean needQualityCheck; // 其他策略参数... }策略工厂模式实现public interface OutboundStrategy { ListStock allocate(OutboundRequest request); } public class OutboundStrategyFactory { public OutboundStrategy getStrategy(String tenantId) { OutboundPolicy policy policyService.getPolicy(tenantId); switch(policy.getStrategy()) { case FIFO: return new FIFOStrategy(); case FEFO: return new FEFOStrategy(); default: return new DefaultStrategy(); } } }3.3 库存盘点设计多租户库存盘点需要处理大量数据我们采用分片处理方案盘点任务创建public void createInventoryTask(String tenantId, Long warehouseId) { // 1. 创建盘点任务 InventoryTask task new InventoryTask(); task.setTenantId(tenantId); task.setWarehouseId(warehouseId); taskMapper.insert(task); // 2. 分片生成盘点明细 int shardSize 1000; int total stockMapper.countByWarehouse(tenantId, warehouseId); for(int i0; itotal; ishardSize) { ListStock stocks stockMapper.selectByWarehouse( tenantId, warehouseId, i, shardSize); inventoryDetailMapper.batchInsert( stocks.stream() .map(s - convertToDetail(task.getId(), s)) .collect(Collectors.toList()) ); } }盘点结果处理public void processInventoryResult(String tenantId, Long taskId, ListInventoryResult results) { // 校验任务所属租户 InventoryTask task taskMapper.selectById(taskId); if(!task.getTenantId().equals(tenantId)) { throw new BusinessException(盘点任务不属于当前租户); } // 处理差异 for(InventoryResult result : results) { if(result.getDiffQuantity() ! 0) { stockAdjustmentService.adjust( tenantId, result.getSkuId(), result.getWarehouseId(), result.getDiffQuantity(), INVENTORY_ADJUST, taskId ); } } // 更新任务状态 task.setStatus(InventoryStatus.COMPLETED); taskMapper.updateById(task); }4. 性能优化实战经验4.1 多租户数据查询优化仓储模块的查询往往需要跨多表关联且带有tenant_id条件我们采用以下优化手段索引设计-- 商品库存查询SQL SELECT s.* FROM wms_stock s JOIN wms_warehouse w ON s.warehouse_id w.id AND s.tenant_id w.tenant_id WHERE s.tenant_id tenant1 AND s.sku_id 123 AND w.status 1; -- 对应索引 CREATE INDEX idx_stock_tenant_sku ON wms_stock(tenant_id, sku_id); CREATE INDEX idx_warehouse_tenant_status ON wms_warehouse(tenant_id, status);分库分表策略按tenant_id哈希分库按时间范围分表如wms_stock_2023、wms_stock_2024缓存设计// 多租户缓存key设计 public String getStockCacheKey(String tenantId, Long skuId, Long warehouseId) { return String.format(stock:%s:%d:%d, tenantId, skuId, warehouseId); } // 使用租户隔离的缓存区域 Cacheable(cacheNames tenantStock, key #tenantId:#skuId:#warehouseId) public Stock getStock(String tenantId, Long skuId, Long warehouseId) { return stockMapper.selectOne(tenantId, skuId, warehouseId); }4.2 批量操作优化仓储管理涉及大量批量操作我们总结了以下最佳实践MyBatis批量插入public void batchInsertItems(String tenantId, ListItem items) { SqlSession session sqlSessionFactory.openSession(ExecutorType.BATCH); try { ItemMapper mapper session.getMapper(ItemMapper.class); for (Item item : items) { item.setTenantId(tenantId); mapper.insert(item); } session.commit(); } finally { session.close(); } }库存变更合并public void batchUpdateStock(String tenantId, ListStockChange changes) { // 按SKU仓库分组合并变更 MapStockKey, BigDecimal mergedChanges changes.stream() .collect(Collectors.groupingBy( c - new StockKey(c.getSkuId(), c.getWarehouseId()), Collectors.reducing(BigDecimal.ZERO, StockChange::getChange, BigDecimal::add) )); // 批量执行合并后的变更 mergedChanges.forEach((key, change) - { stockMapper.updateQuantity( tenantId, key.getSkuId(), key.getWarehouseId(), change ); }); }4.3 租户级限流设计为防止某个租户的异常操作影响整体系统我们实现了租户级限流限流配置ratelimit: tenant-default: 1000/60s # 默认60秒1000次 tenant-premium: 5000/60s # 高级租户配额更高限流拦截器public class TenantRateLimitInterceptor implements HandlerInterceptor { Override public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) { String tenantId TenantContext.getCurrentTenant(); RateLimiter limiter rateLimitService.getLimiter(tenantId); if(!limiter.tryAcquire()) { response.sendError(429, 请求过于频繁); return false; } return true; } }5. 多租户权限控制方案5.1 数据权限设计仓储管理需要精细化的数据权限控制权限模型public class DataPermission { private String tenantId; private ListLong warehouseIds; // 可访问的仓库 private boolean allowViewCost; // 是否可查看成本价 private boolean allowAdjust; // 是否可调整库存 }权限拦截Aspect Component public class DataPermissionAspect { Before(annotation(requirePermission)) public void checkPermission(RequirePermission requirePermission) { String tenantId TenantContext.getCurrentTenant(); DataPermission permission permissionService.getPermission( tenantId, UserContext.getCurrentUserId()); if(!permission.getWarehouseIds().contains(warehouseId)) { throw new BusinessException(无权访问该仓库数据); } } }5.2 功能权限设计基于RBAC模型实现租户级功能权限权限表设计CREATE TABLE tenant_role ( id BIGINT PRIMARY KEY, tenant_id VARCHAR(32) NOT NULL, name VARCHAR(64) NOT NULL, UNIQUE KEY uk_tenant_role (tenant_id, name) ); CREATE TABLE tenant_permission ( id BIGINT PRIMARY KEY, tenant_id VARCHAR(32) NOT NULL, resource VARCHAR(64) NOT NULL, -- 如wms:stock:query action VARCHAR(32) NOT NULL, -- read/write/admin UNIQUE KEY uk_tenant_resource_action (tenant_id, resource, action) );权限校验public void checkPermission(String tenantId, String userId, String resource, String action) { // 获取用户角色 ListRole roles roleMapper.selectByUser(tenantId, userId); // 检查角色是否有对应权限 boolean hasPerm permissionMapper.exists( tenantId, roles.stream().map(Role::getId).collect(Collectors.toList()), resource, action ); if(!hasPerm) { throw new BusinessException(无权执行此操作); } }6. 典型问题与解决方案6.1 租户数据交叉问题问题现象A租户用户能看到B租户的仓库数据排查过程检查SQL日志发现某些查询缺少tenant_id条件追查代码发现手动编写的SQL未添加租户过滤解决方案统一使用MyBatis拦截器自动注入tenant_idpublic class TenantInterceptor implements Interceptor { Override public Object intercept(Invocation invocation) { // 获取当前租户 String tenantId TenantContext.getCurrentTenant(); // 修改SQL添加tenant_id条件 BoundSql boundSql ((MappedStatement)invocation.getArgs()[0]) .getBoundSql(invocation.getArgs()[1]); String newSql addTenantCondition(boundSql.getSql(), tenantId); // 使用新SQL继续执行 resetSql(invocation, newSql); return invocation.proceed(); } }代码审查时重点关注手动SQL编写测试用例验证数据隔离6.2 库存超卖问题问题现象并发下单时出现库存超卖排查过程检查库存扣减逻辑发现先查后改存在竞态条件压力测试重现问题解决方案采用乐观锁重试机制Transactional(isolation Isolation.READ_COMMITTED) public void deductStock(String tenantId, Long skuId, Long warehouseId, BigDecimal quantity) { int retry 3; while(retry-- 0) { Stock stock stockMapper.selectForUpdate( tenantId, skuId, warehouseId); if(stock.getQuantity().compareTo(quantity) 0) { throw new BusinessException(库存不足); } int updated stockMapper.updateQuantity( stock.getId(), stock.getQuantity().subtract(quantity), stock.getVersion() ); if(updated 0) { return; // 更新成功 } } throw new BusinessException(库存扣减冲突请重试); }引入分布式锁作为补充关键操作添加审计日志6.3 跨租户报表性能问题问题现象总部查看所有租户库存汇总时响应缓慢排查过程发现直接UNION ALL查询所有租户数据缺少合适的索引解决方案采用物化视图预聚合数据CREATE MATERIALIZED VIEW mv_cross_tenant_stock REFRESH COMPLETE ON DEMAND AS SELECT sku_id, SUM(quantity) AS total_quantity, COUNT(DISTINCT tenant_id) AS tenant_count FROM wms_stock GROUP BY sku_id;建立跨租户查询专用副本实现分页查询和异步导出7. 监控与运维设计7.1 租户资源监控public class TenantMetrics { private String tenantId; private int dbQueryCount; private int apiCallCount; private int stockUpdateCount; // 其他指标... public void checkQuota() { TenantQuota quota quotaService.getQuota(tenantId); if(dbQueryCount quota.getMaxDbQuery()) { throw new QuotaExceededException(数据库查询配额不足); } // 其他配额检查... } }7.2 慢查询分析-- 租户慢查询日志表 CREATE TABLE tenant_slow_query ( id BIGINT PRIMARY KEY, tenant_id VARCHAR(32) NOT NULL, sql_text TEXT, execution_time INT, create_time DATETIME, INDEX idx_tenant_time (tenant_id, create_time) );7.3 自动化扩缩容# 租户资源分配策略 tenant-resource: default: db-connections: 50 thread-pool-size: 20 premium: db-connections: 200 thread-pool-size: 100在多租户ERP仓储系统的开发过程中最大的体会是隔离与共享的平衡艺术。过于严格的隔离会导致系统僵化和资源浪费而过度的共享又会带来安全和性能隐患。我们的经验是核心业务数据严格隔离统计分析数据适度共享系统资源按需分配。