Socket.get 回调未在 socket.on 函数中触发

Question

我已经在这个问题上停留了一段时间，答案可能非常基本，但我不明白问题出在哪里。 AFAIU 它执行了函数但没有触发回调，我不知道为什么。

我的脚本旨在让 tcp 服务器拥有连接 tcp 套接字的设备 (raspberry pi) 和客户端连接到 sailsjs 应用程序上的 websocket。

我设法在下面的代码中同时拥有这两个东西运行，问题是它们只能分开工作，同时但分开工作，当我尝试从套接字外部尝试时，一切正常，但是当我在套接字内部进行时, io.socket 对象只是在 requestQueue 中堆积 get 请求。

{ useCORSRouteToGetCookie: true,
  url: 'http://localhost:1337',
  multiplex: undefined,
  transports: [ 'polling', 'websocket' ],
  eventQueue: { 'sails:parseError': [ [Function] ] },
  query:'__sails_io_sdk_version=0.11.0&__sails_io_sdk_platform=node&__sails_io_sdk_language=javascript',
   _raw:
    { socket:
      { options: [Object],
        connected: true,
        open: true,
        connecting: false,
        reconnecting: false,
        namespaces: [Object],
        buffer: [],
        doBuffer: false,
        sessionid: '0xAlU_CarIOPQAGUGKQW',
        closeTimeout: 60000,
        heartbeatTimeout: 60000,
        origTransports: [Object],
        transports: [Object],
        heartbeatTimeoutTimer: [Object],
        transport: [Object],
        connectTimeoutTimer: [Object],
        '$events': {} },
     name: '',
     flags: {},
     json: { namespace: [Circular], name: 'json' },
     ackPackets: 0,
     acks: {},
     '$events':
      { 'sails:parseError': [Function],
        connect: [Object],
        disconnect: [Function],
        reconnecting: [Function],
        reconnect: [Function],
        error: [Function: failedToConnect],
        undefined: undefined } },
  requestQueue:
   [ { method: 'get', headers: {}, data: {}, url: '/', cb: [Function] },
     { method: 'get', headers: {}, data: {}, url: '/', cb: [Function] } ] }

代码如下：

//library to connect to sailsjs websockets
var socketIOClient = require('socket.io-client');
var sailsIOClient = require('sails.io.js');

//library to do the tcp server
var net = require('net');


// Instantiate the socket client (`io`)
// (for now, you must explicitly pass in the socket.io client when using this library from Node.js)
var io = sailsIOClient(socketIOClient);

// Set some options:
// (you have to specify the host and port of the Sails backend when using this library from Node.js)
io.sails.url = 'http://localhost:1337';



var server = net.createServer(function(tcpSocket) { //'connection' listener


    //socket was sucessfully connected
    console.log('client connected');

    //notify on deconnection
    tcpSocket.on('end', function() {
        console.log('client disconnected');
    });

 // Handle incoming messages from clients.
    tcpSocket.on('data', function (data) {


        console.log(data.toString('utf8', 0, data.length));

        //if data is PING respond PONG
        if(data.toString('utf8', 0, 4)=='PING'){
            console.log('I was pinged');
            tcpSocket.write('PONG\r\n'); 
        }

        console.log(io.socket);//debugging purpose
        //trigger a socket call on the sails app
        io.socket.get('/', function (body, JWR) {
            //display the result
            console.log('Sails responded with: ', body);
            console.log('with headers: ', JWR.headers);
            console.log('and with status code: ', JWR.statusCode);

        });
    });

});


server.listen(8124, function() { //'listening' listener
    console.log('server bound');
});

Answer 1

您的套接字似乎没有自动连接。尝试手动连接：

// Instantiate the socket client (`io`)
// (for now, you must explicitly pass in the socket.io client when using this library from Node.js)
var io = sailsIOClient(socketIOClient);

// Set some options:
// (you have to specify the host and port of the Sails backend when using this library from Node.js)
io.sails.url = 'http://localhost:1337';

var socket = io.sails.connect();

socket.on('connect', function() {

   ... connect TCP server and continue ...

});

Answer 2

我找到了一个解决方案，我刚刚摆脱了 sails.io.js 并使用了普通的 socket.io 它现在可以按预期工作尽管可以解释为什么它没有在 sails.io.js

//library to connect to sailsjs websockets
    var socketIOClient = require('socket.io-client');
    //var sailsIOClient = require('sails.io.js');

    //library to do the tcp server
    var net = require('net');


            var socket=socketIOClient.connect('http://localhost:1337', {
'force new connection': true
});

    var server = net.createServer(function(tcpSocket) { //'connection' listener

        //socket was sucessfully connected
        console.log('client connected');

        //notify on deconnection
        tcpSocket.on('end', function() {
            console.log('client disconnected');
        });

     // Handle incoming messages from clients.
        tcpSocket.on('data', function (data) {

            console.log(data.toString('utf8', 0, data.length));

            console.log(data.toString('utf8', 0, data.length));

            //if data is PING respond PONG
            if(data.toString('utf8', 0, 4)=='PING'){
                console.log('I was pinged');
                tcpSocket.write('PONG\r\n'); 
            }

            if(data.toString('utf8', 0, 4)=='test'){

                socket.emit('test',{message : 'test'});

             //io.socket.disconnect();
            }


        });

    });

Socket.get 回调未在 socket.on 函数中触发

Socket.get callback not triggered in socket.on function

node.js

sockets

tcp

sails.js

sails.io.js