nodeJS——网络编程
服务器
var net = require('net')
// 1. 创建服务器,得到一个 server 服务器对象实例
var server = net.createServer()
var count = 0
var users = []
// 2. 监听 server 服务器对象的 connection 连接事件
// 当客户端与服务器连接成功之后,触发 connection 事件,执行对应的回调函数
// 当客户端与服务器连接成功之后,会把当前这个连接的客户端的 ip 地址和端口号 抽象成一个 编程接口:socket
// 然后将 socket 这个接口对象传递会 connection 回调处理函数
// socket 说白了就是一个 ip 地址和端口号,
// 每个客户端与服务器连接成功之后,只会触发一次 connection 事件,之后再收发数据不会再触发了
// 之后就是收发数据,可能会触发自己 socket 对象对应的 data 事件,可以传 socket 参数
server.on('connection', function (socket) {
users.push(socket)
count++
console.log('有客户端连接上来了,当前客户端连接数:' + count)
console.log(socket.remoteAddress)
console.log(socket.remotePort)
// socket 抽象成了一个 可读可写流
// 可写表示可以调用 write 方法,向客户端发送数据
socket.write('welcome to our chart room..')
// 当与服务器连接的客户端发送消息过来之后就会触发自己的 socket 对象的 data 事件
// 然后服务器将收到的数据,通过回调函数,传递给第一个参数
// 网络传递的都是二进制数据,所以接收到的 data 也是二进制的一个 Buffer 数组
socket.on('data', function (data) {
console.log(data.toString())
users.forEach(function (user) {
user.write(data)
})
})
})
// 3. 设置端口号(没有被占用的),启动监听 : server.listen(8080)
// listen 还可以接收第二个参数回调函数,当开启监听成功,触发这个回调函数
// 第二个参数可以指定,地址是客户端地址
server.listen(8080, '127.0.0.1',function () {
console.log('server is running at port 8080')
})
socket.on('data', function (data) {?}) ?监听当前与服务器链接的客户端,data 是客户端返回数据
客户端:
var net = require('net')
// 通过 net.createConnection 方法创建得到的 client 是一个 socket 对象,这个对象就指向了 与之连接的服务器
var client = net.createConnection({
port: 8080,
host: '192.168.137.79'
})
// 当 当前客户端与服务器连接成功之后,就会触发这个事件
client.on('connect', function () {
console.log('客户端与服务器连接成功了')
// client.write('hello')
process.stdin.on('data', function (data) {
// 去除前后空格和回车换行符
data = data.toString().trim()
client.write(data)
})
})
// 服务器如果要给当前客户端发送消息数据
// 监听服务器发送数据的 data 事件
client.on('data'
, function (data) {
// console.log("服务器说:"+data.toString())
console.log(data.toString())
})
socket:可读可写流
评论