Topics

#0xfnzero #automated-trading #copy-trading #defi #fnzero #follow-trading #http-api #memecoin #nodejs #pumpswap #risk-management #solana #solana-bot #stop-loss #strategy #take-profit #trading-bot #trading-bot-proxy #typescript #websocket

Language breakdown

TypeScript 98.0%

Shell 2.0%

▸ Files click to expand

README

Solana DEX 连续买入跟单机器人

专业的 Solana PumpSwap 交易机器人，基于连续买入模式识别和跟单策略。当检测到某个代币连续大额买入时，自动跟单买入并进行止盈止损管理。

这个项目提供什么

| 方向 | 内容 | | --- | --- | | 策略 | PumpSwap 连续买入检测、跟单买入、自动止盈止损 | | 数据源 | trading-bot-proxy WebSocket 数据流 / HTTP API | | 风控 | 最大持仓、冷却时间、滑点保护、固定买入金额 | | 运行环境 | TypeScript、Node.js、Solana Web3.js、代理服务 | | 使用场景 | PumpSwap 跟单 Bot、策略研究、小额测试、事件监听 |

✨ 核心特性

🎯 智能跟单: 检测连续买入模式，自动跟单交易
📊 实时监控: 毫秒级延迟监听链上 PumpSwap 交易事件
💰 自动止盈止损: 15% 止盈，10% 止损，全自动执行
🛡️ 风险管理: 多重风险控制，保护资金安全
⚙️ 灵活配置: 所有参数可通过环境变量自定义
📈 实时统计: 持仓跟踪、盈亏统计、性能分析

🚀 快速开始

环境要求

Node.js 16.0+
NPM 7.0+
Solana 交易代理服务正在运行

安装依赖

# 克隆项目后进入目录
cd trading-bot-ts
安装依赖
npm install

配置策略参数

# 复制配置模板
cp .env.example .env
编辑配置文件
nano .env  # 或使用其他编辑器

核心配置说明

🔗 服务连接

HTTPAPIURL=http://localhost:3000     # 交易代理 HTTP API
WS_URL=ws://127.0.0.1:9001            # WebSocket 数据流
REQUEST_TIMEOUT=30000                  # 请求超时 (毫秒)

📈 交易策略

CONSECUTIVE_BUYS=3                     # 连续买入次数检测
TOTALAMOUNTTHRESHOLD=5.0             # 总金额阈值 (SOL)
TIMEWINDOWMINUTES=5                  # 时间窗口 (分钟)
BUYAMOUNTSOL=0.01                   # 跟单买入金额 (SOL)

💰 止盈止损

TAKEPROFITPERCENT=15.0              # 止盈百分比
STOPLOSSPERCENT=-10.0               # 止损百分比
CHECKINTERVALSECONDS=10             # 检查间隔 (秒)

🛡️ 风险控制

MAX_POSITIONS=5                        # 最大同时持仓数
COOLDOWN_MINUTES=5                     # 代币冷却时间 (分钟)
SLIPPAGE_BPS=500                      # 滑点保护 (5%)

🎯 运行机器人

启动交易机器人

# 开发模式 (实时日志)
npm run bot
生产模式 (编译后运行)
npm run bot:prod
构建项目
npm run build
仅监听事件 (不执行交易)
npm run subscribe

启动输出示例

🚀 启动交易机器人... ✅ 服务器状态: healthy 🚀 交易机器人已连接到数据流 📡 正在监听链上交易事件... 📊 当前状态: 0 个持仓, 总投资 0 SOL 📊 分析买入事件: A1B2C3D4... Amount: 2.5000 SOL 📊 分析买入事件: A1B2C3D4... Amount: 1.8000 SOL 📊 分析买入事件: A1B2C3D4... Amount: 3.2000 SOL 🎯 检测到连续买入模式! 代币: A1B2C3D4E5F6G7H8... 连续买入: 3次总金额: 7.5000 SOL 🚀 执行跟单买入! 我们买入: 0.01 SOL ✅ 买入成功: 5YoP8xT2M... 📊 当前状态: 1 个持仓, 总投资 0.01 SOL

📈 A1B2C3D4... PnL: +12.50% 🎯 触发止盈: 16.20% >= 15.00% ✅ 止盈成功: 3KpL9vN8Q... 盈亏: +16.20% (+0.00162 SOL)

💡 使用方式

🤖 自动交易模式 (推荐)

import { TradingBot } from 'trading-proxy-client';
const bot = new TradingBot(); await bot.start();
// 机器人自动执行： // ✅ 监听 PumpSwap 买入事件 // ✅ 检测连续买入模式 // ✅ 自动跟单买入 // ✅ 实时止盈止损管理 // ✅ 风险控制和仓位管理

📊 仅数据监控

import { EventSubscriber } from 'trading-proxy-client';
const subscriber = new EventSubscriber();
subscriber.on('pumpswap', (event, latency) => {   const action = event.is_buy ? '🟢 BUY' : '🔴 SELL';   console.log(${action} ${event.mint} ${latency?.latency_ms}ms); });
subscriber.connect();

🔧 手动交易

import { TradingProxyClient } from 'trading-proxy-client';
const client = new TradingProxyClient();
// 健康检查 const health = await client.health();
// 手动买入 const result = await client.buy(dexParams, {   mint: 'token_address',   amount_sol: 0.01,   slippage_bps: 500 });

🧠 策略详解

连续买入跟单策略

机器人采用智能的连续买入模式识别策略，通过检测短时间内的大额买入行为来发现潜在的交易机会。

📊 工作原理

时间轴: 00:00 ────────────► 00:05 ────────────► 00:10

代币 ABC: ├─ 00:01 🟢 买入 2.5 SOL (用户A) ├─ 00:02 🟢 买入 1.8 SOL (用户B) ├─ 00:03 🟢 买入 3.2 SOL (用户C) └─ 00:04 🎯 触发跟单！总计 7.5 SOL > 5.0 SOL 阈值

🎯 触发条件 (全部满足)

连续买入检测: 在时间窗口内检测到连续买入
金额阈值: 累计买入金额达到设定阈值
时间限制: 所有买入发生在指定时间窗口内
风险检查: 通过持仓限制、冷却时间等风险控制

⚡ 执行流程

graph TD
    A[监听PumpSwap买入事件] --> B[记录买入数据]
    B --> C{是否达到连续买入次数?}
    C -->|否| A
    C -->|是| D{总金额是否超过阈值?}
    D -->|否| A
    D -->|是| E[风险检查]
    E --> F{通过风险检查?}
    F -->|否| A
    F -->|是| G[执行跟单买入]
    G --> H[开始持仓管理]
    H --> I[监控止盈止损]
    I --> J{触发止盈/止损?}
    J -->|否| I
    J -->|是| K[自动卖出]

💰 止盈止损机制

实时监控: 每10秒检查一次持仓收益
止盈触发: 达到15%收益时自动卖出
止损保护: 亏损达到10%时自动止损
精确计算: 基于买入价格实时计算收益率

🛡️ 多重风险控制

持仓限制: 最多同时持有5个代币仓位
冷却机制: 同一代币5分钟内只能买入一次
滑点保护: 交易时设置5%滑点保护
金额控制: 固定小额买入，控制单笔风险
时间窗口: 限制在短时间窗口内的买入行为

📈 性能特性

⚡ 低延迟优势

毫秒级响应: WebSocket实时数据流，延迟<100ms
高效处理: 异步事件处理，不阻塞主线程
智能缓存: 价格历史缓存，快速计算收益

🔄 自动化管理

无人值守: 7x24小时自动运行
自动清理: 定期清理过期数据，保持性能
异常恢复: 网络断线自动重连，容错性强

📊 实时统计

// 获取实时统计
const stats = bot.getStats();
console.log(
持仓数量: ${stats.totalPositions}
总投资: ${stats.totalInvested} SOL
总盈亏: ${stats.totalPnL} SOL
平均收益: ${stats.avgPnL.toFixed(2)}%
);

⚠️ 注意事项

💡 使用建议

测试先行: 建议先在小金额下测试策略效果
参数调优: 根据市场情况调整连续买入阈值
风险意识: 设置合理的持仓上限和买入金额
网络稳定: 确保网络连接稳定，避免错过交易机会

🚨 风险提示

加密货币交易具有高风险，可能导致本金损失
机器人交易无法保证盈利，请理性投资
建议设置合理的资金上限，控制整体风险
定期监控机器人运行状态，及时处理异常

🔧 故障排除

常见问题

Q: 机器人无法连接到服务器

# 检查服务器状态 curl http://localhost:3000/health
检查WebSocket连接
wscat -c ws://127.0.0.1:9001

Q: 交易执行失败

检查钱包余额是否充足
验证滑点设置是否合理
确认代理服务正常运行

Q: 未检测到买入机会

降低 TOTALAMOUNTTHRESHOLD 阈值
增加 TIMEWINDOWMINUTES 时间窗口
检查 WebSocket 连接是否正常

📚 API 文档

TradingBot 类

class TradingBot {
  constructor()                        // 创建机器人实例
  async start(): Promise<void>         // 启动机器人
  stop(): void                        // 停止机器人
  getPositions(): Map<string, Position> // 获取当前持仓
  getStats(): Stats                   // 获取统计信息
}

事件监听

bot.on('buy-success', (data) => {
  // 买入成功事件
});
bot.on('sell-success', (data) => {   // 卖出成功事件 });
bot.on('error', (error) => {   // 错误事件处理 });

License

MIT

🔗 More in this category