6

我是 node.js 的新手，所以如果这很简单，请原谅我的无知。

我想要做的是设置一个简单的 node.js http 服务器，一个 web 客户端连接到该服务器。我还希望 node.js 服务器充当单独端口上的 UDP 侦听器，在该端口上它将接收来自其他应用程序的 JSON 有效负载。我希望 node.js 服务器将这些 JSON 有效负载立即转发到一个或多个连接的 Web 客户端。

我与最初的谷歌搜索相差甚远：

  1. 创建一个简单的 node.js http 服务器，它以静态 html 页面响应：

    //Initialize the HTTP server on port 8080, serve the index.html page
var server = http.createServer(function(req, res) {
    res.writeHead(200, { 
        'Content-type': 'text/html'});
        res.end(fs.readFileSync(__dirname + '/index.html'));
    }).listen(8080, function() {
        console.log('Listening at: 127.0.0.1 8080');
    }
);

  2. 在单独的端口上初始化 UDP 服务器：

    //Initialize a UDP server to listen for json payloads on port 3333
var srv = dgram.createSocket("udp4");
srv.on("message", function (msg, rinfo) {
  console.log("server got: " + msg + " from " + rinfo.address + ":" + rinfo.port);
  io.sockets.broadcast.emit('message', 'test');
  //stream.write(msg);
  //socket.broadcast.emit('message',msg);
});

srv.on("listening", function () {
  var address = srv.address();
  console.log("server listening " + address.address + ":" + address.port);
});

srv.bind(5555);

  3. 使用 socket.io 在 web 客户端和服务器之间建立实时连接：

    //this listens for socket messages from the client and broadcasts to all other clients
var io = require('socket.io').listen(server);
io.sockets.on('connection', function (socket) {
    socket.on('message', function (msg) {
      console.log('Message Received: ', msg.data.skeletons[0] ? msg.data.skeletons[0].skeleton_id : '');
      socket.broadcast.emit('message', msg);
    }
  );
});

我想我的问题是我不知道如何桥接 2 和 3，以便将接收到的 UDP 数据包广播到连接的 socket.io 客户端。或者也许有一种更简单、更优雅的方式来做到这一点？我发现缺少 socket.io 的文档...

编辑：感谢修复代码格式的人

4

1 回答 1

12

我为你做了一个运行示例：http ://runnable.com/UXsar5hEezgaAACJ

现在它只是一个环回客户端 -> socket.io -> udp 客户端 -> udp 服务器 -> socket.io -> 客户端。

这是它的核心：

var http = require('http');
var fs = require('fs');
var html = fs.readFileSync(__dirname + '/index.html');

//Initialize the HTTP server on port 8080, serve the index.html page
var server = http.createServer(function(req, res) {
  res.writeHead(200, { 
    'Content-type': 'text/html'
  });
  res.end(html);
}).listen( process.env.OPENSHIFT_NODEJS_PORT, process.env.OPENSHIFT_NODEJS_IP, function() {
  console.log('Listening');
});

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

io.set('log level', 0);

io.sockets.on('connection', function (socket) {
  socket.emit('message', 'connected');
  socket.on('message', function (data) {
    console.log(data);
    var address = srv.address();
    var client = dgram.createSocket("udp4");
    var message = new Buffer(data);
    client.send(message, 0, message.length, address.port, address.address, function(err, bytes) {
      client.close();
    });
  });
});

var dgram = require('dgram');

//Initialize a UDP server to listen for json payloads on port 3333
var srv = dgram.createSocket("udp4");
srv.on("message", function (msg, rinfo) {
  console.log("server got: " + msg + " from " + rinfo.address + ":" + rinfo.port);
  io.sockets.emit('message', 'udp');
});

srv.on("listening", function () {
  var address = srv.address();
  console.log("server listening " + address.address + ":" + address.port);
});

srv.on('error', function (err) {
  console.error(err);
  process.exit(0);
});

srv.bind();
于 2013-04-27T00:53:20.377 回答