为什么需要socket.io?
node.js提供了高效的服务端运行环境,但是由于浏览器端对HTML5的支持不一,为了兼容所有浏览器,提供卓越的实时的用户体验,并且为程序员提供客户端与服务端一致的编程体验,于是socket.io诞生。
var http = require( 'http' ),
url = require( 'url' ),
fs = require( 'fs' ),
server;
server = http.createServer( function (req, res){
// your normal server code
var path = url.parse(req.url).pathname;
switch (path){
case '/' :
res.writeHead(200, { 'Content-Type' : 'text/html' });
res.write( '<h1>Hello! Try the <a href="/index.html">Socket.io Test</a></h1>' );
res.end();
break ;
case '/index.html' :
fs.readFile(__dirname + path, function (err, data){
if (err) return send404(res);
res.writeHead(200, { 'Content-Type' : path == 'json.js' ? 'text/javascript' : 'text/html' })
res.write(data, 'utf8' );
res.end();
});
break ;
default : send404(res);
}
}), send404 = function (res){
res.writeHead(404);
res.write( '404' );
res.end();
}; server.listen(8080); var io = require( 'socket.io' ).listen(server);
io.sockets.on( 'connection' , function (socket){
console.log( "Connection " + socket.id + " accepted." );
socket.on( 'message' , function (message){
console.log( "Received message: " + message + " - from client " + socket.id);
});
socket.on( 'disconnect' , function (){
console.log( "Connection " + socket.id + " terminated." );
});
}); |
客户端编程模型
客户端编程也是相似的处理方式,连接服务器,交互信息。比如下面的index.html页面:
<!doctype html> <html> <head> <title>Socket.io Test</title> <script src= "/json.js" ></script> <!-- for ie -->
<script src= "/socket.io/socket.io.js" ></script>
</head> <body> <script> var socket;
var firstconnect = true ;
function connect() {
if (firstconnect) {
socket = io.connect( null );
socket.on( 'message' , function (data){ message(data); });
socket.on( 'connect' , function (){ status_update( "Connected to Server" ); });
socket.on( 'disconnect' , function (){ status_update( "Disconnected from Server" ); });
socket.on( 'reconnect' , function (){ status_update( "Reconnected to Server" ); });
socket.on( 'reconnecting' , function ( nextRetry ){ status_update( "Reconnecting in "
+ nextRetry + " seconds" ); });
socket.on( 'reconnect_failed' , function (){ message( "Reconnect Failed" ); });
firstconnect = false ;
} else {
socket.socket.reconnect();
}
} function disconnect() {
socket.disconnect();
} function message(data) {
document.getElementById( 'message' ).innerHTML = "Server says: " + data;
} function status_update(txt){
document.getElementById( 'status' ).innerHTML = txt;
} function esc(msg){
return msg.replace(/</g, '<' ).replace(/>/g, '>' );
} function send() {
socket.send( "Hello Server!" );
}; </script> <h1>Socket.io Test</h1> <div><p id= "status" >Waiting for input</p></div>
<div><p id= "message" ></p></div>
<button id= "connect" onClick= 'connect()' />Connect</button>
<button id= "disconnect" onClick= 'disconnect()' >Disconnect</button>
<button id= "send" onClick= 'send()' />Send Message</button>
</body> </html> |
1. 启动服务器还是交给node,打开命令行窗口,定位到server.js所在文件夹,输入node server.js启动服务器。
在上面的index.html中,注意这行:<script src="/socket.io/socket.io.js"></script>。如果不想使用本地的socket.io脚本,可以直接使用下面这个公开的脚本:
|
此外需要注意这行:socket = io.connect(null)。这里的null代表连接本地服务,可以换成"localhost",效果也是一样的。
2. 可以使用socket.io直接启动http服务。例如:
var io = require( 'socket.io' ).listen(80);
io.sockets.on( 'connection' , function (socket) {
io.sockets.emit( 'this' , { will: 'be received by everyone' });
}); |
3. socket.io可以直接通过send方法发送消息,使用message事件接收消息,例如:
//server.js var io = require( 'socket.io' ).listen(80);
io.sockets.on( 'connection' , function (socket) {
socket.on( 'message' , function () { });
}); //index.html <script> socket.on( 'connect' , function () {
socket.send( 'hi' );
socket.on( 'message' , function (msg) {
// my msg
});
}); </script> |
4. 发送和处理数据
两端可以互发事件,互发数据,相互通信。发送事件的代码为:socket.emit(action, data, function),其中action为事件的名称,data为数据,function为回调函数;处理事件代码 为:socket.on(action,function),如果emit发送的时候有数据data,则function中参数包含了这个数据。 socket.io除了发送和处理内置事件,如connect, disconnect, message。还允许发送和处理自定义事件,例如:
//服务端: io.sockets.on( 'connection' , function (socket) {
socket.emit( 'news' , { hello: 'world' });
socket.on( 'my other event' , function (data) {
console.log(data);
});
}); //客户端: <script src= "/socket.io/socket.io.js" ></script>
<script> socket.on( 'news' , function (data) {
console.log(data);
socket.emit( 'my other event' , { my: 'data' });
}); </script> |
5. 从上面可以看出来,发送数据的时候,send和emit是都可以使用的。只不过emit更是强化了自定义事件的处理。
6. 可以在服务端使用socket的get/set方法存储客服端的相关数据,例如:
//服务端 var io = require( 'socket.io' ).listen(80);
io.sockets.on( 'connection' , function (socket) {
socket.on( 'set nickname' , function (name) {
socket.set( 'nickname' , name, function () { socket.emit( 'ready' ); });
});
socket.on( 'msg' , function () {
socket.get( 'nickname' , function (err, name) {
console.log( 'Chat message by ' , name);
});
});
}); //客户端 <script> socket.on( 'connect' , function () {
socket.emit( 'set nickname' , confirm( 'What is your nickname?' ));
socket.on( 'ready' , function () {
console.log( 'Connected !' );
socket.emit( 'msg' , confirm( 'What is your message?' ));
});
}); </script> |
实用参考
socket.io介绍:http://davidchambersdesign.com/getting-started-with-socket.io/
socket.io安装和使用说明:http://socket.io/
相关推荐
<script src="/socket.io/socket.io.js"> const socket = io(); let username = prompt("请输入您的昵称:"); socket.emit('newUser', username); socket.on('usersConnected', (count) => { document....
在本文中,我们将深入探讨如何使用Node.js和socket.io库构建一个实时的、基于Web的小游戏,特别是描述中的"SpaceGame"。Node.js是一个流行的JavaScript运行环境,它允许开发者在服务器端使用JavaScript进行编程。而...
在本文中,我们将深入探讨如何使用JavaScript、socket.io、WebRTC、Node.js和Express搭建一个简易版的远程视频聊天应用。这些技术都是现代Web开发中的关键组件,它们各自扮演着不同的角色,共同构建出实时、低延迟的...
3. **客户端连接**:在 HTML 页面中引入 socket.io 的客户端库,并使用 `io.connect()` 连接到服务器。 4. **事件监听与发送**:使用 `socket.on()` 监听服务器发送的消息,同时使用 `socket.emit()` 发送消息到...
Node.js 结合 Socket.IO 实现即时通讯功能的详解 在技术发展潮流中,即时通讯功能已经成为各种应用的核心需求。对于实时数据交换而言,传统的HTTP请求方式因频繁的请求与响应导致了效率问题。为了解决这一问题,Web...
socket.io.js存在于socket.io-client socket.io存在于socket.io 演示的功能 客户端发送消息给服务端 后端触发事件告知客户端 客户端离开触发服务端事件 服务端 server.js var express = require('express'); ...
<script src="https://cdn.socket.io/4.1.2/socket.io.min.js"> #messages { list-style-type: none; margin: 0; padding: 0; } #messages li { padding: 5px 10px; } #input { width: 100%; box-sizing: ...
Socket.IO 是一个实时应用框架,它为Web开发者提供了一种简单、高效的通信方式,支持WebSocket以及其他几种降级的传输协议。这个压缩包文件"unity-SocketIO-master"显然是关于在Unity游戏引擎中集成Socket.IO的示例...
nodejs + socket.io 的多人在线聊天后台系统+源码+运行教程,适合毕业设计、课程设计、项目开发。项目源码已经过严格测试,可以放心参考并在此基础上延申使用~ nodejs + socket.io 的多人在线聊天后台系统+源码+...
【基于NodeJS的聊天室程序(socket.io实现)】 在当今互联网技术中,实时通信成为了一个不可或缺的特性,尤其是在社交应用和协作工具中。本项目基于Node.js和socket.io,构建了一个能够实现多人在线聊天的聊天室程序...
NULL 博文链接:https://fuyu365-163-com.iteye.com/blog/2154066
laravel-realtime-chat, 实时聊天w/Laravel + Redis + node.js + socket.io Laravel 实时聊天 用 Laravel 4.2 + node.js + + Socket.io. 编写的实时聊天示例Live: http://chat.guilhermeslk.com.br: )##Requirem
【Node.js-网站在线客服基于socket.io和node】 在当今的Web开发中,实时通信已经成为一个重要的需求,尤其是在构建互动性强、用户体验丰富的在线客服系统时。Node.js以其非阻塞I/O和事件驱动的特性,成为了实现此类...
io.on('connection', (socket) => { console.log('A user connected'); socket.on('disconnect', () => { console.log('User disconnected'); }); }); ``` 为了让用户能够互相发送消息,我们需要监听客户端...
本示例“Nodejs Socket IO Mysql Demo”将带你了解如何将这些技术结合在一起。 1. **Node.js基础知识** - **事件驱动编程**:Node.js的核心设计是基于事件驱动模型,这使得它能高效地处理大量并发连接。 - **非...
nodejs + socket.io 的多人在线聊天前台系统+源码+运行教程,适合毕业设计、课程设计、项目开发。项目源码已经过严格测试,可以放心参考并在此基础上延申使用~ nodejs + socket.io 的多人在线聊天前台系统+源码+...
马上要年会了,有个什么总突然...nodejs express(ejs模板引擎) socket.io excel-export shake.js 年会摇一摇H5小游戏完整demo,有截图,可先去看看截图 https://blog.csdn.net/qq_38652871/article/details/103424198
标题中的“Node.js + Socket.IO 多人同步画板”是指使用Node.js作为后端服务器,结合Socket.IO实现实时通信,创建一个可以让多个用户同时在线绘画并实时看到彼此画作更新的平台。这个项目的核心在于实现Web端的实时...
本项目是一个利用nodejs.socket.io实先的多人会议画板功能。实现会议同步,插入图片,插入线条,更换背景色,和移动端兼容等。若有不足之处望批评。谢谢