clq
浏览(580) -
2022-11-28 11:27:24 发表
编辑
关键字:
https://blog.csdn.net/u010821983/article/details/122696898
nodejs的socket网络编程
简单介绍使用nodejs的net模块进行socket网络编程，不涉及深入的自定义应用层协议知识，仅仅进行了文本的传输，没有设计数据的结构，数据的结束位置等。
socket默认使用传输层的TCP可靠送达协议，默认是长连接。
server端：
const net = require("net");
const HOST = "127.0.0.1";
const PORT = 6868;
const server = net.createServer();
server.listen(PORT, HOST);
// 重要：双方建立链接时，会自动获得一个socket对象（std，socket描述符）
server.on("connection", (socket) => {
// 远程客户端地址
console.log(`connected:${socket.remoteAddress}:${socket.remotePort}`);
// 本地服务端地址
console.log(`local:${socket.localAddress}:${socket.localPort}`);
// 向客户端发送数据
socket.write("服：你好客户端");
// 收到客户端数据时
socket.on("data", (data) => {
console.log(`${data}`);
});
// 客户端主动断连，触发end事件
socket.on("end", (data) => {
console.log(`客户端${socket.remoteAddress}:${socket.remotePort}已断连`);
});
// 如果链接断开，write方法就无效了
setInterval(() => {
socket.write(`服：定时消息${Date.now()}`);
}, 1000);
});
console.log(`server listen on ${HOST}:${PORT}`);
client端：
const net = require("net");
const HOST = "127.0.0.1";
const PORT = 6868;
const client = new net.Socket();
client.connect(PORT, HOST, () => {
console.log(`connected to:${HOST}:${PORT}`);
// 向服务端发送数据
client.write("客：你好服务端");
// 收到服务端数据时
client.on("data", (data) => {
console.log(data.toString());
client.write("客：已收到");
// client.end(); // 主动关闭此次tcp长连接
});
// 客户端主动断连，触发自己的end事件
client.on("end", () => {
console.log("链接已主动断开");
});
});
————————————————
https://www.jb51.net/article/190028.htm
Nodejs环境实现socket通信过程解析
这篇文章主要介绍了Nodejs环境实现socket通信过程解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
结构：
socket是应用层和传输层的桥梁。（传输层之上的协议所涉及的数据都是在本机处理的，并没进入网络中）
涉及数据：
socket所涉及的数据是报文，是明文。
作用：
建立长久链接，供网络上的两个进程通信。
nodejs环境下的简单通信。
代码：
serve：
// 1 引入模块
const net = require('net');
// 2 创建服务器
let clientArr = [];
const server = net.createServer();
// 3 绑定链接事件
server.on('connection',(person)=>{
console.log(clientArr.length);
// 记录链接的进程
person.id = clientArr.length;
clientArr.push(person);
person.setEncoding('utf8');
// 客户socket进程绑定事件
person.on('data',(chunk)=>{
console.log(chunk);
clientArr.forEach((val)=>{
// 数据写入全部客户进程中
val.write(chunk);
})
})
person.on('close',(p1)=>{
clientArr[p1.id] = null;
} )
person.on('error',(p1)=>{
clientArr[p1.id] = null;
})
})
server.listen(800);
client：
// 1 引入模块
const net = require('net');
const readline = require('readline');
// 2 创建套接字和输入输出命令行
let rl = readline.createInterface({
// 调用std接口
input:process.stdin,
output:process.stdout
})
let client = new net.Socket();
// 3 链接
client.connect(800,'localhost');
client.setEncoding('utf8');
client.on('data',(chunk)=>{
})
client.on('error',(e)=>{
console.log(e.message);
})
// 绑定输io流事件,获取输入输出字符
rl.on('line',(mes)=>{
client.write(mes);
})
小结：
server端：绑定连接事件 --> 在连接事件中管理客户端进程对象（1，把添加到数组中 2，处理客户端发来的数据）-->开启端口监听请求 。
client端：创建连接服务器用的套接字 --> 连接服务器 。
socket建立的连接是长久连接。而应用层的http协议是3次握手协议，是短连接。
socket工作原理和http类似，只是不规定断开连接的时间。可以把http理解成一个人办一件事情就跑一次连接流程。socket理解成只跑一次连接流程，只到把所有的事情都做完了才回去。
Socket主要作用是实现客户端与服务端的实时通信保持通话，它不像ajax请求，每次对话完成后都会把连接断开。Socket通信在
Node.js中实现其实很简单，没有想象中复杂，基本上只要懂得监听（.on）和推送（.emit）消息，即能实现Socket通信。
Socket服务端
在服务端使用Socket，需先引入socket.io模块，该模块详细文档可参考https://socket.io/：
cnpm install socket.io
服务端实例代码如下：
var server = app.listen(8081, "127.0.0.1", function() {
var host = server.address().address;
var port = server.address().port;
});
/********************socketIO********************/
var io = require('socket.io').listen(server);
// 建立连接
io.sockets.on('connection', function(socket) { //此处每个回调socket就是一个独立的客户端，通常会用一个公共列表数组统一管理
// 连接断开，如关闭页面时触发
socket.on('disconnect', function() {
console.log('已断开链接');
});
// 监听客户端发送的消息
socket.on('clientmessage', function(data) {
//推送给除自己外其他所有用户的消息，类似于广播
socket.broadcast.emit('message', {
text: '你的朋友上线了'
});
});
//发送给自己的消息
socket.emit('message', {
text: '你上线了'
});
});
上例中实现了4步：
1. 建立连接并添加断开连接监听。
2. 建立clientmessage监听，当客户端发来该名称的事件时，服务器向除自己外其他的用户广播事件名称为message的消息。
3.在刚建立连接时，向客户端推送事件名称为message的消息。
其中主要应用到的函数有5个：
.on('connection', function(socket){ })：与客户端建立连接时监听。
.on('disconnect', function(){ })：与客户端断开连接时监听。
.on('event-name', function(data) { })：监听客户端发来的消息。
.broadcast.emit('event-name', { })：向除自己外的所有其他用户广播消息。
.emit('event-name', { })：仅向当前连接的客户端（自己）推送消息。
（注）相关客户端的接口关联请往下看客户端的例子。
Socket客户端
需先去下载socket.io.js文件，下载地址为：https://github.com/socketio/socket.io-client
客户端实例代码如下：
<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>socketio测试</title>
<script>
var tmp_html = '<link rel="stylesheet" href="../js/libs/bootstrap/3.3.7/css/bootstrap.css" rel="external nofollow" />';
tmp_html += '<script src="../js/libs/jquery/3.2.1/jquery.js"><\/script>';
tmp_html += '<script src="../js/libs/bootstrap/3.3.7/bootstrap.js"><\/script>';
tmp_html += '<script src="../js/libs/socketio/socket.io.js"><\/script>';
document.write(tmp_html);
document.close();
</script>
</head>
<body>
<button id="btn">发送消息</button>
</body>
<script>
var socket = io.connect('http://127.0.0.1:8081');
socket.on('message', function(data) {
console.log(data.text);
})
$("#btn").click(function() {
socket.emit('clientmessage', {
text: "hello"
});
});
</script>
</html>
客户端主要应用到的函数有2个：
.on('event-name', function(data) { })：监听服务端发来的消息。
.emit('event-name', { })：向服务端推送消息。
Socket即时通信就是那么简单，而且在连接断开时还会自动重连。还有一种实现方法就是使用net模块的套接字，可以直接查看Node.js文档。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
本帖子属于以下条目()
NEWBT官方QQ群1: 276678893
可求档连环画,漫画;询问文本处理大师等软件使用技巧;求档softhub软件下载及使用技巧.
但不可"开车",严禁国家敏感话题,不可求档涉及版权的文档软件.
验证问题说明申请入群原因即可.
