Прокси Socket.IO NodeJS

@dedsec1337 · Регистрация: 18.10.2015

Author24 — интернет-сервис помощи студентам

Всем доброго времени суток!
Необходимо реализовать следующие: (картинка в аттаче)
Другими словами нужно сделать локальный прокси сервер для socket.io на другом сервере. Как это лучше сделать? И может быть уже есть готовые решения?

@dedsec1337 · 20.10.2015, 22:42 **[ТС]**

BANO, поможете разобраться с работой с клиентами?

@BANO · 20.10.2015, 22:54

dedsec1337, можно попробовать

@dedsec1337 · 21.10.2015, 19:32 **[ТС]**

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

Javascript

1	socket.emit('init', body);

в переменой body хранится json. На клиенте стоит обработчик:

Javascript

socket.on('init', function (data) {
        alert(data);
        alert(data['state']);
});

Проблема в том что alert(data) обрабатывается и выводится json, а вот alert(data['state']) проходит с ошибкой "undefined".. с чем это связанно? В данных точно есть state, сам json выглядит примерно так:

JSON

{
    "auth": {
        "auth": false,
        "token": null,
        "steamid_3": null,
        "userid": null,
        "profile": null
    },
    "state": {
        "stats": {
            "totalGamesPlayed": 145,
            "totalPayed": 3838,
            "totalUniquePlayers": 378,
            "maxPayed": 6829.72,
            "serverTime": 1445432720685,
            "con": 241
        },
        "game": {
            "number": 61467,
            "prize": 0,
            "itemsNum": 0,
            "itemsArr": [],
            "timeOldEnds": 0,
            "timeNewStarts": 0,
            "winner": null,
            "closed": null,
            "tape": null,
            "rand": null,
            "md5": "64be59bc56b0d9525fe4aaa1e52772cc"
        },
        "lastWinner": {
            "name": "Faller",
            "steamid64": "76561198105976261",
            "prize": 2429.13,
            "image": "https://steamcdn-a.akamaihd.net/steamcommunity/public/images/avatars/bd/bdae0bbe1d3fe754d950ff4d1b1f0b22ebb166df_full.jpg",
            "time": 200994,
            "bet": 2019.7
        },
        "serverTime": 1445432850292,
        "con": 228
    }
}

Добавлено через 10 минут
UPD: решил проблему надо было в клиентском скрипте переопределить data вот так: data = JSON.parse(data);

@BANO · 21.10.2015, 21:05

dedsec1337, по-моему у клиентов есть такой метод .json, и ваш код должен был выглядеть так

Javascript

1	socket.json('init', body);

только тогда body должен быть простым объектом

@dedsec1337 · 21.10.2015, 21:40 **[ТС]**

BANO,

Сообщение от dedsec1337

data = JSON.parse(data);

работает и ладно, у меня сейчас проблема в другом: первые 2 запроса проходят, но вот 3 и следующие нет: (Cкрин 1).
При этом иногда он все таки обрабатывает и 3 запрос, на скрине видно что был загружен еще и "end-game". Видать как то умудряюсь попасть в нужный момент..
Мой клиент на c# работает без таких проблем: (Скрин 2)
С чем связанно такое поведение?

Добавлено через 2 минуты
BANO, Код сервера если нужен:

Javascript

var app = require('express')();
var http = require('http')
    .Server(app);
var io = require('socket.io')(http);
var clients = [];
var count = 0;
//PROXYING
var unirest = require('unirest');
var CookieJar = unirest.jar();
unirest.get('https://server01.csgofast.com/socket.io/')
    .query(
    {
        'EIO': '3'
        , 'transport': 'polling'
        , 't': Date.now() + '-' + count++
    })
    .jar(CookieJar)
    .headers(
    {
        'Accept': '*/*'
        , 'Origin': 'https://csgofast.ru'
        , 'Referer': 'https://csgofast.ru'
        , 'Accept-Language': 'ru,en-us;q=0.7,en;q=0.3'
    })
    .end(function (response)
    {
        var sid = parse('"sid":"', '"', response.body.toString());
        var interval = setInterval(function ()
        {
            unirest.get('https://server01.csgofast.com/socket.io/')
                .query(
                {
                    'EIO': '3'
                    , 'transport': 'polling'
                    , 't': Date.now() + '-' + count
                    , 'sid': sid
                })
                .jar(CookieJar)
                .headers(
                {
                    'Accept': '*/*'
                    , 'Origin': 'https://csgofast.ru'
                    , 'Referer': 'https://csgofast.ru'
                    , 'Accept-Language': 'ru,en-us;q=0.7,en;q=0.3'
                })
                .end(function (response)
                {
                    even = parse('["', '"', response.body);
                    if (even != '')
                    {
                        response.body = response.body.toString().substr(response.body.toString().indexOf('['));
                        response.body = response.body.toString().substr(response.body.toString().indexOf('{'));
                        response.body = response.body.toString().substr(0, response.body.toString().length - 1);
                        clients.forEach(function (socket)
                        {
                            socket.emit(even, response.body);
                        });
                        console.log(count++ + ': ' + even + ' | ' + response.body.toString().substr(0, 250));
                    }
                    else
                    {
                        console.log(count++ + ': error:');
                        console.log(response.body);
                    }
                });
        }, 1500)
    });
//CLIENTS LOGIC
io.on('connection', function (socket)
{
    clients.push(socket);
    socket.on('disconnect', function ()
    {
        clients.splice(clients.indexOf(socket), 1);
    });
    socket.on('re-init', function ()
    {
        console.log('re-init');
    });
    socket.on('ladder-request', function ()
    {
        console.log('ladder-request');
    });
    socket.on('error', function ()
    {
        console.log('error');
    });
    socket.on('history-request', function ()
    {
        console.log('history-request');
    });
    socket.on('token-link', function ()
    {
        console.log('token-link');
    });
});
//START SERVER
http.listen(80, function ()
{
    console.log('Server start!');
});
 
function parse(str1, str2, content)
{
    try
    {
        var arr1 = content.toString()
            .split(str1);
        var arr2 = arr1[1].toString()
            .split(str2);
        return arr2[0];
    }
    catch (error)
    {
        return '';
    }
}

@BANO · 21.10.2015, 21:42

dedsec1337, честно говоря не знаю
вы какую-то библиотеку подключили, которую я совершенно не знаю

@dedsec1337 · 21.10.2015, 22:11 **[ТС]**

BANO, это что то похожее на cUrl вот тут мануал если интересно: http://unirest.io/nodejs.html, есть догадки хотя бы почему так может происходить? Куки отправляются, хеадеры и get параметры я указал, а он ошибки возвращает

Добавлено через 25 минут
BANO, понял в чем была ошибка, я использовал setinterval, а не settimeout. В связи с этим каждый тик сервер отправлял новый запрос.. Но это малозначительно повлияло, т.к. теперь после "init" евента он вообще перестает отправлять запросы

@dedsec1337 · 21.10.2015, 22:29 **[ТС]**

Так и с этим разобрался (скрин в аттаче), осталась работа с клиентами..

@dedsec1337 0 / 0 / 0 Регистрация: 18.10.2015 Сообщений: 29
	21.10.2015, 22:11 [ТС]	47
	BANO, это что то похожее на cUrl вот тут мануал если интересно: http://unirest.io/nodejs.html, есть догадки хотя бы почему так может происходить? Куки отправляются, хеадеры и get параметры я указал, а он ошибки возвращает Добавлено через 25 минут BANO, понял в чем была ошибка, я использовал setinterval, а не settimeout. В связи с этим каждый тик сервер отправлял новый запрос.. Но это малозначительно повлияло, т.к. теперь после "init" евента он вообще перестает отправлять запросы 0

@dedsec1337 0 / 0 / 0 Регистрация: 18.10.2015 Сообщений: 29
	21.10.2015, 22:29 [ТС]	48
	Так и с этим разобрался (скрин в аттаче), осталась работа с клиентами.. Миниатюры 0

@dedsec1337 0 / 0 / 0 Регистрация: 18.10.2015 Сообщений: 29
		1
	Прокси Socket.IO NodeJS 18.10.2015, 20:41. Показов 4347. Ответов 47 Метки нет (Все метки) Всем доброго времени суток! Необходимо реализовать следующие: (картинка в аттаче) Другими словами нужно сделать локальный прокси сервер для socket.io на другом сервере. Как это лучше сделать? И может быть уже есть готовые решения? Миниатюры 0

@dedsec1337 0 / 0 / 0 Регистрация: 18.10.2015 Сообщений: 29
	20.10.2015, 22:42 [ТС]	41
	BANO, поможете разобраться с работой с клиентами? 0

@BANO Ренегат 1740 / 1085 / 386 Регистрация: 06.08.2014 Сообщений: 5,203 Записей в блоге: 1
	20.10.2015, 22:54	42
	dedsec1337, можно попробовать 0

@BANO Ренегат 1740 / 1085 / 386 Регистрация: 06.08.2014 Сообщений: 5,203 Записей в блоге: 1
	21.10.2015, 21:42	46
	dedsec1337, честно говоря не знаю вы какую-то библиотеку подключили, которую я совершенно не знаю 0

Опции темы