【课程笔记】Node.js：Socket通信

本文介绍: 有关Nod e.js中的Soc k e t 通信的学习

一、建立监听 服务（接收 客户端 响应，并返回给客户端 数据）

有状态：客户端和服务端直接可以进行多个回合的通信

无状态：客户端和服务端一般只进行一个回合的通信

require(‘net‘);

demo1 创建 监听 服务，用来 接收 客户端的响应，并返回给客户端数据

注意：创建服务端Soc k e t，要指定一个端口号（Po rt）

代码如下：

var net = require('net');
var server = net.createServer(function(socket){
    console.log('客户端与服务器端连接已经建立');
    //接收客户端数据，并向客户端返回数据
    socket.on('data', function(data){
        console.log(data.toString());  //data是buffer,必须转换
        socket.write('hello');  //服务端接收到客户端数据之后返回给客户端"hello"
    });
    socket.on('end', function(){
        console.log('连接中断');
    });
});
server.listen(4567, 'localhost', function(){   //指定localhost，只有本地能访问
    address = server.address();
    console.log('被监听的地址信息为：%j', address);
});

运行结果：

（1）先启动 so cket_server.js：node so cket_server.js

（2）另开一个窗口，输入：telnet 127.0.0.1 4567，连接服务器

（3）客户端连接服务器成功后，输入：I am Ch in ese，回车，发送消息给客户端

（4）最终，服务端显示客户端的I am Chin s es 消息，并返回 hello给客户端，客户端显示服务器的响应消息：hello

二、建立客户端Socket

net.connect(p ort, host, callback

代码如下：

服务器端同上，（可不指定本地 ip，即server.listen中去掉 local host）

客户端代码如下：

var net = require('net');
var client = net.connect('4567', 'localhost', function(){
    console.log('已经与服务器连接');
    client.write('Yesrn');
});
client.on('data', function(data){
    console.log(data.toString());
    client.end();
});
client.on('end', function(){
    console.log('客户端连接中断');
});

运行结果：

（1）先启动 server：no de socket_server.js

（2）再另开一个窗口，启动 client：no de socket_client.js

三、使用 服务端Socket建立HTTP服务器

HTTP/1.1 OKrn

Content-Ty pe: text/htmlrn

Content-length

demo httpserver.js

var net = require('net');
var server = net.createServer(function(socket){
    socket.on('data', function(data){
        console.log(data.toString());
        socket.write("HTTP/1.1 OKrn");
        socket.write("Content-Type:text/htmlrn");
        var s = "<h1>Hello World</h1>"
        socket.write("Content-length:" + s.length + "rnrn");
        socket.end(s);
    });
    socket.on('end', function(){
        console.log('连接中断');
    });
});
server.listen(4567, 'localhost', function(){
    address = server.address();
    console.log('被监听的地址信息为%j', address);
});

运行结果：

四、建立UDP服务端和客户端

UDP和TCP

有关dg ram 模块

demo

udp server.js

var dgram = require('dgram');
var server = dgram.createSocket('udp4');
server.on("message", function(msg, info){
    console.log("msg:" + msg + ' from ' + info.address + ":" + info.port);
});
server.on("listening", function(){
    var addr = server.address();
    console.log('server listening:' + addr.address + ":" + addr.port);
});
server.bind(12345, 'localhost');

udp client.js

var dgram = require('dgram');
var message = new Buffer("Node.js高级培训");
var client = dgram.createSocket("udp4");
client.send(message, 0, message.length, 12345, "localhost", function(err, bytes){
    client.close();
});