forum.boolean.name - Node.JS + MongoDB

forum.boolean.name (http://forum.boolean.name/index.php)

- JavaScript / HTML (http://forum.boolean.name/forumdisplay.php?f=136)

- - Node.JS + MongoDB (http://forum.boolean.name/showthread.php?t=18507)

Ответ: Node.JS + MongoDB

И я подобное писал для обработки массива и секвенции, но в примерах выше оно не помогает

PHP код:


		
			
// index - startIndex
// processor - function(item, itemIndex, next)
module.exports.processArrayAsync = function (array, index, processor, onEndCallback) {
    index = typeof index !== 'undefined' ? index : 0;

    if (index >= array.length) {
        if (onEndCallback) onEndCallback();
        return;
    }
    process.nextTick(function () {
        processor(array[index], index, function () {
            module.exports.processArrayAsync(array, index + 1, processor, onEndCallback);
        });
    });
};


module.exports.runJobsQueueAsync = function(jobs, index, onEndCallback) {
    index = typeof index !== 'undefined' ? index : 0;

    if (index >= jobs.length) {
        if (onEndCallback) {
            onEndCallback();
        }
        return;
    }
    process.nextTick(function () {
        jobs[index](function () {
            module.exports.runJobsQueueAsync(jobs, index + 1, onEndCallback);
        })
    });
};

Ответ: Node.JS + MongoDB

Потому что тебе нужен не статичный chain, что потребует модификации в твой - возможность вставлять job'ы по пути выполнения.

Ответ: Node.JS + MongoDB

Хм, а я не подумал что можно вставлять джобы в цепочку... Спасибо, навел на мысль...

Ответ: Node.JS + MongoDB

Я это сделал!

PHP код:


		
			
function AFlow() {
    this.index = 0;
}

module.exports.AFlow = AFlow;

module.exports.run = function (jobs) {
    var flow = new AFlow;
    flow.jobs = jobs;
    flow.doJob();
    return flow;
};

AFlow.prototype.add = function (job) {
    this.jobs.splice(this.index + 1, 0, job);
};



AFlow.prototype.doJob = function () {
    var flow = this;
    if (flow.index >= flow.jobs.length) {
        return;
    }
    process.nextTick(function () {
        flow.jobs[flow.index](function () {
            flow.index++;
            flow.doJob();
        }, flow)
    });
};

использование:

PHP код:


		
			
var util = require('util');
var AFlow =  require('AFlow');

var data = [];

flow = AFlow.run([
    function (next) {
        data.push('one');
        console.log(util.inspect(data));
        setTimeout(next, 500);
    },
    function (next) {
        data.push('two');
        flow.add(function (next) {
            data.push('three');
            console.log(util.inspect(data));
            setTimeout(next, 500);
        });
        console.log(util.inspect(data));
        setTimeout(next, 500)
    },
    function (next) {
        data.push('four');
        console.log(util.inspect(data));
        setTimeout(next, 500)
    },
    function(){
        data.push('five');
        console.log(util.inspect(data));
    }
]);

Ответ: Node.JS + MongoDB

а есть ли для node js ubjson парсер?

UPD: кажется нагуглил https://github.com/Sannis/node-ubjson

Ответ: Node.JS + MongoDB

Цитата:

Сообщение от moka (Сообщение 267713)

UPD:
Я не советую, но есть socket.io клиент для unity: https://github.com/NetEase/UnitySocketIO

Использую UnitySocketIO, нашел 2 серьезные проблемы:

1) Клиент создает слишком большую нагрузку на CPU
https://github.com/NetEase/UnitySocketIO/issues/13
http://forum.unity3d.com/threads/204...-UnitySocketIO

2) Нельзя принимать и посылать ивенты (socket.emit). Работают только месаги (socket.send)
https://github.com/NetEase/UnitySocketIO/issues/16

Ответ: Node.JS + MongoDB

Я уже написал бинарную сериализацию пакетов и связал Unity и node js по tcp с использованием net модуля. Сейчас хочется сделать некую архитетуру для создания ММО решений.

Ответ: Node.JS + MongoDB

Не думаешь зарефакторить код, и выложить github проект? Т.к. думаю на него спрос будет весьма большой.

Если с точки зрения пользователя это работает как socket.io то вообще сказка и у тебя есть возможность менеджить популярный модуль на npm.

В общем, на такой модуль будет спрос если его maintain'ить нормально.

Ответ: Node.JS + MongoDB

Цитата:

Сообщение от moka (Сообщение 269477)

Пока еще не думал, видно будет. Я бы предложил тебе поучаствовать в его разработке если интересно, когда будет что-то получаться, то можно будет подумать о выкладывании. Пока наверное рано.

Ответ: Node.JS + MongoDB

На данный момент чат сервер "все со всеми" можно сделать вот так:

PHP код:


		
			
var nodeSharpTCP = require('NodeSharpTCP');

// полиси сервер
var SocketPolicyServer = nodeSharpTCP.SocketPolicyServer;
SocketPolicyServer.listen(__dirname + '/public/crossdomain.xml', 843);

// чат сервер
var tcpServer = new nodeSharpTCP.TCPServer();

tcpServer.packetProcessors.push(function (server, client, packet, next) {
    server.broadcastObject(packet);
});

tcpServer.listen(8124, function () {
    console.log('server bound');
});

Ответ: Node.JS + MongoDB

Прикольно.
Как понимаю нужен обмен Policy чтобы сделать нормальное общение? (также как в flash'е?).

packetProcesors - как понимаю ты пушаешь функцию потом которая будет вызываться для каждого пакета.

Как тебе подход как в socket.io? В плане имён пакетов и подпиской на них?
Например:

PHP код:


		
			
var UnitySocket    = require('unitySocket').Socket,
    PolicyProvider = require('unitySocket').PolicyProvider;

// create policy server with preloaded policy provider file
var unityPolicy = new PolicyProvider(__dirname + '/public/crossdomain.xml');
unityPolicy.listen(843);

// create server socket
var server = new UnitySocket();

// if error occured
server.on('error', function(err) {
  throw err;
})

// once bound
server.on('bound', function() {
  // server is bound and ready to accept connections
});

// someone connects
server.on('connect', function(socket) {

  // subscribe to generic event for each packet
  socket.on('packet', function(name, data) {
    // name == 'foo'
    // data == json
  });

  // subscribe to packet with specific name
  socket.on('foo', function(data) {
    // data == json
  });

  // subscribe to client disconnect
  socket.on('disconnect', function(data) {
    // data contains reason and additional details
  });

});

// bind server socket
server.listen(8080);

В node.js да и везде вообще, очень важен поток мысли и дизайн технического решения.
Например использовать EventEmitter'ы для использования event-driven парадигмы - очень збсь штука.
Также можно предоставить promises как альтернативная парадигма, это уже зависит от разраба что и как юзать.

Я сейчас promises юзаю, и порой очень просто и элегантно выходят решения (никаких пирамид).

Можно выложить на github и там уже по пути менеджить и т.п.

Ответ: Node.JS + MongoDB

Цитата:

Сообщение от moka (Сообщение 269522)

Прикольно.
Как понимаю нужен обмен Policy чтобы сделать нормальное общение? (также как в flash'е?).

Да, WebPlayer Unity так же проверяет возможность подключения как и флеш.

Цитата:

Сообщение от moka (Сообщение 269522)

packetProcesors - как понимаю ты пушаешь функцию потом которая будет вызываться для каждого пакета.

Да там похоже на middleware в express

Цитата:

Сообщение от moka (Сообщение 269522)

Как тебе подход как в socket.io? В плане имён пакетов и подпиской на них?

Вчера написал по просьбе ant2on'а нечто похожее на socket.io как враппер над своим сервером.
Node js

PHP код:


		
			
var util = require('util');
var NodeSharpTCP = require('NodeSharpTCP');

// полиси сервер
var SocketPolicyServer = NodeSharpTCP.SocketPolicyServer;
SocketPolicyServer.listen(__dirname + '/public/crossdomain.xml', 843);

// евент сервер
var EventServer = NodeSharpTCP.EventServer;

var server = new EventServer();

server.on('connection', function(client){

    console.log('Clients: '+ server.clients.length);

    client.emit('welcome', {id: client.id});

    client.on('disconnect', function(){
        console.log('Clients: '+ server.clients.length);
    });

    client.on('message', function(msg){
        console.log('message: '+ util.inspect(msg));
        client.sendMessage(msg);
    });

    client.on('custom-event', function(data){
        console.log('custom-event: '+ util.inspect(data));
        client.emit('custom-event', data);
    });
});


server.listen(8124, function(){
    console.log('Event Server bound')
});

Unity/C#

PHP код:


		
			
using System.Collections.Generic;
using BinarySerialization;
using UnityEngine;
using System.Collections;

public class EventServerClientTest : MonoBehaviour
{
    private EventServerClient _client;

    public void Start ()
    {
        _client = GetComponent<EventServerClient>();

        _client.On("connect", OnConnect);
        _client.On("welcome", OnWelcome);
        _client.On("custom-event", OnCustomEvent);


        _client.Connect();
    }

    private void OnCustomEvent(object obj)
    {
        Debug.Log("Custom Event Received: " + obj.ToDebugString());
    }

    private void OnWelcome(object obj)
    {
        var welcomeEvent = (Dictionary<string, object>) obj;
        Debug.Log("Welcome: " + welcomeEvent["id"]);
    }


    private void OnConnect(object obj)
    {
        Debug.Log("OnConnect");
        _client.Emit("custom-event", new object[]{1, true, "three"});
    }

}