毫秒级体育盘口API与即时赔率数据接入引擎

package main

import (
    "context"
    "fmt"
    "time"
    "github.com/odds-api-cn/ruiju-sdk-go/v4/inplay"
)

func main() {
    client := inplay.NewStreamClient(&inplay.Config{
        AccessKey:   "RJ_LIVE_9928347102",
        SecretKey:   "sk_prod_8f92a7c1e4b09d32...",
        Endpoint:    "wss://stream.odds-api.com.cn/v4/inplay",
        Compression: inplay.CompressionZstd,
        AutoRecover: true, // 自动检测Seq_ID断层并触发快照补偿
    })

    // 订阅英超与欧冠滚球亚盘、大小球及危险球封盘信号
    sub := inplay.Subscription{
        SportID:   1,
        LeagueIDs: []string{"lg_epl_1", "lg_ucl_1"},
        Markets:   []string{"ah_full_time", "ou_full_time", "ah_corners"},
    }

    client.OnBetStop(func(ev *inplay.BetStopSignal) {
        fmt.Printf("[URGENT LOCK] Match=%s Reason=%s Latency=%dms\n",
            ev.MatchID, ev.TriggerReason, time.Since(ev.ServerTime).Milliseconds())
    })

    client.OnOddsDelta(func(delta *inplay.OddsDeltaPacket) {
        fmt.Printf("[SEQ:%d] Match=%s Market=%s Line=%s Home=%.2f Away=%.2f\n",
            delta.SeqID, delta.MatchID, delta.MarketID, delta.Line, delta.HomeOdds, delta.AwayOdds)
    })

    _ = client.ConnectAndSubscribe(context.Background(), sub)
}

import asyncio
import hmac, hashlib, time
from ruiju_odds_sdk import AsyncOddsStreamClient, MarketFilter

async def consume_inplay_odds():
    client = AsyncOddsStreamClient(
        api_key="RJ_LIVE_9928347102",
        api_secret="sk_prod_8f92a7c1e4b09d32...",
        region="ap-shenzhen-bgp",
        enable_local_orderbook=True
    )

    @client.on_event("ODDS_DELTA_UPDATE")
    async def handle_delta(payload: dict):
        if payload["inplay_clock"]["bet_stop"]:
            print(f"⚠️ 触发毫秒级危险球锁盘: {payload['match_id']}")
            return
        print(f"SEQ={payload['seq_id']} | 延迟={payload['latency_ms']}ms | 盘口更新={len(payload['markets_delta'])}条")

    await client.subscribe(
        sport_id=1,
        markets=[MarketFilter.ASIAN_HANDICAP, MarketFilter.OVER_UNDER, MarketFilter.CORNERS]
    )

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

import { RuiJuOddsStream, OddsFormat } from '@odds-api-cn/sdk-node';

const stream = new RuiJuOddsStream({
  accessKey: process.env.RUIJU_ACCESS_KEY!,
  secretKey: process.env.RUIJU_SECRET_KEY!,
  oddsFormat: OddsFormat.HONG_KONG, // 自动输出香港盘与欧赔双字段
  heartbeatIntervalMs: 3000,
});

stream.on('betStop', (signal) => {
  console.warn(`[BET_STOP] Match ${signal.matchId} suspended at ${signal.minute}'`);
});

stream.on('marketDelta', (packet) => {
  for (const m of packet.marketsDelta) {
    console.log(`[${packet.seqId}] ${packet.matchId} ${m.marketId} (${m.line}):`, m.selections);
  }
});

await stream.connect({ sportId: 1, inplayOnly: true });

import cn.com.oddsapi.sdk.RuiJuStreamClient;
import cn.com.oddsapi.sdk.model.OddsDeltaEvent;

public class InPlayConsumer {
    public static void main(String[] args) {
        RuiJuStreamClient client = RuiJuStreamClient.builder()
            .credentials("RJ_LIVE_9928347102", "sk_prod_8f92a7c1e4b09d32...")
            .endpoint("wss://stream.odds-api.com.cn/v4/inplay")
            .ringBufferSize(65536) // 内置Disruptor无锁队列
            .build();

        client.registerDeltaListener((OddsDeltaEvent event) -> {
            if (event.isBetStop()) {
                RiskEngine.suspendMarketImmediately(event.getMatchId());
                return;
            }
            OrderbookCache.applyDelta(event.getSeqId(), event.getMarketsDelta());
        });

        client.start();
    }
}