快速接入

MP_SDK_V1.0R002_<commit>_<arch>.BIN

chmod +x MP_SDK_V1.0R002_xxxx_x86_64.BIN
./MP_SDK_V1.0R002_cc80499b31dd_x86_64.BIN

# 检查 SDK 进程是否运行
ps -ef | grep mp-sdk | grep -v grep

echo '{"ifName":"eth0"}' > /usr/local/etc/mp-speeder/mp_client_ifname.conf

#!/bin/bash
# Linux SDK 一键接入示例
set -u

SDK="http://127.0.0.1:9801/api/v2"

# ==== 按实际情况修改以下变量 ====
DATA_KEY="PUT_YOUR_DATA_KEY_HERE"
ACC_IFS='["eth0","eth1"]'   # 参与加速的网卡列表
SRC_CIDR="0.0.0.0/0"
DST_CIDR="10.0.0.0/24"
DST_PORTS="443"
PROTO="TCP"
# =============================

# 检查用户是否忘记修改 DATA_KEY
[ "$DATA_KEY" = "PUT_YOUR_DATA_KEY_HERE" ] && { echo "请先修改 DATA_KEY 变量为实际的 dataKey"; exit 1; }

echo "[1/6] 开启策略路由"
curl -s -X POST "$SDK/route/policyRouteManagment" -H "enable: true"
echo

echo "[2/6] 配置加速参数"
curl -s -X POST "$SDK/client/mp-speeder" \\
  -H "Content-Type: application/json" \\
  -d "{
    \\"dataKey\\": \\"$DATA_KEY\\",
    \\"interfaces\\": $ACC_IFS,
    \\"scheduleMode\\": \\"bonding\\"
  }"
echo

echo "[3/6] 添加业务引流"
curl -s -X POST "$SDK/route/businessRoute" \\
  -H "all: false" \\
  -H "Content-Type: application/json" \\
  -d "[{
    \\"srcIP\\": \\"$SRC_CIDR\\",
    \\"dstIP\\": \\"$DST_CIDR\\",
    \\"protocol\\": \\"$PROTO\\",
    \\"dstPorts\\": \\"$DST_PORTS\\"
  }]"
echo

# 步骤 4（可选，需要按特定模式调度时再使用）
# curl -s -X POST "$SDK/client/multi-mode" \\
#   -H "Content-Type: application/json" \\
#   -d '{"dstIP":"10.0.0.0/24","protocol":"TCP","dstPorts":"443","speedMode":2,"priority":100}'

echo "[5/6] 重启加速（使新配置生效）"
curl -s -X POST "$SDK/client/mp-speeder/restart"
echo

echo "[6/6] 查询加速状态（最多等待 30 秒）"
for i in $(seq 1 30); do
    ready=$(curl -s "$SDK/client/mp-speeder" | grep -o '"ready":[^,}]*' | awk -F: '{print $2}' | tr -d ' ')
    if [ "$ready" = "true" ]; then
        echo "加速已就绪"
        exit 0
    fi
    sleep 1
done
echo "加速未在 30 秒内就绪"
exit 1

curl -s -X POST "http://127.0.0.1:9801/api/v2/client/mp-speeder/stop"

package main

import (
        "bytes"
        "encoding/json"
        "fmt"
        "io"
        "log"
        "net/http"
        "os"
        "time"
)

const sdkBase = "http://127.0.0.1:9801/api/v2"

// 通用 HTTP 调用
func call(method, path string, headers map[string]string, body interface{}) ([]byte, error) {
        var reqBody io.Reader
        if body != nil {
                bs, _ := json.Marshal(body)
                reqBody = bytes.NewReader(bs)
        }
        req, err := http.NewRequest(method, sdkBase+path, reqBody)
        if err != nil {
                return nil, err
        }
        if body != nil {
                req.Header.Set("Content-Type", "application/json")
        }
        for k, v := range headers {
                req.Header.Set(k, v)
        }
        resp, err := http.DefaultClient.Do(req)
        if err != nil {
                return nil, err
        }
        defer resp.Body.Close()
        respBody, _ := io.ReadAll(resp.Body)
        if resp.StatusCode >= 400 {
                return respBody, fmt.Errorf("status=%d body=%s", resp.StatusCode, string(respBody))
        }
        return respBody, nil
}

func main() {
        // 简化日志格式：仅保留时间，不带文件名前缀
        log.SetFlags(log.LstdFlags)

        // ==== 按实际情况修改 ====
        dataKey := "PUT_YOUR_DATA_KEY_HERE"
        accIfs := []string{"eth1"}
        // =====================

        // 检查用户是否忘记修改 dataKey
        if dataKey == "PUT_YOUR_DATA_KEY_HERE" {
                log.Fatal("请先修改 dataKey 变量为实际的 dataKey")
        }

        // 1. 开启策略路由
        log.Println("[1/6] 开启策略路由 ...")
        _, err := call("POST", "/route/policyRouteManagment",
                map[string]string{"enable": "true"}, nil)
        if err != nil {
                log.Fatalf("开启策略路由失败: %v", err)
        }

        // 2. 配置加速参数
        log.Println("[2/6] 配置加速参数 ...")
        accCfg := map[string]interface{}{
                "dataKey":      dataKey,
                "interfaces":   accIfs,
                "scheduleMode": "bonding",
        }
        _, err = call("POST", "/client/mp-speeder", nil, accCfg)
        if err != nil {
                log.Fatalf("配置加速参数失败: %v", err)
        }

        // 3. 添加业务引流
        log.Println("[3/6] 添加业务引流 ...")
        routes := []map[string]string{
                {
                        "srcIP":    "0.0.0.0/0",
                        "dstIP":    "10.0.0.0/24",
                        "protocol": "TCP",
                        "dstPorts": "443",
                },
        }
        _, err = call("POST", "/route/businessRoute",
                map[string]string{"all": "false"}, routes)
        if err != nil {
                log.Fatalf("添加业务引流失败: %v", err)
        }

        // 4. （可选）添加多模规则
        // modeRule := map[string]interface{}{
        //      "dstIP":    "10.0.0.0/24",
        //      "protocol": "TCP",
        //      "dstPorts": "443",
        //      "speedMode": 2,
        //      "priority":  100,
        // }
        // call("POST", "/client/multi-mode", nil, modeRule)

	// 5. 重启加速（使新配置生效）
	log.Println("[5/6] 重启加速 ...")
	_, err = call("POST", "/client/mp-speeder/restart", nil, nil)
	if err != nil {
		log.Fatalf("重启加速失败: %v", err)
	}

        // 6. 轮询加速状态
        log.Println("[6/6] 等待加速就绪（最多 30 秒）...")
        type status struct {
                Ready bool `json:"ready"`
        }
        const maxWait = 30
        for i := 1; i <= maxWait; i++ {
                body, err := call("GET", "/client/mp-speeder", nil, nil)
                if err == nil {
                        var s status
                        if json.Unmarshal(body, &s) == nil && s.Ready {
                                log.Printf("加速已就绪（耗时 %ds）", i)
                                return
                        }
                }
                time.Sleep(time.Second)
        }
        log.Println("加速未在 30 秒内就绪")
        os.Exit(1)
}

call("POST", "/client/mp-speeder/stop", nil, nil)

curl --interface mp_tun0 https://www.qq.com

iptables -t mangle -nvL