Javascript Node.js和Socket.IO广播服务器

Question

我只需要一个简单的例子来说明如何做一个Node.JS服务器，我会解释一下。

基本上Node.js的将有2台服务器上运行： - 粗TCP服务器和 - 一个Socket.IO服务器 的目的是从一个TCP客户端将数据转发给感兴趣

各种Socket.IO客户

这样做的原因是为了方便与其他语言进行通信（我将有一个java服务器在tcp套接字中发送消息，因为我找不到更好的方法来做到这一点 - 所有可用的java库（套接字.io服务器和用java实现的客户端）都有bug，因为几乎每种语言都有套接字API。

TCP客户端将在连接后立即发送一个字符串，并且Node.JS服务器将为其创建一个名称空间并为其提供数据，以便Socket.IO客户端必须能够接收服务器将从TCP客户端。

步骤：

• 监听TCP连接

• 在一个新的TCP连接从客户端

• 收到一个字符串创建一个名为字符串命名空间的Socket.IO服务器由tcp客户端提供

• 开始从TCP客户端接收数据并将其广播到全部ËSocket.IO客户conected到在此套接字打开

这已经在各种TCP客户端和Socket.IO客户端可以通信的方式进行时创建的命名空间

我不能找到如何以有效的方式做到这一点，如果有人可以提供一个简单的例子，我相信它会帮助很多人（如Node.JS和Socket.IO缺乏文档），这很容易使人们已经知道的ppl主题。

谢谢。

---

UPDATE：

我做到了：

的Node.js代码：

var javaPort = 8080; 
var sIOPort = 8081; 
var javaServer = require('net').createServer(); 
var browserServer = require('socket.io').listen(sIOPort); 

console.log('Socket.IO version: ' + require('socket.io').version); 

javaServer.on('listening', function() { 
    console.log('Server is listening on ' + javaPort); 
}); 

javaServer.on('error', function (e) { 
    console.log('Server error: ' + e.code); 
}); 

javaServer.on('close', function() { 
    console.log('Server closed'); 
}); 

javaServer.on('connection', function (javaSocket) { 
    var clientAddress = javaSocket.address().address + ':' + javaSocket.address().port; 
    console.log('Java ' + clientAddress + ' connected'); 

    var firstDataListenner = function (data) { 
     console.log('Received namespace from java: ' + data); 
     javaSocket.removeListener('data', firstDataListenner); 
     createNamespace(data, javaSocket); 
    } 

    javaSocket.on('data', firstDataListenner); 

    javaSocket.on('close', function() { 
     console.log('Java ' + clientAddress + ' disconnected'); 
    }); 
}); 

javaServer.listen(javaPort); 

function createNamespace(namespaceName, javaSocket) { 
    var browserConnectionListenner = function (browserSocket) { 
     console.log('Browser Connected'); 
     var javaSocketDataListenner = function(data) { 
      console.log('Data received from java socket and sent to browser: ' + data); 
      browserSocket.emit('m', data + '\r\n'); 
     } 

     var javaSocketClosedListenner = function() { 
      console.log('The java socket that was providing data has been closed, removing namespace'); 
      browserSocket.disconnect(); 
      browserServer.of('/' + namespaceName).removeListener('connection', browserConnectionListenner); 
      javaSocket.removeListener('data', javaSocketDataListenner); 
      javaSocket.removeListener('close', javaSocketClosedListenner); 
     } 

     javaSocket.on('close', javaSocketClosedListenner); 
     javaSocket.on('data', javaSocketDataListenner); 

     browserSocket.on('disconnect', function() { 
      console.log('Browser Disconnected'); 
      javaSocket.removeListener('data', javaSocketDataListenner); 
      javaSocket.removeListener('close', javaSocketClosedListenner); 
     }); 
    } 

    var namespace = browserServer.of('/' + namespaceName).on('connection', browserConnectionListenner); 
} 

java代码：

import java.io.ByteArrayOutputStream; 
import java.io.IOException; 
import java.io.InputStream; 
import java.net.Socket; 

public class Client { 

    public static void main(String[] args) { 
     try { 
      Socket nodejs = new Socket("localhost", 8080); 
      sendMessage(nodejs, "testnamespace"); 
      Thread.sleep(100); 
      int x = 0; 
      while (true) 
      { 
       sendMessage(nodejs, x + ""); 
       x++; 
       Thread.sleep(1000); 
       System.out.println(x + " has been sent to server"); 
      } 
     } catch (Exception e) { 
      e.printStackTrace(); 
     } 
    } 

    public static void sendMessage(Socket s, String message) throws IOException { 
     s.getOutputStream().write(message.getBytes("UTF-8")); 
     s.getOutputStream().flush(); 
    } 

    public static String readMessage(Socket s) throws IOException { 
     InputStream is = s.getInputStream(); 
     int curr = -1; 
     ByteArrayOutputStream baos = new ByteArrayOutputStream(); 
     while ((curr = is.read()) != -1) { 
      if (curr == '\n') { 
       break; 
      } 
      baos.write(curr); 
     } 
     return baos.toString("UTF-8"); 
    } 
} 

的html代码：

<html> 
    <head> 
    <script src="socket.io.js"></script> 
    </head> 
    <body> 
    <script> 
     var socket = io.connect("http://localhost/testnamespace", {port: 8081}); 
     console.log(io.version); 
     socket.on('connect', function() { 
      console.log('Connected'); 
      }); 
     socket.on('m', function (msg) { 
      console.log('Message received: ' + msg); 
     }); 
     socket.on('disconnect', function() { 
      console.log('Disconnected'); 
     }); 
    </script> 
    </body> 
</html> 

工作原理：

Java的连接不上的NodeJS TCP套接字然后发送一个命名空间名称，创建的NodeJS与命名空间的socket.io服务器转发所有消息的java插座发送给所有的客户socket.io连接到该名称空间

如果任何人看到可能发生的错误或改进请分享。

感谢

Answer 1

我正在做一个类似的应用程序，而不是使用TCP我使用ZeroMQ在TCP之上。这段代码很简单。

看看我的代码在这里： https://github.com/EhevuTov/netPeek

务必：

$:node support/msu_gen.js 
$:node app.js 

我希望帮助。

作为一个方面说明，我不认为我的回调函数执行得当。我想我每次消息传递时都设置on事件对象。如果您找到更好的方法，请提交修复请求。 :-)