Nodejs는 Socket.IO를 결합하여 인스턴트 메시징 기능을 실현합니다.
- 小云云원래의
- 2018-01-15 09:42:052640검색
이 글에서는 Nodejs와 Socket.IO가 결합된 인스턴트 메시징 기능을 주로 소개하며, Socket.IO와 결합된 nodejs의 관련 운영 기술과 주의사항을 자세히 분석하여 필요한 친구들이 예시 형태로 인스턴트 메시징을 구현할 수 있도록 돕습니다. 참고하셔서 모두에게 도움이 되었으면 좋겠습니다.
동적 웹
HTML5 이전에는 웹 디자인이 항상 문서 중심으로 설계되었습니다. 사용자는 웹 페이지를 한 번 요청하고 페이지를 얻습니다. 그러나 시간이 지남에 따라 사람들은 웹이 단순히 문서를 표시하는 것 이상의 기능을 수행하기를 원하며 개발자들 사이에서는 웹 페이지를 홍보하는 데 항상 JavaScript가 사용되었습니다.
Ajax는 의심할 여지없이 동적 웹 페이지의 주요 개발입니다. 더 이상 약간의 콘텐츠를 업데이트하더라도 전체 페이지를 새로 고칠 필요가 없지만 어떤 측면에서는 단점을 반영합니다. 서버에 데이터를 요청하면 괜찮지만, 서버가 브라우저에 데이터를 푸시하려고 하면 어떻게 될까요? Ajax 기술은 고객에게 데이터를 푸시하는 것을 쉽게 지원할 수 없지만 국경을 넘는 장애물이 많고 브라우저마다 작동 방식이 다릅니다. 예를 들어 IE와 FireBox는 서로 다른 커널을 사용하므로 작업 방법도 동일하지 않습니다.
WebSocket은 서버와 클라이언트 간의 양방향 통신 문제에 대한 응답입니다. 모든 브라우저에서 항상 작동하지 않는 복잡한 설정을 거치는 대신 개발자가 일관된 방식으로 애플리케이션을 만드는 데 사용할 수 있는 표준을 처음부터 다시 설계하는 것이 아이디어였습니다. 아이디어는 웹 서버와 브라우저 사이에 지속적으로 열린 연결을 유지하여 서버와 브라우저가 원할 때 데이터를 푸시할 수 있도록 하는 것입니다. 연결이 지속적이기 때문에 데이터 교환이 매우 빠르고 실시간이 됩니다.
Socket.IO
이제 메인 스피커를 소개하겠습니다. Socket.IO는 WebSocket을 통해 통신하는 간단한 방법을 제공하는 모듈입니다. 그러나 Socket.IO는 서버와 클라이언트 모두에 대한 구성 요소를 제공하므로 애플리케이션에 WebSocket에 대한 지원을 추가하려면 하나의 모듈만 필요합니다. 또한 다양한 브라우저를 지원합니다.
Basic Socket.IO
Socket.IO는 서버측과 클라이언트측 모두에서 작동할 수 있으므로 사용하려면 서버측 JavaScript(Node.js)와 클라이언트측 JavaScript(JQuery)에 추가해야 합니다. ), 내부 통신은 일반적으로 양방향이기 때문에 Sokcet.IO는 양방향에서 작동할 수 있어야 합니다.
var server = http.createServer(function (req,res){
fs.readFile('./index.html',function(error,data){
res.writeHead(200,{'Content-Type':'text/html'});
res.end(data,'utf-8');
});
}).listen(3000,"127.0.0.1");
console.log('Server running at http://127.0.0.1:3000/');그리고 Socket.IO 기능을 추가하려면 Socket.IO 라이브러리가 포함되어야 합니다.
var io = require('socket.io').listen(server);
그런 다음 클라이언트의 연결 여부에 응답하는 이벤트를 추가하세요. 이벤트 내용은 다음과 같습니다.
io.sockets.on('connection',function(socket){
console.log('User connected');
socket.on('disconnect',function(){
console.log('User disconnected');
});
});매우 간단하지 않나요? 완전한 코드 구현이 어떻게 구현되는지 살펴보겠습니다.
Simple Socket.IO 애플리케이션
New app.js
새 폴더 Socket.io를 만들고 이 폴더 아래에 새 app.js를 만든 후 다음 코드를 작성합니다.
var http = require('http');
var fs = require('fs');
var server = http.createServer(function (req,res){
fs.readFile('./index.html',function(error,data){
res.writeHead(200,{'Content-Type':'text/html'});
res.end(data,'utf-8');
});
}).listen(3000,"127.0.0.1");
console.log('Server running at http://127.0.0.1:3000/');
var io = require('socket.io').listen(server);
io.sockets.on('connection',function(socket){
console.log('User connected');
socket.on('disconnect',function(){
console.log('User disconnected');
});
});New index.html
새 index.html 만들기 파일에서 코드는 다음과 같습니다.
<!DOCTYPE html> <html> <head> <meta charset="utf-8" /> <title>Socket.IO Example</title> </head> <body> <h1>Socket.IO Example</h1> <script src="/socket.io/socket.io.js"></script> <script> var socket = io.connect('http://127.0.0.1:3000'); </script> </body> </html>
새 package.json을 생성합니다.
모듈을 소개하기 위해 새 package.json을 생성합니다.
{
"name":"socketio_example",
"version":"4.13.2",
"private":true,
"dependencies":{
"socket.io":"1.4.5"
}
}버전 번호는 nodejs -V 또는 소켓.io -v를 입력하여 버전 번호를 확인할 수 있습니다.
Run
Socket.IO를 설치하지 않은 경우 다음 코드를 실행할 수 있습니다. 설치한 경우 이 단계는 자동으로 건너뜁니다.
npm install socket.io
터미널에서 다음 명령을 실행하여 모듈을 설치하세요
npm install
다음 명령을 실행하여 서버를 시작하세요
node app.js
브라우저를 열고 http://127.0.0.1을 입력하세요. 3000/, 탭을 몇 개 더 열고 URL을 입력한 다음 아무 탭이나 닫고 cmd 명령 창이 다음과 같은지 확인하세요.
여기에는 사용된 연결 수와 사용자 수가 자세히 기록됩니다. 연결이 끊어졌습니다. 웹 페이지 방문 횟수를 계산할 수 있도록 연결을 엽니다.
서버에서 클라이언트로 데이터 보내기
위의 예에서는 녹음을 위해 서버와의 연결 또는 연결 해제를 구현했지만 메시지를 푸시하려면 어떻게 해야 할까요? 예를 들어 친구의 QQ는 다음과 같습니다. 온라인, Tencent 그들은 모두 기침을 하여 친구가 온라인에 있다는 것을 상기시킵니다. 이 기능을 살펴보겠습니다.
한 명의 사용자에게 보내기
io.sockets.on('connection',function(socket){
socket.emit('message',{text:'你上线了'});
});모든 사용자에게 보내기
io.sockets.on('connection',function(socket){
socket.broadcast.emit('message',{'你的好某XXX上线了'});
});한 명의 사용자에게 보내는 메시지인지 전체 사용자에게 보내는 메시지인지 이 메시지는 제가 직접 작성한 것이지만 반드시 클라이언트에서 사용되므로 이름 지정에 주의하세요.
클라이언트
在客户端我们可以添加侦听事件来接收数据。
var socket = io.connect('http://127.0.0.1:3000');
socket.on('message',function(data){
alert(data.text);
})通过这些功能，我们就在第一个例子的基础上，实现用户数量的统计。这里只需要在服务端设置一个变量，count,如果有一个上线，那么就数量+1，并通知所有用户，最新的在线人数。
新建app.js
var http = require('http');
var fs = require('fs');
var count = 0;
var server = http.createServer(function (req,res){
fs.readFile('./index.html',function(error,data){
res.writeHead(200,{'Content-Type':'text/html'});
res.end(data,'utf-8');
});
}).listen(3000,"127.0.0.1");
console.log('Server running at http://127.0.0.1:3000/');
var io = require('socket.io').listen(server);
io.sockets.on('connection',function(socket){
count++;
console.log('User connected' + count + 'user(s) present');
socket.emit('users',{number:count});
socket.broadcast.emit('users',{number:count});
socket.on('disconnect',function(){
count--;
console.log('User disconnected');
socket.broadcast.emit('users',{number:count});
});
});创建index.html文件
<!DOCTYPE html>
<html>
<head>
<meta charset="utf-8" />
<title>Socket.IO Example</title>
</head>
<body>
<h1>Socket.IO Example</h1>
<h2>How many users are here?</h2>
<p id="count"></p>
<script src="http://***.***.**.***:9001/jquery.min.js"></script>
<script src="/socket.io/socket.io.js"></script>
<script>
var socket = io.connect('http://127.0.0.1:3000');
var count = document.getElementById('count');
socket.on('users',function(data){
console.log('Got update from the server');
console.log('There are ' + data.number + 'users');
count.innerHTML = data.number
});
</script>
</body>
</html>创建package.json文件
{
"name":"socketio_example",
"version":"4.13.2",
"private":true,
"dependencies":{
"socket.io":"1.4.5"
}
}安装模块npm install
启动服务器node app.js
打开浏览器，输入http://127.0.0.1:3000,可以看到如下图片：
再打开一个连接http://127.0.0.1:3000，可以看到如下结果：
可以看到如果我们打开两个连接，那么两个页签都会显示当前又两个用户在线，如果关闭其中一个，我们可以看到又显示只有一个用户在线。
将数据广播给客户端
接下来我们来看看Socket.IO是如何实现客户端与客户端的通信呢。
要想实现该功能，首先需要客户端将消息发送到服务端，·然后服务端发送给除自己之外的其他客户。服务器将消息发送给客户端的方法在上一个例子中我们已经实现了，那么我们需要的是客户端把接收到的消息发送给服务器。
下边的代码思想是利用表单来实现的。
<form id="message-form" action="#">
<textarea id="message" rows="4" cols="30"></textarea>
<input type="submit" value="Send message" />
</form>
<script src="http://***.***.***.**:9001/jquery.min.js"></script>
<script src="/socket.io/socket.io.js"></script>
<script>
var socket = io.connect('http://127.0.0.1:3000');
var message = document.getElementById('message');
$(message.form).submit(function() {
socket.emit('message', { text: message.value });
return false;
});
socket.on('push message', function (data) {
$('form').after('<p>' + data.text + '</p>');
});
</script>实现的思想是,将JQuery和SocketIO库包含进来，只是浏览器拦截127.0.0.1:3000的服务，使用Jquery的submit方法加入侦听期，等候用户提交表单。
发送消息给Socket>IO服务器，文本区域的内容位消息发送。
添加return false ，防止表单在浏览器窗口提交。
在上边已经说过服务器如何广播消息，下边我们说一下客户端如何显示客户端发送的消息。
socket.on('push message', function (data) {
$('form').after('<p>' + data.text + '</p>');
})实例实现
创建messaging的新文件夹
在文件夹下创建package.json文件，代码如下：
{
"name":"socketio_example",
"version":"4.13.2",
"private":true,
"dependencies":{
"socket.io":"1.4.5"
}
}创建app.js文件，代码如下：
var http = require('http');
var fs = require('fs');
var server = http.createServer(function (req,res){
fs.readFile('./index.html',function(error,data){
res.writeHead(200,{'Content-Type':'text/html'});
res.end(data,'utf-8');
});
}).listen(3000,"127.0.0.1");
console.log('Server running at http://127.0.0.1:3000/');
var io = require('socket.io').listen(server);
io.sockets.on('connection',function(socket){
socket.on('message',function(data){
socket.broadcast.emit('push message',data);
});
});创建index.html
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="utf-8" />
<title>Socket.IO Example</title>
</head>
<body>
<h1>Socket.IO Example</h1>
<form id="message-form" action="#">
<textarea id="message" rows="4" cols="30"></textarea>
<input type="submit" value="Send message" />
</form>
<script src="http://222.222.124.77:9001/jquery.min.js"></script>
<script src="/socket.io/socket.io.js"></script>
<script>
var socket = io.connect('http://127.0.0.1:3000');
var message = document.getElementById('message');
$(message.form).submit(function() {
socket.emit('message', { text: message.value });
return false;
});
socket.on('push message', function (data) {
$('form').after('<p>' + data.text + '</p>');
});
</script>
</body>
</html>加载模块npm install
启动服务器node app.js
然后打开浏览器的多个页签，都输入http://127.0.0.1:3000
可以看到我们再任何一个窗口输入内容，都会在其他的页面显示我们输入的内容，效果如下：
小结
这篇博客好长，其实说了这么多，还是有很多的东西没有说，但是我们还是讨论了Socket.IO如何实现动态的，通过服务端能显示用户的连接，和统计链接次数统计，到最后的消息的通知和聊天功能的实现。在我们的生活中这种例子比比解释，例如QQ，例如淘宝的抢购，都是可以通过这种方式实现的，这样我们就能实时的实现动态的功能了。
相关推荐：
HTML5+NodeJs实现WebSocket即时通讯的示例代码分享
Workerman+layerIM+ThinkPHP5的webIM，即时通讯系统
위 내용은 Nodejs는 Socket.IO를 결합하여 인스턴트 메시징 기능을 실현합니다.의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!