集体流动性
1）为什么需要它
新集群中的即时流动性。在区域/利基中运行-"缓和"共享池。
更好的合规性和价格。深度市场→小于"价差"，高于EPI（提高有效价格/选择）。
需求/供应冲击。节点之间的负载流动减少了故障和队列。
经济学。高于fill rate和ARPU，成本适度增加；cross-sell的可能性。
2）集体流动性模式
3）建筑组件
Orderbook/目录：申请/离职抽象、状态和版本、SLA和兼容性属性。
SOR（智能订单路由）：根据价格/质量/管辖权/潜伏期选择池/供应商的规则。
一致性：CDC和事件日志，对"event_id"进行去除，以补偿事务。
归属和计费：谁是交易/佣金的"所有者"，索赔窗口，重新计算。
质量和声誉：合作伙伴评级/SLA，罚款，徽章。
隐私和本地化：PD掩盖，地理定位，事件导出规则。
mermaid flowchart LR
U [Demand] --> GW [Routing Gateway]
P1 [Pool A] --- GW
P2 [Pool B] --- GW
P3 [Partner C] --- GW
GW --> SB[Settlement/Billing]
GW --> OBS[Observability/SLO]4）数据合同（最低字段）
yaml offer. v1:
id: uuid kind: product slot capacity price: {amount: decimal, currency: ISO4217}
quality: {rating: 0..5, sla_ttm_ms: int}
geo: {region: "EU", city: "Tallinn"}
vendor: {id: "partner-123", tier: "gold"}
terms: {ttl_s: 60, cancellation: "window:15m"}
version: 7 request. v1:
id: uuid constraints: {geo, time, price_ceiling, compliance}
qos: {max_ttm_ms: 500, min_rating: 4. 0}
trace_id: uuid consent: {...}5） SOR： 规则与伪代码
排名标准：- `score = w_priceprice_improvement + w_slattm_slo + w_qquality + w_geodistance_penalty + w_riskvendor_risk_penalty`
python def route(request, pools):
candidates = []
for pool in pools:
if not compliant(request, pool):
continue quotes = pool. quote (request) # timebox, idempotent for q in quotes:
s = score(q, request)
candidates. append((s, pool, q))
ordered = sorted(candidates, key=lambda x: -x[0])
return best_feasible(ordered, fairness=request. fairness)公平：供应商轮换、营业额份额配额、声誉差距和最近的收益。
6）流动性指标
Fill rate=封闭申请/所有申请（按部分/集群）。
时间到比赛（p50/p95）-在选择/执行之前的时间。
深度-在给定的价格/质量范围内可用的体积。
Spread/EPI-提高有效价格vs基准。
Utilization-加载报价（idle% ↓-如果没有SLA失败,则效果良好）。
Integrity-取消/犯规转换的比例，在重构中的差异（<ε）。
Fairness是质量相等的供应商周转分布的方差。
- "fill_rate_month ≥ 92%"在具有≥ N主动离线器的集群中。
- "p95_time_to_match ≤ 3s"在高峰时段。
- `cancel_rate ≤ 1.5%在供应商的SLA上≥ 98%。
7）可观察性和证据基础
事件： 'request。sent`, `quote.received`, `match.made`, `settled`, `cancelled`, `refund`.
跟踪："trace_id"通过SOR →池→供应商端到端。
审计：webhook签名，手册版本日志，报价"截图"。
Reconciliation：双边报告、去除、<ε差异、SLA结束索赔。
8）隐私，合规性，主权
Geo-pinning： 敏感类别/PII不来自允许的区域。
别名：对于跨卡特纳交换-仅伪标识符。
作为代码的保留：事件的TTL，删除权，法律保留。
DPA/webhooks：签名，反重播，电路控制。
9）操作模型和计算
角色：市场运营商（您）、池/合作伙伴（供应）、频道/店面（点播）。
商业：RevShare/CPA/最低保证金；路由/提高价格的"剪辑"。
贷款/罚款：对SLA中断，虚假开销，报告不一致。
定位：T+N频率，保留，充电包，报告。
yaml partner_id: "pool-A"
sla:
fill_rate: ">= 90%"
on_time: ">= 98%"
quote_ttl_s: 2 limits:
rps: 200 region: ["EU","TR"]
commercials:
model: "revshare: 20% of net"
security:
webhook_signature: "Ed25519"10）集成模式
带有超时框的Pull-cote API（idempotency-key）。
由Webhooks签名的比赛。"made"/"settled"（具有指数的retrai）。
用于CDC授权手册和分析的事件总线（事件版本）。
Batch-recon（每日SFTP/Blob+校验和）。
两侧的Outbox/Inbox+dedup。
电路转换/SDK，兼容性窗口。
11）过载和摆动控制
反同质性：限制，队列，VIP/复杂案例优先级，surge系数。
反仲裁（有毒）：禁止低价/质量的"自我执行"，监视"乒乓"请求。
反兄弟：设备/行为签名，蜂拥而至，延迟资格（冷静）。
荣誉退化：倒退到本地池，"最佳effort"具有透明的退化。
12）逻辑示例（草图）
12.1基于管辖和SLO的漫游
python def compliant(req, pool):
return (req. constraints. geo in pool. regions and pool. sla. quote_ttl_s <= 2 and pool. vendor_tier in {"gold","silver"})12.2公平政策（Rego想法）
rego package fairness deny["overexposed vendor"] {
usage. share[input. vendor] > 0. 45 input. vendor. tier == "silver"
}12.3 Orderbook收敛样本
sql
SELECT offer_id, MAX(version)-MIN(version) AS drift
FROM orderbook_events
WHERE ts >= now() - interval '5 minutes'
GROUP BY 1
HAVING MAX(version)-MIN(version) > 1; -- fragmentation signal13）成熟度量
Coverage：有≥个X活动开销的细分/区域的比例。
Elasticity： fill rate在+Δ需求下恢复的速度有多快。
EPI/Spread-provement：聚合vs独奏池的好处。
公平分配：周转份额与预期质量的偏差。
Recon-Health：差异关闭的频率/截止日期。
隐私评分：不将PD带出政治边界的路线比例。
14）反模式
一个没有SOR和质量规则的裸体联盟→分裂，取消。
"玻璃市场"：向所有人开放一切-炸药和价格战的爆发。
没有归属和重新分配→永恒的争议和冻结的付款。
池之间的硬同步板→级联潜伏性/故障。
不同领域的相同规则→高级/本地利基市场的经验退化。
TTL无视offers →"破旧"条款下的交易。
单个加密密钥进入整个市场→不可能逐点"擦除"数据。
15）建筑师支票清单
1.确定了模型（共享池/联邦/枢纽）和主权限制?
2.是否有数据合同（电路、版本、TTL、签名）和兼容窗口?
3.SOR与fairness和becomps、SLO流动性和行车记录仪一起实施？
4.有没有规定账单/归属，索赔窗口，贷款/罚款？
5.是否内置了反同源/反同源/反仲裁和降级模式？
6.是否建立了"交易证据"的回收和人工制品？
7.私有性：化名，geo-pinning，还原，删除权？
8.教学：需求压力峰值/池下降/手令同步化？
9.FinOps： egress预算、路由成本、目标EPI?
10.政府：门槛份额,合作伙伴认证,审计。
二.结论
集体流动性不是"连接另一个合作伙伴"，而是设计市场：统一合同和事件，透明的路由和公平规则，强大的可观察性和计算，隐私和"作为代码"的管辖权。因此，从不同的来源诞生了一个单一、深刻和可持续的供求群--为用户提供更好的体验，为整个生态系统提供可预测的经济。