0

这可能是一个简单的错误。我有一个运行 socket.io 的 nodejs 服务器，我已经在服务器中完成了所有工作。

但是，我希望能够通过 PHP 将 CURL 发布到节点服务器，并让它发出数据。我可以让服务器接收请求，但是当我尝试发出数据时，我收到一个错误，指出未定义套接字。

这在我的代码中很明显。我的问题是，在设置服务器之前如何要求 socket.io？希望我的代码段将有助于解释我的问题：

var http = require('http')
, url = require('url')
, fs = require('fs')
, server;

server = http.createServer(function(req, res) {
// your normal server code
var path = url.parse(req.url).pathname;
switch (path){
   case '/':
     res.writeHead(200, {'Content-Type': 'text/html'});
     res.write('<h1>Hello! <a href="/index.html">Enter</a></h1>');
     res.end();
     break;
   case '/index.html':
     fs.readFile(__dirname + path, function(err, data){
        if (err) return send404(res);
        res.writeHead(200, {'Content-Type': path == 'json.js' ? 'text/javascript' : 'text/html'})
        res.write(data, 'utf8');
        res.end();
     });
    break;
   case '/write.html':
     fs.readFile(__dirname + path, function(err, data){
        if (err) return send404(res);
        res.write(data, 'utf8');
        res.end();
     });
   break;
  case '/post':
     console.log(req.toString());
     socket.broadcast.emit('user', {state: 'PHP Post', userid: 'PHP'});
     res.writeHead(200);
     res.end();
   break;

  default: send404(res);
}
}),

send404 = function(res){
   res.writeHead(404);
   res.write('404');
   res.end();
};

server.listen(843);

// socket.io 
var io = require('socket.io').listen(server);

// Regular socket.io events
4

1 回答 1

3

在设置服务器之前如何要求 socket.io？

那部分很简单；在文件的顶部，执行以下操作：

var http = require('http')
, url = require('url')
, fs = require('fs')
, socketIO = require('socket.io')  // <-- added line
, server;

在底部：

var io = socketIO.listen(server);

问题是，在您的POST处理程序中，您正在使用socket.broadcast.emit，但socket未定义。您是否尝试向所有Socket.IO 用户发送消息？如果是这样，您可以使用io.sockets.emit; 我可能会做这样的事情：

var http = require('http')
, url = require('url')
, fs = require('fs')
, server
, io;

...

case '/post':
   console.log(req.toString());
   io.sockets.emit('user', {state: 'PHP Post', userid: 'PHP'});
   res.writeHead(200);
   res.end();
 break;

...

io = require('socket.io').listen(server);

如果您尝试将数据发送到单个套接字或除特定套接字之外的每个套接字（这是您通常使用的socket.broadcast方式），您将需要以某种方式将 HTTP 请求映射到 Socket.IO 套接字；为此使用会话很常见。

于 2012-09-18T16:02:31.130 回答