开放接口文档

// 依赖: npm install socket.io-client playwright
const { io } = require("socket.io-client");

const socket = io("http://127.0.0.1:9001");
const call = (event, data = {}) =>
  new Promise((resolve) => socket.emit(event, data, resolve));

socket.on("connect", async () => {
  console.log("[连接] 已连接到启元客户端");

  // ── 新增代理 ──────────────────────────────────────────────────────────
  console.log("[代理] 正在新增代理...");
  let res = await call("proxy:create", {
    proxy_name: "美国住宅-01", proxy_type: "socks5",
    proxy_addr: "1.2.3.4",   proxy_port: 1080,
    username: "user",         password: "pass",
  });
  console.log("[代理] 结果:", res);
  const proxyCode = res.data.code;
  console.log("[代理] code=", proxyCode);

  // ── 新增环境 ──────────────────────────────────────────────────────────
  console.log("[环境] 正在新增环境...");
  res = await call("env:create", {
    name: "账号-01",
    // proxy_ip_code 暂不绑定，如需绑定传入: proxy_ip_code: proxyCode
    timezone: "custom",     timezone_value: "Asia/Shanghai",
    geo_location: "custom", longitude: "116.3", latitude: "39.9",
    language: "custom",     languages: ["zh-CN", "en-US"],
    cpu_cores: "8", memory_gb: "16",
  });
  console.log("[环境] 结果:", res);
  const envCode = res.data.code;
  console.log("[环境] code=", envCode);

  // ── 刷新指纹 ──────────────────────────────────────────────────────────
  console.log("[指纹] 正在随机刷新指纹...");
  res = await call("env:randomize_fingerprint", { code: envCode });
  console.log("[指纹] 结果:", res.data);

  // ── 打开浏览器 ────────────────────────────────────────────────────────
  console.log("[浏览器] 正在打开浏览器...");
  res = await call("env:open", { code: envCode, headless: true });
  console.log("[浏览器] 结果:", res);
  const debugPort = res.data.debug_port;
  console.log("[浏览器] 调试端口=", debugPort);

// ── 接入 Playwright ───────────────────────────────────────
console.log("[Playwright] 正在连接...");
const { chromium } = require("playwright");

let browser = null; // 提升作用域，finally 里能访问

try {
    // 1. 连接浏览器
    browser = await chromium.connectOverCDP(`http://127.0.0.1:${debugPort}`);

    // 2. 获取页面
    const page = browser.contexts()[0].pages()[0];

    // 3. 访问网页
    await page.goto("https://www.example.com");
    const title = await page.title();
    console.log("[Playwright] 页面标题=", title);

} catch (err) {
    // 出错立即抛出，不吞错，保证及时报错
    console.error("[Playwright] 执行失败:", err.message);
    throw err; // 关键：抛出错误，外部能捕获

} finally {
    // ======================= 无论成功/失败/崩溃，100% 执行 =======================
    console.log("[兜底] 开始执行统一关闭流程...");

    try {
        // 1. 关闭 Playwright 浏览器
        if (browser) {
            await browser.close().catch(() => {}); // 关闭失败也不阻塞
            console.log("[Playwright] 已安全关闭");
        }

        // 2. 执行 env:close 兜底
        await call("env:close", { code: envCode }).catch(() => {});
        console.log("[关闭] env:close 已执行");

        // 3. 断开 socket
        if (socket) {
            socket.disconnect();
            console.log("[连接] socket 已断开");
        }

    } catch (cleanupErr) {
        console.warn("[兜底] 关闭流程出现轻微异常:", cleanupErr.message);
    }

    console.log("[兜底] 所有收尾任务执行完成");
}
});

// Maven 依赖:
//   io.socket:socket.io-client:2.1.0
//   org.json:json:20231013
import io.socket.client.IO;
import io.socket.client.Socket;
import org.json.JSONArray;
import org.json.JSONObject;
import java.util.concurrent.CountDownLatch;

public class QiyuanDemo {

    static Socket socket;

    static JSONObject call(String event, JSONObject data) throws Exception {
        JSONObject[] result = {null};
        CountDownLatch latch = new CountDownLatch(1);
        socket.emit(event, data, (Object... args) -> {
            result[0] = new JSONObject(args[0].toString());
            latch.countDown();
        });
        latch.await();
        return result[0];
    }

    public static void main(String[] args) throws Exception {
        System.out.println("[连接] 正在连接到启元客户端...");
        socket = IO.socket("http://127.0.0.1:9001");
        socket.connect();
        Thread.sleep(1000);
        System.out.println("[连接] 已连接");

        // ── 新增代理 ──────────────────────────────────────────────────
        System.out.println("[代理] 正在新增代理...");
        JSONObject proxyRes = call("proxy:create", new JSONObject()
            .put("proxy_name", "美国住宅-01").put("proxy_type", "socks5")
            .put("proxy_addr", "1.2.3.4").put("proxy_port", 1080)
            .put("username", "user").put("password", "pass"));
        System.out.println("[代理] 结果: " + proxyRes);
        String proxyCode = proxyRes.getJSONObject("data").getString("code");
        System.out.println("[代理] code=" + proxyCode);

        // ── 新增环境 ──────────────────────────────────────────────────
        System.out.println("[环境] 正在新增环境...");
        JSONObject envRes = call("env:create", new JSONObject()
            .put("name", "账号-01")
            // .put("proxy_ip_code", proxyCode)  // 暂不绑定，如需绑定取消注释
            .put("timezone", "custom").put("timezone_value", "Asia/Shanghai")
            .put("geo_location", "custom").put("longitude", "116.3").put("latitude", "39.9")
            .put("language", "custom").put("languages", new JSONArray().put("zh-CN").put("en-US"))
            .put("cpu_cores", "8").put("memory_gb", "16"));
        System.out.println("[环境] 结果: " + envRes);
        String envCode = envRes.getJSONObject("data").getString("code");
        System.out.println("[环境] code=" + envCode);

        // ── 刷新指纹 ──────────────────────────────────────────────────
        System.out.println("[指纹] 正在随机刷新指纹...");
        JSONObject fpRes = call("env:randomize_fingerprint",
            new JSONObject().put("code", envCode));
        System.out.println("[指纹] 结果: " + fpRes.opt("data"));

        // ── 打开浏览器 ────────────────────────────────────────────────
        System.out.println("[浏览器] 正在打开浏览器...");
        JSONObject openRes = call("env:open", new JSONObject()
            .put("code", envCode).put("headless", true));
        System.out.println("[浏览器] 结果: " + openRes);
        int debugPort = openRes.getJSONObject("data").getInt("debug_port");
        System.out.println("[浏览器] 调试端口=" + debugPort);

        // ── 接入 Playwright (com.microsoft.playwright) ────────────────
        // System.out.println("[Playwright] 正在连接...");
        // Playwright pw = Playwright.create();
        // Browser browser = pw.chromium()
        //     .connectOverCDP("http://127.0.0.1:" + debugPort);
        // Page page = browser.contexts().get(0).newPage();
        // page.navigate("https://www.example.com");
        // System.out.println("[Playwright] 标题=" + page.title());

        // ── 关闭浏览器 ────────────────────────────────────────────────
        System.out.println("[关闭] 正在关闭浏览器...");
        call("env:close", new JSONObject().put("code", envCode));
        System.out.println("[关闭] 完成");
        socket.disconnect();
        System.out.println("[连接] 已断开");
    }
}