在node.js中创建TCP服务器与HTTP服务器之间的WebSockets。

Question

在node.js中创建TCP服务器与HTTP服务器之间的WebSockets。

node.jswebsocketsocket.iotcpserverhttpserver

7

我使用Node.js创建了一个TCP服务器，用于监听客户端连接。我需要通过Websocket（socket.io）将数据从TCP服务器传输到HTTP服务器中。但是，我不知道如何创建这样的连接，以使TCP服务器能够通过Websocket向HTTP服务器推送数据。非常感谢。

- Ravish

你可以使用socket.io-client来连接使用socket.io的HTTP服务器。 - nguyenkha

@nguyenkha：你能帮我提供一下代码示例吗？ - Ravish

从socket.io示例http://socket.io/#how-to-use中获取客户端的代码，只包括JavaScript部分和`var io = require('socket.io-client');`。 - nguyenkha

3个回答

2

如果需要进行服务器间通信，WebSockets 可能不是最佳选择。可以尝试使用其中一个RPC 库，或者只使用 HTTP 或自己的协议。请注意，保留了 HTML 标签。

- Andrey Sidorov

嘿，谢谢 @Andrey 和 rdrey。虽然我已经在Node.js中使TCP和HTTP服务器之间的套接字工作了，但是在这种情况下，我肯定会尝试使用RPC库。非常感谢。 :) - Ravish

0

您可以在 Node.js 上使用 socket.io 或 ws（仅限 WebSocket）作为客户端（不仅可以在浏览器中使用）

var io = require('socket.io-client');
var socket = io.connect('http://IP address of Websocket server');
socket.on('news', function (data) {
  console.log(data);
  socket.emit('my other event', { my: 'data' });
});

- nguyenkha

我尝试过这个。然而，问题在于它无法与在Node.js上创建的TCP服务器进行通信。即 var app = require('net').createServer(handle); 但是当我将其更改为http时，它可以工作。 - Ravish

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Ravish · Accepted Answer

我尝试了很多方法来让它工作。大多数时候，我依靠 socket.io 来使其正常工作，但是它在使用 TCP 时无法正常运行。

然而，net.Socket 能够满足需求。

以下是可行的示例。

TCP 服务器

var net = require('net');

var HOST = 'localhost';
var PORT = 4040;

var server = net.createServer();
server.listen(PORT, HOST);

server.on('connection', function(sock) {
    console.log('CONNECTED: ' + sock.remoteAddress +':'+ sock.remotePort);
sock.write("TCP sending message : 1");
    console.log('Server listening on ' + server.address().address +':'+ 
        server.address().port);
}).listen(PORT, HOST);

HTTP Server

var http = require('http').createServer(httpHandler),
    fs = require("fs"),
    wsock = require('socket.io').listen(http),
    tcpsock = require('net');

var http_port = 8888;

var tcp_HOST = 'localhost';
var tcp_PORT = 4040;

/**
 * http server
 */
function httpHandler (req, res) {
  fs.readFile(__dirname + '/index.html',
  function (err, data) {
    if (err) {
      res.writeHead(500);
      return res.end('Error loading index.html');
    }

    res.writeHead(200);
    res.end(data);
  });
}

http.listen(http_port);
console.info("HTTP server listening on " + http_port);

wsock.sockets.on('connection', function (socket) { 

    var tcpClient = new tcpsock.Socket();
    tcpClient.setEncoding("ascii");
    tcpClient.setKeepAlive(true);

    tcpClient.connect(tcp_PORT, tcp_HOST, function() {
        console.info('CONNECTED TO : ' + tcp_HOST + ':' + tcp_PORT);

        tcpClient.on('data', function(data) {
            console.log('DATA: ' + data);
            socket.emit("httpServer", data);
        });

        tcpClient.on('end', function(data) {
            console.log('END DATA : ' + data);
        });
    });

    socket.on('tcp-manager', function(message) {
        console.log('"tcp" : ' + message);
        return;
    });

    socket.emit("httpServer", "Initial Data");
});

浏览器客户端

<script src="/socket.io/socket.io.js"></script>
<script>
  var socket = io.connect('http://localhost');
  socket.on('httpServer', function (data) {
    console.log(data);
    document.write(data + "\r\n");
    socket.emit('tcp', "For TCP");
  });
</script>

在Node.js中，HTTP服务器和TCP服务器之间会打开一个套接字。