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理解成只跑一次连接流程，只到把所有的事情都做完了才回去。

————————————————
版权声明：本文为CSDN博主「yiqiebyjian」的原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接及本声明。
原文链接：https://blog.csdn.net/yiqiebyjian/article/details/79644482

nodejs系列（10）实现socket通信

2018-02-08 14:33:50 @黄小泽阅读数 2987更多

分类专栏：前端集合 nodejs

本文链接：https://blog.csdn.net/zeping891103/article/details/79287969

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"/>';

            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>