Node.js

npm install undici

import { ProxyAgent, request } from 'undici';

const PROXY = 'http://USERNAME-country-US-session-job1-time-30:PASSWORD@GATEWAY_HOST:58971';

const dispatcher = new ProxyAgent(PROXY);

const { statusCode, body } = await request('https://api.ipify.org?format=json', {
  dispatcher,
});
console.log(statusCode, await body.json());

await dispatcher.close();

import { ProxyAgent, setGlobalDispatcher } from 'undici';

setGlobalDispatcher(
  new ProxyAgent('http://USERNAME-country-US:PASSWORD@GATEWAY_HOST:58971'),
);

// 之后所有的 fetch 都走代理
const response = await fetch('https://api.ipify.org');
console.log(await response.text());

import { ProxyAgent, request } from 'undici';

const PROXY = 'http://USERNAME-country-US:PASSWORD@GATEWAY_HOST:58971';

for (let i = 0; i < 5; i += 1) {
  const dispatcher = new ProxyAgent(PROXY);
  const { body } = await request('https://api.ipify.org', { dispatcher });
  console.log(await body.text());
  await dispatcher.close();
}

import { ProxyAgent, request } from 'undici';

const GATEWAY = 'GATEWAY_HOST:58971';
const USER = 'USERNAME';
const PASSWORD = 'PASSWORD';

function proxyFor(sessionId, country = 'US', minutes = 30) {
  const user = `${USER}-country-${country}-session-${sessionId}-time-${minutes}`;
  return `http://${user}:${PASSWORD}@${GATEWAY}`;
}

async function fetchWith(sessionId) {
  const dispatcher = new ProxyAgent(proxyFor(sessionId));
  try {
    const { body } = await request('https://api.ipify.org', { dispatcher });
    return await body.text();
  } finally {
    await dispatcher.close();
  }
}

const results = await Promise.all(
  // session 值只允许 [A-Za-z0-9.-]，用点号不用下划线
  Array.from({ length: 8 }, (_, i) => fetchWith(`task.${i}`)),
);
console.log(results);

import { ProxyAgent } from 'undici';

const dispatcher = new ProxyAgent({
  uri: 'http://USERNAME-country-US:PASSWORD@GATEWAY_HOST:58971',
  connections: 16,
  // 网关空闲超时是 5 分钟，客户端设得更短能避免用到已被关闭的连接
  keepAliveTimeout: 60_000,
  keepAliveMaxTimeout: 240_000,
});

npm install axios https-proxy-agent

import axios from 'axios';
import { HttpsProxyAgent } from 'https-proxy-agent';

const PROXY = 'http://USERNAME-country-US-session-job1-time-30:PASSWORD@GATEWAY_HOST:58971';
const agent = new HttpsProxyAgent(PROXY);

const client = axios.create({
  httpAgent: agent,
  httpsAgent: agent,
  // 必须关掉，否则 axios 会尝试自己处理代理并和 agent 冲突
  proxy: false,
  timeout: 30_000,
});

const { data } = await client.get('https://api.ipify.org?format=json');
console.log(data);

npm install got hpagent

import got from 'got';
import { HttpProxyAgent, HttpsProxyAgent } from 'hpagent';

const PROXY = 'http://USERNAME-country-US:PASSWORD@GATEWAY_HOST:58971';

const client = got.extend({
  agent: {
    http: new HttpProxyAgent({ proxy: PROXY, keepAlive: true }),
    https: new HttpsProxyAgent({ proxy: PROXY, keepAlive: true }),
  },
  timeout: { request: 30_000 },
  retry: {
    limit: 3,
    // 先区分代理握手错误和目标响应；仅对可安全重放的请求退避重试
    statusCodes: [429, 500, 502, 503, 504],
  },
});

console.log(await client('https://api.ipify.org').text());

npm install socks-proxy-agent

import { SocksProxyAgent } from 'socks-proxy-agent';
import { request } from 'undici';

// socks5h 让代理解析域名
const agent = new SocksProxyAgent(
  'socks5h://USERNAME-country-US:PASSWORD@GATEWAY_HOST:58971',
);

// 配合 node:https
import https from 'node:https';

https.get('https://api.ipify.org', { agent }, (response) => {
  response.setEncoding('utf8');
  response.on('data', (chunk) => process.stdout.write(chunk));
});

import http from 'node:http';
import tls from 'node:tls';

const USER = 'USERNAME-country-US';
const PASSWORD = 'PASSWORD';
const auth = Buffer.from(`${USER}:${PASSWORD}`).toString('base64');

const req = http.request({
  host: 'GATEWAY_HOST',
  port: 58971,
  method: 'CONNECT',
  path: 'api.ipify.org:443',
  headers: { 'Proxy-Authorization': `Basic ${auth}` },
});

req.on('connect', (res, socket) => {
  if (res.statusCode !== 200) {
    console.error('隧道建立失败:', res.statusCode);
    socket.destroy();
    return;
  }

  const tlsSocket = tls.connect({ socket, servername: 'api.ipify.org' }, () => {
    tlsSocket.write('GET / HTTP/1.1\r\nHost: api.ipify.org\r\nConnection: close\r\n\r\n');
  });
  tlsSocket.pipe(process.stdout);
});

req.end();

const API = 'https://api.example.com/api/v1/proxy/extract';

async function fetchProxyPool(apiKey, count = 10) {
  const params = new URLSearchParams({
    apikey: apiKey,
    num: String(count),
    type: 'json',
    country: 'US',
    session: 'sticky',
    time: '10',
  });

  const response = await fetch(`${API}?${params}`);
  if (!response.ok) {
    throw new Error(`提取失败: ${response.status} ${await response.text()}`);
  }
  const { data } = await response.json();
  // 免密端口，不需要凭据
  return data.map((item) => `http://${item.ip}:${item.port}`);
}

const pool = await fetchProxyPool('YOUR_API_KEY', 5);
console.log(pool);