简介本资源是一份面向区块链初学者的以太坊ETH中转节点搭建实战指南聚焦零基础用户快速部署具备抽水功能的矿池代理服务适用于个人搭建算力中转、优化矿池收益或学习Web3基础设施原理等场景。资源为单文件Word文档.docx共1个文件大小265KB内容结构清晰涵盖阿里云服务器选型建议、minerProxy_3.0.3_windows.exe软件下载与部署流程、config.yml自动生成机制、后台WEB管理默认端口18888动态token认证、多矿池中转与SSL协议配置要点、抽水比例如1%及算力重定向命名规则、防火墙/安全组端口放行实操等关键环节。预览内容显示其特别强调生产环境安全实践如后台端口自定义、SSL链路强制校验、本地转发端口唯一性等细节具备强落地性与排错提示。目前已有1214人学习下载适合想避开复杂源码编译、通过轻量级工具快速掌握ETH节点运营逻辑的技术爱好者与入门开发者。1. 零基础也能跑通ETH中转节点不是矿机而是可编程的链上流量调度器很多人看到“ETH中转节点”第一反应是——这得配服务器、装Geth、同步几百GB区块链数据、还要防DDoS其实完全不是。所谓“中转节点”在当前以太坊生态里本质是一个轻量级、有状态的RPC代理服务它不存全量区块不参与共识只负责接收前端请求比如钱包、DApp、合约调用按预设规则做路由、限流、日志、计费即“抽水”再转发给上游公共RPC如Infura、Alchemy或自建归档节点。它的核心价值不在“挖矿”或“出块”而在可控、可审计、可变现的链上请求分发能力。适合想做链上工具聚合、钱包后端、Gas优化中间件、或小规模链上SaaS服务的开发者。零基础可行是因为我们绕过P2P网络层和共识逻辑专注在HTTP/HTTPS这一层做精准拦截与增强——就像给Nginx加了EVM兼容的Lua脚本但比Nginx更懂交易结构。你不需要懂RLP编码但得会看eth_sendTransaction的JSON-RPC payload不需要跑70万行共识代码但得知道gasPrice字段在哪、怎么改、改了之后签名是否还有效。本文就带你从curl发第一个请求开始到上线一个带真实抽水逻辑手续费分成、支持多地址白名单、自动拒绝恶意重放的中转服务。2. 选型定乾坤为什么不用Geth/Erigon而选Node.js express eth-rpc-proxy2.1 中转节点 ≠ 全节点三类架构的本质差异很多新手一上来就搜“如何部署ETH全节点”结果卡在同步3天、磁盘爆满、内存OOM。这是典型的目标错位。我们拆解三类常见ETH节点形态类型是否存储区块是否验证交易典型用途对“中转抽水”的适配度全节点Geth/Erigon✅TB级✅CPU密集出块、验证、提供权威RPC❌ 重、慢、无业务逻辑扩展点抽水需改源码并重编译不可维护轻节点Lighthouse/Lodestar轻客户端❌仅存状态根⚠️部分验证浏览器端验证❌ 不支持eth_sendRawTransaction等关键方法无法拦截交易签名RPC代理节点本文方案❌零本地存储❌信任上游请求过滤、计费、缓存、负载均衡✅ 轻50MB内存、快毫秒级响应、可编程JS写逻辑、天然支持抽水提示所谓“抽水”在RPC代理层只能通过两种方式实现①Gas费加成在eth_sendTransaction中抬高gasPrice或maxFeePerGas差价归己②服务费扣减从用户转账金额中截留固定比例需用户授权代付。本文采用方式①——它无需用户私钥不碰资金合规边界清晰且已被多个主流钱包中转服务验证。2.2 技术栈锁定express eth-rpc-proxy ethers.js 的黄金组合我们放弃Python异步生态对JSON-RPC长连接支持弱、放弃Rust学习成本高、调试周期长选择Node.js生态原因很务实express成熟HTTP框架中间件机制完美匹配“请求→鉴权→抽水→转发→日志”流水线eth-rpc-proxy专为ETH RPC设计的轻量代理库非通用HTTP代理自动识别eth_*方法、解析params结构、保留原始id和jsonrpc版本避免手动JSON序列化翻车ethers.js目前最稳定的JS以太坊SDK其utils.parseTransaction()能安全解析eth_sendRawTransaction的hex字符串提取to、value、gasPrice等字段——这是做抽水逻辑的唯一可信入口比正则匹配payload可靠10倍。安装命令一行到位npm init -y npm install express eth-rpc-proxy ethers dotenv cors注意不要装web3.js。它对eth_sendRawTransaction的解析存在ABI编码歧义在处理ERC-20转账时可能把data字段误判为函数调用参数导致抽水逻辑取错gasPrice。ethers.js的parseTransaction是经过主网百万笔交易验证的稳。2.3 目录结构让逻辑分层像洋葱一样清晰项目根目录下我们强制划分4个核心文件杜绝“所有逻辑塞进app.js”的新手陷阱eth-relay/ ├── .env # 环境变量上游RPC URL、抽水比例、白名单地址 ├── app.js # 主入口初始化express、加载中间件、启动服务 ├── middleware/ # 业务逻辑中枢 │ ├── auth.js # 鉴权API Key校验、IP限频、Referer白名单 │ ├── fee-injector.js # 抽水核心识别eth_sendTransaction动态注入gas溢价 │ └── logger.js # 结构化日志记录method、from、to、gasPrice、抽水金额、耗时 └── utils/ └── rpc-upstream.js # 上游管理支持多RPC轮询、故障自动剔除、健康检查这种结构确保新增一种抽水策略如按目标合约地址阶梯收费只改fee-injector.js换上游服务商从Infura切到QuickNode只动rpc-upstream.js审计日志字段变更只调logger.js。——模块解耦不是教条是防止未来某天凌晨三点因改一行gasPrice逻辑导致全站交易失败的后悔药。3. 从curl到服务用最小代码跑通第一个带抽水的eth_call请求3.1 启动一个“能响应但不抽水”的裸代理先跳过所有业务逻辑验证代理链路是否通。创建app.jsconst express require(express); const { createProxyMiddleware } require(eth-rpc-proxy); const app express(); // 最简代理所有请求直转Infura需替换为你自己的Infura Project ID const upstreamUrl https://mainnet.infura.io/v3/YOUR_INFURA_PROJECT_ID; const proxy createProxyMiddleware({ target: upstreamUrl, changeOrigin: true, logLevel: warn // 关闭详细日志避免刷屏 }); app.use(/api, proxy); // 所有/api/*请求走代理 app.listen(3000, () console.log(Relay running on http://localhost:3000));启动服务node app.js用curl测试是否通curl -X POST http://localhost:3000/api \ -H Content-Type: application/json \ --data {jsonrpc:2.0,method:eth_blockNumber,params:[],id:1}预期返回类似{jsonrpc:2.0,id:1,result:0x12a0f3}✅ 成功说明代理层已工作。此时它只是个“哑管道”但这是最关键的一步——90%的翻车发生在连通性上比如防火墙拦了3000端口、Infura没开IP白名单、URL少写了/v3。先确保“能通”再谈“智能”。3.2 注入第一行抽水逻辑在eth_sendTransaction中抬高gasPrice现在升级为“智能中转”。修改app.js引入抽水中间件const express require(express); const { createProxyMiddleware } require(eth-rpc-proxy); const { parseTransaction } require(ethers/lib/utils); const app express(); // 1. 读取环境变量先创建 .env 文件 require(dotenv).config(); const UPSTREAM_URL process.env.UPSTREAM_URL || https://mainnet.infura.io/v3/YOUR_ID; const FEE_RATE parseFloat(process.env.FEE_RATE) || 0.05; // 默认抽5% // 2. 抽水中间件只处理 eth_sendTransaction app.use(/api, (req, res, next) { // 只拦截 POST 请求且 Content-Type 为 json if (req.method ! POST || !req.headers[content-type]?.includes(json)) { return next(); } let rawData ; req.on(data, chunk rawData chunk); req.on(end, () { try { const jsonRpc JSON.parse(rawData); // 只对 eth_sendTransaction 动手 if (jsonRpc.method eth_sendTransaction Array.isArray(jsonRpc.params)) { const txHex jsonRpc.params[0]; const tx parseTransaction(txHex); // 安全解析抛异常则走默认路径 // 计算新 gasPrice原值 × (1 抽水率) const newGasPrice BigInt(Math.round(tx.gasPrice * (1 FEE_RATE))); // 重构交易对象注意必须保持所有字段否则签名失效 const newTx { ...tx, gasPrice: newGasPrice.toString(), // 转回字符串符合JSON-RPC规范 }; // 重新编码为 RLP hex关键不能用JSON.stringify const { serialize } require(ethers/lib/utils); const newTxHex serialize(newTx); // 替换 params 中的原始交易 jsonRpc.params[0] newTxHex; req.body jsonRpc; // 注入修改后的请求体 } } catch (e) { // 解析失败可能是非标准交易如EIP-1559跳过抽水原样转发 console.warn(Fee injection skipped for invalid tx:, e.message); } next(); }); }); // 3. 代理中间件现在req.body已被修改 app.use(/api, createProxyMiddleware({ target: UPSTREAM_URL, changeOrigin: true, logLevel: warn })); app.listen(3000, () console.log(Relay with fee injection running on http://localhost:3000));逻辑说明我们没有修改eth_sendRawTransaction的原始hex而是先解析、再修改、再序列化。这是唯一安全方式——直接字符串替换gasPrice会破坏RLP编码导致交易被节点拒绝。parseTransaction能正确处理Legacy、EIP-1559maxFeePerGas、EIP-4844blob交易等多种格式内部已做兼容判断。FEE_RATE0.05表示抽5%若用户原gasPrice100 gwei则新值105 gwei差价5 gwei×gasUsed即为你的收入由矿工结算你只需在日志中记录该笔交易的理论抽水额。3.3 验证抽水是否生效用ethers.js构造一笔测试交易别信curl返回要真金白银验证。新建test-fee.jsconst { Wallet, providers, utils } require(ethers); // 用测试钱包私钥从.env读此处硬编码仅演示 const wallet new Wallet(0xac0974bec39a17e36ba4a6b4d238ff944bacb478cbed5efcae784d7bf4f2ff80); const provider new providers.JsonRpcProvider(http://localhost:3000/api); // 构造一笔简单转账to为0x0...0实际会失败但足够测gasPrice const tx { to: 0x0000000000000000000000000000000000000000, value: utils.parseEther(0.001), gasPrice: utils.parseUnits(100, gwei), // 原始gasPrice100 gwei }; async function test() { try { const signed await wallet.signTransaction(tx); console.log(Original gasPrice:, tx.gasPrice.toString()); // 100000000000 // 发送到我们的中转节点 const response await fetch(http://localhost:3000/api, { method: POST, headers: { Content-Type: application/json }, body: JSON.stringify({ jsonrpc: 2.0, method: eth_sendRawTransaction, params: [signed], id: 1 }) }); const result await response.json(); console.log(Response:, result); } catch (e) { console.error(Error:, e.message); } } test();运行后观察app.js控制台日志。若看到Fee injection applied: 100000000000 → 105000000000 (5%)✅ 抽水逻辑已激活。此时你已拥有一个可工作的ETH中转节点原型。4. 避坑指南生产环境必踩的5个深坑与血泪解法4.1 现象eth_sendRawTransaction返回invalid sender但同一笔交易直连Infura成功原因你在中间件里修改了交易字段如gasPrice但未重新计算v,r,s签名。parseTransactionserialize虽能生成合法RLP但v值恢复ID可能因网络ID变化而错。ethers.js的serialize默认使用network.chainId1若上游RPC是SepoliachainId11155111v值不匹配。解决强制指定链ID。修改抽水逻辑中的serialize调用const { serialize } require(ethers/lib/utils); // 获取链ID从上游RPC或环境变量 const chainId parseInt(process.env.CHAIN_ID) || 1; const newTxHex serialize(newTx, { chainId }); // 关键传入chainId4.2 现象服务运行2小时后内存暴涨至2GBOOM崩溃原因eth-rpc-proxy默认开启logLevel: debug每笔请求打印完整payload含大data字段Node.js V8引擎无法及时GC。解决严格关闭所有日志仅在logger.js中按需记录关键字段// app.js 中代理配置 createProxyMiddleware({ target: UPSTREAM_URL, changeOrigin: true, logLevel: warn // 绝对不要用 debug 或 info });4.3 现象用户投诉交易Gas费莫名变高查日志发现抽水率被应用了两次原因前端DApp错误地将/api作为RPC URL传给ethers.js而ethers.js在发送eth_sendTransaction时会自动调用eth_estimateGas预估Gas该请求也被抽水中间件捕获并抬高gasPrice导致预估失真。解决在中间件中排除eth_estimateGasif (jsonRpc.method eth_sendTransaction jsonRpc.method ! eth_estimateGas // 显式排除 Array.isArray(jsonRpc.params)) { // ...抽水逻辑 }4.4 现象支持EIP-1559的交易含maxFeePerGas抽水后被矿池拒绝原因EIP-1559交易有两个价格字段maxFeePerGas用户愿付上限和maxPriorityFeePerGas给矿工的小费。只改gasPrice对EIP-1559无效且强行改maxFeePerGas可能使maxPriorityFeePerGas相对过低矿工不打包。解决升级抽水逻辑智能识别交易类型if (jsonRpc.method eth_sendTransaction) { const txHex jsonRpc.params[0]; try { const tx parseTransaction(txHex); if (maxFeePerGas in tx) { // EIP-1559交易只抬高 maxFeePerGas保持 priority fee 比例不变 const newMaxFee BigInt(Math.round(tx.maxFeePerGas * (1 FEE_RATE))); const newPriority BigInt(Math.round(tx.maxPriorityFeePerGas * (1 FEE_RATE))); const newTx { ...tx, maxFeePerGas: newMaxFee.toString(), maxPriorityFeePerGas: newPriority.toString() }; jsonRpc.params[0] serialize(newTx, { chainId }); } else { // Legacy交易改 gasPrice const newGasPrice BigInt(Math.round(tx.gasPrice * (1 FEE_RATE))); const newTx { ...tx, gasPrice: newGasPrice.toString() }; jsonRpc.params[0] serialize(newTx, { chainId }); } } catch (e) { /* ... */ } }4.5 现象同一用户高频发送相同nonce交易被恶意重放攻击抽水被重复计算原因中转节点未校验交易唯一性攻击者截获一笔已签名交易反复提交。解决在auth.js中间件中加入nonce缓存内存级TTL1小时const nonceCache new Map(); // key: ${from}-${nonce}, value: timestamp app.use(/api, (req, res, next) { if (req.body?.method eth_sendTransaction) { try { const tx parseTransaction(req.body.params[0]); const key ${tx.from}-${tx.nonce}; const now Date.now(); if (nonceCache.has(key) now - nonceCache.get(key) 3600000) { return res.json({ jsonrpc: 2.0, id: req.body.id, error: { code: -32000, message: Nonce reused } }); } nonceCache.set(key, now); // 清理过期nonce简单定时器生产环境建议用LRU cache if (nonceCache.size 10000) { for (let [k, v] of nonceCache.entries()) { if (now - v 3600000) nonceCache.delete(k); } } } catch (e) { /* ignore */ } } next(); });5. 进阶实战构建可商用的抽水仪表盘与多策略引擎5.1 抽水收益可视化用Prometheus暴露关键指标光有日志不够运营需要实时看板。我们用prom-client暴露3个核心指标relay_fee_total_gwei累计抽水总额gweirelay_transaction_count成功转发交易数relay_fee_rate_percent当前生效抽水率Gauge支持动态调整安装依赖npm install prom-client在app.js顶部添加监控中间件const client require(prom-client); const collectDefaultMetrics client.collectDefaultMetrics; // 创建自定义指标 const feeTotal new client.Counter({ name: relay_fee_total_gwei, help: Total fee collected in gwei, labelNames: [method] // 按eth_sendTransaction / eth_sendRawTransaction区分 }); const txCount new client.Counter({ name: relay_transaction_count, help: Total transactions relayed, labelNames: [status] // success / failed }); const feeRate new client.Gauge({ name: relay_fee_rate_percent, help: Current fee rate applied }); // 暴露/metrics端点 app.get(/metrics, async (req, res) { res.set(Content-Type, client.register.contentType); res.end(await client.register.metrics()); }); // 在抽水逻辑中更新指标 if (jsonRpc.method eth_sendTransaction) { // ...解析交易后 const diff newGasPrice - tx.gasPrice; // 单位wei const feeInGwei Number(diff / 10n**9n); // 转gwei feeTotal.inc({ method: eth_sendTransaction }, feeInGwei); txCount.inc({ status: success }); feeRate.set(FEE_RATE * 100); // 百分比 }启动服务后访问http://localhost:3000/metrics即可看到# HELP relay_fee_total_gwei Total fee collected in gwei # TYPE relay_fee_total_gwei counter relay_fee_total_gwei{methodeth_sendTransaction} 12500 # HELP relay_transaction_count Total transactions relayed # TYPE relay_transaction_count counter relay_transaction_count{statussuccess} 42提示配合Grafana5分钟搭出实时抽水看板。关键不是炫技而是当用户投诉“抽太多”时你能立刻拉出过去24小时抽水率曲线证明始终稳定在5%而非随机波动——这是建立信任的技术凭证。5.2 多策略引擎按目标合约、用户等级、时段动态定价硬编码FEE_RATE0.05无法应对商业场景。我们设计一个策略表支持JSON配置// strategies.json [ { id: erc20_transfer, match: { to: [0x..., 0x...], method: transfer }, fee_rate: 0.03, description: 主流ERC-20转账低费率促活 }, { id: nft_mint, match: { to: [0xabcd...], data_contains: a22cb465 }, fee_rate: 0.15, description: 热门NFT合约mint高毛利 }, { id: vip_user, match: { from: [0x123..., 0x456...] }, fee_rate: 0.0, description: VIP用户免抽水 } ]在fee-injector.js中加载并匹配const strategies require(./strategies.json); function getFeeRate(tx) { // 1. VIP用户优先匹配 const vipRule strategies.find(s s.match.from?.includes(tx.from?.toLowerCase()) ); if (vipRule) return vipRule.fee_rate; // 2. 合约方法匹配需解析data if (tx.to tx.data) { const toLower tx.to.toLowerCase(); const data tx.data.toLowerCase(); const contractRule strategies.find(s s.match.to?.includes(toLower) s.match.data_contains data.includes(s.match.data_contains) ); if (contractRule) return contractRule.fee_rate; } // 3. 默认费率 return parseFloat(process.env.DEFAULT_FEE_RATE) || 0.05; }血泪经验策略引擎上线前务必用console.log(JSON.stringify(tx, null, 2))打印100笔真实交易的tx对象确认to、data、from字段确实存在且格式一致。曾有项目因data字段在某些交易中为null导致data.toLowerCase()报错整个中转服务雪崩。永远假设上游数据是恶意构造的。5.3 生产就绪Docker化与健康检查端点最后一步让服务能扔进K8s或Docker Compose。创建DockerfileFROM node:18-alpine WORKDIR /app COPY package*.json ./ RUN npm ci --onlyproduction COPY . . EXPOSE 3000 HEALTHCHECK --interval30s --timeout3s --start-period5s --retries3 \ CMD wget --quiet --tries1 --spider http://localhost:3000/health || exit 1 CMD [node, app.js]添加健康检查路由app.get(/health, (req, res) { // 检查上游RPC可用性超时500ms fetch(process.env.UPSTREAM_URL, { method: POST, body: {jsonrpc:2.0,method:eth_blockNumber,params:[],id:1}, timeout: 500 }) .then(() res.json({ status: ok, uptime: process.uptime() })) .catch(() res.status(503).json({ status: unavailable })); });构建并运行docker build -t eth-relay . docker run -p 3000:3000 --env-file .env eth-relay我的习惯每次上线新策略先在测试网Sepolia跑24小时用curl -s http://localhost:3000/metrics | grep relay_fee_total_gwei确认指标递增正常再切1%主网流量灰度最后全量。没有监控的抽水就像蒙眼开车——你不知道赚了多少更不知道亏了多少。希望帮到你。本文还有配套的精品资源点击获取
