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庫就被棄用了