socket.io с ExtJS и socket.io-клиентом - PullRequest
3 голосов
/ 15 декабря 2011

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

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

У меня этот код в качестве моего сервера.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 

Ответы [ 2 ]

1 голос
/ 27 декабря 2011

Две вещи

  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

0 голосов
/ 16 июля 2012

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

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

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

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...