const dgram = require('dgram');
//創(chuàng)建upd套接字
//參數(shù)一表示套接字類型，'udp4' 或 'udp6'
//參數(shù)二表示事件監(jiān)聽函數(shù)，'message' 事件監(jiān)聽器
let server = dgram.createSocket('udp4');
//綁定端口和主機(jī)地址
server.bind(8888, '127.0.0.1');
//有新數(shù)據(jù)包被接收時(shí)，觸發(fā)
server.on('message', function (msg, rinfo) {
  //msg表示接收到的數(shù)據(jù)
  //rinfo表示遠(yuǎn)程主機(jī)的地址信息
  console.log('接收到的數(shù)據(jù) : ', msg.toString());
  console.log(rinfo);
  //發(fā)送數(shù)據(jù)，如果發(fā)送數(shù)據(jù)之前沒有綁定過地址和端口，則會(huì)隨機(jī)分配端口。
  //參數(shù)一表示，要發(fā)送的數(shù)據(jù) string或buffer
  //參數(shù)二表示，發(fā)送數(shù)據(jù)的偏移量
  //參數(shù)三表示，發(fā)送數(shù)據(jù)的字節(jié)數(shù)
  //參數(shù)四表示，目標(biāo)端口
  //參數(shù)五表示，目標(biāo)主機(jī)名或IP地址
  //參數(shù)六表示，消息發(fā)送完畢后的回調(diào)函數(shù)
  server.send('你好', 0, 6, rinfo.port, rinfo.address);
});
//開始監(jiān)聽數(shù)據(jù)包時(shí)，觸發(fā)
server.on('listening', function () {
  console.log('監(jiān)聽開始');
});
//使用 close() 關(guān)閉socket之后觸發(fā)
server.on('close', function () {
  console.log('關(guān)閉');
});
//發(fā)生錯(cuò)誤時(shí)觸發(fā)
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發(fā)送數(shù)據(jù)
client.send('你好', 0, 6, 8888, '127.0.0.1', function (error, bytes) {
  if (error) {
    console.log(error);
  }
  console.log(`發(fā)送了 ${bytes} 個(gè)字節(jié)數(shù)據(jù)`);
});

const dgram = require('dgram');
let server = dgram.createSocket('udp4');
//注意setBroadcast()必須在綁定socket成功后才能調(diào)用
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('廣播數(shù)據(jù)');
setInterval(function () {
  //向廣播IP發(fā)送數(shù)據(jù)
  //注意客戶端監(jiān)聽的端口要與這里的端口一致，不然無法接收到廣播
  server.send(buf, 0, buf.length, 6666, '192.168.1.255', function (error, bytes) {
    if (error) {
      console.log(error);
    }
    console.log(`發(fā)送 ${bytes} 個(gè)字節(jié)數(shù)據(jù)`);
  });
}, 3000);

const dgram = require('dgram');
let client = dgram.createSocket('udp4');
//如果監(jiān)聽不到廣播數(shù)據(jù)，設(shè)置成 0.0.0.0 看看
client.bind(6666, '192.168.1.111');
client.on('message', function (msg, rinfo) {
  console.log(msg.toString());
});

const dgram = require('dgram');
//組播地址
const multicastAddr = '224.1.1.1';
let server = dgram.createSocket('udp4');
//注意setMulticastLoopback()要在綁定成功后設(shè)置
server.bind(8888, '192.168.1.102', function () {
  //設(shè)置數(shù)據(jù)包的生存時(shí)間
  server.setMulticastTTL(128);
  //將socket加入組播組中
  server.addMembership(multicastAddr);
  //開啟組播
  server.setMulticastLoopback(true);
});
server.on('message', function (msg, rinfo) {
  console.log(msg.toString());
});
let buf = Buffer.from('組播數(shù)據(jù)');
setInterval(function () {
  //向組播IP發(fā)送數(shù)據(jù)
  //注意，客戶端監(jiān)聽的端口要與這里一致
  server.send(buf, 0, buf.length, 6666, multicastAddr, function (error, bytes) {
    console.log(`發(fā)送 ${bytes} 字節(jié)數(shù)據(jù)`);
  });
}, 3000);

const dgram = require('dgram');
const multicastAddr = '224.1.1.1';
let client = dgram.createSocket('udp4');
client.bind(6666, '0.0.0.0', function() {
  //將socket加入組播組中
  client.addMembership(multicastAddr);
});
client.on('message', function (msg, rinfo) {
  console.log(msg.toString());
});