S2B2C Supply Chain Middleware

Hive 聚合供应链中台

连接上游供应链,赋能下游 B 端客户。把京东、天猫等供应链的商品能力,标准化后输出给积分商城与企业福利平台。

Next.jsGoPostgreSQLElasticsearchRedisRabbitMQ

双引擎架构

HAG 做管道,HCM 做大脑。高并发网关与全栈业务平台完美协同。

京东 VOP
天猫
更多供应链

Hive Platform

聚合供应链中台

HCM中台管理平台 · Next.js
PIM商品中心
OMS订单中心
AFS售后中心
BMS结算中心
CRM客户中心
DMS分销中心
<--> 内部 API
HAGAPI 网关 · Go
SCA供应链适配
OAP开放接口
MCS消息服务
共享数据层
PostgreSQL
核心数据
Elasticsearch
商品搜索
Redis
缓存/限流
RabbitMQ
消息推送
积分商城
企业福利平台
私域电商

为什么是 双引擎

不采用过度工程化的四层微服务,也不采用无法满足高并发的纯单体。 一期用模块化单体思维,遇到性能瓶颈再拆分。

双引擎 vs 四层微服务

维度四层微服务双引擎
服务数量4-6 个独立服务2 个核心服务
运维复杂度服务发现、链路追踪、分布式事务两个服务 + 共享数据层
团队匹配度需 Go + Next.js 全面配备Next.js 做 80% 业务,Go 专注高并发
数据一致性跨服务数据同步困难共享数据层,天然一致
演进空间一开始就定型模块化设计,按瓶颈拆分

核心理念:HAG 做管道(高并发 I/O),HCM 做大脑(业务逻辑 + UI)。凡是"高频外部 I/O"走 HAG,"业务逻辑和界面"走 HCM。

S2B2C 模式对比

对比维度自营电商纯 SaaSHive S2B2C
是否持有库存
直接面向 C 端
核心资产供应链+流量软件产品聚合能力+技术平台
扩展方式增加品类/仓储增加客户双边网络效应

盈利模式

70%
供销价差
20%
技术服务费
10%
增值服务

系统边界划分

凡是涉及"高频外部 I/O"的走 HAG,涉及"业务逻辑和界面"的走 HCM。

HAG
Go 网关服务高并发 I/O 密集
上游供应链 API 调用高频 I/O、并发处理
SCA
商品数据按需拉取实时调用供应链接口
SCA
订单/售后转发到供应链需要快速响应
SCA
下游开放 API 服务高 QPS、限流鉴权
OAP
RabbitMQ 消费者VOP 消息推送接收
MCS
VOP Token 管理定时刷新 Access Token
SCA
HCM
Next.js 业务平台业务逻辑 + UI
商品选品、定价、底池管理PIM
订单生命周期管理OMS
售后全流程处理AFS
结算对账、财务管理BMS
客户管理(开户/分级/授信)CRM
客户 SaaS 工作台DMS
所有管理后台页面和交互HCM
数据分析和报表HCM
HCM
HTTP 内部 API / 二期 gRPC
HAG

9 大 子系统

HCM 6 大业务模块 + HAG 3 大网关模块,覆盖供应链中台全链路能力。

PIM

商品中心

底池管理、选品引擎、定价引擎

OMS

订单中心

订单全生命周期、拆单、状态同步

AFS

售后中心

退款、退货、换货全流程

BMS

结算中心

上下游对账、客户余额管理

CRM

客户中心

客户分级、授信、权限管理

DMS

分销中心

客户 SaaS 工作台、应用管理

SCA

供应链适配

京东 VOP 对接、多供应商接入

OAP

开放接口

下游 API、鉴权限流、Webhook

MCS

消息服务

VOP 消息推送、实时数据同步

商品底池选品架构

不做全量同步。2000W+ SKU 按需拉取,底池本质是一个选品缓存层,事件驱动 + 定时兜底确保数据一致性。

在线搜索上游

HCM + HAG

运营在 HCM 后台实时搜索京东 VOP 2000W+ SKU 全量商品池

运营选品入池

PIM

人工精选 + 规则辅助(毛利率/好评率/品类白名单),批量或单个入池

底池缓存层

底池

选中商品写入 PostgreSQL + Elasticsearch + Redis(预计 100W-500W 级别)

事件驱动刷新

MCS

VOP 推送实时更新 + 高频 30min 活跃商品 + 每日凌晨全底池兜底校准

分池分发

DMS

按客户等级、品类策略分为默认池/品类池/专属池,差异化定价

客户选品上架

OAP

B 端客户从分发池选品到自己的商品库,通过 OAP 对外提供

底池刷新策略

三层防护确保数据准确性

实时推送
VOP RabbitMQ 消息推送价格/上下架/池变更
定时兜底
每 30min 活跃商品库存 + 每日凌晨全底池校准
下单校验
实时调用 VOP 校验库存 + 价格,最终防线

定价引擎

// 分发价计算公式
分发价 = 成本价 x (1 + 品类加价率)
x 客户等级系数
// 标准 1.0 | 高级 0.95 | 旗舰 0.90

技术栈选型

每一项技术选择都经过深思熟虑,匹配团队能力和业务需求。

Next.js 15

全栈业务平台

App Router + Server Actions,团队主力技术栈

Go + Gin

高并发网关

I/O 密集场景最佳选择,供应链 API 对接

PostgreSQL 16

核心数据 + 多租户 RLS

JSONB 适合商品异构属性,RLS 支持多租户

Elasticsearch 8

商品搜索

底池商品全文检索,聚合查询性能优秀

Redis 7

缓存 + 限流 + 队列

API 限流令牌桶、分布式锁、库存预扣

RabbitMQ

VOP 消息推送

接收京东 VOP 消息推送,AMQP 协议要求

BullMQ

内部任务队列

Node.js 原生生态,可靠的延迟任务和重试机制

Prisma

类型安全 ORM

迁移管理与 Next.js 深度集成,类型安全

Docker Compose

容器编排

一期简单可靠,二期可平滑迁移 K8s

核心业务链路

从下单到交付,完整追踪一笔订单的生命历程。

1

客户通过 OAP 下单

下游系统调用开放 API 提交订单

2

HAG 鉴权 + 限流

AppKey 签名校验,令牌桶限流

3

HCM 业务校验 + 冻结余额

库存校验、价格校验、客户余额冻结

4

HAG·SCA 调用京东 VOP 下单

转发订单到供应链,获取供应链订单号

5

VOP 消息推送订单状态

RabbitMQ 实时推送发货/运单号

6

Webhook 通知客户系统

主动推送订单状态到客户回调 URL

关键数据

0W+

京东 VOP SKU 覆盖

0

VOP API 接口对接

0

实时消息推送类型

< 0s

数据同步延迟

数据架构概览

PostgreSQL 为核心,JSONB 支持异构属性,RLS 实现多租户隔离,配合 Elasticsearch 和 Redis 构建完整数据层。

基础数据

jd_categories京东三级分类直接同步京东
jd_areas京东四级地址省/市/区/镇
suppliers供应商京东 VOP / 天猫 / ...

商品体系

products底池商品100W-500W 级 / JSONB 属性
product_pools分池关联默认池/品类池/专属池
product_prices定价规则品类加价率 + 等级系数

订单体系

orders主订单父订单 + 供应链订单号
order_items子订单/明细京东拆单 / 独立运单号
after_sales售后单退款/退货/换货/维修

客户 + 资金

tenants客户/租户RLS 多租户隔离
tenant_apps客户应用AppKey / Secret
balance_records资金流水收入/支出/退款
settlements结算单月度对账

核心设计要点

主键ULID (有序 + 全局唯一 + URL 安全)
金额BIGINT 分为单位,避免浮点精度问题
多租户PostgreSQL RLS 行级安全自动隔离
异构属性JSONB 存储商品差异化属性
搜索同步PostgreSQL -> BullMQ -> ES(< 5s)

部署架构

简单、可靠、快速上线。数据层使用云服务托管,应用层 Docker Compose 编排。

应用服务器

Docker Compose
Server 14C8G
Nginx反向代理
HCM (Next.js)业务平台
Server 24C8G
HAG (Go)API 网关
BullMQ Worker任务队列

数据层(云服务托管)

PostgreSQL2C4G
核心业务数据
Elasticsearch2C4G
商品搜索
Redis2G
缓存/BullMQ/锁
RabbitMQDocker
VOP 消息推送

自动备份、主从切换、监控告警。避免 DBA 运维成本,一期数据量基础规格足够。

Nginx 路由规则

admin.domain.comHCM运营后台
tenant.domain.comHCM客户工作台
api.domain.comHAG开放 API

监控与告警

服务器CPU > 80% / 内存 > 85%
应用错误率 > 1% / 响应 > 2s
数据库连接 > 80% / 慢查询 > 1s
业务订单失败 > 5% / 熔断告警
演进路径Docker ComposeK8s + HPA + Ingress + APM

实施路线图

分三个阶段稳步推进,从 MVP 到完整生态。

Phase 1
3 个月

MVP 核心链路

京东 VOP + 商品/订单/售后

  • 京东 VOP 33 个接口全对接
  • 商品底池选品 + 定价引擎
  • 订单全生命周期管理
  • 售后退款退货全流程
  • 客户管理 + API 鉴权
Phase 2
3 个月

功能增强

高级定价 + 分销完善 + 报表增强

  • 高级定价策略(阶梯/分级)
  • 分销中心 SaaS 工作台
  • 结算对账自动化
  • 数据分析报表增强
  • 客户分级体系完善
Phase 3
持续迭代

生态扩展(二期)

SaaS 商户宝 + AI 选品 + 多供应链

  • 天猫/其他供应链适配器接入
  • SaaS 商户宝(白牌商城 H5/小程序)
  • AI 智能选品推荐
  • BI 数据分析平台
  • Docker Compose 迁移 K8s