rustdx

⚠️ 网络连接问题？ 请查看 网络连接说明指南 或运行 ./scripts/diagnose_network.sh 诊断

受 pytdx 启发的 A 股数据获取工具，包含：

1. 一个 Rust 通用库 rustdx-complete；
2. 一个命令行工具 rustdx-cmd。

🎉 v1.0.0 重大更新 (2025-01-06)

✨ 企业级功能完整版

rustdx 现已升级为功能完整的企业级A股数据获取库，在保持原有核心功能的基础上，新增了大量企业级特性：

📊 P0 核心功能

🚀 P1 增强功能

📈 测试覆盖

• 总测试数: 94个 (✅ 100% 通过)
• 代码覆盖率: 核心模块 100%
• 示例程序: 6个完整示例

🌟 核心特性

1️⃣ 数据完整性验证

use rustdx_complete::tcp::stock::validator;

// 验证K线数据连续性
let result = validate_kline_continuity(&data, "600000");

// 检测异常数据
let anomalies = detect_anomalies(&data, 0.10); // 10%阈值

2️⃣ 技术指标计算

use rustdx_complete::indicators::{sma, ema, macd, rsi, bollinger_bands};

// 计算移动平均线
let sma20 = sma(&closes, 20);

// 计算MACD
let macd_result = macd(&closes, 12, 26, 9);

// 计算布林带
let bb = bollinger_bands(&closes, 20, 2.0);

3️⃣ 智能缓存层

use rustdx_complete::cache::Cache;
use std::time::Duration;

// 创建内存缓存（5分钟TTL）
let cache = Cache::memory(Duration::from_secs(300));

// 自动缓存-回源模式
let data = cache.get_or_fetch("kline:600000", || {
    // 只在缓存未命中时执行
    fetch_from_server()
});

4️⃣ 增强错误处理

use rustdx_complete::error::{TcpError, ValidationError};

// 分层错误类型
match tcp_connection() {
    Ok(data) => Ok(data),
    Err(e) => Err(TcpError::ConnectionFailed {
        host: "server".to_string(),
        port: 7709,
        reason: e.to_string(),
    }),
}

5️⃣ 中国A股交易日历

use rustdx_complete::calendar::TradingCalendar;

// 判断是否交易日
let is_trading = TradingCalendar::is_trading_day(&date);

// 获取前一个交易日
let prev = TradingCalendar::previous_trading_day(&date);

// 获取最近N个交易日
let days = TradingCalendar::get_trading_days(&date, 10);

6️⃣ Builder 模式 API

use rustdx_complete::builder::KlineBuilder;

// 流畅的链式调用
let kline = KlineBuilder::new()
    .code("600000")
    .category(9)  // 日线
    .count(100)
    .build()?;

// 或使用便捷方法
let kline = KlineBuilder::daily("600000", 100)?;

7️⃣ TCP 连接池

use rustdx_complete::pool::ConnectionPool;

// 创建连接池（最大3个连接）
let pool = ConnectionPool::new(3)?;

// 获取连接（自动复用）
let mut conn = pool.get_connection()?;

// 连接自动归还到池中

📦 快速开始

安装

# Cargo.toml
[dependencies]
rustdx-complete = "1.0"

基础使用

use rustdx_complete::tcp::{Tcp, Tdx};
use rustdx_complete::tcp::stock::Kline;

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 连接到通达信服务器
    let mut tcp = Tcp::new()?;

    // 获取K线数据
    let mut kline = Kline::new(1, "600000", 9, 0, 10);
    kline.recv_parsed(&mut tcp)?;

    // 打印结果
    for bar in kline.result() {
        println!("{}: 收盘价 {:.2}", bar.dt, bar.close);
    }

    Ok(())
}

使用 Builder 模式

use rustdx_complete::builder::KlineBuilder;

let kline = KlineBuilder::daily("600000", 100)?;
kline.recv_parsed(&mut tcp)?;

使用连接池

use rustdx_complete::pool::ConnectionPool;

let pool = ConnectionPool::new(3)?;
let mut conn = pool.get_connection()?;
// 使用conn执行查询...

📚 完整功能列表

原有核心功能

新增功能 (v1.0)

📝 示例程序

运行示例：

cargo run --example test_technical_indicators

🌐 网络连接说明

重要: rustdx-complete 不需要在本地运行通达信服务！

工作原理

你的应用
    ↓
rustdx-complete (TCP 客户端)
    ↓
通达信公共服务器 (115.238.56.198:7709)
    ↓
返回股票数据

快速测试

# 测试网络连接
cargo run --example test_connection

# 运行诊断脚本
./scripts/diagnose_network.sh

📚 详细文档: NETWORK_CONNECTION_GUIDE.md

🚀 性能优化

1. 使用连接池

   • 复用TCP连接，减少握手开销
   • 默认3个连接，适合大多数场景

2. 启用缓存

   • 实时行情数据：3-5分钟TTL
   • 日线数据：1小时TTL
   • 财务数据：1天TTL

3. 批量查询

   • 一次查询多只股票，而非逐个查询
   • 建议不超过80只股票/次

4. 使用 release 模式

   cargo run --release
   

📖 API 文档

• docs.rs: https://docs.rs/rustdx-complete
• crates.io: https://crates.io/crates/rustdx-complete

🤝 贡献指南

欢迎贡献代码、报告问题或提出建议！

1. Fork 本仓库
2. 创建特性分支 (git checkout -b feature/AmazingFeature)
3. 提交更改 (git commit -m 'Add some AmazingFeature')
4. 推送到分支 (git push origin feature/AmazingFeature)
5. 开启 Pull Request

📄 许可证

本项目采用 MIT 许可证 - 查看 LICENSE 文件了解详情。

🙏 致谢

• pytdx - Python 版本的通达信接口
• 通达信 - 提供数据服务器
• trade_date_a - 中国交易日历数据

📊 版本历史

详细更新记录请查看 CHANGELOG.md

v1.0.0 (2025-01-06) - 🎉 企业级完整版

• ✅ 新增数据完整性验证模块
• ✅ 新增技术指标计算库
• ✅ 新增智能缓存层
• ✅ 新增增强错误处理系统
• ✅ 新增中国A股交易日历
• ✅ 新增Builder模式API
• ✅ 新增TCP连接池
• ✅ 94个单元测试全部通过
• ✅ 6个完整示例程序

v0.6.6 (2025-12-31) - 行业和概念板块

• 股票行业分类映射
• 东方财富概念板块支持

v0.6.4 (2025-12-31) - 完整五档买卖盘

• 补充 SecurityQuotes 完整五档买卖盘字段

rustdx - 功能完整的企业级 A 股数据获取库 🚀