开云体育数据接口：毫秒级实时流分发与标准化API集成底座

package main

import (
    "context"
    "log"
    "time"
    kaiyun "github.com/kaiyuntech/kaiyun-sports-sdk-go/v4"
)

func main() {
    cfg := kaiyun.NewConfig(
        kaiyun.WithCredentials("ak_live_89201", "sk_live_f901a8..."),
        kaiyun.WithRegion(kaiyun.RegionSingaporeBGP),
        kaiyun.WithAutoReconnect(true, 100*time.Millisecond),
    )

    client, err := kaiyun.NewStreamClient(cfg)
    if err != nil {
        log.Fatalf("初始化开云数据流客户端失败: %v", err)
    }

    // 注册增量帧处理器：SDK内部自动校验 sequence_id 连续性并触发缺失补偿
    client.OnMatchDelta(func(ctx context.Context, frame *kaiyun.MatchDeltaFrame) error {
        log.Printf("[SEQ:%d] 赛事:%s 事件:%s 端到端延迟:%dms",
            frame.SequenceID, frame.MatchID, frame.DeltaPayload.EventCode, frame.LatencyMs())
        return nil
    })

    // 订阅足球与电竞滚球全频道
    _ = client.SubscribeSports(context.Background(), []int{kaiyun.SportFootball, kaiyun.SportEsports})
    select {}
}

import com.kaiyun.platform.sdk.v4.KaiyunStreamClient;
import com.kaiyun.platform.sdk.v4.config.ClientOptions;
import com.kaiyun.platform.sdk.v4.model.MatchDeltaEvent;

public class SportsDataConsumer {
    public static void main(String[] args) {
        ClientOptions options = ClientOptions.builder()
            .accessKey("ak_live_89201")
            .secretKey("sk_live_f901a8...")
            .endpoint("wss://stream.kaiyun-platform.com/v4/live")
            .enableSequenceGapRecovery(true) // 启用断层自动回溯补偿
            .compressionMode(ClientOptions.Compression.ZSTD)
            .build();

        KaiyunStreamClient client = new KaiyunStreamClient(options);

        client.registerListener((MatchDeltaEvent event) -> {
            System.out.printf("收到实时帧 -> Match: %s | Score: %d-%d | Seq: %d%n",
                event.getMatchId(),
                event.getHomeScore(),
                event.getAwayScore(),
                event.getSequenceId());
        });

        client.connectAndSubscribeAllInPlay();
    }
}

import { KaiyunSportsStream, SportType } from '@kaiyun-platform/sports-sdk';

const stream = new KaiyunSportsStream({
  accessKey: process.env.KAIYUN_ACCESS_KEY!,
  secretKey: process.env.KAIYUN_SECRET_KEY!,
  region: 'ap-southeast-1',
  enableSnapshotSync: true,
});

stream.on('delta', (frame) => {
  const { match_id, sequence_id, delta_payload } = frame;
  console.log(`[KaiyunFeed] 赛事 ${match_id} 状态更新 (#${sequence_id}):`, delta_payload.event_code);
});

stream.on('gap_recovered', ({ fromSeq, toSeq }) => {
  console.info(`[AutoRecovery] 已自动补齐网络抖动缺失帧: ${fromSeq} -> ${toSeq}`);
});

await stream.connect();
await stream.subscribe({ sports: [SportType.Football, SportType.Basketball] });