nodejs结合Socket.IO实现websocket即时通讯 -

websocket 是一种网络通信协议，一般用来进行实时通信会使用到。本文主要介绍了nodejs结合Socket.IO实现websocket即时通讯，感兴趣的可以了解一下
目录
为什么要用 websocket
Socket.io
开源项目
效果预览
app.js
index.html

为什么要用 websocket
websocket 是一种网络通信协议，一般用来进行实时通信会使用到。

websocket 协议和 http 协议类似，http 协议有一个缺陷，只能由客户方端发起请求，服务端根据请求 url 和传过去的参数返回对应结果

websocket 是双向通信的，只要 websocket 连接建立起来，可以由客户端给服务端发送数据，也可以由服务端主动给客户端发送数据

websocket 适用场景：网页版聊天室，网页版客服，前后端频繁交换数据的即时通讯场景。

Socket.io
双向和低延迟的websocket通信包，高性能，高可靠，可伸缩。
（简单地讲，就是将websocket进行封装和优化。）
首先需要安装express和socket.io库

输入npm install express —save或者yarn add express

输入npm install socket.io—save或者yarn add socket,io

接下来实现对 / 和 /test 两个路径的监听

/返回hello world
/test返回html连接页面
socket.on(“chat message”,callback function)
表示开始监听”chat message”通道，只要前后端都是一致的通道即可。

socket.emit(“chat message”, msg.toUpperCase());
表示对这个”chat message”通道进行回复，我们暂时是对英文字母做大写处理并返回。
`const express = require(‘express’);
const app = express();
const http = require(‘http’);
const server = http.createServer(app);
const { Server } = require(“socket.io”);
const io = new Server(server);

app.get(‘/‘, (req, res) => {
res.send(‘<h1>Hello world</h1>‘);
});

app.get(‘/test’, (req, res) => {
res.sendFile(__dirname + ‘/index.html’);
});

// io.on(‘connection’, (socket) => {
// console.log(‘a user connected’);
// });
//by zhengkai.blog.csdn.net
//处理socket.on信息并socket.emit回复信息
//这里对接收到的msg做大写处理
io.on(‘connection’, (socket) => {
//Socket.io by zhengkai.blog.csdn.net
socket.on(‘chat message’, (msg) => {
console.log(‘received: ‘ + msg);
socket.emit(“chat message”, msg.toUpperCase());
});
});
//监听端口3000
server.listen(3000, () => {
console.log(‘listening on *:3000’);
});
index.html
这做一些样式处理，并且有以下body内容：

message的ul，可以用来追加li信息，显示记录往来
一个form表单，用来提交要发送的信息
script部分而言，首先使用官方的socket.io 的js client ，初始化一个连接，添加监听事件：

输入非空内容提交后，发送信息给websocket后台，同事也输出在信息列表
接收到信息之后，显示在信息列表
`<!DOCTYPE html>

<html>
<head>
<title>Socket.IO chat</title>
<style>
body { margin: 0; padding-bottom: 3rem; font-family: -apple-system, BlinkMacSystemFont, “Segoe UI”, Roboto, Helvetica, Arial, sans-serif; }

  #form { background: rgba(0, 0, 0, 0.15); padding: 0.25rem; position: fixed; bottom: 0; left: 0; right: 0; display: flex; height: 3rem; box-sizing: border-box; backdrop-filter: blur(10px); }
  #input { border: none; padding: 0 1rem; flex-grow: 1; border-radius: 2rem; margin: 0.25rem; }
  #input:focus { outline: none; }
  #form > button { background: #333; border: none; padding: 0 1rem; margin: 0.25rem; border-radius: 3px; outline: none; color: #fff; }
  #messages { list-style-type: none; margin: 0; padding: 0; }
  #messages > li { padding: 0.5rem 1rem; }
  #messages > li:nth-child(odd) { background: #efefef; }
</style>

</head>
<body>
<ul id="messages"></ul>
<form id="form" action="">
<input id="input" autocomplete="off" /><button>Send</button>
</form>
</body>
<script src="/socket.io/socket.io.js"></script>
<script>
var socket = io();

var messages = document.getElementById('messages');
var form = document.getElementById('form');
var input = document.getElementById('input');
//输出到屏幕
function addMessage(str){
    const li = document.createElement("li")
    li.innerHTML=str;
    messages.appendChild(li); 
}
// console.log(form)
form.addEventListener('submit', function(e) {
  e.preventDefault();
  if (input.value) {
    //Socket.io by zhengkai.blog.csdn.net
    let msg = '发送消息:'+input.value ;
    console.log(msg)
    socket.emit('chat message', input.value);
    addMessage(msg);
    //清空个输入框
    //input.value = '';
  }
});
socket.on("chat message", (arg) => {
    let msg = '接收消息:'+arg ;
    console.log(msg); // world
    addMessage(msg);
});

</script>

</html>
到此这篇关于nodejs结合Socket.IO实现websocket即时通讯的文章就介绍到这了,更多相关node websocket即时通讯内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:``