我们把客户端连接发送的数据保存到一个文件下 var net=require("net"); var fs=require("fs"); var server =net.createServer(); var op={ flags:"a", encoding:"utf-8" } var file=fs.createWriteStream('./socket.txt',op) server.on('connection',function(socket){ socket.on('data',function(data){
以管道形式发送数据到文件 var net=require("net"); var fs=require("fs"); var server =net.createServer(); var op={ flags:"a", encoding:"utf-8" } var file=fs.createWriteStream('./socket.txt',op) server.on('connection',function(socket){ //socket.on('data',function(data){ // file.write(data); //}) socket.pipe(file,{end:false}); socket.on("end",function(){ file.end("wanbi") }) }) server.on('listening',function(){ console.log("监听开始") }) server.listen('1111','192.168.0.3')
tcp客户端 创建tcp客户端 var client =new net.socket([opations]) optation:fd 一个现有的socket端口对象文件描述 type :ipv4 、ipv6 allowHalfOpne:true、false 连接服务器 client.connect(prot,[host],[callback]) host不指定默认为本地ip 回调函数表示连接上了做什么 若没有可以socket端口对象触发connect事件 client.on("connect",function(){ })
我们实现一个服务器读一个文件的信息,当有客户单连接上,吧这个信息传给客户端,输出在控制台 服务器代码 var net=require("net"); var fs=require("fs"); var server =net.createServer(); var op={ flags:"r", encoding:"utf-8" } var file=fs.createReadStream('./socket.txt',op) server.on('connection',function(socket){ file.on('data',function(data){ socket.write(data); })
socket.on("end",function(){ file.end("wanbi") }) }) server.on('listening',function(){ console.log("监听开始") }) server.listen('1111','192.168.0.3') 客户端代码 var net=require("net"); var client=new net.Socket(); client.connect(1111,'192.168.0.3') client.on('connect',function(){ console.log("ok")