私域直播系统源码架构解析：从开播到成交的完整链路设计

前端（H5 / 小程序 / App）
        ↓
API 网关（鉴权、限流）
        ↓
直播服务  ←→  IM 服务
        ↓
商品服务 →  订单服务 → 支付服务
        ↓
数据分析 / 私域用户沉淀

@PostMapping("/live/room/create")
public LiveRoom createRoom(@RequestBody LiveRoomDTO dto) {
    LiveRoom room = new LiveRoom();
    room.setTitle(dto.getTitle());
    room.setAnchorId(dto.getAnchorId());
    room.setStatus("INIT");
    room.setCreateTime(LocalDateTime.now());
    liveRoomMapper.insert(room);
    return room;
}

public String generatePushUrl(Long roomId) {
    String streamKey = DigestUtils.md5DigestAsHex(
        (roomId + SECRET + System.currentTimeMillis()).getBytes()
    );
    return "rtmp://push.xxx.com/live/" + streamKey;
}

@ServerEndpoint("/ws/live/{roomId}")
public class LiveSocket {

    @OnMessage
    public void onMessage(String message, Session session) {
        // 广播弹幕
        broadcastToRoom(message);
    }
}

public void userJoin(Long roomId, Long userId) {
    redisTemplate.opsForSet()
        .add("live:room:users:" + roomId, userId);
}

@PostMapping("/live/goods/bind")
public void bindGoods(@RequestBody LiveGoodsDTO dto) {
    redisTemplate.opsForList()
        .rightPush("live:goods:" + dto.getRoomId(), dto.getGoodsId());
}

用户点击商品
   ↓
创建预订单
   ↓
库存校验
   ↓
锁库存
   ↓
生成订单

@Transactional
public Order createOrder(Long goodsId, Long userId) {
    if (!stockService.lock(goodsId)) {
        throw new RuntimeException("库存不足");
    }
    Order order = new Order(goodsId, userId);
    orderMapper.insert(order);
    return order;
}

@PostMapping("/pay/unified")
public PayResult unifiedPay(@RequestBody PayDTO dto) {
    return payStrategyFactory
        .getStrategy(dto.getPayType())
        .pay(dto);
}

@PostMapping("/pay/callback")
public String payCallback(@RequestBody PayNotify notify) {
    orderService.markPaid(notify.getOrderId());
    return "SUCCESS";
}

public void tagUser(Long userId, String tag) {
    redisTemplate.opsForSet()
        .add("user:tags:" + userId, tag);
}