webSocket和socket.IO

时间 2020-02-13

原文原文链接

http://nodejs.cn/api/https.htmljavascript

HTTP难以实现实时数据传输 1长轮询 ajax 2长链接html

websocket 协议可以让浏览器和服务器互相通讯，服务器也能主动通知客户端java

原理：利用http请求产生握手，http头部憨厚webSocket协议的请求，握手以后，二者使用tcp协议进行交流（qq的协议） 2.websocket协议须要浏览器和服务器同时支持
node 0 apache 7.02 nginx 1.3node

网址：http://socket.io/nginx

先要npm下载这个库 npm install socket.ioweb

socket.io 还为不支持webSocket协议浏览器，提供了长轮询的透明模拟机制ajax

var http=require("")express

当server建立出来以后,调用io函数，取得一个socket对象 var socket=io();apache

写原生的JS，搭建一个服务器，server建立好以后，建立一个io对象

var http = require("http");

var server = http.createServer(function(req,res){
	res.end("你好");
});

var io = require('socket.io')(server);
//监听链接事件
io.on("connection",function(socket){
	console.log("1个客户端链接了");
})
server.listen(3000,"127.0.0.1");

写完这句话以后，你就会发现，http://127.0.0.1:3000/socket.io/socket.io.js 就是一个js文件的地址了。此时，在服务器上，app.js中就要书写静态文件呈递程序，可以呈递静态页面npm

如今须要制做一个index页面，这个页面中，必须引用秘密js文件。调用io函数，取得socket对象。

1<!DOCTYPE html>
2<html lang="en">
3<head>
4	<meta charset="UTF-8">
5	<title>Document</title>
6</head>
7<body>
8	<h1>我是index页面，我引用了秘密script文件</h1>
9	<script type="text/javascript" src="/socket.io/socket.io.js"></script>
10	<script type="text/javascript">
11		var socket = io();
12	</script>
13</body>
</html>

此时，在服务器上，app.js中就要书写静态文件呈递程序，可以呈递静态页面。

1var server = http.createServer(function(req,res){
2	if(req.url == "/"){
3		//显示首页
4		fs.readFile("./index.html",function(err,data){
5			res.end(data);
6		});
7	}
8});

至此，服务器和客户端都有socket对象了。服务器的socket对象：

服务器端的：

1var io = require('socket.io')(server);
2//监听链接事件
3io.on("connection",function(socket){
4	console.log("1个客户端链接了");
5	socket.on("tiwen",function(msg){
6		console.log("本服务器获得了一个提问" + msg);
7		socket.emit("huida","吃了");
8	});
9});

每个链接上来的用户，都有一个socket。因为咱们的emit语句，是socket.emit()发出的，因此指的是向这个客户端发出语句。

广播，就是给全部当前链接的用户发送信息：

1//建立一个io对象 
2var io = require('socket.io')(server);
3//监听链接事件
4io.on("connection",function(socket){  //  服务器的socket是经过回调函数得到的
5	console.log("1个客户端链接了");
6	socket.on("tiwen",function(msg){
7		console.log("本服务器获得了一个提问" + msg);
                 socket.emit("huida","吃了");      //  单个发送socket
8		io.emit("huida","吃了");         //  就是给全部当前链接的用户发送信息：
9	});
10});

io.on 监听 io.emit 发送

express和socket.io配合使用

●Express框架能够和Socket.IO搭配使用，可是不能像一般的Express程序那样，用app.listen进行监听了，而是采用一种固定的模式： var express = require('express'); var app = express(); var http = require('http').Server(app); var io = require('socket.io')(http);

http.listen(3000);

//session公式： var session = require('express-session'); app.use(session({ secret: 'keyboard cat', resave: false, saveUninitialized: true }));