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

Question

[ury123]

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

Comments

[Роман]

Да что угодно, опирающееся на сетевой стэк. Например свой 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 );

Answer 1

[VoidVolker]

Например чат, вебсокет сервер, веб-сервер или любое другое веб-приложение.

Answer 2

[Andrey Tsvetkov]

Можно изобрести JSON RPC для общения сервисов между собой

Comments

[ury123]

Хорошая идея, попробую написать пару микросервисов, и настроить коммуникацию между ними.
Кстати, можно ли назвать "http-сервером" сервер, который был создан модулем "Net" (nodejs)? Ведь, с одной стороны у такого сервера не будет доставать каких-то характеристик, которые есть в Http модуле (каких конкретно, я пока не знаю). Но, с другой стороны, такой сервер все равно ведь может получать и обрабатывать http-запросы.

[Andrey Tsvetkov]

можно ли назвать "http-сервером" сервер, который был создан модулем "Net"

думаю да, но с ооочень большой натяжкой