Dial - 建立网络连接

# TCP 连接
conn = Dial("example.com:80")

# WebSocket 连接
ws = Dial("wss://stream.binance.com:9443/ws/btcusdt@kline_1m")

# 带协议的连接
conn = Dial("tcp://example.com:80")
conn = Dial("tls://example.com:443")

import json

# 连接到 Binance WebSocket
ws = Dial("wss://stream.binance.com:9443/ws/btcusdt@kline_1m")

if ws:
    Log("✅ WebSocket 已连接")
    
    while True:
        # 接收消息
        msg = ws.recv(5000)  # 5秒超时
        
        if msg:
            data = json.loads(msg)
            kline = data['k']
            Log(f"时间: {_D(kline['t']/1000)}")
            Log(f"收盘价: {kline['c']}")
        else:
            # 超时，发送 ping 保持连接
            ws.ping()
        
        Sleep(100)
else:
    Log("❌ WebSocket 连接失败")

ws = Dial("wss://stream.binance.com:9443/ws")

if ws:
    # 订阅K线和交易数据
    ws.subscribe(["btcusdt@kline_1m", "btcusdt@trade"])
    
    while True:
        msg = ws.recv(5000)
        if msg:
            data = json.loads(msg)
            Log(f"收到数据: {data}")
        
        Sleep(100)

# 连接到服务器
conn = Dial("tcp://example.com:8080", 5000)

if conn:
    # 发送数据
    conn.write("GET / HTTP/1.1\r\nHost: example.com\r\n\r\n")
    
    # 读取响应
    response = conn.read(4096)
    if response:
        Log(f"响应: {response}")
    
    # 关闭连接
    conn.close()

import time

ws = Dial("wss://stream.example.com/ws")
last_ping = time.time()

while True:
    # 每30秒发送一次ping
    if time.time() - last_ping > 30:
        ws.ping()
        last_ping = time.time()
        Log("发送心跳")
    
    # 接收消息
    msg = ws.recv(1000)
    if msg:
        Log(f"收到: {msg}")
    
    Sleep(100)