在掘金查看该文章
1. TCP服务搭建
1.1 socket
先来粗略了解下socket
套接字（socket）是一个抽象层，应用程序可以通过它发送或接收数据，可对其进行像对文件一样的打开、读写和关闭等操作。套接字允许应用程序将I/O插入到网络中，并与网络中的其他应用程序进行通信。网络套接字是IP地址与端口的组合。 (摘自百度百科)
socket用于在两个基于TCP/IP协议的应用程序之间相互通信.最早出现在UNIX系统中,是UNIX系统主要的信息传递方式.在windows系统中，socket称为winsock.
两种形式的socket：流式套接字,对应与TCP协议.
数据报套接字,对应与UDP协议.
2.创建TCP服务端
server.js(服务端)
const net = require("net");
const sever = net.createServer();
// const clients = [];
const users = [];
const types = require("./types");
sever.on("connection", clientSocket => {
console.log("有连接进来,请注意```");
// clients.push(clientSocket)
clientSocket.on("data", data => {
console.log("监听data事件,有人说:", data.toString());
data = JSON.parse(data.toString().trim());
switch (data.type) {
case types.login:
if (users.find(item => item.nickName === data.nickName)) {
return clientSocket.write(
JSON.stringify({
type: types.login,
success: false,
message: "昵称已存在"
})
);
}
clientSocket.nickName = data.nickName;
users.push(clientSocket);
clientSocket.write(
JSON.stringify({
type: types.login,
success: true,
message: "登录成功",
nickName:data.nickName,
sumUsers: users.length
})
);
users.forEach(user=>{
if(user!==clientSocket){
user.write(JSON.stringify({
type:types.log,
message:`${data,nickName} 进入聊天室,当前在线用户数${user.length}`
}))
}
})
break;
// 群聊天
case types.broadcast:
users.forEach(item => {
item.write(JSON.stringify({
type:types.broadcast,
message:data.message,
nickName:clientSocket.nickName
}))
})
break;
// 点对点
case types.p2p:
const user = users.find(item => item.nickName === data.nickName)
if(!user){
return clientSocket.write(JSON.stringify({
type:types.p2p,
success:false,
message:"该用户不存在"
}))
}
console.log('clientSocket.nickName',clientSocket.nickName)
user.write(JSON.stringify({
type:types.p2p,
message:data.message,
nickName:clientSocket.nickName,
success:true
}))
break;
default:
break;
}
});
// 离线
clientSocket.on("end",()=>{
console.log("有用户离线了~~~")
const index =users.findIndex(user => user.nickName === clientSocket.nickName)
if(index !== -1){
const offlineUser = users[inde]
users.splice(index,1)
users.forEach(user=>{
if(user!==clientSocket){
user.write(JSON.stringify({
type:types.log,
message:`${offlineUser,nickName} 离开了聊天室,当前在线用户数${user.length}`
}))
}
})
}
})
// clientSocket.write('hello,返回的是buffer,用tostring转一下哦')
});
sever.listen(2000, () => {
console.log("server running 127.0.0.1 2000");
});
3.创建客户端
client.js(客户端)
const net = require("net");
const types = require("./types");
let nickName = null;
const client = net.createConnection({
host: "127.0.0.1",
port: 2000
});
client.on("connect", () => {
console.log("连接成功了~~~");
process.stdout.write("请输入昵称:");
// 连接完毕后,可以监听终端的信息,发给服务端
process.stdin.on("data", data => {
data = data.toString().trim();
console.log("nickName", nickName);
if (!nickName) {
client.write(
JSON.stringify({
type: types.login,
nickName: data
})
);
}
const matches = /^@(\w+)\s(.+)$/.exec(data);
if (matches) {
//符合 @xxx xxx 格式
return client.write(
JSON.stringify({
type: types.p2p,
nickName: matches[1],
message: matches[2]
})
);
}
//群聊天
client.write(
JSON.stringify({
type: types.broadcast,
message: data
})
);
});
});
client.on("data", data => {
// console.log("服务端发来的data:::", data.toString());
data = JSON.parse(data.toString().trim());
switch (data.type) {
case types.login:
if (!data.success) {
console.log("登录失败", `${data.message}`);
process.stdout.write("请输入昵称");
} else {
process.stdout.write("登录成功,当前在线人数:", data.sumUsers);
nickName = data.nickName;
}
break;
case types.broadcast:
console.log(`${data.nickName}:${data.message}`);
break;
case types.p2p:
if (!data.success) {
return console.log(`发送失败:${data.message}`);
}
console.log(`${data.nickName}对你说:${data.message}`);
break;
case types.log:
console.log(`${data.message}`);
break;
default:
console.log("未知消息类型哦~");
break;
}
});
types.js
module.exports = {
login: 0,
broadcast: 1,
p2p: 2,
log: 3
};
总结
- 通过net模块建立TCP服务
- TCP必须建立连接(3次握手)后才能通信
- socket通信模型
- 和使用其他node模块(如koa)一样的思路,都是先建立服务(server),指定端口号
