当前位置:网站首页 / Node.js / 正文

[AY-Node.js]写给自己的NodeJs-通讯系统-udp-dgram模块【四】[17]

时间:2015年10月27日 | 作者 : aaronyang | 分类 : Node.js | 浏览: 6739次 | 评论 0

2015年10月27日 ========== AYUI www.ayjs.net AY 杨洋原创编写,请不要转载谢谢===============

创建UDP服务器

打开webstorm,创建udpdemo项目,设置编码

新建udpserver.js

/**
 * Created by aaronyang on 2015/10/27.
 */
var dgram = require('dgram');
var server = dgram.createSocket('udp4');
server.on('message', function ( msg , rinfo ) {
    console.log('客户端发送的数据:' + msg);
   //客户端信息
    console.log('信息:%j', rinfo);
    //回发确认
    var buf = new Buffer('服务器:我已收到');
    server.send(buf,0,buf.length,rinfo.port,rinfo.address);
});
server.on('listening', function () {
    var address=server.address();
    console.log('服务启动成功:%j', address);
});
server.bind(41234,'localhost');

message方法,接收数据,毁掉函数rinfo的其他值,address,family(例如IPv4),port,size

创建客户端udpclient.js

/**
 * Created by aaronyang on 2015/10/27.
 */
var dgram = require('dgram');
var buf = new Buffer('你好,udp的server');
var client = dgram.createSocket('udp4');
client.send(buf,0,buf.length,41234,'localhost', function (err,bytes) {
    if (err) {
        console.log('客户端信息发送失败');
    } else {
        console.log('客户端发送了数据%d字节', bytes);
    }
});

client.on('message', function (msg,rinfo) {
    console.log('服务器发来的数据:%s', msg);
    console.log('服务器信息:%j', rinfo);
})

效果图:

blob.pngblob.png

左边图,因为我的客户端重启了1次,但是服务器没有关闭,所以显示了2次


close方法

client.close,和close的回调函数,比如client收到服务器发送的关闭命令,就关闭程序

修改服务端发送的消息为msg=close

/**
 * Created by aaronyang on 2015/10/27.
 */
var dgram = require('dgram');
var server = dgram.createSocket('udp4');
server.on('message', function ( msg , rinfo ) {
    console.log('客户端发送的数据:' + msg);
   //客户端信息
    console.log('信息:%j', rinfo);
    //回发确认
    //var buf = new Buffer('服务器:我已收到');
    var buf = new Buffer('msg=close');

    server.send(buf,0,buf.length,rinfo.port,rinfo.address);
});
server.on('listening', function () {
    var address=server.address();
    console.log('服务启动成功:%j', address);
});
server.bind(41234,'localhost');

客户端收到后,关闭程序

/**
 * Created by aaronyang on 2015/10/27.
 */
var dgram = require('dgram');
var buf = new Buffer('你好,udp的server');
var client = dgram.createSocket('udp4');
client.send(buf,0,buf.length,41234,'localhost', function (err,bytes) {
    if (err) {
        console.log('客户端信息发送失败');
    } else {
        console.log('客户端发送了数据%d字节', bytes);
    }
});

client.on('message', function (msg,rinfo) {
    console.log('服务器发来的数据:%s', msg);
    console.log('服务器信息:%j', rinfo);
    if(msg=='msg=close'){
        client.close();
    }
})
client.on('close', function () {
    console.log('收到服务器的关闭消息');
})

blob.png

2015年10月27日 ========== AYUI www.ayjs.net AY 杨洋原创编写,请不要转载谢谢===============

服务端,不要使用close方法去关闭服务器,比如使用unref()显式的当与客户端不存在连接时关闭服务器。

setTimeout(function(){server.unref();},10000);


使用socket.ref()取消unref方法的使用


socket.on('error',function(err){})在网络中发送的每个数据包都拥有一个TTL(Time to Live)值,用于标识一个数据包的生存时间。每个路由器或网管在转发一个数据包的时候,都会消耗一些TTL值,如果TTL为0,则数据包会被抛弃。大多操作系统,TTL默认值为64    nodejs中可以setTTL方法设置最大值1-255

server.setTTL(128);


广播与组播

服务端udpzuServer.js

/**
 * Created by aaronyang on 2015/10/27.
 */
var dgram=require('dgram');
var server=dgram.createSocket('udp4');
server.on('message', function (msg,rinfo){
    var buf=new Buffer('客户端('+rinfo.address+':'+rinfo.port+'):'+msg);
    server.setBroadcast(true);
        //在本例中,客户端需要将端口号指定为40404
        server.send(buf,0,buf.length,40404,'192.168.4.255');
});
server.bind(40403,'192.168.4.145');

服务器端收到任何消息,都会向我本机ip(192.168.4.145)的40404的端口的客户端推送消息

接下来,我们新建客户端udpzuClient.js

/**
 * Created by aaronyang on 2015/10/27.
 */
var dgram=require('dgram');
var client=dgram.createSocket('udp4');
client.bind(40404,'192.168.4.145');
var buf=new Buffer('你好,ay,你好,udp');
client.send(buf,0,buf.length,40403,'192.168.4.145');
client.on('message', function (msg,rinfo) {
    console.log('服务器消息:%s',msg);
})

向服务器发送你好,ay,你好,udp,然后服务器给它推了信息。

我们复制udpzuClient.js为udpzuClient2.js,把端口号改成40405,和udpzuClient3.js,端口40406,然后分别改变中间发送的内容。运行效果如下

首先运行udpzuServer.js,然后是第一个客户端,然后第二个,然后第三个

987.gif

组播

网络中同一业务类型主机进行逻辑上的分组,某个socket信息只能被改组的人接收。所以我们不能发送目标ip和端口,而是将数据发送到组播地址,操作系统把改组数据组播给组内的其他所有成员。

使用D类地址作为组播地址:224.0.0.0到239.255.255.255的ip地址

局部组播地址:224.0.0.0~224.0.0.255这是为路由协议和其他用户保留的地址

预留组播地址: 224.0.1.0~238.255.255.255可用于全球范围或网络协议。

管理权限组播地址:239.0.0.0 ~ 239.255.255.255 可供组织内部使用,不能用于Internet,可限制组播范围。

在Nodejs中,使用socket端口对象的addMembership方法将对象加入组播组中。

dropMembership退出组播组。

设置组播经过的路由器的最大数量 setMulticastTTL(ttl)

setMulticastLoopback,设置是否允许组播数据回送,如果允许,被组播的数据将被主机的本地接口所接收。

setMulticastLoopback(true/false)



组播服务器端DEMO,新建udpzuboServer.js

每隔一秒向224.222.222.222地址发送信息

/**
 * Created by aaronyang on 2015/10/27.
 */
var dgram=require('dgram');
var server=dgram.createSocket('udp4');
server.on('listening', function () {
    server.setMulticastTTL(128);
    server.addMembership('224.222.222.222');
})

setInterval(broadCast,1000);
function broadCast(){
    var buf=new Buffer((new Date()).toLocaleString());
    server.send(buf,0,buf.length,8888,'224.222.222.222');
}


新建客户端demo      udpzuboClient.js

加入这个组播地址,每当有信息,就会触发message事件,然后你在回调函数中处理这个数据

/**
 * Created by aaronyang on 2015/10/27.
 */
var dgram=require('dgram');
var client=dgram.createSocket('udp4');
client.on('listening', function () {
    client.addMembership('224.222.222.222');
})

client.on('message', function (msg,rinfo) {
    console.log(msg.toString());
})

client.bind(8888,'192.168.4.145');

效果图:

312.gif

2015年10月27日 ========== AYUI       www.ayjs.net      AY         杨洋原创编写,请不要转载谢谢===============







推荐您阅读更多有关于“nodejs,”的文章

猜你喜欢

额 本文暂时没人评论 来添加一个吧

发表评论

必填

选填

选填

必填

◎欢迎参与讨论,请在这里发表您的看法、交流您的观点。

  查看权限

抖音号:wpfui,可以看到我的很多作品效果

AYUI8社区版Github地址:前往获取

作者:杨洋(AaronYang简称AY,安徽六安人)目前是个人,还没公司AY唯一QQ:875556003和AY交流

高中学历,2015年1月17日开始,兴趣学习研究WPF,目前工作繁忙,不接任何活

声明:AYUI7个人与商用免费,源码可购买。部分DEMO不免费.AY主要靠卖技术服务挣钱

不是从我处购买的ayui7源码,我不提供任何技术服务,如果你举报从哪里买的,我可以帮你转正为我的客户,并送demo

查看捐赠

AYUI7.X MVC教程 更新如下:

第一课 第二课 程序加密教程

兼容XP到win10,vs2015/2017/2019,最新AYUI:7.6.5.5

vs2015 企业版密钥HM6NR-QXX7C-DFW2Y-8B82K-WTYJV

vs2017 企业版密钥NJVYC-BMHX2-G77MM-4XJMR-6Q8QF

标签列表