构建高可用Skill Marketplace的技术架构与实战

2次阅读

共计 2049 个字符，预计需要花费 6 分钟才能阅读完成。

现代技能交易平台 (Skill Marketplace) 需要处理复杂的实时交互场景。以家教平台为例：

即时匹配需求：学生发布需求后，系统需在 300ms 内返回符合条件的教师列表
双盲评价体系：服务完成后双方互评需保证评价不可篡改且延迟低于 1 秒
动态定价：钢琴陪练等稀缺技能需根据供需关系实时调整价格

单体架构痛点：
支付模块 CPU 密集型操作阻塞评价系统 IO 请求
技能检索功能无法单独扩展
发版时所有服务必须同时部署

微服务优势：

graph TD
  A[API Gateway] --> B[Skill Service]
  A --> C[Payment Service]
  A --> D[Rating Service]
  B --> E[Elasticsearch]
  C --> F[PostgreSQL]

// 自定义分词器配置
@Bean
public RestHighLevelClient elasticsearchClient() {
    return new RestHighLevelClient(
        RestClient.builder(new HttpHost("es-cluster", 9200, "http")
        ).setRequestConfigCallback(builder -> builder.setSocketTimeout(30000)
        )
    );
}

// 搜索示例：钢琴 + 即兴伴奏 +10km 内
SearchRequest request = new SearchRequest("skills");
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder()
    .query(QueryBuilders.boolQuery()
        .must(QueryBuilders.matchQuery("category", "钢琴"))
        .must(QueryBuilders.matchQuery("tags", "即兴伴奏"))
        .filter(QueryBuilders.geoDistanceQuery("location")
            .distance("10km")
            .point(39.9, 116.4)));

// Saga 补偿示例
@SagaAction(compensationMethod = "cancelBooking")
public void reserveTimeSlot(BookingRequest request) {
    // 预留时间段
    bookingRepository.updateStatus(request.getBookingId(), 
        BookingStatus.RESERVED);
}

public void cancelBooking(BookingRequest request) {
    // 超时后自动释放
    bookingRepository.updateStatus(request.getBookingId(),
        BookingStatus.AVAILABLE);
}

# application-security.yaml
security:
  oauth2:
    resourceserver:
      jwt:
        issuer-uri: https://auth.skill-market.com
        audience: skill-service
    client:
      registration:
        google:
          client-id: ${OAUTH_GOOGLE_CLIENT}
          scope: profile,email

接口类型	QPS	P99 延迟	错误率
技能搜索	12k	210ms	0.01%
支付确认	8k	150ms	0%
评价提交	5k	90ms	0.02%

-- 用户表按地理位置分片
CREATE TABLE users (
    id BIGINT PRIMARY KEY,
    region VARCHAR(4) NOT NULL,
    ...
) PARTITION BY LIST (region);

CREATE TABLE users_east PARTITION OF users
    FOR VALUES IN ('CN-E', 'JP', 'KR');