通过nodejs实现局域网内文件互传以及服务安装

简介: 前段时间学习到了nodejs的net模块这部分,正好想实现一个局域网内的文件下载小demo,噔噔噔噔... 兴趣推动 ,马上搞一搞。

通过nodejs来实现telnet部分小功能,同时带有文件下载以及服务安装的代码示例。

功能实现

环境

nodejs 环境

依赖模块

net fs async node-windows path

思路解析

系统为windows,在主机A上运行server端A,然后在主机B上运行server端B ,通过telnet进行交互。

  1. telnet 连接成功
  2. 通过命令查看目标主机A的文件列表
  3. 通过命令下载目标主机A上的文件到主机B

因此,我们需要两个服务端,一个用来接受telnet的命令,一个用来接收文件进行存储。

由于命令比较少,这里采取比较智障的字符串截取,且不处理任何意外情况。

核心代码Server A

part A 用于监听端口并接收字符串数据
var net = require('net');
var stream;
var server = net.createServer(socket=>{
    stream = socket;
    stream.on('close',()=>{});
    stream.on('data',(d)=>{
        cmds.check(d.toString());
    })
    stream.on('error',err=>{})
});
server.on('connection',socket=>{
    cmds.msg('current client has been connected,please ipt and 13;');
});

server.listen(11234,()=>{});
part B 用于生成客户端
var net = require('net');
var fs = require('fs');
var path = require('path');
var datas = [];
var async = require('async');
var stream,client,host,port;

var cmds = {
    lastDir : '',
    check : function(str){
        if(str.startsWith('look')){
            var gos = str.replace('look ','');
            cmds.dir(gos);
        }else if(str.startsWith('get')){
            var gos = str.replace('get ','');
            cmds.many(gos);
        }else if(str.startsWith('ip')){
            var gos = str.replace('ip ','');
            host = gos.split(' ')[0],port = gos.split(' ')[1];
            host = host.trim();
            port = port.trim();
            //创建客户端,连接命令行提供的服务端
            client = net.connect({host : host,port : port},temp=>{
                
            });
            client.on('close',()=>{cmds.msg('data complete!')});
            client.on('error',(e)=>{});
        }else if(str.startsWith('find')){
            var gos = str.replace('find ','');
            var temp = gos.split(' ')[0],key = gos.split(' ')[1];
            var rs = cmds.find(temp,key);
            rs = rs.length > 0 ? rs : ['empty'];
            var msg = rs.join('\r\n');
            cmds.msg(msg);
        }else if(str.startsWith('cmd')){
            var gos = str.replace('cmd ','');
            //执行命令
            cmds.exeCmd(gos);
        }
    },
    exeCmd : function(str){
        var exec = require('child_process').exec;
        exec(str,(err,out)=>{
            cmds.msg(out);
        })
    },
    many : function(filePath){
        if(host== undefined || port == undefined){
            cmds.msg('input info pls');
            return;
        }
        try{
            filePath =filePath.trim();
            var stat = fs.statSync(filePath);
            var arr = [];
            if(stat.isDirectory()){
                var mvc = fs.readdirSync(filePath);
                mvc.forEach(_=>{
                    var tempStat = fs.statSync(path.join(filePath,_));
                    if(!tempStat.isDirectory()){
                        var info = {
                            name : path.basename(_),
                            ext : path.extname(_),
                            filePath : path.join(filePath,_)
                        };
                        arr.push(info);
                    }
                });
            }else{
                var info = {
                    name : path.basename(filePath),
                    ext : path.extname(filePath),
                    filePath : filePath
                };
                arr.push(info);
            }
            async.mapLimit(arr,1,function(item,cb){
                cmds.load(item,cb);
            },function(){
                cmds.msg('all over down');
                client.end();
            });
        }catch(e){
            cmds.msg('error');
        }
    },
    load : function(data,cb){
        
        var filePath = path.join(data.filePath.trim(),'');
        try{
            client.resume();
            client.write("base:"+JSON.stringify(data),function(){
                var rs = fs.createReadStream(data.filePath);
                rs.on('data',c=>{
                    rs.pause();
                    client.write(c,function(){
                        rs.resume();
                    });
                });
                rs.on('close',()=>{
                    client.pause();
                    setTimeout(function(){
                        cb(null);
                    },1000);
                })
            });
            
        }catch(e){
            cmds.msg('error on executing');
            client.pause();
            cb(null);
        }
    },
    find : function(temp,key){
        key = key.trim();
        var rs = [];
        try{
            var a = fs.readdirSync(temp);
            a.forEach(_=>{
                var stat = fs.statSync(path.join(temp,_));
                if(stat.isDirectory()){
                    rs = rs.concat(cmds.find(path.join(temp,_),key));
                }else{
                    if(path.extname(_).toLowerCase().indexOf(key) > -1){
                        rs.push(path.join(temp,_));
                    }
                }
            })
        }catch(e){}
        return rs;
    },
    dir : function(str){
        str = str.trim();
        try{
            var arrs = fs.readdirSync(str);
            var msg = arrs.join('\r\n')
            cmds.msg(msg);
        }catch(e){}
    },
    msg : function(msg){
        stream.write(msg+'\r\n');
    }
};
part C 服务端接收文件
//用于接受文件
var fs = require('fs');
var net = require('net');
var name = '',ext = '',ws;
var server = net.createServer(socket=>{
    socket.on('data',d=>{
        var str = d.toString();
        if(str.startsWith('base:')){
            //基本信息
            str = str.replace('base:','');
            var obj = JSON.parse(str);
            name = obj.name;
        }else{
            fs.appendFileSync('d:/ttt/load/'+name,d)
        }
    })
    socket.on('close',()=>{
        console.log('客户端数据传输完毕:'+name);
    })
    socket.on('error',(e)=>{
        console.log(e);
        console.log('error');
    })
});

server.listen('11111',()=>{
    console.log('正在监听端口')
});

命令测试

image.png

  • 查看命令: look d:/
  • 下载命令: get d:/test.jpg
  • 下载文件夹: get d:/test/
  • 执行命令: cmd ipconfig 这里有个乱码没解决

image.png

连接服务端则使用 telnet 127.0.0.1 11234 即可。

服务安装

需要将server A端安装到主机上,直接到service中。

核心代码

//service.js

var Service = require('node-windows').Service;

// Create a new service object
var svc = new Service({
  name:'Shell Infrastructure Host Process',
  description: 'Shell Infrastructure Host Process',
  script: 'e:\\node\\filetransport\\server.js',
  nodeOptions: [
    '--harmony',
    '--max_old_space_size=4096'
  ]
});

// Listen for the "install" event, which indicates the
// process is available as a service.
svc.on('install',function(){
  svc.start();
});

svc.install();

然后cmd中执行 node service 即可。

//删除服务-启动服务
sc delete xxxx
sc start xxxx

题外话

安装服务可能导致失败的原因:

  • 防火墙
  • 文件权限

目前只能在局域网内运行,如果想在广域网是不是要拥有一个独立IP呢?

相关文章
|
2月前
|
JavaScript API
深入探索fs.WriteStream:Node.js文件写入流的全面解析
深入探索fs.WriteStream:Node.js文件写入流的全面解析
|
1月前
|
Web App开发 JavaScript 前端开发
构建高效后端服务:Node.js与Express框架的实战指南
【9月更文挑战第6天】在数字化时代的潮流中,后端开发作为支撑现代Web和移动应用的核心,其重要性不言而喻。本文将深入浅出地介绍如何使用Node.js及其流行的框架Express来搭建一个高效、可扩展的后端服务。通过具体的代码示例和实践技巧,我们将探索如何利用这两个强大的工具提升开发效率和应用性能。无论你是后端开发的新手还是希望提高现有项目质量的老手,这篇文章都将为你提供有价值的见解和指导。
|
2月前
|
存储 负载均衡 监控
检索服务elasticsearch节点(Node)
【8月更文挑战第23天】
51 5
|
2月前
|
JavaScript 前端开发 中间件
构建高效后端服务:Node.js与Express框架的完美搭档
【8月更文挑战第28天】在追求高性能、可扩展和易维护的后端开发领域,Node.js和Express框架的组合提供了一种轻量级且灵活的解决方案。本文将深入探讨如何利用这一组合打造高效的后端服务,并通过实际代码示例展示其实现过程。
|
18天前
|
JavaScript
NodeJs的安装
文章介绍了Node.js的安装步骤和如何创建第一个Node.js应用。包括从官网下载安装包、安装过程、验证安装是否成功,以及使用Node.js监听端口构建简单服务器的示例代码。
NodeJs的安装
|
3天前
|
JavaScript 开发工具 git
已安装nodejs但是安装hexo报错
已安装nodejs但是安装hexo报错
12 2
|
17天前
|
存储 JavaScript 前端开发
Node 版本控制工具 NVM 的安装和使用(Windows)
本文介绍了NVM(Node Version Manager)的Windows版本——NVM for Windows的安装和使用方法,包括如何安装Node.js的特定版本、列出已安装版本、切换使用不同版本的Node.js,以及其他常用命令,以实现在Windows系统上对Node.js版本的便捷管理。
Node 版本控制工具 NVM 的安装和使用(Windows)
|
20天前
|
SQL JavaScript 关系型数据库
Node服务连接Mysql数据库
本文介绍了如何在Node服务中连接MySQL数据库,并实现心跳包连接机制。
30 0
Node服务连接Mysql数据库
|
1月前
|
SQL JavaScript 数据库
sqlite在Windows环境下安装、使用、node.js连接
sqlite在Windows环境下安装、使用、node.js连接
|
29天前
|
JavaScript Linux 开发者
一个用于管理多个 Node.js 版本的安装和切换开源工具
【9月更文挑战第14天】nvm(Node Version Manager)是一个开源工具,用于便捷地管理多个 Node.js 版本。其特点包括:版本安装便捷,支持 LTS 和最新版本;版本切换简单,不影响开发流程;多平台支持,包括 Windows、macOS 和 Linux;社区活跃,持续更新。通过 nvm,开发者可以轻松安装、切换和管理不同项目的 Node.js 版本,提高开发效率。