Bringen Sie Ihnen Schritt für Schritt bei, wie Sie Node.js für die TCP-Netzwerkkommunikation verwenden (Übung)

Wie verwende ich Node.js für die TCP-Netzwerkkommunikation? Der folgende Artikel hilft Ihnen zu verstehen, wie Sie Node.js für die TCP-Netzwerkkommunikation verwenden.

Zusammenfassung: Das Netzwerk ist die Grundlage für Kommunikation und Verbindung. Node.js bietet Module wie net, http und dgram, die hauptsächlich zur Implementierung der TCP-, HTTP- und UDP-Kommunikation verwendet werden TCP-Kommunikation mit Node.js Einige Übungsaufzeichnungen. [Empfohlenes Lernen: „nodejs-Tutorial“]

1. Erstellen Sie einen TCP-Server

1.1. Verwenden Sie Node.js, um einen TCP-Server zu erstellen

Um Node.js zum Erstellen zu verwenden Um einen TCP-Server zu erstellen, müssen Sie zuerst require('net') aufrufen, um das Netzmodul zu laden, und dann die createServer-Methode des Netzmoduls aufrufen, um auf einfache Weise einen TCP-Server zu erstellen. Das Syntaxformat lautet wie folgt:

net.createServer([options][, connectionListener])
options是一个对象参数值，有两个布尔类型的属性allowHalfOpen和pauseOnConnect。这两个属性默认都是false；
connectionListener是一个当客户端与服务端建立连接时的回调函数，这个回调函数以socket端口对象作为参数。

1.2 . Client-Verbindungen überwachen

Verwenden Sie den TCP-Server. Die Listen-Methode kann mit der Überwachung der Client-Verbindung beginnen. Das Syntaxformat lautet wie folgt:

server.listen(port[, host][, backlog][, callback]);
port：为需要监听的端口号，参数值为0的时候将随机分配一个端口号；
host：服务器地址；
backlog：连接等待队列的最大长度；
callback：回调函数。

Der folgende Code kann einen TCP-Server erstellen und Port 8001 überwachen:

//引入net模块
const net = require('net');
//创建TCP服务器
const server = net.createServer(function (socket) {
    console.log('有新的客户端接入');
});
//设置监听端口
server.listen(8001, function () {
    console.log('服务正在监听中。。。')
});

Run In diesem Code können Sie die Rückruffunktion sehen, die die Listen-Methode auf der Konsole ausführt, wie im Bild gezeigt:

Sie können den entsprechenden TCP-Client oder das Debugging-Tool verwenden, um eine Verbindung zu diesem erstellten TCP-Server herzustellen. Wenn Sie beispielsweise Windows Telnet verwenden möchten, können Sie zum Herstellen einer Verbindung den folgenden Befehl verwenden:

telnet localhost 8001

Nachdem die Verbindung erfolgreich hergestellt wurde, können Sie sehen, dass die Konsole die Worte „Neuer Clientzugriff“ ausgibt, was darauf hinweist, dass die Rückruffunktion von Die Methode createServer wurde ausgeführt und zeigt an, dass eine erfolgreiche Verbindung mit dem erstellten TCP-Server hergestellt wurde. Die Methode

server.listen() löst tatsächlich das Abhörereignis unter dem Server aus, sodass Sie das Abhörereignis auch manuell überwachen können. Der Code lautet wie folgt:

//设置监听端口
server.listen(8001);
//设置监听时的回调函数
server.on('listening', function () {
    console.log("服务正在监听中。。。")
});

Zusätzlich zum Abhörereignis auch der TCP-Server unterstützt die folgenden Ereignisse:

connection：当有新的链接创建时触发，回调函数的参数为socket连接对象。
close：TCP服务器关闭的时候触发，回调函数没有参数。
error：TCP服务器发生错误的时候触发，回调函数的参数为error对象。

Der folgende Code verwendet die net.Server-Klasse, um einen TCP-Server zu erstellen und die oben genannten Ereignisse hinzuzufügen:

//引入net模块
const net = require('net');
//实例化一个服务器对象
const server = new net.Server();
//监听connection事件
server.on('connection', function (socket) {
    console.log('有新的客户端接入');
});
//设置监听端口
server.listen(8001);
//设置监听时的回调函数
server.on('listening', function () {
    console.log('服务正在监听中。。。');
});
//设置关闭时的回调函数
server.on('close', function () {
    console.log('服务已关闭');
});
//设置出错时的回调函数
server.on('error', function (err) {
    console.log('服务运行异常', err);
});

1.3 Zeigen Sie die Adresse an, auf die der Server lauscht

Nach dem Erstellen eines TCP-Server: Sie können die Methode server.address() verwenden, um die Adresse zu überprüfen, auf die der TCP-Server lauscht, und ein JSON-Objekt zurückzugeben. Da diese Methode die Adressinformationen zurückgibt, auf die der TCP-Server lauscht, sollte sie wann aufgerufen werden Die Methode server.listen() wird aufgerufen oder die Callback-Funktion im Event-Listening wird an die Methode gebunden. Die Eigenschaften dieses Objekts sind:

port：TCP服务器监听的端口号；
family：说明TCP服务器监听的地址是IPv6还是IPv4；
address：TCP服务器监听的地址。

Der Code lautet wie folgt:

//引入net模块
const net = require('net');
//创建TCP服务器
const server = net.createServer(function (socket) {
    console.log('有新的客户端接入');
});
//设置监听端口
server.listen(8001);
//设置监听时的回调函数
server.on('listening', function () {
    //获取地址信息
    let address = server.address();
    //获取地址详细信息
    console.log("服务器监听的端口是：" + address.port);
    console.log("服务器监听的地址是：" + address.address);
    console.log("服务器监听的地址类型是：" + address.family);
});

Das laufende Ergebnis ist wie folgt:

1.4. Die Anzahl der mit dem Server verbundenen Clients

Nach dem Erstellen eines TCP-Server, Sie können die Methode server.getConnections() verwenden, um die Anzahl der Clients abzurufen, die mit diesem TCP-Server verbunden sind. Diese Methode ist eine asynchrone Methode. Die Rückruffunktion verfügt über zwei Parameter:

第一个参数为error对象。
第二个参数为连接TCP服务器的客户端数量。

Zusätzlich zum Abrufen der Anzahl der Verbindungen können Sie auch die maximale Anzahl von Verbindungen für diesen TCP-Server festlegen, indem Sie das Attribut maxConnections des TCP-Servers festlegen. Wenn die Anzahl der Verbindungen die maximale Anzahl an Verbindungen überschreitet, lehnt der Server neue Verbindungen ab. Der folgende Code legt die maximale Anzahl von Verbindungen für diesen TCP-Server auf 3 fest.

//引入net模块
const net = require('net');
//创建TCP服务器
const server = net.createServer(function (socket) {
    console.log('有新的客户端接入');
    //设置最大连接数量
    server.maxConnections = 3;
    server.getConnections(function (err, count) {
        console.log("当前连接的客户端个数为：" + count);
    });
});
//设置监听端口
server.listen(8001, function () {
    console.log("服务正在监听中。。。")
});

Führen Sie diesen Code aus und versuchen Sie, eine Verbindung mit mehreren Clients herzustellen. Es kann festgestellt werden, dass neue Clients keine Verbindung zum Server herstellen können, wenn die Anzahl der Clientverbindungen 3 überschreitet, wie in der Abbildung gezeigt:

1.5 Rufen Sie die vom Client gesendeten Daten ab

createServer-Methode Der Callback-Funktionsparameter ist ein net.Socket-Objekt (das Portobjekt, das der Server abhört). Dieses Objekt verfügt auch über eine Address()-Methode, mit der die an den TCP-Server gebundene Adresse abgerufen wird die Port-, Familien- und Adressattribute. Die vom Client gesendeten Stream-Daten können über das Socket-Objekt abgerufen werden. Durch Abhören dieses Ereignisses können die vom Client gesendeten Daten abgerufen werden wie folgt:

//引入net模块
const net = require('net');
//创建TCP服务器
const server = net.createServer(function (socket) {
    //监听data事件
    socket.on("data", function (data) {
        //打印数据
        console.log("接收到数据：" + data.toString());
    });
});
//设置监听端口
server.listen(8001, function () {
    console.log("服务正在监听中。。。")
});

Die Testergebnisse lauten wie folgt:

Zusätzlich zu Datenereignissen verfügt das Socket-Objekt auch über Verbindungs-, End-, Fehler-, Timeout- und andere Ereignisse.

1.6. Daten an den Kunden senden

调用socket.write()可以使TCP服务器发送数据，这个方法只有一个必需参数，就是需要发送的数据；第二个参数为编码格式，可选。同时，可以为这个方法设置一个回调函数。当有用户连接TCP服务器的时候，将发送数据给客户端，代码如下：

//引入net模块
const net = require('net');
//创建TCP服务器
const server = net.createServer(function (socket) {
    //设置消息内容
    const message = "Hello Client......";
    //发送数据
    socket.write(message, function () {
        const writeSize = socket.bytesWritten;
        console.log("数据发送成功，数据长度为：" + writeSize);
    });

    //监听data事件
    socket.on("data", function (data) {
        const readSize = socket.bytesRead;
        //打印数据
        console.log("接收到数据为：" + data.toString(), "；接收的数据长度为：" + readSize);
    });
});
//设置监听端口
server.listen(8001, function () {
    console.log("服务正在监听中。。。")
});

测试结果如下：

在上面这段代码中还用到了socket对象的bytesWritten和bytesRead属性，这两个属性分别代表着发送数据的字节数和接收数据的字节数。除了上面这两个属性外，socket对象还有以下属性：

socket.localPort：本地端口的地址;
socket.localAddress：本地IP地址;
socket.remotePort：进程端口地址;
socket.remoteFamily：进程IP协议族;
socket.remoteAddress：进程IP地址。

2、构建TCP客户端

Node.js在创建一个TCP客户端的时候同样使用的是net（网络）模块。

2.1、使用Node.js创建TCP客户端

为了使用Node.js创建TCP客户端，首先要调用require(‘net’)来加载net模块。创建一个TCP客户端只需要创建一个连接TCP客户端的socket对象即可：

//引入net模块
const net = require('net');
//创建TCP客户端
const client = new net.Socket();

创建一个socket对象的时候可以传入一个json对象。这个对象有以下属性：

fd：指定一个存在的文件描述符，默认值为null；
readable：是否允许在这个socket上读，默认值为false；
writeable：是否允许在这个socket上写，默认值为false；
allowHalfOpen：该属性为false时，TCP服务器接收到客户端发送的一个FIN包后，将会回发一个FIN包；该属性为true时，TCP服务器接收到客户端发送的一个FIN包后不会回发FIN包。

2.2、连接TCP服务器

创建了一个socket对象后，调用socket对象的connect()方法就可以连接一个TCP服务器，代码如下：

//引入net模块
const net = require('net');
//创建TCP客户端
const client = new net.Socket();
//设置连接的服务器
client.connect(8001, '127.0.0.1', function () {
    console.log("连接服务器成功");
});

连接成功如下图所示：

2.3、获取从TCP服务器发送的数据

socket对象有data、error、close、end等事件，因可以通过监听data事件来获取从TCP服务器发送的数据，代码如下：

//引入net模块
const net = require('net');
//创建TCP客户端
const client = new net.Socket();
//设置连接的服务器
client.connect(8001, '127.0.0.1', function () {
    console.log("连接服务器成功");
});
//监听data事件
client.on("data", function (data) {
    //打印数据
    console.log("接收到数据为：" + data.toString());
});

先启动TCP服务端，再运行上面客户端，可以发现命令行中已经输出了来自服务端的数据，说明此时已经实现了服务端和客户端之间的通信：

2.4、向TCP服务器发送数据

因为TCP客户端是一个socket对象，所以可以使用以下代码来向TCP服务器发送数据：

//引入net模块
const net = require('net');
//创建TCP客户端
const client = new net.Socket();
//设置连接的服务器
client.connect(8001, '127.0.0.1', function () {
    console.log("连接服务器成功");
    //给服务端发送数据
    client.write("Hello Server......");
});
//监听data事件
client.on("data", function (data) {
    //打印数据
    console.log("接收到数据为：" + data.toString());
});
//监听end事件
client.on("end", function () {
    console.log("客户端发送数据结束")
});

客户端控制台输出：

服务端控制台输出：

至此使用Node.js进行TCP网络通信完成，如有不对的地方欢迎指正。

原文地址：https://bbs.huaweicloud.com/blogs/300544?utm_source=juejin&utm_medium=bbs-ex&utm_campaign=other&utm_content=content

作者：lwq1228

更多编程相关知识，请访问：编程视频！！

Das obige ist der detaillierte Inhalt vonBringen Sie Ihnen Schritt für Schritt bei, wie Sie Node.js für die TCP-Netzwerkkommunikation verwenden (Übung). Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!