Node.js：向服务器发送消息 [英] Node.js: send message to server

问题描述

我的服务器上运行了以下node.js：

I have the following node.js running on my server:

var net=require('net');
var util=require('util');

var server=net.createServer(function(conn){
    conn.on('connect',function(){
        util.puts('connect');
    });
    conn.on('data',function(data){
        util.puts(data);
    });
});
server.listen(5000,'172.16.1.197');

这个工作正常，我可以telnet到172.16.1.197:5000并且它的行为符合预期。

This works just fine and i can telnet to 172.16.1.197:5000 and it behaves as expected.

现在，我有一个客户端在另一个IP地址为172.16.1.218的盒子上运行，我只是想向服务器发送一条消息。

Now, I have a client running on another box with IP address 172.16.1.218 and I simply want to send a message to the server.

function sendAMessage(payLoad){
    //what to put in here?
}

payLoad应该打印在服务器端。

payLoad should get printed on the server side.

我知道这看起来很简单，但我真的无法理解它 - 我对node.js很新。

I know this seems so simple, but I really can't get my head around it - I'm quite new to node.js.

非常感谢提前，

添加一些代码：

这是客户端（172.16.1.218）：

Here's the client side (172.16.1.218):

var http = require('http');
var util=require('util');
var net=require('net');

var localHash={};
var chunkLength=100;

http.createServer(function(request, response) {
    var proxy = http.createClient(80, request.headers['host'])
    var proxy_request = proxy.request(request.method, request.url, request.headers);
    proxy_request.addListener('response', function (proxy_response) {
        proxy_response.addListener('data', function(x) {
            var responseData=x.toString("binary");
            var bytes=getBytes(responseData);
            util.puts(bytes.length);
            for(var i=0;i<bytes.length;i++){
                var hash=DJBHash(bytes[i]);
                //util.puts(hash);
                if(hash in localHash){
                    //in hash, send alias
                    //response.write("<EOH>"+hash+"</EOH>",'binary');
                    response.write(bytes[i],'binary');
                }else{
                    //not in hash, send full chunk
                    updateRemoteHash(hash,bytes[i]);
                    response.write(bytes[i],'binary');
                    localHash[hash]=bytes[i];

                }

            }
            //response.write(bytes,"binary");
        });
        proxy_response.addListener('end', function() {
            response.end();
        });
        response.writeHead(proxy_response.statusCode, proxy_response.headers);
    });
    request.addListener('data', function(chunk) {
        util.puts(chunk);
        proxy_request.write(chunk, 'binary');
    });
    request.addListener('end', function() {
        proxy_request.end();
    });
}).listen(8080,'172.16.1.218');


function getBytes(responseData){
    var f=chunkLength;
    var toTransmit="";
    var p=0;
    var bytes=Array();      

    var N=responseData.length;
    if(N>f){
        p=Math.floor(N/f);

        var hash="";
        var chunk="";
        for(var i=0;i<p;i++){
            chunk=responseData.substr(f*i,f);
            toTransmit=toTransmit+chunk;
            bytes[i]=chunk;
            /*hash=DJBHash(chunk);
            if(localHash[hash]==undefined){
                localHash[hash]=chunk;
                //updateRemoteHash(hash,chunk);
                toTransmit=toTransmit+chunk;
            }else{
                sys.puts("***hit"+chunk);
                toTransmit=toTransmit+chunk;//"***EOH"+hash;
            }*/
        }
        //remainder:
        chunk=responseData.substr(f*p);
        toTransmit=toTransmit+chunk;
        bytes[p]=chunk;
        /*hash=DJBHash(chunk);
        if(localHash[hash]==undefined){
            localHash[hash]=chunk;
            //updateRemoteHash(hash,chunk);
            toTransmit=toTransmit+chunk;
        }else{
            toTransmit=toTransmit+chunk;//"***EOH"+hash;
        }*/
    }else{
        toTransmit=responseData;
        bytes[0]=responseData;
    }
    return bytes;
}
function DJBHash(str) {
    var hash = 5381;
    for(var i = 0; i < str.length; i++) {
        hash = (((hash << 5) + hash) + str.charCodeAt(i)) & 0xffffffff;
    }
    if(hash<-1){
        hash=hash*-1;
    }
    return hash;
}

function updateRemoteHash(hash,chunk){
    var c=net.createConnection(5000,'172.16.1.197');
    c.on('connect',function(){
        c.write(hash);
        c.end();
    });
}

服务器端（172.16.1.197）：

And the server side (172.16.1.197):

var net=require('net');
var util=require('util');

var server=net.createServer(function(conn){
    conn.on('connect',function(){
        util.puts('connect');
    });
    conn.on('data',function(data){
        util.puts(data);
    });
});
server.listen(5000,'172.16.1.197');

推荐答案

你用过 net .createServer 设置TCP服务器。您现在需要使用 net.createConnection 连接到TCP服务器。

You've used net.createServer to set up a TCP server. You now need to use net.createConnection to connect to a TCP server.

function sendAMessage(msg) {
  var c = net.createConnection(5000, '172.16.1.218');
  c.on("connect", function() {
    // connected to TCP server.
    c.write(msg);
  });
}

这篇关于Node.js：向服务器发送消息的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！