在文件或者目录被添加,删除或者更新时,能够收到消息通知,这个能力对我们来说还是非常重的。
sockets 通信
sockets翻译过来叫套接字。我们呢,可以把它理解为一种可读可写的文件,本质上还是一个数据容器。
在一些操作系统上它其实是一种特殊类型的文件,它实现起来更加复杂。
TCP 客户端 和 server
我们还是用一个例子来说明一下,我们创建一个server.js
代码语言:javascript复制const net = require('net')
net
.createServer((socket) => {
console.log('-> client-connected')
socket.on('data', (name) => {
socket.write(`你好:${name}`)
})
socket.on('close', () => {
console.log('-> client-disconnected')
})
})
.listen('4000')
然后创建一个client.js
代码语言:javascript复制const net = require('net')
const socket = net.connect(4000, 'localhost')
const name = process.argv[2] || 'Terrence'
socket.write(name)
socket.on('data', (data) => {
console.log(data.toString())
})
socket.on('close', () => {
console.log('-> disconnected by server')
})
然后我们打开两个终端窗口,一个运行server.js另一个运行client.js
你会发现它们两个之间的通信过程:
中间的过程
我们用net.createServer方法实例化了一个TCP服务。
这个服务会返回一个net对象,监听了4000端口。然后它有个回调函数,每次有新链接进来时都会触发这个回调,并且它接收socket作为参数,我们可以监听整个socket数据进行处理。当然,我们也监听了close事件,当链接断开时,就会触发这个事件。
同样,我们的client.js用net.connect方法链接到了4000端口上的服务,同样它也监听了data和close事件,这样,客户端和服务端就可以进行通信了。
作为streams流处理
sockets实际上继承了streams的接口。这样,我们可以重新修改我们的代码。
index.js
代码语言:javascript复制require('net')
.createServer((socket) => socket.pipe(socket))
.listen(4000)
server.js
代码语言:javascript复制process.stdin.pipe(require('net').connect(4000)).pipe(process.stdout)
这样,你在客户端的终端输入什么,服务端直接给我们返回。