nodejs聊天室源码
① NodeJs 写的一份源码该怎么使用
var cookie = require('cookie');
mole.exports = function (req, res, conf, views, db) {
..var body = req.body,
....id = req.ids[0],
....usid = cookie.parse(req.headers.cookie).usid;
..function redirect () {
....res.writeHead(302, { 'location' : '/accounts' });
....res.end();
..}
..function joinpage () {
....res.writeHead(200, { 'Content-Type' : 'text/html;charset=utf-8' });
....res.write(views.ACCOUNTS_JOIN);
....res.write(views.unit({
......id : 'accounts_menu',
......name : 'accounts_menu',
........options : {
..........class_id : id
........}
....}));
....res.write(views.unit({
......id : 'accounts_join',
......name : 'accounts_join',
......options : {
........action : '/accounts/' + id + '/join',
........num : '0'
......}
....}));
....res.end(views.FOOTER);
..}
..db.session(usid, function (state) {
....// 已经建立会话
....if (state) {
......joinpage();
......return;
....}
....// 没有建立会话
....redirect();
..});
};
//////////////////////////////////////////////////////////////////////////////////////////////////////////
这段代码，是nodejs其中一个路由处理函数.
使用到了views视图模型，db数据库模型，以及conf全局配置文件.
并且使用了cookie模块来解析会话ID.
views视图模型 ： 生产HTML界面 [可以随时切换到PC或者移动HTML，接口一致]
db数据模型 ： 生产数据库数据
conf全局配置文件 ：你所需要的全局环境内容
代码的功能:
检测请求
....是否建立会话?
........是，跳转到"/"路由
........否，为用户显示登录界面
其中views负责生产视图界面， 在views模型中缓存了大量的常量，类似ACCOUNTS_JOIN，是页面布局。
对于其中的动态内容，采用facebook的bigpipe技术。
views.unit(/*id, name, css, js, content*/)输出script片段，分流到浏览器渲染。
整个服务器端在启动时渲染完毕所有的页面布局体，并缓存到views模型中，动态内容由bigpipe发送到前端渲染。
② nodejs 怎么把socket数据写入数据库
先说下我对socket.io的理解，websocket更像是开启了一个端口服务，来监视过往的通讯。所以我们可以依赖于当前站点80端口启socket服务，也可以放于其他端口上，比如：
1
require('socket.io').listen(3000);
这样就是监视3000端口了，由于我用的免费服务器，没有权限打开其他端口，所以，我还是使用80了，由于80已经被express使用了，所以我只好在express使用的时候传进来了。
var server = http.createServer(app);
var socket = require('./socket/msg')(server);
然后 我在msg.js里是这样写的
var db = require('../db/mysql');
var sio = require('socket.io');
var IO = function(server) {
var io = sio.listen(server)
这样就和谐了，db是创建mysql连接的方法，不在本节内容里，略。
在socket.io里是这样的，首先创建一个io通道的连接，然后监视里面的socket的事件，nodejs是事件驱动嘛。代码如下：
io.on('connection', function(socket) {
console.log('a user connected.');
socket.on('disconnect', function() {
console.log('user disconnected.');
});
})
这时只要有用户连接上，就会进入connection中了，然后它的参数是个socket,如果是公聊，我们可以直接用
1
io.emit('chat message', {});
这种形式了。但我们这里是私聊，所以我们要临时的把这个socket对象保存在全局里，供与你私聊的对象使用找到你的socket,很绕口，其实这里的私聊，不算完全的点对点，它还是经过了服务器的，消息传给服务器，服务器再找到你要传达给的那个人的socket对象，发给他。这就是整个的过程了。这里我使用的是一个类数组对象来存储的.
var users = {},
usocket = {};
socket.on('user join', function(data) {
users[username] = username;
usocket[username] = socket;
})
由于我这里需要用户名登录，所以我就把用户名作为了唯一的标识，这里用类数组的形式的好处就是我不用循环也能够很快的找到它。再我给A发送私聊时，我会先在这个uscoket里面找到它，然后调用它的emit。
function sendUserMsg(data) {
if (data.to in usocket) {
console.log('================')
console.log('to' + data.to, data);
usocket[data.to].emit('to' + data.to, data);
usocket[data.user].emit('to' + data.user, data);
console.log('================')
}
}
这里我emit了两次的原因是，我发给对方消息的同时，我自己也要收到这个消息，然后把它显示出来，为什么这样？其一，接口统一了，聊天里的内容全是服务器过来的，其二，证明我发送成功了。
然后我在客户端监听时，也用我自己的用户名起了一个to+用户名的事件监听。
socket.on('to' + user, function(data) {
//console.log(data);
formatMsg(data);
})
这样，不管是我发的消息，还是我收到消息，都会进入这个事件了。最后，在用户离开的时候别忘记delete掉这个对象。
socket.on('disconnect', function() {
console.log('disconnect')
if (username) {
counter--;
delete users[username];
delete usocket[username];
if (home.name == username) {
homeLeave(username);
}
sendmsg({
type: 0,
msg: "用户<b>" + username + "</b>离开聊天室",
counter: counter,
users: users
})
}
});
③ c#怎么向nodejs的socket.io发送请求
1. 简介
首先是Socket.IO的官方网站：http://socket.io
官网非常简洁，甚至没有API文档，只有一个简单的“How to use”可以参考。因为Socket.IO就跟官网一样简洁好用易上手。
那么Socket.IO到底是什么呢？Socket.IO是一个WebSocket库，包括了客户端的js和服务器端的nodejs，它的目标是构建可以在不同浏览器和移动设备上使用的实时应用。它会自动根据浏览器从WebSocket、AJAX长轮询、Iframe流等等各种方式中选择最佳的方式来实现网络实时应用，非常方便和人性化，而且支持的浏览器最低达IE5.5，应该可以满足绝大部分需求了。
2. 安装部署
2.1 安装
首先安装非常简单，在node.js环境下只要一句：
复制代码
代码如下:
npm install socket.io
2.2 结合express来构建服务器
express是一个小巧的Node.js的Web应用框架，在构建HTTP服务器时经常使用到，所以直接以Socket.IO和express为例子来讲解。
复制代码
代码如下:
var express = require('express')
,
app = express()
, server = require('http').createServer(app)
, io
= require('socket.io').listen(server);
server.listen(3001);
若不使用express，请参考socket.io/#how-to-use
3. 基本使用方法
主要分为服务器端和客户端两段代码，都非常简单。
Server（app.js）：
复制代码
代码如下:
//接上面的代码
app.get('/', function (req,
res) {
res.sendfile(__dirname + '/index.html');});
io.sockets.on('connection', function (socket) {
socket.emit('news', {
hello: 'world' });
socket.on('other event', function (data) {
console.log(data);
});
});
首先io.sockets.on函数接受字符串"connection"作为客户端发起连接的事件，当连接成功后，调用带有socket参数的回调函数。我们在使用socket.IO的时候，基本上都在这个回调函数里面处理用户的请求。
socket最关键的是emit和on两个函数，前者提交（发出）一个事件（事件名称用字符串表示），事件名称可以自定义，也有一些默认的事件名称，紧接着是一个对象，表示向该socket发送的内容；后者接收一个事件（事件名称用字符串表示），紧接着是收到事件调用的回调函数，其中data是收到的数据。
在上面的例子中，我们发送了news事件和收到了other
event事件，那么客户端应该会有对应的接收和发送事件。没错，客户端代码和服务器正好相反，而且非常相似。
Client（client.js）
复制代码
代码如下:
<script
src="/socket.io/socket.io.js"></script>
<script>
var
socket = io.connect('http://localhost');
socket.on('news', function
(data) {
console.log(data);
socket.emit('other event', {
my: 'data' });
});
</script>
有两点要注意的：socket.io.js路径要写对，这个js文件实际放在了服务器端的node_moles文件夹中，在请求这个文件时会重定向，因此不要诧异服务器端不存在这个文件但为什么还能正常工作。当然，你可以把服务器端的socket.io.js这个文件拷贝到本地，使它成为客户端的js文件，这样就不用每次都向Node服务器请求这个js文件，增强稳定性。第二点是要用var
socket =
io.connect('网站地址或ip');来获取socket对象，接着就可以使用socket来收发事件。关于事件处理，上面的代码表示收到“news”事件后，打印收到的数据，并向服务器发送“other
event”事件。
注：内置默认的事件名例如“disconnect”表示客户端连接断开，“message”表示收到消息等等。自定义的事件名称，尽量不要跟Socket.IO中内置的默认事件名重名，以免造成不必要的麻烦。
4. 其他常用API
1).向所有客户端广播：socket.broadcast.emit('broadcast message');
2).进入一个房间（非常好用！相当于一个命名空间，可以对一个特定的房间广播而不影响在其他房间或不在房间的客户端）：socket.join('your
room name');
3).向一个房间广播消息（发送者收不到消息）：socket.broadcast.to('your room name').emit('broadcast
room message');
4).向一个房间广播消息（包括发送者都能收到消息）（这个API属于io.sockets）：io.sockets.in('another room
name').emit('broadcast room message');
5).强制使用WebSocket通信：（客户端）socket.send('hi')，（服务器）用socket.on('message',
function(data){})来接收。
5. 使用Socket.IO构建一个聊天室
最后，我们通过一个简单的实例来结束本篇。用Socket.IO构建一个聊天室就是50行左右的代码的事情，实时聊天效果也非常好。以下贴出关键代码：
Server（socketChat.js）
复制代码
代码如下:
//一个客户端连接的字典，当一个客户端连接到服务器时，
//会产生一个唯一的socketId，该字典保存socketId到用户信息（昵称等）的映射
var
connectionList = {};
exports.startChat = function (io) {
io.sockets.on('connection',
function (socket) {
//客户端连接时，保存socketId和用户名
var socketId =
socket.id;
connectionList[socketId] = {
socket:
socket
};
//用户进入聊天室事件，向其他在线用户广播其用户名
socket.on('join', function
(data) {
socket.broadcast.emit('broadcast_join',
data);
connectionList[socketId].username =
data.username;
});
//用户离开聊天室事件，向其他在线用户广播其离开
socket.on('disconnect', function
() {
if (connectionList[socketId].username) {
socket.broadcast.emit('broadcast_quit', {
username:
connectionList[socketId].username
});
}
delete connectionList[socketId];
});
//用户发言事件，向其他在线用户广播其发言内容
socket.on('say', function (data)
{
socket.broadcast.emit('broadcast_say',{
username: connectionList[socketId].username,
text:
data.text
});
});
})
};
Client(socketChatClient.js)
复制代码
代码如下:
var socket =
io.connect('http://localhost');
//连接服务器完毕后，马上提交一个“加入”事件，把自己的用户名告诉别人
socket.emit('join',
{
username: 'Username hehe'
});
//收到加入聊天室广播后，显示消息
socket.on('broadcast_join', function (data) {
console.log(data.username + '加入了聊天室');
});
//收到离开聊天室广播后，显示消息
socket.on('broadcast_quit', function(data) {
console.log(data.username + '离开了聊天室');
});
//收到别人发送的消息后，显示消息
socket.on('broadcast_say', function(data) {
console.log(data.username + '说: ' + data.text);
});
//这里我们假设有一个文本框textarea和一个发送按钮.btn-send
//使用jQuery绑定事件
$('.btn-send').click(function(e)
{
//获取文本框的文本
var text = $('textarea').val();
//提交一个say事件，服务器收到就会广播
socket.emit('say', {
username: 'Username
hehe'
text: text
});
});
④ 如何用nodejs net进行聊天
初始工作
安装express, 用这个来托管socket.io,以及静态页面,命令npm install express --save,--save可以使包添加到package.json文件里.
安装socket.io,命令npm install socket.io --save.
- 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(' 33[96msomeone is connect 33[39m ');
- 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 + '离开聊天室!');
- }
- })})
- // 检查昵称是否重复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;}
- <!DOCTYPE html><html><head>
- <title>socket.io 聊天室例子</title>
- <meta charset="utf-8">
- <link rel="stylesheet" href="css/reset.css"/>
- <link rel="stylesheet" href="css/bootstrap.css"/>
- <link rel="stylesheet" href="css/app.css"/></head><body>
- <div class="wrapper">
- <div class="content" id="chat">
- <ul id="chat_conatiner">
- </ul>
- </div>
- <div class="action">
- <textarea ></textarea>
- <button class="btn btn-success" id="clear">清屏</button>
- <button class="btn btn-success" id="send">发送</button>
- </div>
- </div>
- <script type="text/javascript" src="js/socket.io.js"></script>
- <script type="text/javascript">
- var ws = io.connect('http://172.16.2.184:8888');
- var sendMsg = function(msg){
- ws.emit('send.message', msg);
- }
- var addMessage = function(from, msg){
- var li = document.createElement('li');
- li.innerHTML = '<span>' + from + '</span>' + ' : ' + msg;
- document.querySelector('#chat_conatiner').appendChild(li);
- // 设置内容区的滚动条到底部
- document.querySelector('#chat').scrollTop = document.querySelector('#chat').scrollHeight;
- // 并设置焦点
- document.querySelector('textarea').focus();
- }
- var send = function(){
- var ele_msg = document.querySelector('textarea');
- var msg = ele_msg.value.replace(' ', '').trim();
- console.log(msg);
- if(!msg) return;
- sendMsg(msg);
- // 添加消息到自己的内容区
- addMessage('你', msg);
- ele_msg.value = '';
- }
- ws.on('connect', function(){
- var nickname = window.prompt('输入你的昵称!');
- while(!nickname){
- nickname = window.prompt('昵称不能为空，请重新输入!')
- }
- ws.emit('join', nickname);
- });
- // 昵称有重复
- ws.on('nickname', function(){
- var nickname = window.prompt('昵称有重复，请重新输入!');
- while(!nickname){
- nickname = window.prompt('昵称不能为空，请重新输入!')
- }
- ws.emit('join', nickname);
- });
- ws.on('send.message', function(from, msg){
- addMessage(from, msg);
- });
- ws.on('announcement', function(from, msg){
- addMessage(from, msg);
- });
- document.querySelector('textarea').addEventListener('keypress', function(event){
- if(event.which == 13){
- send();
- }
- });
- document.querySelector('textarea').addEventListener('keydown', function(event){
- if(event.which == 13){
- send();
- }
- });
- document.querySelector('#send').addEventListener('click', function(){
- send();
- });
- document.querySelector('#clear').addEventListener('click', function(){
- document.querySelector('#chat_conatiner').innerHTML = '';
- });
- </script></body></html>
编写服务端代码
首先我们通过express来托管网站，并附加到socket.io实例里，因为socket.io初次连接需要http协议
添加服务器连接事件，当客户端连接成功之后，发公告告诉所有在线用户，并且，当用户发送消息时，发广播通知其它用户.
由于客户端是通过昵称来标识的，所以服务端需要一个检测昵称重复的函数
编写客服端代码
由于服务端采用第三方websokcet框架，所以前端页面需要单独引用socket.io客户端代码，源文件可以从socket.io模块里找，windows下路径为node_molessocket.io ode_molessocket.io-clientdist,这里有开发版和压缩版的，默认引用开发版就行.
前端主要处理输入昵称检查，消息处理，完整代码如下
⑤ nodejs怎么把html以源码的形式在网页中显示了，而不是解析它
可以通过设置输出到浏览器的'Content-Type的值为text/html即文本类型的html即可实现将html代码发送到浏览器中解释，而如果设置的值为text/plain则值会显示为文本而不会被浏览器渲染。
代码实例如下：
consthttp=require('http');
consthostname='127.0.0.1';
constport=3000;
constserver=http.createServer((req,res)=>{
res.statusCode=200;
res.setHeader('Content-Type','text/html');
res.end("<pstyle='color:red;font-size:30px;'>helloworld</p>");
});
server.listen(port,hostname,()=>{
console.log(`服务器运行在http://${hostname}:${port}/`);
});运行的结果如下：
⑥ 请问国内有没有用nodejs开发的微商城源码，比较完备的
可以去H5e看看，HTML5课程融合了HTML5开发基础课程、CSS3基础课程和移动前端交互JavaScript+JQuery+Ajex，还有微信开发课程
⑦ nodejs开发的socket聊天室在性能优化方面有哪些可以做的
做性能优化 先做性能监控 不然怎么对症下药。
node不清楚，可以了解下java里的mina是怎么做线程的复用
⑧ 如何使用nodejs创建直播聊天室
可以实现生产自动化，避免大理繁琐单调重复的工作。目的就是为了自动化，减少你重复做的工作。当你配置好了一个Grunt任务管理之后，它可以帮你减少很多重复性工作，按照配置使用并减少出错可能。
⑨ 聊天室用nodejs为什么那么快
这是node.js本身的语言特征所决定的
传统的服务器语言写入数据库时只有一个进程，每一个用户的请求都会单独开一个进程和分配一些资源，所以当用户数量多起来的时候，资源分配不足，就会产生延迟的现象
但是node.js的调用是在用户请求的时候分配一个单独的事件，收集请求的时候有单独同时运行的模块同时进行收集，然后单独地开一个模块写入数据库，这些区别导致了node.js在处理大规模并发数据方面能够具备极大优势
目前淘宝用的就是node.js，facebook等企业也是用的node，不过node的限制就是对于cpu的占用和消耗很大，不过相对于没有配置node服务器要消耗的资源来说，还是很划得来的
⑩ nodejs源码阅读求助
uv.这个是作者自己基于libev和libeio封装的一个用于处理nodejs异步事件循环的库，用libeio是因为，linux下，对于传统文件的读写操作时必然会导致阻塞的，那么如何处理异步呢，那就用了libeio，eio是一个用多线程来模拟异步的库，查看他的源码就会知道，默认的线程池是4个线程，LZ说的应该是这个。一年多以前ev库就被弃用了