可以实现的
// 创建一个Socket实例var socket = new WebSocket('ws://localhost:8080')
// 打开Socket
socket.onopen = function(event) {
// 发送一个初始化消息
socket.send('I am the client and I\'m listening!')
// 监听消息
socket.onmessage = function(event) {
console.log('Client received a message',event)
}
// 监听Socket的关闭
socket.onclose = function(event) {
console.log('Client notified socket has closed',event)
}
// 关闭Socket....
//socket.close()
}
参数为URL，ws表示WebSocket协议。onopen、onclose和onmessage方法把事件连接到Socket实例上。每个方法都提供了一个事件，以表示Socket的状态。
nodejs中我们使用net模块来创建tcp服务器，tcp客户端，实现服务器与客户端之前的数据通信创建tcp服务器
var server=net.createServer([optations],[connectionListener])
optations:{allowHalfOpen:boolean}
allowHalfOpen：false 当服务器接受到客户端发送的一个FIN包时候，会回发一个FIN包，当为true时服务器不会回FIN包，使得tcp服务器可以继续发送数据到客户端，但是不会接受客户端发送的数据，开发者必须调动end方法来关闭socket，默认是false
connectionListener：当客户端与服务器连接上了，可以触发的回调函数。
function(socket){
//.......
}
我们也可以不用回调函数来写连接上做什么处理,连接上会触发connection事件
var server=net.createServer()返回创建的tcp服务器
我们可以server.on('connection',function(socket){
})
在创建完tcp服务器我们通知服务器要监听客户端连接
server.listen(port,[host],[backlog],[callback])
port：监听的端口，为0时候tcp服务器分配一个随机的端口
host：监听的ip和主机名，省略该参数，服务器监听任何ipv4地址的客户端连接
backlog：指定等待队列中最大的客户端连接最大数量 默认511
当指定端口、ip这个时候服务器开始监听这个ip这个端口的客户端了，这个时候触发listening事件，可以指定callback参数来处理触发listening具体要做什么
我们也可以
server.on('lisening',function(){
//.......
})
创建一个tcp服务器后可以用server.address（）查看tcp服务器监听的信息
var address=server.address()
addres是一个对象
prot ：监听的端口
address：监听的ip
family：ipv4还是ipv6
我们可以使用getConnections（）查看与服务器连接的客户端的数量
server.getConnections(callback)
callback:function(err,count){
}
err:错误信息
count：为连接服务器的数量
我们也可以设置最大的连接数，超过这个数字，服务器不允许连接
server.maxConnections=2
服务器关闭
server.close([callback])
这个 方法让tcp服务器拒绝新的客户端连接，原有已经连上的客户端是不关闭的，当所有的连接服务器的客户端关闭时候，服务器默认自动关闭，触发服务器的close事件
下面我们写一个tcp服务器
var net=require("net")
opations={allowHalfOpne:false}
var server=net.createServer(opations)
server.on('connection',function(socket){
server.maxConnections=2
console.log("服务器最大连接数为%s",server.maxConnections)
server.getConnections(function(err,count){
console.log("已经有%s个客户端连接",count)
})
console.log("%s客户端与服务器建立连接",server.address().address)
})
server.on('error',function(err){
throw err
})
server.on('listening',function(){
console.log("服务器开始监听%j",server.address())
console.log("服务器开始监听")
})
server.listen(9966,'192.168.0.3')
setTimeout(function(){
server.close(function(){
console.log("tcp服务器关闭11111")
})
console.log("tcp服务器关闭")
},20000)
注意连接成功的时候触发的connection事件，执行的方法，参数是一个socket端口对象，这个就是服务器所监听的端口对象，所以我们socket.address().address返回给我们的是监听ip
socket端口对象
port：端口
address：ip
family：ipv4 ipv6
socket端口对象，可以读取客户端发送的流数据，每次接收到客户端发送的数据触发data事件。
接受客户端发送的消息（在连接成功的触发函数中 让server监听data事件做相应的处理）
server.on('connection',function(socket){
socket.on('data',function(data){
socket.setEncoding("utf-8")
console.log(data)
//console.log(data.toString())
})
})
bytesRead为socket端口对象监听客户端发送的数据字节数
console.log(socket.bytesRead)
当客户端关闭时候，触发socket端口对象的end事件
我们把客户端连接发送的数据保存到一个文件下
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)
})
})
server.on('listening',function(){
console.log("监听开始")
})
server.listen('1111','192.168.0.3')
以管道形式发送数据到文件
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(){
})
当我们连接成功后客户端服务器端的socket端口对象有下面的属性
remoteAddress、remotePort、localAddress、localPort
socket端口对象可以写入服务器、客户端流数据
socket.write(data,[encodeing],[callback])
写入数据少时候我们直接写入缓存区，数据很多时候，缓存区满了，我们要把数据写入缓存队列中，这个时候write（data） 返回false，触发drain
我们可以用bufferSize看缓存队列中有多少个字节
socket.on("error",function(err){
})
当遇到error时候这个socket端口对象应该销毁
socket.destory()
socket.end([data],[encoding])
这个方法表示我们要关闭socket端口对象，这个不是关闭服务器的close方法，后者是关闭服务器，实现的效果是不能让客户端连接了，前者是关闭连接（socket端口对象）
当我们使用服务器的socket端口对象（连接客户端得）的end（data，encoding）方法时候，会触发客户端socket端口对象end事件
服务器：
socket.end('88')
客户端会执行下面的代码：
client.on("end",function(){
//......
})
服务器端不会退出应用程序，即使所有的客户端都断开了，这个时候我们要server.unref(),退出程序，可以用server.ref()阻止程序退出.
当socket端口对象彻底关闭时候会触发close事件，我们可以指定当端口对象关闭时候做的处理
socket.on(''close',faction(had_error){
if(had_error){}
else{}
})
socket.writtenBytes表示写了多少个字节
我们tcp服务器与客户端连接了，但是突然间有一个断电了，来不及向另一端发送关闭连接的FIN包，这样另一边这个socket端口永远处于连接状态，我们用socket.setKeepAlive([enable],[inteval])定时向另一端发送监测包，
我们实现一个服务器读一个文件的信息，当有客户单连接上，吧这个信息传给客户端，输出在控制台
服务器代码
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")
})
client.on("data",function(data){
console.log(data.toString())
})
Nagent是TCP内网穿透实现，名称来源于Nat与Agent的组合。类似frp项目，可以在局域网与互联网提供桥梁。
前提是你要有一台流量服务器并且有一个公网IP。如果没有，也可以找服务商。
暂不能向frp那样为HTTP服务，但可以实现简单的分发————你只需要在两台内网HTTP服务器上运行Nagent客户端即可。
项目位置： https://github.com/FettLuo/nagent
可以使用
未向特殊协议优化，例如http/s的转发
虽然协议有涉及账号名与密码，但未实现
未来希望你或我，向项目添加账号管理支持，以webservice的形式支持
客户端：运行在内网的Nagent客户端。
服务端：运行在公网服务器上的Nagent服务端。
用户：互联网上的实际用户。
服务器监听在5670端口（默认）。
客户端配置好自己的服务端口，也可以指定内网其他计算机。假设本机80端口。
客户端登录到服务器，通知服务器我需要监听的外网端口，比如90。
一切正常的话（防火墙没问题，端口没被占用等），服务器上90端口的连接即会被导向到内网的80端口服务上。
客户端与服务器保持着一定数量的连接，每个连接都需要登录成功。
用户连接公网服务器的端口后会从客户端的列表中弹出一个用于数据转发。
当客户端第一次收到数据时，建立与本地服务的连接，并发送/转发数据。
需要NodeJS
windows/linux:
node nagent.js -s
linux:
./nagent.js -s
windows/linux:
node nagent.js -p 90 -P 80
linux:
./nagent.js -p 90 -P 80
保存下面内容到nagent.js所在的目录，文件名为nagent.config，方括号内替换为你的参数。
local_port=[你的本地服务端口]
server_port=5670// 服务端端口号
server_host='[服务端的主机地址，IP或域名均可]'
remote_port=[你需要服务端为你开放的公网端口]
keep_conn_count=10// 同时保持的最大连接数量
