Utilisez Angular, Nodejs et socket.io pour créer des salles de discussion et des compétences en salles de discussion multi-personnes_javascript

1. Utilisez Node pour créer un serveur statique

C'est la partie support sous-jacente de ce projet. Utilisé pour prendre en charge l'accès aux fichiers de ressources statiques tels que html, css, gif, jpg, png, javascript, json, texte brut, etc. Il existe ici un mappage de fichier de type MIME.

mime.js

/**
 * mime类型的 map
 * @ author Cheng Liufeng
 * @ date 2014/8/30
 * 当请求静态服务器文件的类型 html, css, gif, jpg, png, javascript, json, plain text, 我们会在此文件进行映射
 */
exports.types = {
 "css": "text/css",
 "gif": "image/gif",
 "html": "text/html",
 "ico": "image/x-icon",
 "jpeg": "image/jpeg",
 "jpg": "image/jpeg",
 "js": "text/javascript",
 "json": "application/json",
 "pdf": "application/pdf",
 "png": "image/png",
 "svg": "image/svg+xml",
 "swf": "application/x-shockwave-flash",
 "tiff": "image/tiff",
 "txt": "text/plain",
 "wav": "audio/x-wav",
 "wma": "audio/x-ms-wma",
 "wmv": "video/x-ms-wmv",
 "xml": "text/xml"
};

Ici, je vais d'abord expliquer le processus depuis la saisie de l'URL jusqu'à l'apparition de la page. Lorsque l'utilisateur saisit une URL dans la barre d'adresse du navigateur.

Une série de processus se produira ensuite. La première est la résolution DNS, qui convertit le nom de domaine en adresse IP correspondante. Ensuite, le navigateur et le serveur Web distant établissent une connexion TCP/IP via une négociation TCP à trois voies. La prise de contact comprend un message de synchronisation, un message de réponse de synchronisation et un message de réponse. Ces trois messages sont transmis entre le navigateur et le serveur. Dans cette poignée de main, le client tente d'abord d'établir la communication, puis le serveur répond et accepte la demande du client, et enfin le client envoie un message indiquant que la demande a été acceptée. Une fois la connexion TCP/IP établie, le navigateur enverra une requête HTTP GET au serveur distant via la connexion.

Le serveur distant trouve la ressource et la renvoie à l'aide d'une réponse HTTP. Un statut de réponse HTTP de 200 indique une réponse correcte. À ce stade, le serveur Web fournit des services de ressources et le client commence à télécharger les ressources. Les ressources téléchargées incluent des fichiers HTML, des fichiers CSS, des fichiers javascript et des fichiers image. Commencez ensuite à construire un arbre de rendu et un arbre DOM, au cours desquels il y aura un blocage CSS et un blocage JS. Par conséquent, la couche inférieure nécessite un support de serveur statique. Ici, je construis un serveur statique de manière native sans utiliser le framework express.

En fait, le processus de chaque requête de fichier de ressources est une requête GET. Ensuite, j'expliquerai le processus de traitement côté serveur correspondant à la requête GET du client (côté navigateur ou utilisant la méthode curl sous Linux). Une fois qu'une requête Get est envoyée au serveur, le serveur peut correspondre au chemin d'un fichier de ressources en fonction de la requête GET. Après avoir connu ce chemin, nous pouvons utiliser la lecture et l'écriture de fichiers pour obtenir les ressources sous le chemin spécifié, puis les renvoyer au client.

Nous savons que les API de lecture et d'écriture de fichiers dans Node incluent readFile et readFileSync, mais une meilleure façon consiste à utiliser un flux pour lire des fichiers. L'avantage d'utiliser un flux est qu'il peut utiliser la mise en cache et la compression gzip.

OK, alors comment implémenter la mise en cache ? Normalement, lorsque le client fait une demande pour la première fois, le serveur lit le fichier de ressources et le renvoie au client. Mais lorsque vous demandez le même fichier pour la deuxième fois, vous devez quand même envoyer une requête au serveur. Le serveur déterminera si cette ressource a été mise en cache en fonction de l'expiration, du contrôle du cache, de If-Modified-Since et d'autres informations d'en-tête HTTP. S'il existe un cache, le serveur n'accédera plus au chemin réel du fichier de ressources. Renvoie directement les ressources mises en cache.

server.js

/**
 * 聊天室服务端
 * 功能：实现了Node版的静态服务器
 * 实现了缓存，gzip压缩等
 * @ author Cheng Liufeng
 * @ date 2014/8/30
 */
 // 设置端口号
var PORT = 3000;
// 引入模块
var http = require('http');
var url = require('url');
var fs = require('fs');
var path = require('path');
var zlib = require('zlib');
// 引入文件
var mime = require('./mime').types;
var config = require('./config');
var chatServer = require('./utils/chat_server');
var server = http.createServer(function (req, res) {
 res.setHeader("Server","Node/V8");
 // 获取文件路径
 var pathName = url.parse(req.url).pathname;
 if(pathName.slice(-1) === "/"){
 pathName = pathName + "index.html"; //默认取当前默认下的index.html
 }
 // 安全处理（当使用Linux 的 curl命令访问时，存在安全隐患）
 var realPath = path.join("client", path.normalize(pathName.replace(/\.\./g, "")));
 // 检查文件路径是否存在
 path.exists(realPath, function(exists) {
 // 当文件不存在时的情况， 输出一个404错误
 if (!exists) {
  res.writeHead(404, "Not Found", {'Content-Type': 'text/plain'});
  res.write("The request url" + pathName +" is not found!");
  res.end();
 } else {   // 当文件存在时的处理逻辑
  fs.stat(realPath, function(err, stat) {
    // 获取文件扩展名
  var ext = path.extname(realPath);
  ext = ext ? ext.slice(1) : "unknown";
  var contentType = mime[ext] || "text/plain";
  // 设置 Content-Type
  res.setHeader("Content-Type", contentType);
  var lastModified = stat.mtime.toUTCString();
  var ifModifiedSince = "If-Modified-Since".toLowerCase();
  res.setHeader("Last-Modified", lastModified);
  if (ext.match(config.Expires.fileMatch)) {
   var expires = new Date();
   expires.setTime(expires.getTime() + config.Expires.maxAge * 1000);
   res.setHeader("Expires", expires.toUTCString());
   res.setHeader("Cache-Control", "max-age=" + config.Expires.maxAge);
  }
  if (req.headers[ifModifiedSince] && lastModified == req.headers[ifModifiedSince]) {
   res.writeHead(304, "Not Modified");
   res.end();
  } else {
   // 使用流的方式去读取文件
   var raw = fs.createReadStream(realPath);
   var acceptEncoding = req.headers['accept-encoding'] || "";
   var matched = ext.match(config.Compress.match);
   if (matched && acceptEncoding.match(/\bgzip\b/)) {
   res.writeHead(200, "Ok", {'Content-Encoding': 'gzip'});
   raw.pipe(zlib.createGzip()).pipe(res);
   } else if (matched && acceptEncoding.match(/\bdeflate\b/)) {
   res.writeHead(200, "Ok", {'Content-Encoding': 'deflate'});
   raw.pipe(zlib.createDeflate()).pipe(res);
   } else {
   res.writeHead(200, "Ok");
   raw.pipe(res);
   }

//Ce qui suit est une manière courante de lire des fichiers, non recommandée

//   fs.readFile(realPath, "binary", function(err, data) {
//   if(err) {
//    // file exists, but have some error while read
//    res.writeHead(500, {'Content-Type': 'text/plain'});
//    res.end(err);
//   } else {
//    // file exists, can success return
//    res.writeHead(200, {'Content-Type': contentType});
//    res.write(data, "binary");
//    res.end();
//   }
//   });
  }
  });
 }
 });
});

//Écouter le port 3000

server.listen(PORT, function() {
 console.log("Server is listening on port " + PORT + "!");
});

// Laisser le serveur socket.io et le serveur http partager un port

chatServer.listen(server);

Deuxièmement, le serveur utilise WebSocket pour créer le serveur de salle de discussion

Pourquoi utiliser websocket ?

Nous savons que les salons de discussion grand public utilisent encore ajax pour réaliser la communication entre le client et le serveur. Un mécanisme d'interrogation est utilisé. Le soi-disant sondage signifie que le client envoie une requête de temps en temps pour demander au serveur de voir s'il y a de nouvelles données de discussion sur le serveur. S'il y a de nouvelles données, elles sont renvoyées au client.

Websocket est complètement différent. Websocket est basé sur des liens longs. Autrement dit, une fois qu’un lien est établi entre le client et le serveur, le lien existera toujours. Il s'agit d'une communication en duplex intégral. Le mécanisme actuel est quelque peu similaire au modèle de publication-abonnement. Le client s'abonnera à certains événements et, une fois que de nouvelles données apparaîtront sur le serveur, elles seront activement transmises au client.

Websocket utilise le protocole ws, pas le protocole http ou https. Un autre avantage de l’utilisation de Websocket est qu’elle peut réduire considérablement le trafic de données. Au début de l'article, j'ai présenté le processus traditionnel de demande de ressources unique, qui nécessite un protocole de négociation à trois voies, et chaque en-tête de demande occupe un espace relativement grand, ce qui consommera beaucoup de trafic. Les en-têtes utilisés pour communiquer entre eux dans Websocket sont très petits – seulement environ 2 octets.

/**
 * 聊天服务。
 */
var socketio = require('socket.io');
var io;
var guestNumber = 1;   //初始用户名编号
var nickNames = {};   // 昵称列表
var namesUsed = [];   //使用过的用户名
var currentRoom = {};   //当前聊天室
function assignGuestName(socket, guestNumber, nickNames, namesUsed) {
 var name = 'Guest' + guestNumber;
 nickNames[socket.id] = name;
 socket.emit('nameResult', {
 success: true,
 name: name
 });
 namesUsed.push(name);
 return guestNumber + 1;
}
function joinRoom(socket, room) {
 socket.join(room);
 currentRoom[socket.id] = room;
 socket.emit('joinResult', {room: room});
 socket.broadcast.to(room).emit('message', {
 text: nickNames[socket.id] + 'has joined ' + room + '.'
 });
}
function handleMessageBroadcasting(socket) {
 socket.on('message', function(message) {
 socket.broadcast.to(message.room).emit('message', {
  text: nickNames[socket.id] + ':' + message.text
 });
 });
}
exports.listen = function(server) {
 io = socketio.listen(server);
 io.set('log level', 1);
 // 定义每个用户的连接处理
 io.sockets.on('connection', function(socket) {
 // 分配一个用户名
 guestNumber = assignGuestName(socket, guestNumber, nickNames, namesUsed);
 // 将用户加入聊天室Lobby里
 joinRoom(socket, 'Lobby');
 //处理聊天信息
 handleMessageBroadcasting(socket, nickNames);
 //handleNameChangeAttempts(socket, nickNames, namesUsed);
 //handleRoomJoining(socket);
 //handleClientDisconnection(socket, nickNames, namesUsed);
 });
};

三，利用Angular搭建聊天室客户端

        为什么使用Angular?

         作为一款前端MVC框架，Angular.js无疑是引人注目的。模块化，双向数据绑定，指令系统，依赖注入。而且Angular内置jquerylite，这让熟悉jQuery语法的同学很容易上手。

当然，个人认为， angular在构建一个单页应用和crud项目方面有很大的优势。 我们这个聊天室就是基于SPA（single page application）的目的。

index.html

<!DOCTYPE html>
<html ng-app="chatApp">
<head>
 <meta name="viewport" content="width=device-width, user-scalable=no">
</head>
<body ng-controller="InitCtrl">
 <div ng-view></div>
 <script src="lib/angular.js"></script>
 <script src="lib/angular-route.js"></script>
 <script src="lib/socket.io.js"></script>
 <script src="app.js"></script>
 <script src="controllers/InitCtrl.js"></script>
</body>
</html>

怎样构建一个单页应用？单页应用的原理？

        先谈谈单页应用的原理。所谓单页，并不是整个页面无刷新。当你审查一下google chrome的console控制台的时候，你会发现，angular内部还是采用了ajax去异步请求资源。所以只是局部刷新。但是这种方式相对于以前的DOM节点的删除和修改已经有很大的进步了。

     构建单页应用，我们需要借助于angular-route.js。这个angular子项目可以帮助我们定义路由和对应的逻辑处理控制器。利用它，我们可以实现一个单页应用。

app.js 

/**
 * 客户端（目前只支持浏览器，将来会扩展到移动端）程序入口文件
 * 创建一个模块，并且命名为chatApp
 * 配置路由，实现单页应用(single page application)
 */
 var chatApp = angular.module("chatApp", ['ngRoute']);
 // 路由配置
 chatApp.config(function($routeProvider) {
 $routeProvider.when('/', {
  templateUrl : 'views/init.html',
  controller: 'InitCtrl'
 })
 .when('/init', {
  templateUrl : 'views/init.html',
  controller: 'InitCtrl'
 });
 });

客户端聊天界面的代码逻辑如下

InitCtrl.js

/**
 * # InitCtrl
 */
angular.module('chatApp').controller('InitCtrl', function($scope) {
 var socket = io.connect('http://127.0.0.1:3000');
 socket.on('nameResult', function(result) {
 var message;
 if (result.success) {
  message = 'you are now known as ' + result.name + '.'; 
  console.log('message=', message);
  document.getElementById('guestname').innerHTML = message;
 } else {
  message = result.message;
 }
 });
 socket.on('joinResult', function(result) {
 document.getElementById('room').innerHTML = result.room;
 });
 $scope.sendMessage = function() {
 var message = {
  room: 'Lobby',
  text: document.getElementById('user_input').value
 };
 socket.emit('message', message);
 };
 socket.on('message', function(message) {
 var p = document.createElement('p');
 p.innerHTML = message.text;
 document.getElementById('message').appendChild(p);
 });
});

基于node.js和socket.io搭建多人聊天室

刚学node.js，想着做点东西练练手。网上的东西多而杂，走了不少弯路，花了一天时间在调代码上。参考网上的一篇文章，重写了部分代码，原来的是基于基于node-websocket-server框架的，我没用框架，单单是socket.io。

一、基本功能

1、用户随意输入一个昵称即可登录

2、登录成功后

1) 对正在登录用户来说，罗列所有在线用户列表，罗列最近的历史聊天记录

2) 对已登录的用户来说，通知有新用户进入房间，更新在线用户列表

3、退出登录

1)支持直接退出

2) 当有用户退出，其他所有在线用户会收到信息，通知又用户退出房间，同时更新在线用户列表

4、聊天

1) 聊天就是广播，把信息广播给所有连接在线的用户

5、一些出错处理

1) 暂时简单处理了系统逻辑错误、网络出错等特殊情况的出错提示

问题：功能不完善，有bug(退出后，新用户重新登录，还是原来的用户) 。抽空完善吧

二、技术介绍

socket.io(官网：http://socket.io/)是一个跨平台，多种连接方式自动切换，做即时通讯方面的开发很方便，而且能和expressjs提供的传统请求方式很好的结合，即可以在同一个域名，同一个端口提供两种连接方式：request/response, websocket(flashsocket,ajax…)。

这篇文章对socket.io的使用做了详细介绍：http://www.jb51.net/article/71361.htm

《用node.js和Websocket做个多人聊天室吧》http://www.html5china.com/HTML5features/WebSocket/20111206_3096.html

三、注意事项

（1）客户端这样引用socket.io.js：

<script src="/socket.io/socket.io.js"></script>

可能会加载失败（我在这里耗了不少时间）

可以改为：

<script src="http://ip:port/socket.io/socket.io.js"></script>

(对应服务器的ip地址和端口号，比如说localhost和80端口)

（2）实现广播的时候，参考官网的写法，竟然不起作用，如：

var io = require('socket.io').listen(80);

io.sockets.on('connection', function (socket) {
 socket.broadcast.emit('user connected');
 socket.broadcast.json.send({ a: 'message' });
});

后来看了这个：http://stackoverflow.com/questions/7352164/update-all-clients-using-socket-io

改为以下才起作用：

io.sockets.emit('users_count', clients);

四、效果图

五、源码下载

　　Nodejs多人聊天室（点击此处下载源码）

ps:

1、在命令行运行

node main.js

然后在浏览器中打开index.html,如果浏览器（ff、Chrome）不支持，请升级到支持WebSocket的版本.

2、推荐node.js的IDE WebStorm

以上内容就是本文基于Angular和Nodejs搭建聊天室及多人聊天室的实现，希望大家喜欢。