---
id: daily-okx-dex-ws
name: "okx-dex-ws"
url: https://skills.yangsir.net/skill/daily-okx-dex-ws
author: okx
domain: web3
tags: ["defi", "websocket", "real-time-data", "trading", "dex"]
install_count: 2900
rating: 4.40 (3 reviews)
github: https://github.com/okx/onchainos-skills
---

# okx-dex-ws

> 通过 WebSocket 实时消费 DEX 数据，支持 CLI 持久化监控和自定义脚本，适用于交易机器人和链上分析

**Stats**: 2,900 installs · 4.4/5 (3 reviews)

## Before / After 对比

### DEX 数据获取

**Before**:

手动调用 REST API 轮询 DEX 数据，延迟高且浪费请求配额，难以实时捕捉交易机会

**After**:

通过 WebSocket 实时接收 DEX 流式数据，毫秒级延迟，不浪费 API 配额

| Metric | Before | After | Change |
|---|---|---|---|
| 数据延迟 | 5000毫秒 | 50毫秒 | -99% |

## Readme

# okx-dex-ws

# Onchain OS DEX WebSocket — Unified Skill

Two ways to consume real-time DEX data:

- **CLI** (`onchainos ws`) — start a background session, poll events incrementally. Best for monitoring and agent-driven workflows.

- **Script** — write a custom WebSocket client in Python/Node/Rust. Best for bots and custom logic.

## Pre-flight Checks

Read `../okx-agentic-wallet/_shared/preflight.md`. If that file does not exist, read `_shared/preflight.md` instead.

## Prerequisites

This skill references `ws-protocol.md` files from `okx-dex-market`, `okx-dex-token`, `okx-dex-signal`, and `okx-dex-trenches`. If a referenced file is not found, the corresponding skill may not be installed — inform the user and suggest installing the missing skill from the onchainos-skills plugin.

## Approach 1: CLI (`onchainos ws`)

### Discover Channels

```
onchainos ws channels                          # list all 9 supported channels
onchainos ws channel-info --channel <name>     # detailed info + example for a channel

```

### Start / Poll / Stop

```
onchainos ws start --channel <channel> [params]   # start background session
onchainos ws poll --id <ID> [--channel <ch>]       # pull new events
onchainos ws list                                  # list sessions
onchainos ws stop [--id <ID>]                      # stop session(s)

```

### Channel Quick Reference

Channel
Group
Pattern
Required Params

`kol_smartmoney-tracker-activity`
signal
global
(none)

`address-tracker-activity`
signal
per-wallet
`--wallet-addresses`

`dex-market-new-signal-openapi`
signal
per-chain
`--chain-index`

`price`
market
per-token
`--token-pair`

`dex-token-candle{period}`
market
per-token
`--token-pair`

`price-info`
token
per-token
`--token-pair`

`trades`
token
per-token
`--token-pair`

`dex-market-memepump-new-token-openapi`
trenches
per-chain
`--chain-index`

`dex-market-memepump-update-metrics-openapi`
trenches
per-chain
`--chain-index`

### Parameter Formats

- `--token-pair`: `chainIndex:tokenContractAddress` (e.g. `1:0xdac17f958d2ee523a2206206994597c13d831ec7`)

- `--chain-index`: comma-separated chain IDs (e.g. `1,501,56`)

- `--wallet-addresses`: comma-separated addresses, max 200

- `--idle-timeout`: auto-stop if no poll within this duration (default `30m`; `1h`, `2h`, `300s`, `0` to disable)

### Examples

```
# Smart money trade feed
onchainos ws start --channel kol_smartmoney-tracker-activity

# Track specific wallets
onchainos ws start --channel address-tracker-activity --wallet-addresses 0xAAA,0xBBB

# Token price monitoring
onchainos ws start --channel price --token-pair 1:0xdac17f958d2ee523a2206206994597c13d831ec7

# Buy signal alerts on Ethereum + Solana
onchainos ws start --channel dex-market-new-signal-openapi --chain-index 1,501

# New meme token launches on Solana
onchainos ws start --channel dex-market-memepump-new-token-openapi --chain-index 501

# K-line 1-minute candles
onchainos ws start --channel dex-token-candle1m --token-pair 1:0xdac17f958d2ee523a2206206994597c13d831ec7

```

### Poll Filters (tracker channels only)

When polling `kol_smartmoney-tracker-activity` or `address-tracker-activity`, these filters are available:

- `--min-quote-amount`, `--min-market-cap`, `--min-pnl`

- `--trader` (wallet address prefix match)

- `--tag` (smart_money or kol)

- `--trade-type` (buy or sell)

- `--since` (ms timestamp)

## Approach 2: Custom Script

When the user wants to build a custom WebSocket client with their own logic, read the corresponding protocol reference file:

### Market Data (price & candlestick streams)

**Read**: `../okx-dex-market/references/ws-protocol.md`

Channels: `price`, `dex-token-candle{period}`

### Token Data (detailed token streams)

**Read**: `../okx-dex-token/references/ws-protocol.md`

Channels: `price-info`, `trades`

### Signal & Wallet Tracking

**Read**: `../okx-dex-signal/references/ws-protocol.md`

Channels: `dex-market-new-signal-openapi`, `kol_smartmoney-tracker-activity`, `address-tracker-activity`

### Meme/Trenches

**Read**: `../okx-dex-trenches/references/ws-protocol.md`

Channels: `dex-market-memepump-new-token-openapi`, `dex-market-memepump-update-metrics-openapi`

## Common Protocol (all channels share)

- **Endpoint**: `wss://wsdex.okx.com/ws/v6/dex`

- **Auth**: HMAC-SHA256 login required before subscribing

- **Heartbeat**: send `"ping"` every 25s, expect `"pong"`

- **Subscribe**: `{"op": "subscribe", "args": [...]}`

- **Unsubscribe**: `{"op": "unsubscribe", "args": [...]}`

Weekly Installs527Repository[okx/onchainos-skills](https://github.com/okx/onchainos-skills)GitHub Stars207First Seen13 days agoSecurity Audits[Gen Agent Trust HubPass](/okx/onchainos-skills/okx-dex-ws/security/agent-trust-hub)[SocketPass](/okx/onchainos-skills/okx-dex-ws/security/socket)[SnykWarn](/okx/onchainos-skills/okx-dex-ws/security/snyk)Installed onopencode516codex516github-copilot512cursor512gemini-cli511amp511

---
*Source: https://skills.yangsir.net/skill/daily-okx-dex-ws*
*Markdown mirror: https://skills.yangsir.net/api/skill/daily-okx-dex-ws/markdown*