多语言体育数据SDK与实时赔率解析工具包

package cn.com.oddsapi.demo;

import cn.com.oddsapi.sdk.RuijuOddsClient;
import cn.com.oddsapi.sdk.config.ClientOptions;
import cn.com.oddsapi.sdk.config.ReconnectPolicy;
import cn.com.oddsapi.sdk.model.MarketType;
import cn.com.oddsapi.sdk.model.OddsDeltaEvent;
import cn.com.oddsapi.sdk.model.MatchOddsSnapshot;
import java.time.Duration;
import java.util.List;

public class InPlayOddsBootstrap {
    public static void main(String[] args) {
        // 1. 构建客户端配置：启用本地 L1 缓存树与指数退避断线重连
        ClientOptions options = ClientOptions.builder()
            .appKey(System.getenv("RUIJU_APP_KEY"))
            .appSecret(System.getenv("RUIJU_APP_SECRET"))
            .endpoint("wss://stream-cn-sz.odds-api.com.cn/v3/inplay")
            .fallbackEndpoints(List.of("wss://stream-hk.odds-api.com.cn/v3/inplay"))
            .enableLocalMemoryTree(true)
            .reconnectPolicy(ReconnectPolicy.exponentialBackoff(Duration.ofMillis(50), Duration.ofSeconds(3)))
            .build();

        RuijuOddsClient client = new RuijuOddsClient(options);

        // 2. 注册危险球毫秒级封盘回调（最高优先级线程分发）
        client.onBetStop(signal -> {
            System.out.printf("[BET-STOP] 比赛ID=%d 触发封盘! 原因=%s, 发生时间戳=%d%n",
                signal.getMatchId(), signal.getReason(), signal.getServerTimestamp());
        });

        // 3. 注册增量赔率更新回调（SDK 已自动合并至本地全量快照）
        client.onOddsDelta((OddsDeltaEvent delta, MatchOddsSnapshot mergedSnapshot) -> {
            System.out.printf("[DELTA] 比赛=%d | 亚盘主让球线=%s | 最新主胜香港盘=%s (Seq=%d)%n",
                delta.getMatchId(),
                mergedSnapshot.getMainAsianHandicap().getLine(),
                mergedSnapshot.getMainAsianHandicap().getHomeOddsHk(),
                delta.getSequenceId());
        });

        // 4. 启动长连接并订阅足球滚球全量亚盘与大小球
        client.connectAndSubscribe(List.of(MarketType.ASIAN_HANDICAP_LIVE, MarketType.OVER_UNDER_LIVE));
    }
}

package main

import (
	"context"
	"fmt"
	"os"
	"time"

	"github.com/odds-api-cn/ruiju-sdk-go/oddsclient"
)

func main() {
	// 1. 初始化 Go 客户端配置，开启 Protobuf 二进制流与自动 Seq 补帧
	cfg := &oddsclient.Config{
		AppKey:            os.Getenv("RUIJU_APP_KEY"),
		AppSecret:         os.Getenv("RUIJU_APP_SECRET"),
		PrimaryEndpoint:   "wss://stream-cn-sz.odds-api.com.cn/v3/inplay",
		StandbyEndpoints:  []string{"wss://stream-sg.odds-api.com.cn/v3/inplay"},
		WireFormat:        oddsclient.FormatProtobuf,
		HeartbeatInterval: 3 * time.Second,
		EnableLocalCache:  true,
	}

	client, err := oddsclient.NewClient(cfg)
	if err != nil {
		panic(err)
	}
	defer client.Close()

	// 2. 监听危险球封盘与增量赔率管道 (Zero-Alloc Channel)
	go func() {
		for evt := range client.Events() {
			switch evt.Type {
			case oddsclient.EventBetStop:
				fmt.Printf("[ALERT] 赛事 %d 立即锁盘! 触发信号: %s\n", evt.MatchID, evt.BetStopReason)
			case oddsclient.EventOddsDelta:
				// 直接从本地 L1 内存树 O(1) 读取合并后的完整亚盘快照
				snap, ok := client.Cache().GetMatchSnapshot(evt.MatchID)
				if ok {
					fmt.Printf("[SYNC] Seq=%d | 赛事=%d | 滚球比分=%d-%d | 亚盘水位=%v\n",
						evt.SequenceID, evt.MatchID, snap.HomeScore, snap.AwayScore, snap.MainAH)
				}
			}
		}
	}()

	// 3. 发起连接并订阅全球一级联赛滚球流
	if err := client.Start(context.Background(), oddsclient.SubAllInPlayFootball); err != nil {
		panic(err)
	}
	select {}
}

import asyncio
import os
from ruiju_sports_sdk import AsyncOddsClient, MarketFilter, OddsFormat

async def main():
    # 1. 初始化异步客户端，内置 uvloop 加速与断线自动回放缺失帧
    client = AsyncOddsClient(
        app_key=os.environ.get("RUIJU_APP_KEY"),
        app_secret=os.environ.get("RUIJU_APP_SECRET"),
        odds_format=OddsFormat.DECIMAL,
        enable_local_cache=True,
        auto_reconnect=True
    )

    @client.on_bet_stop
    async def handle_bet_stop(signal):
        print(f"[BET_STOP] Match={signal.match_id} locked! reason={signal.reason}")

    @client.on_odds_update
    async def handle_odds_update(delta, snapshot):
        # snapshot 为自动合并后的 Pydantic 强类型对象，可直接转 Pandas DataFrame
        ah = snapshot.main_asian_handicap
        print(f"[SEQ:{delta.seq_id}] {snapshot.home_team} vs {snapshot.away_team} "
              f"| 让球:{ah.handicap_line} | 主:{ah.home_odds} 客:{ah.away_odds}")

    # 2. 启动流式订阅：足球滚球亚盘、欧赔与角球盘口
    await client.connect(
        markets=[MarketFilter.FT_ASIAN_HANDICAP, MarketFilter.FT_1X2, MarketFilter.CORNERS_LIVE]
    )

if __name__ == "__main__":
    asyncio.run(main())

import { RuijuRealtimeClient, MarketType, OddsFormat } from '@odds-api/realtime-sdk';

const client = new RuijuRealtimeClient({
  appKey: process.env.RUIJU_APP_KEY!,
  appSecret: process.env.RUIJU_APP_SECRET!,
  region: 'cn-shenzhen',
  oddsFormat: OddsFormat.HONG_KONG,
  localStateTree: { enabled: true, maxStaleMs: 5000 },
});

// 1. 监听高优封盘指令（如 VAR 介入、红牌或危险任意球）
client.on('betStop', (payload) => {
  console.warn(`[BET-STOP] Match ${payload.matchId} suspended at ${payload.timestamp}ms`);
});

// 2. 监听增量赔率推送并读取合并后的本地状态树
client.on('oddsDelta', ({ delta, mergedMatch }) => {
  const mainLine = mergedMatch.markets.asianHandicap?.mainLine;
  console.log(`[Seq #${delta.seq}] Match ${mergedMatch.matchId} | Line: ${mainLine?.hdp} | Home: ${mainLine?.home}`);
});

// 3. 建立 WebSocket 连接并订阅滚球频道
await client.connect();
await client.subscribe({
  sport: 'football',
  inPlayOnly: true,
  markets: [MarketType.ASIAN_HANDICAP, MarketType.OVER_UNDER, MarketType.EURO_1X2],
});