今天我来实现一个简单的聊天室，后台用nodejs, 客户端与服务端通信用socket.io,这是一个比较成熟的websocket框架.
初始工作
1.安装express, 用这个来托管socket.io,以及静态页面,命令npm install express --save,--save可以使包添加到package.json文件里.
2.安装socket.io,命令npm install socket.io --save.
编写服务端代码
首先我们通过express来托管网站，并附加到socket.io实例里，因为socket.io初次连接需要http协议
var express = require('express'),
io = require('socket.io');
var app = express();
app.use(express.static(__dirname));
var server = app.listen(8888);
var ws = io.listen(server);
添加服务器连接事件，当客户端连接成功之后，发公告告诉所有在线用户，并且，当用户发送消息时，发广播通知其它用户.
ws.on('connection', function(client){
console.log('\033[96msomeone is connect\033[39m \n');
client.on('join', function(msg){
// 检查是否有重复
if(checkNickname(msg)){
client.emit('nickname', '昵称有重复!');
}else{
client.nickname = msg;
ws.sockets.emit('announcement', '系统', msg + ' 加入了聊天室!');
}
});
// 监听发送消息
client.on('send.message', function(msg){
client.broadcast.emit('send.message',client.nickname, msg);
});
// 断开连接时，通知其它用户
client.on('disconnect', function(){
if(client.nickname){
client.broadcast.emit('send.message','系统', client.nickname + '离开聊天室!');
}
})
})
由于客户端是通过昵称来标识的，所以服务端需要一个检测昵称重复的函数
系统功能介绍 1 包含企业网站所必备的功能：企业信息、产品管理、人才招聘、新闻资讯、企业图片、以及视频下载等模块2 由于是从CMS系统的基础上开发而成，因此相对于一些其他的企业网站管理系统，本系统具备更强的可扩展能力，可以胜任从小型工作室到大中型企业网上门户等各种不同规模网站的需求。3 后台管理与模板完全分离，并具备非常灵活的标签技术，可以实现无限制个性化的界面定制4 操作简单，利用已经制作好的模
// 检查昵称是否重复
var checkNickname = function(name){
for(var k in ws.sockets.sockets){
if(ws.sockets.sockets.hasOwnProperty(k)){
if(ws.sockets.sockets[k] && ws.sockets.sockets[k].nickname == name){
return true;
}
}
}
return false;
}
编写客服端代码
由于服务端采用第三方websokcet框架，所以前端页面需要单独引用socket.io客户端代码，源文件可以从socket.io模块里找，windows下路径为node_modules\socket.io\node_modules\socket.io-client\dist,这里有开发版和压缩版的，默认引用开发版就行.
前端主要处理输入昵称检查，消息处理，完整代码如下：
<script type="text/javascript" src="js/socket.io.js"></script>
<script type="text/javascript"> <p> var ws = io.connect('http://172.16.2.184:8888');<br> var sendMsg = function(msg){<br> ws.emit('send.message', msg);<br> }<br> var addMessage = function(from, msg){<br> var li = document.createElement('li');<br> li.innerHTML = '<span>' + from + '' + ' : ' + msg;<br> document.querySelector('#chat_conatiner').appendChild(li); <p> // 设置内容区的滚动条到底部<br> document.querySelector('#chat').scrollTop = document.querySelector('#chat').scrollHeight; <p> // 并设置焦点<br> document.querySelector('textarea').focus(); <p> } <p> var send = function(){<br> var ele_msg = document.querySelector('textarea');<br> var msg = ele_msg.value.replace('\r\n', '').trim();<br> console.log(msg);<br> if(!msg) return;<br> sendMsg(msg);<br> // 添加消息到自己的内容区<br> addMessage('你', msg);<br> ele_msg.value = '';<br> } <p> ws.on('connect', function(){<br> var nickname = window.prompt('输入你的昵称!');<br> while(!nickname){<br> nickname = window.prompt('昵称不能为空，请重新输入!')<br> }<br> ws.emit('join', nickname);<br> }); <p> // 昵称有重复<br> ws.on('nickname', function(){<br> var nickname = window.prompt('昵称有重复，请重新输入!');<br> while(!nickname){<br> nickname = window.prompt('昵称不能为空，请重新输入!')<br> }<br> ws.emit('join', nickname);<br> }); <p> ws.on('send.message', function(from, msg){<br> addMessage(from, msg);<br> }); <p> ws.on('announcement', function(from, msg){<br> addMessage(from, msg);<br> }); <p> document.querySelector('textarea').addEventListener('keypress', function(event){<br> if(event.which == 13){<br> send();<br> }<br> });<br> document.querySelector('textarea').addEventListener('keydown', function(event){<br> if(event.which == 13){<br> send();<br> }<br> });<br> document.querySelector('#send').addEventListener('click', function(){<br> send();<br> }); <p> document.querySelector('#clear').addEventListener('click', function(){<br> document.querySelector('#chat_conatiner').innerHTML = '';<br> });<br> </script>
这里提供完整的代码压缩文件
总结
nodejs是一个好东西，尤其是在处理消息通讯，网络编程方面，天生的异步IO.
