Created
September 28, 2020 11:45
-
-
Save Unitech/ca40379518b794c134846c0cd84924c7 to your computer and use it in GitHub Desktop.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
var udp = require('dgram'); | |
// -------------------- udp client ---------------- | |
var buffer = require('buffer'); | |
// creating a client socket | |
var client = udp.createSocket('udp4'); | |
//buffer msg | |
var data = Buffer.from('siddheshrane'); | |
client.on('message',function(msg,info){ | |
console.log('Data received from server : ' + msg.toString()); | |
console.log('Received %d bytes from %s:%d\n',msg.length, info.address, info.port); | |
}); | |
setInterval(() => { | |
//sending msg | |
client.send(data,2222,'localhost',function(error){ | |
if(error){ | |
client.close(); | |
}else{ | |
console.log('Data sent !!!'); | |
} | |
}); | |
}, 10) | |
var data1 = Buffer.from('hello'); | |
var data2 = Buffer.from('world'); | |
//sending multiple msg | |
client.send([data1,data2],2222,'localhost',function(error){ | |
if(error){ | |
client.close(); | |
}else{ | |
console.log('Data sent !!!'); | |
} | |
}); | |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
var udp = require('dgram'); | |
// --------------------creating a udp server -------------------- | |
// creating a udp server | |
var server = udp.createSocket('udp4'); | |
// emits when any error occurs | |
server.on('error',function(error){ | |
console.log('Error: ' + error); | |
server.close(); | |
}); | |
// emits on new datagram msg | |
server.on('message',function(msg,info){ | |
console.log('Data received from client : ' + msg.toString()); | |
console.log('Received %d bytes from %s:%d\n',msg.length, info.address, info.port); | |
//sending msg | |
server.send(msg,info.port,'localhost',function(error){ | |
if(error){ | |
//client.close(); | |
}else{ | |
console.log('Data sent !!!'); | |
} | |
}); | |
}); | |
//emits when socket is ready and listening for datagram msgs | |
server.on('listening',function(){ | |
var address = server.address(); | |
var port = address.port; | |
var family = address.family; | |
var ipaddr = address.address; | |
console.log('Server is listening at port' + port); | |
console.log('Server ip :' + ipaddr); | |
console.log('Server is IP4/IP6 : ' + family); | |
}); | |
//emits after the socket is closed using socket.close(); | |
server.on('close',function(){ | |
console.log('Socket is closed !'); | |
}); | |
server.bind(2222); |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment