nodejs实现TCP端口转发并截包的小工具

news2024/10/6 14:33:33

近期我正致力于开发一个基于 Go-CQHTTP 的 QQ 机器人应用程序项目,该项目现已成功实现了 Go-CQHTTP 的容器化部署,利用 Docker 技术确保其运行环境的一致性与便捷性。随着项目推进,接下来的工作重心转向部署配套的签名服务器(qsign),同样采用 Docker 进行应用封装与管理。

为了深入理解并有效监控 Go-CQHTTP 机器人与 qsign 服务间的通信交互,我计划运用 Node.js 编写一个专门的 TCP 端口转发与数据包截取工具。此工具不仅将助力调试当前项目中的通讯过程,确保二者间消息传递的准确无误,还因其通用性而有望成为日后调试其他基于 TCP 端口通信应用的理想辅助手段。

1 测试项目基本程序构成及端口设置

项目由3个js文件组成,都采用 net 模块来实现socker 通信。文件分别为:

  • server.js
    创建和启动一个 TCP 服务器,监听端口为:8888
  • tcpMapper.js
    创建一个 TCP 映射应用,包含:一个 TCP 服务端,监听端口为7777,用来接收客户端发送的数据;一个 TCP 客户端,远程连接server.js 监听的端口 8888
  • client.js
    创建一个 TCP 客户端,远程连接tcpMapper.js 监听的端口 7777

2 测试流程及实现功能:

  • 为简化设计,此例不考虑客户端自动连接功能,所以需要注意 3 个 js 的运行顺序:先启动 server.js,再启动 tcpMapper.js,最后启动 client.js(每次调试都需要重新启动一遍,确保连接成功)
  • 连接成功后,在 client.js 应用中输入任意字符串,通过 tcpMapper.js 转发到 server.js,server.js 将收到的数据转成大写后,再转发到 tcpMapper.js,tcpMapper.js 再转发到 client.js,最终在 client.js 中接收转换后的大写字符串。

3 程序代码

3.1 server.js

// 引入 net 模块
const net = require('net');

// 创建本地监听服务器
const server = net.createServer((serverSocket) => {
  
  // 获取本地服务端口接收到的数据
  serverSocket.on('data', (data) => {
    data=data.toString().trim();
    console.log(`C -> S: 【 ${data}`);

    // 将data转换为大写
    data = data.toString().toUpperCase();

    // 显示要发送给客户端的数据
    console.log(`S -> C: 【 ${data} 】\n`);

    // 通过 serverSocket 将数据发送给客户端
    serverSocket.write(`${data}`);
  });
})

// 启动本地监听服务器
server.listen(8888, () => {
    console.log(`Listening on localhost:${server.address().port}`);
});

3.2 tcpMapper.js

// 引入 net 模块
const net = require('net');

// 目标服务器信息
const targetHost = '127.0.0.1';
const targetPort = 8888;

// 创建本地监听服务器
const server = net.createServer((serverSocket) => {

  // 获取本地服务端口接收到的数据
  serverSocket.on('data', (data) => {
    console.log(`C -> M: 【 ${data}`);

    // 向远程服务器发送数据
    clientSocket.write(data);
  });

  // 创建一个客户端 Socket —— clientSocket,连接转发的服务器
  const clientSocket = new net.Socket();

  // 连接转发的目标服务器
  clientSocket.connect(targetPort, targetHost, () => {

    // 接收转发的目标服务器返回的数据
    clientSocket.on('data', (data) => {
      console.log(`M -> C: 【 ${data} 】\n`);

      // 向接入的客户端转发数据
      serverSocket.write(data);
    });

    // 错误处理
    ['error', 'end'].forEach((event) => {
      serverSocket.on(event, () => clientSocket.end());
      clientSocket.on(event, () => serverSocket.end());
    });
  });

  // 远程连接错误处理
  clientSocket.on('error', (err) => {
    console.error(`Error connecting to ${targetHost}:${targetPort}:`, err);
    serverSocket.destroy(err);
  });
});

// 启动本地监听服务器
server.listen(7777, () => {
  console.log(`Listening on localhost:${server.address().port}, forwarding to ${targetHost}:${targetPort}`);
});

3.3 client.js

// 引入 net 模块
const net = require('net');

// 目标服务器信息
const targetHost = '127.0.0.1';
const targetPort = 7777;

// 创建一个客户端 Socket —— clientSocket,连接目标服务器
const clientSocket = new net.Socket();
clientSocket.connect(targetPort, targetHost, () => {
    console.log(`连接成功! ${targetHost}:${targetPort}`)
})

// 监听目标服务器返回的数据
clientSocket.on('data', (data) => {
    console.log(`S -> C: 【 ${data.toString()} 】\n`);
})

// 键盘输入发送数据时
process.stdin.on('data', (data) => {
    data=data.toString().trim();
    console.log(`\nC -> S: 【 ${data}`);
    clientSocket.write(data);
})

4 调试方式

在 vscode 中,调试方式如下:
图1  tcpMapper.js 的调试方式

图1 tcpMapper.js 的调试方式

同时打开 3 个 vscode 终端,从右到左的顺序执行:server.js、tcpMapper.js、client.js,依次执行完之后,在运行 client.js 终端中输入任意字符串,回车后即可看到输出结果。

  • C -> S 表示客户端发送给服务器的数据,客户端并不知道 tcpMapper 的存在
  • S -> C 表示服务器转发给客户端的数据,服务器端也不知道 tcpMapper 的存在
  • C -> M 表示客户端转发给 tcpMapper 的数据,M -> C 表示 tcpMapper 转发给客户端的数据。tcpMapper 知道客户端和服务器的存在

5 总结

tcpMapper.js 作为一个 JavaScript 库,已经成功实现了 TCP 端口转发与数据包截取两大核心功能。然而,当前版本的 tcpMapper.js 在设计与实现上尚未充分关注系统的健壮性建设,故其定位更倾向于作为一种简易实用的工具,用于快速解决特定场景下的端口转发与数据包处理需求,而非面向复杂环境或高可用性要求的应用。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1583502.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

eNSP-抓包解析TCP三次握手和四次挥手的过程

一、环境搭建 1.设备连接 并 启动所有设备 2.服务器配置 3.客服端配置 二、抓包测试 1.打开抓包软件 2.客户端获取数据 三、抓包结果

【自控笔记】线性系统时域分析法

动态稳态性能 一阶系统 二阶系统 二阶系统单位阶跃 系统稳定性分析

PyQt介绍——QChart饼图图表

在PyQt5中,我们可以使用QChart模块来创建各种类型的图表,包括饼图。饼图是一种常用的数据可视化方式,用于展示不同类别在整体中的比例关系。 安装相关的库: 不包含在PyQt5里面,需要另外安装 pip install PyQtChart …

前端工程化理解 (2024 面试题)

最好介绍远古世界最好随性一点,不要太刻板 ,不然像背书 什么是前端工程化? - 知乎 前端工程化的历史 互联网初期,09 年以前,页面只需要展示一些列表、表格、文章内容以及简单图片即可,其目的是为了传送信…

[C语言][数据结构][链表] 单链表的从零实现!

目录 零.必备知识 1.一级指针 && 二级指针 2. 节点的成员列表 a.数据 b.指向下一个节点的指针. 3. 动态内存空间的开辟 (malloc-calloc-realloc) 一.单链表的实现与销毁 1.1 节点的定义 1.2 单链表的尾插 1.3 单链表的头插 1.4 单链表的尾删 1.5 单链表的头删 1…

Harmony鸿蒙南向驱动开发-RTC

RTC(real-time clock)为操作系统中的实时时钟设备,为操作系统提供精准的实时时间和定时报警功能。当设备下电后,通过外置电池供电,RTC继续记录操作系统时间;设备上电后,RTC提供实时时钟给操作系…

第十四届蓝桥杯真题-平方差

考察(数学应用) 代码及其解析:90%数据 #include <iostream> using namespace std; int main() {int ans0;long long a,b;cin>>a>>b;for(int ia;i<b;i){if(i%21)ans;if(i%40)ans; }cout<<ans;return 0; }

一例简单的文件夹病毒的分析

概述 这是一个典型的文件夹病毒&#xff0c;使用xp时代的文件夹图标&#xff0c;通过可移动存储介质传播&#xff0c;会向http://fionades.com/ABIUS/setup.exe下载恶意载荷执行。 其病毒母体只是一个加载器&#xff0c;会在内存是解密加载一个反射型的dll&#xff0c;主要的…

uniapp - 微信小程序 - 使用uCharts的一些问题

文章目录 uniapp - 微信小程序 - 使用uCharts的一些问题一、开发者工具显示正常&#xff0c;真机调试统计图不随页面滚动二、数据过多开启滚动条&#xff0c;无法滑动滚动条三、饼图点击不显示提示窗/点击位置bug、多个同类型统计图点击不显示提示框问题四、 formatter 自定义 …

九州金榜|孩子叛逆期仇视父母怎么办?

孩子在成长到一段阶段就会出现叛逆&#xff0c;孩子出现了叛逆情绪&#xff0c;如果家长处理不好亲子关系&#xff0c;孩子很容易仇视父母&#xff0c;这对于家长来说是非常心痛的&#xff0c;在这个阶段的孩子对父母来说&#xff0c;具有一定挑战性&#xff0c;这也是引导孩子…

基于单片机电子指南针系统设计

**单片机设计介绍&#xff0c;基于单片机电子指南针系统设计 文章目录 一 概要二、功能设计设计思路 三、 软件设计原理图 五、 程序六、 文章目录 一 概要 基于单片机电子指南针系统设计概要主要涵盖了硬件设计、软件设计、磁场传感器选择、数据处理和显示等方面。以下是对该…

【MySQL数据库 | 第二十五篇】深入探讨MVCC底层原理

前言&#xff1a; 在当今互联网时代&#xff0c;数据库扮演着数据存储和管理的关键角色。对于大型Web应用程序和企业级系统而言&#xff0c;高效地处理并发访问和事务管理是至关重要的。多版本并发控制&#xff08;MVCC&#xff09;是一种数据库事务处理的技术&#xff0c;旨…

【数据结构练习题】队——1.用队实现栈2.用栈实现队

♥♥♥♥♥个人主页♥♥♥♥♥ ♥♥♥♥♥数据结构练习题总结专栏♥♥♥♥♥ ♥♥♥♥♥上一章&#xff1a;堆的练习题♥♥♥♥♥ 文章目录 1.用队去实现栈1.1问题描述1.2思路分析1.3绘图分析1.4代码实现2.用栈实现队2.1问题描述2.2思路分析1.3绘图分析2.4代码实现 1.用队去实现…

doss攻击为什么是无解的?

这个让Google、亚马逊等实力巨头公司也无法避免的攻击。可以这么说&#xff0c;是目前最强大、最难防御的攻击之一&#xff0c;属于世界级难题&#xff0c;并且没有解决办法。 Doss攻击的原理不复杂&#xff0c;就是利用大量肉鸡仿照真实用户行为&#xff0c;使目标服务器资源…

【漏洞复现】WordPress Welcart 任意文件读取漏洞(CVE-2022-4140)

0x01 产品简介 Welcart 是一款免费的 WordPress 电子商务插件。Welcart 具有许多用于制作在线商店的功能和自定义设置。您可以轻松创建自己的原始在线商店。 0x02 漏洞概述 Welcart存在任意文件读取漏洞&#xff0c;未授权的攻击者可以通过该漏洞读取任意文件&#xff0c;获…

【无标题】系统思考—心智模式

“直到你使无意识变为有意识&#xff0c;它将指导你的生活并且你会称之为命运。”—卡尔荣格 心智模式深藏于我们内心之中&#xff0c;它潜移默化地影响着我们对世界的理解和判断。往往这些影响是如此隐蔽&#xff0c;以至于我们自己都未必察觉到是什么在驱动我们的选择、决策…

利用Python ARM网关仓储物流AGV小车控制器

在现代智慧物流体系中&#xff0c;高效的信息管理系统是物流中心实现精准跟踪货物、科学管理库存及优化配送路线的关键环节。通过采用ARM架构的工控机或网关&#xff0c;并结合Python的二次开发能力&#xff0c;可以有效集成并强化物流管理系统的数据处理与通信功能&#xff0c…

最坏情况为线性时间的第k大元素

在统计和数据分析中&#xff0c;我们经常会遇到求最大值、最小值、中位数、四分位数、Top K等类似需求&#xff0c;其实它们都属于顺序统计量&#xff0c;本文将对顺序统计量的定义和求解算法进行介绍&#xff0c;重点介绍如何在最差时间复杂度也是线性的情况下求解第k大元素。…

代码随想录:栈与队列4-6

20.有效的括号 题目 给定一个只包括 (&#xff0c;)&#xff0c;{&#xff0c;}&#xff0c;[&#xff0c;] 的字符串 s &#xff0c;判断字符串是否有效。 有效字符串需满足&#xff1a; 左括号必须用相同类型的右括号闭合。左括号必须以正确的顺序闭合。每个右括号都有一…

OpenHarmony分布式软总线API调用测试工具 softbus_tool使用说明

softbus_tool 是 OpenHarmony 分布式软总线 API 调用测试工具&#xff0c;文件结构如下图所示。 softbus_tool 能够将软总线 interfaces 目录下的一些常用接口集中起来&#xff0c;供设备间搭建一些场景时使用&#xff08;比如设备绑定、BR 组网&#xff0c;BLE 组网&#xff…