Что толкового можно написать опираясь на модуль Net (Nodejs)?

Question

ury123 @ury123

Что толкового можно написать опираясь на модуль Net (Nodejs)?

Хочу написать небольшой TCP сервер, чтобы закрепить знания по подулю NET.
Посоветуйте, пожалуйста, что интересного можно написать, используя модуль Net, как срержень прижожения?
ПС: можно использовать только нативные модули nodejs (все кроме http, http/2, https)

Вопрос задан более трёх лет назад
113 просмотров

1 комментарий

Подписаться 2 Средний 1 комментарий

Роман @lastuniverse

Да что угодно, опирающееся на сетевой стэк. Например свой FTP, minecraft server, proxy и другие сервера и клиенты, включая узкоспециализированные такие как vnc клиент с последующей трансляцией управления в браузер. Перечислять можно бесконечно.
Лично я, как любитель изобретать велосипеды, написал для собственных нужд 2 класса, позволяющих достаточно легко обмениваться служебными json сообщениями:

детский трехколесный велик

сам недомодуль (красоты не ждите:):

const net = require("net");

function send(event, data){
	this.write(
		JSON.stringify({
			event: event,
			data: data
		})+"\n"
	);
}

class Server extends EventEmitter {
	constructor(options={}){
		super();
		this.clients = {};
		this.host=options.host||'0.0.0.0';
		this.port=options.port||'8020';
		this.server = net.createServer ((client)=>{
			client.send = send;
			client.on('data', data=>{
				try{
					const str = data.toString();
					const json = JSON.parse(""+str);
					if( json && json.event && json.data!==undefined){
						this.emit(json.event, json.data, client);
					}
				}catch(err){
					console.log('\n\nError parse json', err);
				}
			});

			client.on('close', data=>{
				// ...
			});
		});
	}

	listen(host, port){
		this.host=host||this.host;
		this.port=port||this.port;
		this.server.listen(this.port, this.host);
		console.log('Server was ben started as ' + this.host + ':' + this.port);
	}
}
module.exports.Server = Server;


class Client extends EventEmitter {
	constructor(options={}){
		super();
		this.host=options.host||'192.168.0.1';
		this.port=options.port||'8020';
		this.client = new net.Socket();
		this.client.send = send;
		this.client.on('data', data=>{
			data.toString().split(/[\n\r]+/).forEach(str=>{
				if( !str || str.search(/^[\s\n\r]+$/)+1 ) return;
				try{
					const json = JSON.parse(""+str);
					if( json && json.event && json.data!==undefined){
						this.emit(json.event, json.data, this.client);
					}
				}catch(err){
					console.log('\n\nError parse json ', err);
				}
			});
		});

		this.client.on('close', ()=>{
			console.log('Connection closed');
			this.emit("disconnect", {});
			setTimeout(()=>{
				this.connect()
			}, 6000);
		});

		this.client.on('error', ()=>{
			console.log('Connection error');
			this.emit("disconnect", {});
			this.client.destroy();
			
		});		
	}

	
	connect(host, port){
		this.host=host||this.host;
		this.port=port||this.port;
		this.client.connect(this.port, this.host, (err)=>{
			this.emit('connect', {}, this.client);
			if(err) reject(err);
		});
	}
}
module.exports.Client = Client;

узкоспециализированный сервер на его базе:

const storrage = require("./modules/storrage.js");
const users = storrage("../config/users.json",{});
const config = storrage("../config/config.server.json",{});

const NU = require("./modules/net-union.js");
const server = new NU.Server();
const clients = {};

function getUser(data){
    if( !data || !data.login || !data.password )
        return false;
    const user = users[data.login];
    if( !user || user.password != data.password)
        return false;
    return user;
}

server.on("avance", (data, client )=>{
    const user = getUser(data.auth);
    if( !user ) return client.end();
    
    const username = data.auth.login;
    clients[username] = client;
    user.points-=data.avance;
    client.send("points", user.points);
});

server.on("unlock", (data, client )=>{
    console.log("unlock", data);
    const user = getUser(data);
    if( !user ) return client.end();

    const username = data.login;
    clients[username] = client;
    user.points--;
    client.send("points", user.points);
});

function update_points(username,amount) {
    if( !amount ) return;
    
    const user = users[username];
    if( !user ) return;

    const client = clients[username];
    if( !client ) return;

    client.send("points", user.points);
    client.send("message", "Количество минут "+(amount<0?"уменьшено":"увеличено")+" на "+amount+".\nОсталось "+user.points+" минут");
}

server.listen(config.url.host, config.url.port);

module.exports.server = server;
module.exports.update_points = update_points;

ну и клиент)

const manage = require("./modules/manage.js");
const storrage = require("./modules/storrage.js");
const config = storrage("./config/config.client.json",{});


const NU = require("./modules/net-union.js");
const client = new NU.Client();

var count = 0;
var avance = 0;
var server;
var isConnect = false;

// при подключении к серверу отправить запрос на авторизацию
client.on("connect", (data, serv )=>{
	if(isConnect) return;
	isConnect = true;
	server = serv;
    console.log('\n\nПодключился к ' + client.host + ":" + client.port);
    if(avance)
    	server.send("avance", {auth: config.auth, avance: avance});
});

// при отключении к серверу переходим в автономный режим
client.on("disconnect", (data)=>{
	console.log("client.on disconnect");
	isConnect = false;
});


// при получении количества баллов обновить счетчик
client.on("points", (points, serv )=>{
	console.log("client.on points", points);
	count = points;
	notify();
});

// при получении сообщения - вывести уведомление
client.on("message", (message, serv )=>{
	console.log("client.on message", message);
	manage.notify("Таймер", message);
});

client.connect(config.url.host, config.url.port);

function notify() {
	if(count>8 && count%10===0){
		manage.notify("Таймер", "Осталось "+count+" минут");
	}else if(count==5){
		manage.notify("Таймер", "Осталось "+count+" минут");
	}else if(count>1 && count<5){
		manage.notify("Таймер", "Осталось "+count+" минуты");
	}else if(count==1){
		manage.notify("Таймер", "Осталась 1 минута");
	}else if(count<1){
		manage.notify("Таймер", "ВРЕМЯ ВЫШЛО");
		lock()
	}
}

function lock() {
	setTimeout(function() {
		manage.lock(config.auth.login);
	}, 20000);
}

function observe_session() {
	console.log("next time");
	manage.isLocked(config.auth.login, isLocked=>{
		if(isLocked) return;

		if( isConnect ){
			server.send("unlock", config.auth);
		}else{
			count--;
			avance++;
			notify();
		}
	});
	setTimeout( observe_session , 60000 );
}
setTimeout( observe_session , 10000 );

Написано более трёх лет назад

Решения вопроса 2