项目实战DEX 聚合器后端

中级DeFi 开发4周

DEX 聚合器后端

聚合 Uniswap/Sushiswap/Curve 等 DEX 报价，寻找最优兑换路径

技术栈

Gogo-ethereumRedisGraphQLgRPC

核心功能

多 DEX 协议集成

最优路径寻找算法

滑点计算与保护

MEV 防护策略

实时价格更新

交易模拟执行

系统架构


┌──────────────┐     ┌─────────────┐     ┌──────────────┐
│   Clients    │────▶│  GraphQL/   │────▶│  DEX Router  │
│  (API/gRPC)  │     │  gRPC API   │     │   Engine     │
└──────────────┘     └─────────────┘     └──────────────┘
                            │
        ┌───────────────────┼───────────────────┐
        ▼                   ▼                   ▼
  ┌──────────┐        ┌──────────┐        ┌──────────┐
  │Uniswap V2│        │Uniswap V3│        │  Curve   │
  │ Adapter  │        │ Adapter  │        │ Adapter  │
  └──────────┘        └──────────┘        └──────────┘

课程章节

第一章：DEX 协议适配层

Uniswap V2 适配2小时

Uniswap V3 适配3小时

Curve 适配2小时

第二章：最优路径寻找算法

图论建模2小时

Dijkstra 变体2小时

分割交易优化2小时

第三章：滑点与价格影响

AMM 数学原理2小时

滑点计算1.5小时

价格影响保护1.5小时

第四章：MEV 防护

MEV 攻击类型1.5小时

私有交易池2小时

滑点保护策略1.5小时

核心代码实现

DEX 适配器接口

1type DEXAdapter interface {
2    Name() string
3    GetPools(ctx context.Context, tokenA, tokenB common.Address) ([]*Pool, error)
4    GetQuote(ctx context.Context, pool *Pool, amountIn *big.Int, zeroForOne bool) (*Quote, error)
5    BuildSwapTx(ctx context.Context, params *SwapParams) (*types.Transaction, error)
6}
7 
8type Pool struct {
9    Address   common.Address
10    DEX       string
11    Token0    common.Address
12    Token1    common.Address
13    Reserve0  *big.Int
14    Reserve1  *big.Int
15    Fee       uint32
16}
17 
18type Quote struct {
19    AmountOut    *big.Int
20    PriceImpact  float64
21    Fee          *big.Int
22    Route        []*Pool
23}

最优路径算法

1func (r *Router) FindBestRoute(ctx context.Context, tokenIn, tokenOut common.Address, amountIn *big.Int) (*Route, error) {
2    // 获取所有可能的池
3    pools, err := r.getAllPools(ctx, tokenIn, tokenOut)
4    if err != nil {
5        return nil, err
6    }
7 
8    // 构建交易图
9    graph := r.buildGraph(pools)
10    
11    // 使用修改的 Dijkstra 算法寻找最优路径
12    bestRoute := r.dijkstraWithSplit(graph, tokenIn, tokenOut, amountIn)
13    
14    // 计算最终输出和价格影响
15    totalOutput := big.NewInt(0)
16    for _, split := range bestRoute.Splits {
17        quote, _ := r.getQuoteForPath(ctx, split.Path, split.Amount)
18        totalOutput.Add(totalOutput, quote.AmountOut)
19    }
20 
21    return &Route{
22        TokenIn:     tokenIn,
23        TokenOut:    tokenOut,
24        AmountIn:    amountIn,
25        AmountOut:   totalOutput,
26        Splits:      bestRoute.Splits,
27        PriceImpact: r.calculatePriceImpact(amountIn, totalOutput, tokenIn, tokenOut),
28    }, nil
29}

代币转账历史查询 NFT 交易市场后端