本文实例讲述了Node.js套接字(socket)编程。分享给大家供大家参考,具体如下:
Node.js的net模块提供了socket编程接口,方便我们利用较为底层的套接字接口来实现应用协议。这次我们看一个简单的回显服务器示例,包括服务端和客户端的代码。
代码
分服务器和客户端两部分来说吧。
server代码分析
server.js:
var net = require("net"); // server is an instance of net.Server // sock is an instance of net.Socket var server = net.createServer(function(sock){ console.log('client connected, address - ', sock.remoteAddress, ' port - ', sock.remotePort); sock.setEncoding('utf8'); sock.on('data', function(data){ console.log('got data from client - ', data); sock.write(data); }); sock.on('end', function(){ console.log('client disconnected'); }); sock.on('error', function(err){ console.log('socket error - ', err); }); }); server.maxConnections = 10; server.listen(7, function(){ console.log('echo server bound at port - 7'); });
使用net.createServer来创建一个服务器实例,这个方法的返回值是一个net.Server实例,net.Server提供了listen方法,让我们监听到某个端口上来接受客户端连接,同时还提供了一些属性,比如maxConnections可以设置服务器的并发连接数上限(当服务器的连接数超过这个值时,后续连接就会被拒掉),还有其它的,看文档吧:https://nodejs.org/api/net.html#net_class_net_server。
net.Server还提供了一些事件,比如error、connection等。当有客户端连接被接受时,会发射connection事件,这个事件带一个net.Socket对象作为参数,可以在回调函数里访问这个net.Socket实例来与客户端交互。我在代码里,给createServer方法传入了一个callback来处理connection事件,实际上也可以略作修改,通过监听connection事件的方法处理客户端连接。新代码如下:
var net = require("net"); var server = net.createServer(); server.on('connection', function(sock){ console.log('client connected, address - ', sock.remoteAddress, ' port - ', sock.remotePort); sock.setEncoding('utf8'); sock.on('data', function(data){ console.log('got data from client - ', data); sock.write(data); }); sock.on('end', function(){ console.log('client disconnected'); }); sock.on('error', function(err){ console.log('socket error - ', err); }); }); server.maxConnections = 10; server.listen(7, function(){ console.log('echo server bound at port - 7'); });
效果是一样的。
net.Socket对象有一些方法,比如write可以写数据。还有一些事件,比如error、end、data等,看代码就能明白用法。还有一些属性,比如remoteAddress、remotePort。
client代码分析
client.js:
var net = require("net"); var readline = require('readline'); console.log('type "exit" or "quit" to quit.'); // sock is an instance of net.Socket var sock = net.connect({port: 7}, function(){ console.log('server connected'); sock.setEncoding('utf8'); sock.write('Hello Echo Server\r\n'); }); sock.on('data', function(data){ console.log('got data from server - ', data); }); sock.on('end', function(){ console.log('client disconnected'); }); sock.on('error', function(err){ console.log('socket error - ', err); }); sock.on('close', function(){ console.log('echo client was closed'); process.exit(0); }); var rl = readline.createInterface({ input: process.stdin }); function quitEcho(){ rl.close(); sock.end(); console.log('quit echo client'); } rl.on('line', function(cmd){ if(cmd.indexOf('quit') == 0 || cmd.indexOf('exit') == 0){ quitEcho(); }else{ sock.write(cmd + '\r\n'); } }); rl.on('SIGINT', quitEcho);
调用readline模块来从标准输入读取数据来发送给客户端。readline的文档在这里:https://nodejs.org/api/readline.html。正如它的名字,Readline可以让你一行一行的读取一个流。比较常见的就是读取标准输入流。Readline有一些事件,我们用到的“line”事件,在一行数据就绪时会发射,带一个代表数据的参数。监听line事件,在回调中调用net.Socket的write方法写入数据。当你在控制台输入“quit”或“exit”时,调用quitEcho退出。
net.connect方法可以连接到指定的服务器,它的原型如下:
net.connect(options[, connectionListener])
第一个参数是Object,用于指定和连接相关的选项,比如服务端的host、port等,如果不指定host,就默认用localhost作为服务端主机名.
net.connect返回net.Socket对象,一旦拿到了Socket实例,就可以用net.Socket来为所欲为了。监听了data事件来接收服务端发挥的数据,监听close事件来退出进程。net.Socket的具体API,参考https://nodejs.org/api/net.html#net_class_net_socket。
希望本文所述对大家node.js程序设计有所帮助。
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
稳了!魔兽国服回归的3条重磅消息!官宣时间再确认!
昨天有一位朋友在大神群里分享,自己亚服账号被封号之后居然弹出了国服的封号信息对话框。
这里面让他访问的是一个国服的战网网址,com.cn和后面的zh都非常明白地表明这就是国服战网。
而他在复制这个网址并且进行登录之后,确实是网易的网址,也就是我们熟悉的停服之后国服发布的暴雪游戏产品运营到期开放退款的说明。这是一件比较奇怪的事情,因为以前都没有出现这样的情况,现在突然提示跳转到国服战网的网址,是不是说明了简体中文客户端已经开始进行更新了呢?
更新日志
- 凤飞飞《我们的主题曲》飞跃制作[正版原抓WAV+CUE]
- 刘嘉亮《亮情歌2》[WAV+CUE][1G]
- 红馆40·谭咏麟《歌者恋歌浓情30年演唱会》3CD[低速原抓WAV+CUE][1.8G]
- 刘纬武《睡眠宝宝竖琴童谣 吉卜力工作室 白噪音安抚》[320K/MP3][193.25MB]
- 【轻音乐】曼托凡尼乐团《精选辑》2CD.1998[FLAC+CUE整轨]
- 邝美云《心中有爱》1989年香港DMIJP版1MTO东芝首版[WAV+CUE]
- 群星《情叹-发烧女声DSD》天籁女声发烧碟[WAV+CUE]
- 刘纬武《睡眠宝宝竖琴童谣 吉卜力工作室 白噪音安抚》[FLAC/分轨][748.03MB]
- 理想混蛋《Origin Sessions》[320K/MP3][37.47MB]
- 公馆青少年《我其实一点都不酷》[320K/MP3][78.78MB]
- 群星《情叹-发烧男声DSD》最值得珍藏的完美男声[WAV+CUE]
- 群星《国韵飘香·贵妃醉酒HQCD黑胶王》2CD[WAV]
- 卫兰《DAUGHTER》【低速原抓WAV+CUE】
- 公馆青少年《我其实一点都不酷》[FLAC/分轨][398.22MB]
- ZWEI《迟暮的花 (Explicit)》[320K/MP3][57.16MB]