node.js基于dgram数据报模块创建UDP服务器和客户端操作示例

本文实例讲述了node.js基于dgram数据报模块创建UDP服务器和客户端操作。分享给大家供大家参考，具体如下：

node.js中 dgram 模块提供了udp数据包的socket实现，可以方便的创建udp服务器和客户端。

一、创建UDP服务器和客户端

服务端：

const dgram = require('dgram');//创建upd套接字//参数一表示套接字类型，'udp4' 或 'udp6'//参数二表示事件监听函数，'message' 事件监听器let server = dgram.createSocket('udp4');//绑定端口和主机地址server.bind(8888, '127.0.0.1');//有新数据包被接收时，触发server.on('message', function (msg, rinfo) {  //msg表示接收到的数据  //rinfo表示远程主机的地址信息  console.log('接收到的数据 : ', msg.toString());  console.log(rinfo);  //发送数据，如果发送数据之前没有绑定过地址和端口，则会随机分配端口。  //参数一表示，要发送的数据 string或buffer  //参数二表示，发送数据的偏移量  //参数三表示，发送数据的字节数  //参数四表示，目标端口  //参数五表示，目标主机名或IP地址  //参数六表示，消息发送完毕后的回调函数  server.send('你好', 0, 6, rinfo.port, rinfo.address);});//开始监听数据包时，触发server.on('listening', function () {  console.log('监听开始');});//使用 close() 关闭socket之后触发server.on('close', function () {  console.log('关闭');});//发生错误时触发server.on('error', function (err) {  console.log(err);});

客户端：

const dgram = require('dgram');let client = dgram.createSocket('udp4');client.bind(3333, '127.0.0.1');client.on('message', function (msg, rinfo) {  console.log(msg.toString());});client.on('error', function (err) {  console.log(err);});//给8888端口的UDP发送数据client.send('你好', 0, 6, 8888, '127.0.0.1', function (error, bytes) {  if (error) {    console.log(error);  }  console.log(`发送了 ${bytes} 个字节数据`);});

udp中服务器与客户端并没有严格的划分，既可以作为服务器接收数据处理数据，也可以像客户端一样请求数据，彼此之间相对独立。

二、通过UDP服务器进行广播

我们知道一个IP地址是由网络地址和主机地址组成的，而广播IP的主机位全为1，当我们向一个广播IP发送数据时，则该数据将分发给所有同网段的主机。

服务端：

const dgram = require('dgram');let server = dgram.createSocket('udp4');//注意setBroadcast()必须在绑定socket成功后才能调用server.bind(8888, '192.168.1.102', function () {  //启用广播  server.setBroadcast(true);  server.setTTL(128);});server.on('message', function (msg, rinfo) {  console.log(msg.toString());  console.log(rinfo);});let buf = Buffer.from('广播数据');setInterval(function () {  //向广播IP发送数据  //注意客户端监听的端口要与这里的端口一致，不然无法接收到广播  server.send(buf, 0, buf.length, 6666, '192.168.1.255', function (error, bytes) {    if (error) {      console.log(error);    }    console.log(`发送 ${bytes} 个字节数据`);  });}, 3000);