NodeJS 學習資料

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的實例,所以能夠產生各類不一樣的事件。

  可讀流主要會產生如下事件:

  • data   當讀取到流中的數據時,此事件被觸發
  • end   當流中沒有數據可讀時,此事件被觸發
  • error   當讀取數據出現錯誤時,此事件被觸發
  • close   當流被關閉時,,此事件被觸發,但是並非全部流都會觸發這個事件。(例如,一個鏈接進入的HTTP request流就不會觸發'close'事件。)

  還有一種比較特殊的 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);
    });
  });
});
相關文章
相關標籤/搜索