第七十三期：Node中的I/O操作(socket 通信)

terrence386

发布于 2022-07-15 10:48:54

3240

发布于 2022-07-15 10:48:54

文章被收录于专栏：JavaScript高级程序设计

在文件或者目录被添加，删除或者更新时，能够收到消息通知，这个能力对我们来说还是非常重的。

sockets 通信

sockets翻译过来叫套接字。我们呢，可以把它理解为一种可读可写的文件，本质上还是一个数据容器。

在一些操作系统上它其实是一种特殊类型的文件，它实现起来更加复杂。

TCP 客户端和 server

我们还是用一个例子来说明一下，我们创建一个server.js

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

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

require('net')
  .createServer((socket) => socket.pipe(socket))
  .listen(4000)

server.js

process.stdin.pipe(require('net').connect(4000)).pipe(process.stdout)

这样，你在客户端的终端输入什么，服务端直接给我们返回。

本文参与腾讯云自媒体同步曝光计划，分享自微信公众号。

原始发表：2022-02-22，如有侵权请联系 cloudcommunity@tencent.com 删除

javascript

socket编程

本文分享自 JavaScript高级程序设计微信公众号，前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

本文参与腾讯云自媒体同步曝光计划，欢迎热爱写作的你一起参与！

javascript

socket编程

登录后参与评论

0 条评论

热度