socket.io с ExtJS и socket.io-клиент

Это должно быть довольно тривиально, но по какой-то причине у меня возникли небольшие проблемы с подключением ExtJS4 к службе socket.io/node.js (с использованием последних версий npm и node 0.6.3). Я пытаюсь отправить сообщение на свой сервер. Он рукопожатия, но никогда не попадает в блок сообщений. Я использую «emit», чтобы отправить его из socket.io-client, но не повезло. Любая идея, что я делаю неправильно?

У меня есть весь мой код (разветвленный от Nils Dehl, отличный example) и выполнить отладку с сервера следующим образом...

У меня есть этот код как мой server.js:

var http = require('http'),
           sys  = require('util'),
           fs   = require('fs'),
           io   = require('socket.io');
var Connect = require('connect');

var server = Connect.createServer(
        Connect.logger(), // Log responses to the terminal using Common Log Format.
        Connect.staticCache(), // Add a short-term ram-cache to improve performance.
        Connect.profiler(), 
        Connect.favicon(),
        Connect.static(__dirname + "/public") // Serve all static files in the current dir.
);
var sockets = io.listen(server);
server.listen(4000);

sockets.on('connection', function(socket) {
console.log("Receiving msg...");
        var user;

        socket.on('message', function(message) {
                if (!user) {
                        user = message;
                        socket.send({ message: 'Welcome, ' + user.nickname + '!', nickname: 'server', gravatar: '' });
                        return;
                }
                var response = {
                        'nickname': user.nickname,
                        'gravatar': user.gravatar,
                        'message': message.replace(/&/g,"&amp;").replace(/</g,"&lt;").replace(/>/g,"&gt;")
                };
                sockets.emit(response);
        });

});

Затем на стороне клиента я использую ExtJS и socket.io-client для отправки сообщения. Мой интерфейс в ExtJS для вызова socket-io.client выглядит так:

App.util.Socketio = Ext.extend(Ext.util.Observable, { 
        constructor: function(options){ 
                options = options || {}; 
                App.util.Socketio.superclass.constructor.call( 
                        this 
                ); 
                this.socket = new io.Socket(options); 
                var that = this; 
                this.socket.on('connect', function(){ 
                        that.onConnect(); 
                }); 
                this.socket.on('message', function(data){ 
                        that.onMessage(data); 
                }); 
                this.socket.on('close', function(){ 
                        that.onClose(); 
                }); 
                this.socket.on('disconnect', function(){ 
                        that.onDisconnect(); 
                }); 
        }, 
        connect: function() { 
                this.socket.connect(); 
        }, 
        disconnect: function(){ 
                this.socket.disconnect(); 
        }, 
        send: function(message) { 
                this.socket.emit(message); 
        }, 
        onConnect: function() { 
                this.fireEvent('connect'); 
        }, 
        onDisconnect: function() { 
                this.fireEvent('disconnect'); 
        }, 
        onClose: function() { 
                this.fireEvent('close'); 
        }, 
        onMessage: function(message) { 
                this.fireEvent('message', message); 
        } 
}); 

Вот что я вижу на выходе:

info  - socket.io started 
   debug - client authorized 
   info  - handshake authorized 16300591002012036186 
   debug - client authorized 
   info  - handshake authorized 4532571941614163017 
   debug - setting request GET /socket.io/1/websocket/ 
16300591002012036186 
   debug - set heartbeat interval for client 16300591002012036186 
   debug - client authorized for 
   debug - websocket writing 1:: 
   debug - setting request GET /socket.io/1/websocket/ 
4532571941614163017 
   debug - set heartbeat interval for client 4532571941614163017 
   debug - client authorized for 
   debug - websocket writing 1:: 
   debug - emitting heartbeat for client 16300591002012036186 
   debug - websocket writing 2:: 
   debug - set heartbeat timeout for client 16300591002012036186 
   debug - emitting heartbeat for client 4532571941614163017 
   debug - websocket writing 2:: 
   debug - set heartbeat timeout for client 4532571941614163017 
   debug - got heartbeat packet 
   debug - cleared heartbeat timeout for client 16300591002012036186 
   debug - set heartbeat interval for client 16300591002012036186 
   debug - fired heartbeat timeout for client 4532571941614163017 
   info  - transport end 
   debug - set close timeout for client 4532571941614163017 
   debug - cleared close timeout for client 4532571941614163017 
   debug - discarding transport 

person occasl    schedule 15.12.2011    source источник


Ответы (2)


Две вещи

  1. Вместо socket.send({ message: 'Welcome, ' + user.nickname + '!', nickname: 'server', gravatar: '' }) измените это на socket.emit(hello, { message: 'Welcome, ' + user.nickname + '!', nickname: 'server', gravatar: '' }. Вы должны использовать emit для отправки JSON

    Пример — https://github.com/parj/node-websocket-demo/blob/socket_emit/server.js

  2. Для socket.emit вам нужно использовать пользовательское событие - sockets.emit('response', response);

На стороне клиента для

  1. Со ссылкой на - socket.emit(hello, { message: 'Welcome, ' + user.nickname + '!', nickname: 'server', gravatar: '' }

    socket.on('hello', function (data) {
       $('#message').text("Received - " + data.message);
     });
    
  2. Со ссылкой на - sockets.emit('response', response);

    socket.on('resonse', function (data) {
       $('#message').text("Received - " + data.response);
     });
    

socket.send предназначен только для отправки строки - Пример socket.send("Hello");

Полный рабочий пример socket.send см. в https://github.com/parj/node-websocket-demo Для socket.emit см. - https://github.com/parj/node-websocket-demo/tree/socket_emit/public

person First Zero    schedule 27.12.2011

Я сделал расширение WebSocket для ExtJS: ExtJS-WebSocket

А вот и обсуждение на форуме: Sencha Forum

Может быть интересно ;)

person Wilk    schedule 16.07.2012