高可用即时赔率API集成与全球多源体育数据同步方案

package main

import (
    "context"
    "log"
    "time"
    zm "sdk.odds-software-dev.com.cn/zhimai-go/v3"
)

func main() {
    // 1. 初始化高可用多源流式客户端 (内置 RingBuffer 断线序列号自动追赶)
    client := zm.NewStreamClient(&zm.Config{
        Endpoint:        "wss://stream.odds-software-dev.com.cn/v3/live",
        AppID:           "ZM_PROD_ENTERPRISE_8821",
        AppSecret:       "********************************",
        Protocol:        zm.ProtoBinary, // 启用 Protobuf 二进制极速帧
        HeartbeatPeriod: 15 * time.Second,
        AutoReplaySeq:   true,
    })

    // 2. 注册毫秒级盘口增量与风控封盘回调
    client.OnOddsDelta(func(evt *zm.OddsDeltaEvent) {
        if evt.BetStop {
            log.Printf("[RISK-LOCK] 赛事 %s 触发危险球强制封盘! 原因: %s\n", evt.MatchID, evt.StopReason)
            return
        }
        log.Printf("[SEQ:%d] 赛事:%s | 亚盘线:%.2f | 主水:%.3f | 客水:%.3f | 延迟:%dms\n",
            evt.SeqID, evt.MatchID, evt.HandicapLine, evt.HomeOdds.EU, evt.AwayOdds.EU, evt.LatencyMs)
    })

    // 3. 订阅指定联赛滚球频道并启动守护协程
    ctx := context.Background()
    if err := client.Subscribe(ctx, []string{"sport:football:inplay", "league:EPL"}); err != nil {
        log.Fatal("订阅失败:", err)
    }
    client.Wait()
}

package cn.com.oddssoftware.integration;

import cn.com.oddssoftware.sdk.v3.ZhimaiStreamClient;
import cn.com.oddssoftware.sdk.v3.model.OddsDeltaFrame;
import org.springframework.stereotype.Service;
import jakarta.annotation.PostConstruct;

@Service
public class ZhimaiOddsStreamListener {

    @PostConstruct
    public void initRealTimeOddsStream() {
        ZhimaiStreamClient client = ZhimaiStreamClient.builder()
            .endpoint("wss://stream.odds-software-dev.com.cn/v3/live")
            .credentials("ZM_PROD_ENTERPRISE_8821", System.getenv("ZM_SECRET"))
            .enableZScoreGuard(true) // 开启本地二次异常水位校验
            .reconnectMaxBackoffMs(2000)
            .build();

        client.subscribeInPlay("FOOTBALL", (OddsDeltaFrame frame) -> {
            if (frame.isSuspended()) {
                // 毫秒级同步暂停下游撮合或前端盘口高亮锁定
                MarketCacheManager.lockMatchMarkets(frame.getZmMatchId());
                return;
            }
            MarketCacheManager.applyDeltaPatch(frame.getZmMatchId(), frame.getSeqId(), frame.getMarkets());
        });

        client.connectAsync();
    }
}

import { ZhimaiOddsSocket, MarketType, OddsFormat } from '@zhimai-sports/odds-sdk';

const stream = new ZhimaiOddsSocket({
  url: 'wss://stream.odds-software-dev.com.cn/v3/live',
  apiKey: process.env.ZM_API_KEY!,
  secretKey: process.env.ZM_SECRET_KEY!,
  preferredFormat: [OddsFormat.EU, OddsFormat.HK],
  autoResubscribe: true, // 断线重连后自动携 lastSeqId 补齐缺失帧
});

stream.on('delta', (payload) => {
  const { zm_match_id, seq_id, market_ah, clock } = payload;
  if (market_ah.bet_stop) {
    console.warn(`[BET_STOP] Match ${zm_match_id} at ${clock.minute}' locked immediately.`);
    return;
  }
  console.log(`[SEQ ${seq_id}] ${zm_match_id} AH(${market_ah.line_display}): ${market_ah.home_odds.hk} / ${market_ah.away_odds.hk}`);
});

await stream.connect();
await stream.subscribeMatches(['ZM_M_2025109482', 'ZM_M_2025109485']);

import asyncio
from zhimai_sports_sdk import AsyncOddsStreamClient

async def handle_odds_tick(event: dict):
    if event.get("bet_stop"):
        print(f"[CIRCUIT_BREAKER] Match {event['zm_match_id']} suspended: {event['reason']}")
        return
    print(f"SEQ={event['seq_id']} | Match={event['zm_match_id']} | "
          f"Line={event['market_ah']['line_float']} | Home={event['market_ah']['home_odds']['eu']}")

async def main():
    client = AsyncOddsStreamClient(
        app_id="ZM_PROD_ENTERPRISE_8821",
        app_secret="********************************",
        use_protobuf=True,
        replay_from_last_seq=True
    )
    client.on_delta(handle_odds_tick)
    await client.connect_and_subscribe(channels=["sport:football:inplay", "sport:esports:lol"])

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