1. npmjavascript
除Node自己提供的API外,如今有很多第三方模塊可極大的提升開發效率,npm就是Node的軟件包管理器,能夠用它安裝所需軟件包併發布本身爲nodejs寫的軟件包。html
npm安裝node擴展包一樣是一行代碼:java
npm install <包名> //例:npm install express
注:若是安裝模塊的過程當中報域名錯誤的話,請清空緩存 >npm cache clean 或重啓計算機便可。node
2.模塊web
在Node中,不一樣的功能組件被劃分紅不一樣的模塊。應用能夠根據本身的須要來選擇使用合適的模塊。每一個模塊都會暴露一些公共的方法或屬性。模塊的使用者直 接使用這些方法或屬性便可,對於內部的實現細節就能夠不用瞭解。除了Node自己提供的API外,開發人員也能夠利用這個機制來將應用拆分紅多個模塊,以 提升代碼的可複用性。express
在Node中使用模塊是很是方便的,在 JavaScript 代碼中能夠直接使用全局函數 require() 來加載一個模塊。npm
私有和共有 介紹
數組
先建立一個myModule.js,代碼以下緩存
var name = "Darren"; this.location = "Beijing"; this.showLog = function(){ console.log('Hi Darren.') };
代碼中出現了三種類型,分別是: 私用屬性,共有屬性和共有方法,再建立一個test.js,執行Node服務器
結果高亮的地方很清楚的告訴咱們,私有方法咱們在模塊之外是取不到的,因此是undefined。共有屬性和共有方法的聲明須要在前面加上 this 關鍵字。
事件流
由於Node 採用的是事件驅動的模式,其中的不少模塊都會產生各類不一樣的事件,可由模塊來添加事件處理方法,全部可以產生事件的對象都是事件模塊中的 EventEmitter 類的實例。代碼是全世界通用的語言,因此咱們仍是用代碼說話:
var events = require("events"); var emitter = new events.EventEmitter(); emitter.on("myEvent", function(msg) { console.log(msg); }); emitter.emit("myEvent", "Hello World.");
簡單的分析這段:
1. 使用require()方法添加了events模塊並把返回值賦給了一個變量
2. new events.EventEmitter()這句建立了一個事件觸發器,也就是所謂的事件模塊中的 EventEmitter 類的實例
3. on(event, listener)用來爲某個事件 event 添加事件處理方法監聽器
4. emit(event, [arg1], [arg2], [...]) 方法用來產生事件。以提供的參數做爲監聽器函數的參數,順序執行監聽器列表中的每一個監聽器函數。
EventEmitter 類中的方法都與事件的產生和處理相關:
1. addListener(event, listener) 和 on(event, listener) 這兩個方法都是將一個監聽器添加到指定事件的監聽器數組的末尾
2. once(event, listener) 這個方法爲事件爲添加一次性的監聽器。該監聽器在事件第一次觸發時執行,事後將被移除
3. removeListener(event, listener) 該方法用來將監聽器從指定事件的監聽器數組中移除出去
4. emit(event, [arg1], [arg2], [...]) 剛剛提到過了。
在Node中,存在各式各樣不一樣的數據流,Stream(流)是一個由不一樣對象實現的抽象接口。例如請求HTTP服務器的request是一個 流,相似於stdout(標準輸出);包括文件系統、HTTP 請求和響應、以及 TCP/UDP 鏈接等。流能夠是可讀的,可寫的,或者既可讀又可寫。全部流都是EventEmitter的實例,所以能夠產生各類不一樣的事件。
可讀流主要會產生如下事件:
還有一種比較特殊的 fd 事件,當在流中接收到一個文件描述符時觸發此事件。只有UNIX流支持這個功能,其餘類型的流均不會觸發此事件。
3. socket.io(https://cnodejs.org/topic/50a1fcc7637ffa4155b5a264)
安裝:npm install socket.io
利用Node的搭建Http服務,分爲兩個文件,服務端文件app.js和客戶端index.html
app.js 01 var app = require('http').createServer(handler) 02 , io = require('socket.io').listen(app) 03 , fs = require('fs') 04 05 app.listen(80); 06 07 function handler (req, res) { 08 fs.readFile(__dirname + '/index.html', 09 function (err, data) { 10 if (err) { 11 res.writeHead(500); 12 return res.end('Error loading index.html'); 13 } 14 15 res.writeHead(200); 16 res.end(data); 17 }); 18 } 19 20 io.sockets.on('connection', function (socket) { 21 socket.emit('news', { hello: 'world' }); 22 socket.on('my other event', function (data) { 23 console.log(data); 24 }); 25 });
這裏須要注意的是:
require(’socket.io').listen(app) 實際上這句就是講socket的監聽加入的app設置的http模塊了
io.sockets.on(‘connection’,function()…)這裏設置了在鏈接後進行的處理,代碼示例中,主要包含兩件事,一個是向前段發送news的事件,一個是監聽my other event事件。
index.html 1 <script src="/socket.io/socket.io.js"></script> 2 <script> 3 var socket = io.connect('http://localhost'); 4 socket.on('news', function (data) { 5 console.log(data); 6 socket.emit('my other event', { my: 'data' }); 7 }); 8 </script>
客戶端一個引用了socket.io.js的javscript庫 還有就是鏈接服務器(經過io.connect(’http://localhost')) 以後在監聽收到news的事件後,發送my other event事件
利用Express3框架 上面的例子只是使用nodejs創建了一個交互,也可使用express2的web框架, 具體app.js代碼以下:
var app = require('express')() , server = require('http').createServer(app) , io = require('socket.io').listen(server); server.listen(80); app.get('/', function (req, res) { res.sendfile(__dirname + '/index.html'); }); io.sockets.on('connection', function (socket) { socket.emit('news', { hello: 'world' }); socket.on('my other event', function (data) { console.log(data); }); });
接收發送事件
socket.io容許用戶自定義發送接收的事件。除了connect,message,disconnect三個事件外,用戶能夠自定義本身的事件
// note, io.listen(<port>) will create a http server for you var io = require('socket.io').listen(80); io.sockets.on('connection', function (socket) { io.sockets.emit('this', { will: 'be received by everyone'}); socket.on('private message', function (from, msg) { console.log('I received a private message by ', from, ' saying ', msg); }); socket.on('disconnect', function () { io.sockets.emit('user disconnected'); }); });
存儲數據
有的時候須要存儲一些和客戶端關聯的數據在會話裏,socket.io也是支持的,代碼以下:
var io = require('socket.io').listen(80); io.sockets.on('connection', function (socket) { socket.on('set nickname', function (name) { socket.set('nickname', name, function () { socket.emit('ready'); }); }); socket.on('msg', function () { socket.get('nickname', function (err, name) { console.log('Chat message by ', name); }); }); });
socket.set和socket.get方法分爲用於設置和獲取變量。
設置命名空間
有的時候要一個程序支持多個應用,若是使用默認的 「/」 命名空間可能會比較混亂。若是想讓一個鏈接能夠支持多個鏈接,可使用以下的命名空間的方法:
app.js var io = require('socket.io').listen(80); var chat = io .of('/chat') .on('connection', function (socket) { socket.emit('a message', { that: 'only' , '/chat': 'will get' }); chat.emit('a message', { everyone: 'in' , '/chat': 'will get' }); }); var news = io .of(’/news’) .on(‘connection’, function (socket) { socket.emit(‘item’, { news: ‘item’ }); });
client.js <script> var chat = io.connect('http://localhost/chat') , news = io.connect('http://localhost/news'); chat.on('connect', function () { chat.emit('hi!'); }); news.on('news', function () { news.emit('woot'); }); </script>
發送獲取數據
有的時候,你須要在發送數據後,等待服務器的消息確認。固然簡單的發,能夠經過兩次消息發送,來完成。這裏介紹一種使用回調函數的方法:
app.js var io = require('socket.io').listen(80); io.sockets.on('connection', function (socket) { socket.on('ferret', function (name, fn) { fn('woot'); }); }); client.html <script> var socket = io.connect(); // TIP: .connect with no args does auto-discovery socket.on('connect', function () { // TIP: you can avoid listening on `connect` and listen on events directly too! socket.emit('ferret', 'tobi', function (data) { console.log(data); // data will be 'woot' }); }); </script>
廣播
向全部的鏈接觸發事件,這裏注意:不包括自己鏈接的事件。
var io = require('socket.io').listen(80); io.sockets.on('connection', function (socket) { socket.broadcast.emit('user connected'); });
聊天程序(https://cnodejs.org/topic/50a1fcc7637ffa4155b5a264):
index.html <script src="/socket.io/socket.io.js"></script> <script> var socket = io.connect('http://localhost'); socket.on("notice", function(data){ var msg = document.getElementById('all').value; document.getElementById('all').innerText = msg + "\n" + data.message; }); var chat_fn = function(){ var msg = document.getElementById("message").value; socket.emit("chat", {message: msg}); }; socket.on("nickname ready", function(data){ alert("nickname changed."); }); var change_nickname = function(){ var nickname = document.getElementById("nickname").value; socket.emit('set nickname', nickname); }; </script> <textarea id="all" cols=40 rows=20></textarea> <br /> <label>Message:</label> <input id="message" type="text" name="message" cols=120/> <input id="chat_btn" type="button" value="chat" onclick="javascript:chat_fn()" /> <label>NickName:</label> <input id="nickname" typee="text" name="nickname" /> <input id="chang_name" type="button" value="nickname" onclick="javascript:change_nickname()" /> app.js var app = require('http').createServer(handler) , io = require('socket.io').listen(app) , fs = require('fs'); app.listen(80); function handler (req, res) { fs.readFile(__dirname + '/index.html', function (err, data) { if (err) { res.writeHead(500); return res.end('Error loading index.html'); } res.writeHead(200); res.end(data); }); } io.sockets.on('connection', function (socket) { // socket.emit('news', { hello: 'world' }); // socket.on('my other event', function (data) { // console.log(data); // }); socket.set('nickname', 'nickname', function(){ }); socket.on('set nickname', function(name){ socket.set('nickname', name, function(){ console.log("change nickname=>" + name); socket.emit('nickname ready'); }); }); socket.on('chat', function(data){ socket.get('nickname', function(err, name){ socket.emit("notice", {message: name + ":" + data.message}); socket.broadcast.emit("notice", {message: name + ":" + data.message}); console.log("chat: " + data.message); }); }); });