TCP/XML подписка на получение данных с помощью NodeJS?

Question

[Роман Алексеевич]

Друзья. В реальном времени нужно получать информацию. С синхронным по своей сути php получается довольно несерьезная вещь. Начал изучать NodeJS. Но столкнулся с проблемой. Сама система работает следующим образом: Своим первым запросом клиент объявляет серверу используемую
версию протокола TCP/XML:
<proto ver="1.0"/>
Сервер сообщает, что он готов к работе по указанной версии протокола:
<proto ver="1.0">OK</proto>

Ну дальше уже так же передаем логин, пароль, что нужно получать, и команду подписки и система при получениии данных будет из отправлять нам.
Так вот в php это решатеся так:

$socket = socket_create(AF_INET, SOCK_RAW, SOL_TCP);
    //AF_INET - семейство протоколов
    //SOCK_STREAM - тип сокета
    //SOL_TCP - протокол
  $result = socket_connect($socket, $address, $port);
  $msg = '<proto ver="1.0"/>';
  echo "Сообщение серверу: $msg\n";
    socket_write($socket, $msg, strlen($msg)); //Отправляем серверу сообщение
  $out = socket_read($socket, 128); //Читаем сообщение от сервера
var_dump($out);

Но тут фишка в том что в PHP можно выбрать тип сокета raw. И ответ приходит. И подписка работает. Но к сожалению недолго. И проконтроллировать процесс отключения невозможно. Вот код на JS который, к сожалению не возвращает ответа. Я так понимаю что стучится он по telnet.

var net = require('net');
var HOST = '172.16.221.106';
var PORT = 14074;

var loopConnection = function() {
    var client = new net.Socket();

    client.connect(PORT, HOST, function() {
        console.log('CONNECTED TO: ' + HOST + ':' + PORT);
        client.write('<proto ver="1.0"/>');
    });

    client.on('data', function(data) {
        console.log('DATA: ' + data.toString());
        client.destroy();
    });

    client.on('close', function() {
        console.log('Connection closed');
        setTimeout(function() {
            loopConnection(); // restart again
        }, 1000); // Wait for one second
    });
};

loopConnection(); // Initialize and first call loopConnection

установил raw-socket но он только создает сервер. функционала клиента в нем нет. Как быть, куда копать, что изучать?

ps за помощь скину могарыч на киви или карту =)

Comments

[Владимир Скибин]

У Вас обмен состоит в таком виде? К - клиент, С - сервер
К->C: коннект
К->C: <proto ver="1.0"/>
С->К: <proto ver="1.0">OK</proto>
К->C: <some_xml_data />
С->К: <some_xml_data />

И для каждого последующего доступа к данным надо делать опять коннект или все можно в рамках текущего соединения делать?

И "старый пример" уж больно смахивает на туториал https://gist.github.com/tedmiston/5935757

[Роман Алексеевич]

Владимир Скибин, все верно, все в рамках одного соединения.
ну это не старый пример. это пример прямо из справочника ноды, ну только с реконектом. который видимо, не работает с raw.
ps если соединяться по putty по RAW то ответ возвращает. если по Telnet- соединение закрывается.

Answer 1

[Владимир Скибин]

Что то типа такого должно получиться?

const net = require('net');
const HOST = '172.16.221.106';
const PORT = 14074;
const client = new net.Socket();

let socketData = '';
let socketWaitHello = true;

client.connect(PORT, HOST);

client.on('connect', () => {
	console.log(`CONNECTED TO: ${HOST}:${PORT}`);
	client.write(`<proto ver="1.0"/>`);
	socketWaitHello = true;
});

client.on('data', (data) => {
	socketData += data.toString();
});

client.on('end', () => {
	console.log(`DATA: ${socketData}`);
	if (socketWaitHello) {
		if (socketData === `<proto ver="1.0">OK</proto>`) {
			client.write(`<some_auth_data />`);
		}
		else if (socketData === `<auth_is_accepted />`) {
			socketWaitHello = false;
			client.write(`<get_some_data />`);
		}
		else {
			throw new Error(`Server don't answered for hello`);
		}
	}
	else {
		do_something_with_data(socketData);
	}

	socketData = '';
});

client.on('close', () => {
	console.log(`Connection closed`);
});

Comments

[Роман Алексеевич]

так по большому счету все тот же socket.write, после которого тишина. то есть все останавливается на connected, собсна говоря как и в моем случае(
т.е. коннект есть 100%. а вот данные по телнет не идут. как это все завернуть в raw я не могу понять...

[Владимир Скибин]

Роман Алексеевич, Добавьте client.end() после каждого write, а то похоже сервер ожидает принятия данных от нас, а мы ему FIN не отправляем. Либо делайте отправку именно end-ом а не write-ом.

[Роман Алексеевич]

Владимир Скибин, та же картина...

[Владимир Скибин]

Роман Алексеевич, а есть возможность просмотреть на сервере какие данные от нас принимает?

[Владимир Скибин]

Роман Алексеевич, и Вы кстати добавляете в начало сообщения <?xml version="1.0" encoding="utf-8"?> ?

[Владимир Скибин]

Роман Алексеевич, И, кстати, судя по Вашему годичной давности вопросу по той же проблеме - попробуйте добавить в конец сообщения символы переноса строки - \r\n

[Роман Алексеевич]

Владимир Скибин, ахахаха, я просто не очень! rn опять помогло))) ответ пришел. теперь проблема в другом, как вытаскивать из приходящей информации изображения, но это соовсем другая история))) Вам написал на мейл - в ответе напишите куда кидать на пиво ;)