简介网络协议是计算机通信的基石它定义了数据交换的格式和规则。在Web开发中WebSocket协议因其全双工、低延迟的特性被广泛应用于实时通信场景如在线游戏、即时通讯和自动化工具。理解WebSocket的工作原理包括握手、数据帧和心跳机制是构建稳定实时应用的关键。其技术价值在于能够实现服务器与客户端之间的持久连接和高效双向数据流从而支撑复杂的交互逻辑。在游戏自动化、数据监控和物联网等应用场景中通过逆向工程分析私有协议并结合Node.js的异步非阻塞I/O模型开发者可以构建出高效、稳定的自动化客户端。本文以经典农场游戏为例详细探讨了如何通过抓包分析、协议编解码和任务调度实现一个完整的自动化管理工具涵盖了从网络抓包、二进制协议解析到工程化部署的全过程。1. 项目概述与核心价值最近在整理一些老项目翻到了这个几年前写的“QQ经典农场”自动化脚本。这个项目本质上是一个基于Node.js技术栈通过逆向分析WebSocket通信协议实现对QQ和微信双平台小程序环境下的经典农场游戏进行全自动管理的工具。简单来说就是写了个“机器人”帮你自动完成农场里的播种、浇水、除草、杀虫、收获、偷菜等一系列操作实现24小时不间断的“云挂机”。这个项目诞生的背景是当时这类休闲小游戏在社交平台上重新焕发活力但重复性的操作非常消耗时间和精力。手动操作不仅效率低下还容易错过最佳时机比如作物成熟被好友偷走。因此一个能够精准模拟用户操作、稳定运行的自动化脚本就成了很多玩家的“刚需”。它解决的不仅仅是“懒”的问题更是在游戏规则内通过技术手段实现资源管理效率的最大化。这个项目适合以下几类朋友参考一是对Node.js后端及网络协议感兴趣想通过一个有趣的实际案例来深入学习WebSocket和协议逆向的开发者二是对小程序自动化、游戏辅助脚本开发有需求希望了解完整实现路径的技术爱好者三是单纯怀念经典农场想用技术手段“重温旧梦”的极客玩家。整个实现过程涉及网络抓包、协议分析、数据模拟、定时任务调度等多个环节是一个综合性很强的练手项目。2. 技术选型与整体架构设计2.1 为什么选择Node.js作为技术栈在开始动手之前技术栈的选择是首要问题。当时主要考虑了以下几个因素最终敲定了Node.js。第一异步非阻塞I/O模型与事件驱动。农场自动化脚本的核心是处理大量的网络I/O操作如频繁的WebSocket消息收发、HTTP请求和定时任务。Node.js的异步特性非常适合这种高并发、低计算密集型的场景能够用较少的系统资源维持大量并发的网络连接和定时器这对于需要同时管理多个农场账号或者快速响应游戏事件如成熟通知至关重要。第二丰富的生态系统。npm仓库里有海量的模块可供使用。对于这个项目我们至少需要几个关键模块用于建立WebSocket连接的ws或socket.io-client用于HTTP请求的axios或node-fetch用于解析和构建二进制协议的protobufjs如果游戏协议是Protobuf格式或bytebuffer用于定时任务调度的node-schedule或cron用于配置管理的dotenv等。这些模块成熟稳定能极大降低开发成本。第三开发效率与上手难度。JavaScript语言本身比较灵活对于快速原型开发非常友好。而且整个脚本的逻辑主要是顺序和事件回调用Node.js写起来结构清晰。如果选择Python虽然也有丰富的库如aiohttp, websockets但在处理某些特定场景如复杂的回调地狱管理时我个人觉得Node.js的Promise/async-await模式更直观一些。2.2 核心架构拆解从协议到执行整个脚本的架构可以自上而下分为四层协议通信层、业务逻辑层、任务调度层和配置管理层。协议通信层是整个项目的基石也是最复杂的部分。它的职责是与游戏服务器建立并维持WebSocket连接按照游戏定义的协议格式正确地序列化打包请求数据和反序列化解包响应数据。这一层需要完全通过逆向工程来构建。业务逻辑层建立在稳定的通信层之上。它根据游戏的具体玩法定义了一系列原子操作例如login()登录、getFarmlandInfo()获取田地信息、plant(seedId, plotIndex)在指定地块播种、harvest(plotIndex)收获指定地块等。每个原子操作都对应一个或多个特定的协议请求/响应处理。任务调度层是脚本的“大脑”。它根据配置的策略例如检测作物状态、定时巡逻好友农场调用业务逻辑层提供的原子操作组合成完整的自动化流程。这里需要精心设计状态机和决策逻辑避免无效操作比如给已经浇过水的地块再次浇水和违反游戏规则操作过于频繁导致被检测。配置管理层则负责管理脚本运行所需的所有可变参数如账号凭证、服务器地址、操作间隔、好友列表等。通常使用JSON配置文件或环境变量来管理实现脚本行为的外部可配置化。这个分层架构的好处是职责清晰、耦合度低。当游戏协议更新时我们通常只需要修改协议通信层当想改变挂机策略时只需调整任务调度层和配置其他部分无需变动。3. 深度逆向WebSocket协议与数据包分析3.1 抓包环境搭建与工具选择逆向的第一步是捕获游戏客户端与服务器之间的真实网络通信数据。由于目标是QQ/微信小程序我们需要在移动端或模拟器上进行抓包。移动端抓包以Android为例Root手机或使用模拟器推荐使用Android模拟器如夜神、MuMu方便安装证书和调试。安装抓包工具最常用的是Fiddler或Charles。它们作为中间人代理可以截获并解密HTTPS流量对WebSocket同样有效。配置代理与安装证书在模拟器或手机的网络设置中配置代理服务器地址为运行Fiddler/Charles的电脑IP和端口默认8888。然后访问http://电脑IP:端口下载并安装抓包工具的根证书到手机“受信任的凭据”中。这一步至关重要否则无法解密HTTPS/WebSocket流量。启动游戏并抓包配置完成后启动QQ/微信进入经典农场小程序。此时Fiddler/Charles的会话列表中应该会出现大量来自腾讯域名的请求。注意微信/QQ对小程序的网络请求有严格管控部分请求可能使用更底层的TCP或私有协议不一定能全部被常规HTTP代理捕获。如果关键的游戏通信抓不到可能需要尝试更底层的抓包工具如Wireshark需要处理更复杂的数据或者寻找小程序端的调试方法如开启vConsole但通常需要特定版本或手段。工具选择心得Fiddler的AutoResponder和FiddlerScript功能非常强大可以方便地修改请求和响应进行测试。Charles的界面和映射功能也很优秀。我个人更习惯用Fiddler因为其脚本定制性更强可以快速写一些脚本过滤出目标WebSocket流量。3.2 WebSocket连接建立与消息格式解析成功抓包后我们需要在纷繁的HTTP请求中找到建立WebSocket连接的那个“握手”请求。通常它会是一个HTTP GET请求请求头包含Upgrade: websocket和Connection: Upgrade并且会有一个Sec-WebSocket-Key。服务器返回101 Switching Protocols响应后连接就升级为WebSocket全双工通道了。找到连接后重点分析后续的WebSocket数据帧Data Frames。这里大概率会遇到两种情况明文JSON/文本协议这是最理想的情况。WebSocket传输的就是纯文本的JSON字符串。你可以在Fiddler的WebSocket标签页直接看到可读的{cmd: heartbeat, data: {...}}这样的消息。这种情况下逆向工作就简化为了分析JSON的结构和字段含义。二进制协议更多情况下为了效率和防破解游戏会使用自定义的二进制协议。你在抓包工具里看到的就是一堆十六进制码流。这正是标题中提到的“深度逆向分析”和可能用到Protocol BuffersProtobuf这类工具的场景。如何判断是否是Protobuf观察数据包特征Protobuf编码的二进制数据没有固定的消息头如长度字段但通常游戏会在前面加一个简短的包头如2字节的cmdId和2字节的长度。尝试反推如果服务器地址的路径或域名中包含pb、proto等字样可能性增大。技术猜测腾讯系游戏使用Protobuf作为数据交换格式非常普遍。分析二进制协议的一般步骤 a.定位消息边界首先需要找出每个完整消息从哪里开始到哪里结束。通常协议格式是[消息头][消息体]。消息头里一般包含命令字cmdId/opCode和消息体长度length。通过对比多个不同操作如登录、播种的数据包找出固定位置、变化有规律的字节很可能就是cmdId和length。 b.关联命令与操作记录下执行“登录”、“查看田地”、“播种”等操作时发送和接收的数据包。对比它们的cmdId建立操作与命令字的映射表。 c.解析消息体这是最耗时的部分。你需要对消息体的二进制数据进行逐字段分析。如果怀疑是Protobuf可以尝试以下方法 - 搜索.proto文件在小程序的客户端代码包wxapkg解包后的文件中有时会遗留定义协议的.proto文件。 - 动态调试通过修改小程序代码或使用Xposed等框架hook网络库的序列化/反序列化函数直接打印出结构化的数据。 - 盲解如果没有.proto文件就需要根据数据变化规律手动推测字段类型和含义。例如重复出现的固定长度字节串可能是字符串紧随其后的变长数据可能是它的长度4字节整数可能代表物品ID、数量、时间戳等。这是一个需要耐心和经验的“拼图”过程。3.3 心跳机制与断线重连策略为了保持WebSocket连接活跃游戏客户端会定期向服务器发送“心跳”包。心跳包通常是一个固定的、简单的命令如cmdId1消息体为空或包含一个时间戳。服务器会回应一个心跳响应表明连接正常。在自动化脚本中实现稳健的心跳机制和断线重连是保证长期稳定运行的关键。心跳实现在Node.js中使用setInterval定时发送心跳包。间隔时间需要根据抓包分析确定通常是30秒到几分钟。发送心跳后需要设置一个超时计时器如果在规定时间内如10秒没有收到心跳响应则判定为连接异常触发重连。断线重连策略监听连接事件WebSocket客户端库如ws会提供on(‘close’)、on(‘error’)事件。指数退避重连当连接断开时不要立即尝试重连而是等待一个短暂的时间如1秒如果失败则等待时间加倍2秒、4秒、8秒…直到达到一个最大等待时间如64秒。这可以避免在服务器临时故障时疯狂重连加重服务器负担。重连次数限制设定一个最大重连次数如10次超过后停止脚本并报警如发送邮件或通知。状态恢复重连成功后通常需要重新执行登录流程恢复之前的游戏状态如重新获取田地信息。// 伪代码示例简单的带指数退避的重连逻辑 class GameClient { constructor() { this.reconnectAttempts 0; this.maxReconnectAttempts 10; this.reconnectDelay 1000; // 初始延迟1秒 this.maxReconnectDelay 64000; // 最大延迟64秒 } connect() { this.ws new WebSocket(‘ws://game-server.com‘); this.ws.on(‘open’, () this.onConnected()); this.ws.on(‘close’, () this.scheduleReconnect()); this.ws.on(‘error’, (err) { console.error(‘WebSocket error:‘, err); this.scheduleReconnect(); }); } scheduleReconnect() { if (this.reconnectAttempts this.maxReconnectAttempts) { console.error(‘Max reconnection attempts reached. Exiting.‘); process.exit(1); } const delay Math.min(this.reconnectDelay * Math.pow(2, this.reconnectAttempts), this.maxReconnectDelay); console.log(Scheduling reconnect in ${delay}ms (attempt ${this.reconnectAttempts 1})); setTimeout(() { this.reconnectAttempts; this.connect(); }, delay); } onConnected() { console.log(‘Connected to game server.‘); this.reconnectAttempts 0; // 重置重连计数 this.reconnectDelay 1000; // 重置延迟 // 执行登录等初始化操作 this.login(); } }4. 协议层的具体实现编解码与通信模块4.1 构建协议编解码器在分析清楚协议格式后我们需要在Node.js中实现对应的编解码器Encoder/Decoder。如果协议是自定义二进制格式我们需要手动处理字节序通常是小端序。假设我们分析出的协议头格式为uint16 cmdIduint16 bodyLength后面紧跟消息体。// protocolEncoder.js const ByteBuffer require(‘bytebuffer‘); class ProtocolEncoder { static encode(cmdId, bodyData) { // bodyData 是一个已经序列化好的Buffer例如Protobuf编码后的Buffer const bodyLength bodyData.length; const header Buffer.alloc(4); // 2字节cmdId 2字节length header.writeUInt16LE(cmdId, 0); header.writeUInt16LE(bodyLength, 2); // 将消息头和消息体拼接起来 return Buffer.concat([header, bodyData]); } } class ProtocolDecoder { constructor() { this.buffer Buffer.alloc(0); } // 接收原始的Socket数据流可能包含多个消息或不完整消息 feed(data) { this.buffer Buffer.concat([this.buffer, data]); return this._parseMessages(); } _parseMessages() { const messages []; while (this.buffer.length 4) { // 至少有一个完整的消息头 const cmdId this.buffer.readUInt16LE(0); const bodyLength this.buffer.readUInt16LE(2); const totalLength 4 bodyLength; if (this.buffer.length totalLength) { // 数据包不完整等待下次feed break; } // 提取一个完整的消息 const messageBody this.buffer.slice(4, totalLength); messages.push({ cmdId, body: messageBody }); // 从缓冲区中移除已处理的消息 this.buffer this.buffer.slice(totalLength); } return messages; } }如果消息体是Protobuf格式我们还需要引入protobufjs库来加载.proto文件定义并生成对应的编解码方法。// 假设我们有 compiled_protos.js 文件由 protobufjs 从 .proto 文件编译而来 const protos require(‘./compiled_protos‘); const LoginReq protos.lookup(‘game.LoginRequest‘); const LoginResp protos.lookup(‘game.LoginResponse‘); // 编码请求 const loginReq LoginReq.create({ userId: ‘123‘, token: ‘abc‘ }); const bodyData LoginReq.encode(loginReq).finish(); // 返回Buffer const packet ProtocolEncoder.encode(1001, bodyData); // 假设1001是登录cmdId // 解码响应 function handlePacket({ cmdId, body }) { if (cmdId 1002) { // 假设1002是登录响应cmdId const loginResp LoginResp.decode(body); console.log(‘Login result:‘, loginResp.result); } }4.2 封装稳定的WebSocket客户端有了编解码器我们就可以封装一个健壮的WebSocket客户端类。这个类负责连接管理、数据收发、心跳维持和消息路由。// gameClient.js const WebSocket require(‘ws‘); const EventEmitter require(‘events‘); const ProtocolDecoder require(‘./protocolDecoder‘); class GameClient extends EventEmitter { constructor(url) { super(); this.url url; this.ws null; this.decoder new ProtocolDecoder(); this.heartbeatInterval null; this.isConnected false; this.pendingRequests new Map(); // 用于处理请求-响应回调 this.seq 0; // 请求序列号用于匹配请求和响应 } async connect() { return new Promise((resolve, reject) { this.ws new WebSocket(this.url); this.ws.on(‘open‘, () { this.isConnected true; this.emit(‘connected‘); this._startHeartbeat(); resolve(); }); this.ws.on(‘message‘, (data) { // data 可能是Buffer或ArrayBuffer const buffer Buffer.from(data); const messages this.decoder.feed(buffer); messages.forEach(msg this._handleMessage(msg)); }); this.ws.on(‘close‘, () { this.isConnected false; this._stopHeartbeat(); this.emit(‘disconnected‘); // 清理所有pending的请求通知超时 for (const [seq, { reject }] of this.pendingRequests) { reject(new Error(‘Connection closed while waiting for response‘)); } this.pendingRequests.clear(); }); this.ws.on(‘error‘, (err) { this.emit(‘error‘, err); reject(err); }); }); } sendRequest(cmdId, requestBody, timeout 5000) { if (!this.isConnected) { return Promise.reject(new Error(‘Not connected‘)); } const seq this.seq; const packet ProtocolEncoder.encode(cmdId, requestBody); // 在实际协议中可能需要在requestBody里带上seq字段服务器响应时原样返回 return new Promise((resolve, reject) { const timer setTimeout(() { this.pendingRequests.delete(seq); reject(new Error(Request timeout for cmdId: ${cmdId})); }, timeout); this.pendingRequests.set(seq, { resolve, reject, timer }); this.ws.send(packet, (err) { if (err) { clearTimeout(timer); this.pendingRequests.delete(seq); reject(err); } }); }); } _handleMessage({ cmdId, body }) { // 首先检查是否是某个请求的响应 // 这里假设响应消息体里包含请求的seq我们需要解析body找到它 // const respSeq ... 从body中解析出seq // if (this.pendingRequests.has(respSeq)) { ... } // 如果不是请求-响应模式而是服务器主动推送如好友来偷菜通知 this.emit(‘message‘, cmdId, body); } _startHeartbeat() { this.heartbeatInterval setInterval(() { if (this.isConnected) { const heartbeatPacket ProtocolEncoder.encode(1, Buffer.alloc(0)); // cmdId1 心跳 this.ws.send(heartbeatPacket); } }, 30000); // 30秒一次 } _stopHeartbeat() { if (this.heartbeatInterval) { clearInterval(this.heartbeatInterval); this.heartbeatInterval null; } } disconnect() { if (this.ws) { this.ws.close(); } } }这个客户端类提供了基于Promise的请求发送接口并内置了超时处理使得上层的业务逻辑调用起来非常清晰。服务器推送的消息则通过事件发射器emit传递出去由上层监听并处理。5. 业务逻辑与自动化策略实现5.1 原子操作封装在稳定的通信客户端基础上我们可以封装具体的游戏操作。每个操作对应一个或多个协议请求。// gameApi.js class GameApi { constructor(client) { this.client client; } async login(userId, token) { const req LoginRequest.encode({ userId, token }).finish(); const respBuffer await this.client.sendRequest(CMD_ID.LOGIN, req); const resp LoginResponse.decode(respBuffer); if (resp.code ! 0) { throw new Error(Login failed: ${resp.message}); } this.sessionId resp.sessionId; return resp; } async getFarmlandInfo() { const req GetFarmlandInfoRequest.encode({}).finish(); const respBuffer await this.client.sendRequest(CMD_ID.GET_FARMLAND_INFO, req); return GetFarmlandInfoResponse.decode(respBuffer); } async plant(plotIndex, seedId) { const req PlantRequest.encode({ plotIndex, seedId }).finish(); const respBuffer await this.client.sendRequest(CMD_ID.PLANT, req); return PlantResponse.decode(respBuffer); } async harvest(plotIndex) { const req HarvestRequest.encode({ plotIndex }).finish(); const respBuffer await this.client.sendRequest(CMD_ID.HARVEST, req); return HarvestResponse.decode(respBuffer); } async getFriendList() { // ... 获取好友列表 } async visitFriend(friendId) { // ... 访问好友农场 } async steal(friendId, plotIndex) { // ... 偷取好友作物 } }5.2 核心自动化循环与状态管理脚本的核心是一个无限循环定期检查自己农场和好友农场的状态并执行相应的操作。这里的关键是状态管理和决策逻辑。状态管理我们需要在内存中维护一份自己农场的当前状态地块信息、作物生长阶段、仓库物品等。这些状态通过getFarmlandInfo等接口获取并在每次操作后更新。避免每次决策都去请求服务器减少不必要的网络交互。决策逻辑这是一个简单的规则引擎。自我农场维护遍历所有地块。如果地块为空且仓库有种子则执行播种选择成熟时间合适的种子。如果地块有作物检查状态status。如果是“干旱”则浇水如果是“长草”则除草如果是“生虫”则杀虫。这些状态通常由服务器推送或定期拉取获得。如果作物状态为“已成熟”则立即收获。计算作物预计成熟时间设置定时器在成熟前几分钟开始轮询准备收获防止被偷。好友农场巡逻定期如每10分钟拉取一次好友列表。遍历好友访问其农场获取其地块信息。判断哪些地块的作物已成熟且可偷通常有保护期或次数限制。执行偷取操作。记录已偷过的好友避免短时间内重复访问。// automationEngine.js const schedule require(‘node-schedule‘); class AutomationEngine { constructor(api) { this.api api; this.myFarmland null; this.lastHarvestCheck 0; } async start() { // 1. 登录并初始化状态 await this.api.login(config.userId, config.token); await this.refreshMyFarmland(); // 2. 启动定时任务 // 每30秒检查一次自己农场状态 schedule.scheduleJob(‘*/30 * * * * *‘, () this.checkAndMaintainMyFarm()); // 每5分钟巡逻一次好友农场 schedule.scheduleJob(‘*/5 * * * *‘, () this.patrolFriendFarms()); // 每小时刷新一次完整农场信息同步状态 schedule.scheduleJob(‘0 * * * *‘, () this.refreshMyFarmland()); console.log(‘自动化农场助手已启动。‘); } async refreshMyFarmland() { try { this.myFarmland await this.api.getFarmlandInfo(); console.log(‘农场状态已刷新。‘); } catch (err) { console.error(‘刷新农场状态失败:‘, err.message); } } async checkAndMaintainMyFarm() { if (!this.myFarmland) return; for (const plot of this.myFarmland.plots) { if (plot.isEmpty this.hasSeedInStorage()) { // 播种逻辑 const seedId this.selectBestSeed(); await this.api.plant(plot.index, seedId); plot.isEmpty false; plot.crop { seedId, matureTime: Date.now() seed.growTime * 1000 }; } else if (plot.crop) { if (plot.crop.status ‘dry‘) { await this.api.water(plot.index); plot.crop.status ‘normal‘; } else if (plot.crop.status ‘weed‘) { await this.api.clearWeed(plot.index); plot.crop.status ‘normal‘; } else if (plot.crop.status ‘pest‘) { await this.api.killPest(plot.index); plot.crop.status ‘normal‘; } else if (plot.crop.status ‘mature‘) { await this.api.harvest(plot.index); plot.isEmpty true; plot.crop null; } // 检查是否接近成熟设置精确收获定时器这里简化处理 if (plot.crop plot.crop.matureTime - Date.now() 60000) { // 1分钟内成熟开始高频检查 this.setPreciseHarvestTimer(plot); } } } } async patrolFriendFarms() { try { const friends await this.api.getFriendList(); for (const friend of friends) { if (this.hasVisitedRecently(friend.id)) continue; // 防频繁访问 const friendFarm await this.api.visitFriend(friend.id); const stealablePlots friendFarm.plots.filter(p p.isMature p.isStealable); for (const plot of stealablePlots) { await this.api.steal(friend.id, plot.index); console.log(成功偷取好友 ${friend.name} 地块 ${plot.index} 的作物); await this.sleep(1000); // 偷取间隔避免操作过快 } this.recordVisit(friend.id); } } catch (err) { console.error(‘巡逻好友农场失败:‘, err.message); } } sleep(ms) { return new Promise(resolve setTimeout(resolve, ms)); } }5.3 双平台QQ/微信适配策略虽然都是小程序但QQ和微信的平台环境、登录凭证获取方式、甚至部分API接口可能存在细微差异。我们的脚本需要具备一定的平台适配能力。配置区分在配置文件中明确指定平台platform: ‘qq‘或‘wechat‘。登录凭证这是最大的不同。微信小程序的登录需要code换取session_key和openid而QQ小程序也有类似的流程。脚本不可能模拟完整的OAuth流程。因此最实际的方法是“半自动”获取。我们可以写一个简单的网页或使用其他工具让用户手动登录一次小程序然后通过抓包或小程序调试工具如vConsole获取到关键的登录态Token或Cookie将其填入脚本的配置文件中。这个Token通常有一定有效期需要定期更新。API端点差异游戏服务器的域名或路径可能在两个平台下不同。这可以通过配置不同的serverUrl来解决。协议层统一只要游戏核心逻辑一致通信协议大概率是相同的。因此协议编解码器和WebSocket客户端可以复用。主要差异在于建立连接前的“握手”请求可能携带的平台特定参数和登录请求的字段。在脚本初始化时根据平台选择不同的配置和预处理步骤即可。// config.js module.exports { platform: process.env.PLATFORM || ‘wechat‘, // ‘qq‘ or ‘wechat‘ wechat: { serverUrl: ‘wss://game.wechat.qq.com/ws‘, loginToken: ‘xxx‘ // 从微信小程序获取的token }, qq: { serverUrl: ‘wss://game.qq.com/ws‘, loginToken: ‘yyy‘ // 从QQ小程序获取的token }, // 通用配置 checkInterval: 30000, patrolInterval: 300000 }; // main.js const config require(‘./config‘); const platformConfig config[config.platform]; const client new GameClient(platformConfig.serverUrl); const api new GameApi(client); api.setLoginCredentials(platformConfig.loginToken);6. 工程化提升配置、日志与错误处理一个能长期稳定运行的脚本离不开良好的工程化实践。6.1 配置文件管理使用config.js或config.json来集中管理所有配置项并使用dotenv从.env文件加载敏感信息如Token避免将密码硬编码在代码中。// .env WECHAT_LOGIN_TOKENyour_super_secret_token_here QQ_LOGIN_TOKENyour_qq_token_here // config.js require(‘dotenv‘).config(); module.exports { platform: ‘wechat‘, wechat: { serverUrl: ‘wss://game.wechat.qq.com/ws‘, loginToken: process.env.WECHAT_LOGIN_TOKEN }, qq: { serverUrl: ‘wss://game.qq.com/ws‘, loginToken: process.env.QQ_LOGIN_TOKEN }, // 日志配置 logLevel: ‘info‘, logFile: ‘./logs/farmbot.log‘ };6.2 日志记录使用winston或log4js等日志库替代简单的console.log。可以配置不同级别error, warn, info, debug的日志并输出到文件和控制台方便后期排查问题。// logger.js const winston require(‘winston‘); const config require(‘./config‘); const logger winston.createLogger({ level: config.logLevel, format: winston.format.combine( winston.format.timestamp(), winston.format.printf(({ timestamp, level, message }) { return ${timestamp} [${level.toUpperCase()}]: ${message}; }) ), transports: [ new winston.transports.File({ filename: config.logFile }), new winston.transports.Console() ] }); module.exports logger; // 在业务代码中使用 logger.info(‘自动化脚本启动‘); logger.error(登录失败: ${err.message}, { err });6.3 全局错误处理与进程守护脚本运行在服务器或树莓派上需要保证7x24小时稳定。未捕获的异常可能导致进程退出。全局异常捕获process.on(‘uncaughtException‘, (err) { logger.error(‘未捕获的异常进程即将退出:‘, err); // 可以在这里进行一些清理工作如断开WebSocket连接 if (client) { client.disconnect(); } // 根据错误类型决定是否退出或者尝试重启自身逻辑 setTimeout(() process.exit(1), 1000); }); process.on(‘unhandledRejection‘, (reason, promise) { logger.error(‘未处理的Promise拒绝:‘, reason); // 记录日志但不一定立即退出 });进程守护在生产环境可以使用pm2或forever等进程管理工具来守护脚本。当脚本意外退出时它们会自动重启。npm install -g pm2 pm2 start bot.js --name “farm-bot“ --log ./logs/pm2.log pm2 save pm2 startup # 设置开机自启7. 常见问题、排查技巧与安全考量7.1 常见问题速查表在开发和运行过程中你几乎一定会遇到下面这些问题。问题现象可能原因排查步骤与解决方案连接失败无法建立WebSocket1. 服务器地址错误或变更。2. 网络问题代理、防火墙。3. 需要特定的HTTP头如Origin, User-Agent。1. 重新抓包确认最新的WebSocket URL。2. 检查网络连通性telnet host port。3. 在创建WebSocket时在options中添加上抓包看到的请求头。连接建立后立即被服务器断开1. 缺少必要的握手参数如token未在连接时携带。2. 客户端标识如User-Agent被服务器风控识别。1. 分析建立连接后的第一个数据包看是否需要在连接后立即发送一个认证包。2. 模拟官方客户端的User-Agent等头部信息。发送请求后收不到响应1. 协议格式错误cmdId或长度不对。2. 消息序列号seq未正确匹配。3. 请求频率过高被限制。1. 用抓包工具对比自己发送的数据包和官方客户端发送的包逐字节核对。2. 检查请求-响应匹配逻辑确认seq字段的解析和设置正确。3. 在请求间增加随机延迟如sleep(1000 Math.random()*2000)。收到响应但数据解析失败1. Protobuf.proto文件定义与服务器不一致。2. 字节序大端/小端弄错。3. 存在压缩如gzip。1. 尝试更新或寻找更准确的.proto文件。2. 尝试切换readUInt16LE和readUInt16BE。3. 检查响应头是否有Content-Encoding: gzip如有需先解压。运行一段时间后掉线1. 心跳机制未正常工作或间隔不对。2. Token过期。3. 服务器主动踢人检测到异常行为。1. 确认心跳包被定期发送且收到响应。2. Token有效期通常几小时到几天需要实现Token刷新逻辑或手动更新配置。3. 降低操作频率模拟真人操作节奏随机延迟、夜间休眠。操作失败返回“系统繁忙”或“操作频繁”触发了服务器的频率限制或行为检测。1.大幅增加操作间隔这是最有效的办法。将固定间隔改为随机间隔例如在30-90秒之间随机。2. 模拟人工操作的不规律性例如在浇水、除草后随机等待一段时间再执行下一个操作。3. 避免在深夜等完全无人的时段仍保持高频率操作。7.2 安全与风控规避心得这是自动化脚本能否长期存活的关键。游戏运营商肯定有反自动化机制。行为模拟不要以固定的、机器般的精确间隔执行操作。加入随机延迟和抖动。模拟人类的“思考时间”和“操作误差”。操作链随机化不要总是按固定顺序如从1号地到18号地进行操作。可以随机打乱地块处理顺序。规避峰值时间在凌晨3-6点这种真人几乎不可能活跃的时间段可以降低操作频率甚至暂停脚本。设备指纹虽然是小程序但服务器可能仍然会收集一些客户端环境信息。如果你的脚本运行在固定的服务器IP上行为特征过于明显。可以考虑使用住宅代理IP池来轮换IP但这成本较高且复杂。对于个人挂机保持低调、慢速是更可行的策略。接受“不完美”不要追求100%的收获和偷取。允许脚本“错过”一些操作或者因为随机延迟导致被好友先偷走。追求极致效率反而更容易暴露。7.3 调试技巧数据包存盘与回放在抓包工具中可以将关键的WebSocket会话包括握手和后续消息保存为.saz(Fiddler) 或.chls(Charles) 文件。在编写编解码器时可以写一个单元测试读取这些保存的数据包模拟服务器响应来验证你的解析逻辑是否正确而无需每次都启动真实游戏。Hex编辑器分析二进制协议时一个能高亮显示不同数据类型的Hex编辑器如010 Editor或WinHex非常有用可以帮你直观地猜测字段边界。差分分析对比执行“播种A种子”和“播种B种子”两个操作发出的数据包只有少数几个字节不同这些字节很可能就是种子ID字段。这是逆向中定位关键字段的常用方法。这个项目从技术上看是一个涵盖了网络协议分析、数据编解码、异步编程、状态机设计和基础反反爬策略的综合性实践。它有趣的地方在于目标明确玩游戏但技术栈却相当“硬核”。最终当看到脚本自动帮你收完一波菜并成功从好友那里“偷”到几个果实的时候那种成就感是单纯写业务代码难以比拟的。不过切记技术学习为主享受过程并尊重游戏规则和他人体验。本文还有配套的精品资源点击获取