node --- 创建一个Socket客户端连接到服务器

描述:

net.createrServer().listen(60300) 监听客户端访问
net.connect({ port: 60300 }) 访问服务器

服务器:

一个很简单的监听文件改变的服务器
每当监听的文件改变了,将信息通过json的格式传递给连接到的客户端 connection.write

// 01、net-watcher.js
'use strict'
const fs = require('fs');
const net = require('net');
const filename = process.argv[2];if (!filename) {throw Error('Error: No filename specified.');
}net.createServer(connection => {console.log('Subscriber connected.');connection.write(JSON.stringify({ type: 'watching', file: filename }) + '\n');const watcher =fs.watch(filename, () => connection.write(JSON.stringify({ type: 'changed', timestamp: Date.now() })));connection.on('close', () => {console.log('Subscriber disconnected.');watcher.close();});
}).listen(60300, () => console.log('Listening for subscriber...'));

客户端:

使用 client = net.coonection({port: xxxx}) 连接到服务器.
使用 client.on(‘data’) 来接收服务器传来的数据,并做相应的处理

// 02、net-watcher-json-client.js
'use strict';
const net = require('net');
const client = net.connect({ port: 60300 });
client.on('data', data => {const message = JSON.parse(data);if (message.type === 'watching') {console.log(`Now watching: ${message.file}`);} else if (message.type === 'changed') {const date = new Date(message.timestamp);console.log(` File changed: ${date} `);} else {console.log(`Unrecognized message type:${message.type}`);}
})