码迷,mamicode.com
首页 > Web开发 > 详细

node.js基础内容

时间:2018-10-16 02:13:49      阅读:165      评论:0      收藏:0      [点我收藏+]

标签:delete   cpu   mkdir   调整   listening   通知   编写   移动   each   

node.js 

node.js是建立在谷歌Chrome的JavaScript引擎(v8)的web应用程序框架。

node.js 自带的运行环境可在JavaScript脚本的基础上解释和执行。这个运行是运行在浏览器以外的任何机器上执行JavaScript代码。所以也可以在服务端运行,Node.js还提供了各种丰富的JavaScript模块库,它极大简化了使用Node.js来扩展Web应用程序的研究与开发。

特性

Node.js库的异步和事件驱动的API全部都是异步就是非阻塞。它主要是指基于Node.js的服务器不会等待API返回的数据。服务器移动到下一个API调用,Node.js发生的事件通知机制后有助于服务器获得从之前的API调用的响应。

非常快的内置谷歌Chrome的V8 JavaScript引擎,Node.js库代码执行是非常快的。

单线程但高度可扩展 - Node.js使用具有循环事件单线程模型。

没有缓冲 - Node.js的应用从来不使用缓冲任何数据。这些应用只是输出数据在块中。

应用场景

适合:I/O 绑定应用程序,数据流应用,数据密集型实时应用(DIRT),JSON API的应用程序,单页面应用。

不适合:CPU密集型应用。

下载安装完成后,通过cmd启动执行文件。

node.js - Hello World

node -v 查看当前node版本。

通过编写js文件,然后再cmd当前目录运行文件。

1 var http = require(‘http‘);
2 http.createServer(function(req,res){
3     res.writeHead(200,{‘Content-Type‘:‘text/plain‘});
4     res.end(‘Hello World\n‘);
5 }).listen(1337,‘127.0.0.1‘);
6 console.log(‘Server running at http://127.0.0.1:1337/‘);

执行当前文件目录执行node hello.js 

技术分享图片

起一个简单的服务,在浏览器可输入地址,后显示

 技术分享图片

node.js - npm

npm 表示节点程序包管理器。是Node.js包/模块的在线软件仓库;可以在命令行实用程序安装包,作为Node.js版本管理和依赖包管理。

npm -v 查看当前npm版本。(一般安装node.js自带npm)-g  表示资源包全局安装。

npm  install express (一个实用的web框架)

npm  ls 查询

package.json 

package.json是存在于任何Node应用程序/模块的根目录,并用于定义一个包的属性。

Node.js - 回调

回调是一种异步相当于一个函数。回调函数被调用在完成既定任务。Node大量使用了回调。Node所有的API写的都是支持回调的这样一种方式。例如,一个函数读取一个文件可能开始读取文件,并立即返回控制到执行环境 使得下一个指令可以马上被执行。一旦文件 I/O 完成,它会调用回调函数,同时传递回调函数,该文件作为参数的内容。因此不会有堵塞或等待文件I/O。这使得Node.js高度可扩展,因此可以处理大量的请求,而无需等待任何函数来返回结果。

阻塞代码/非阻塞代码。

技术分享图片
1 var fs = require(‘fs‘);
2 
3 fs.readFile(‘text.txt‘,function(err,data){
4     if(err) return console.log(err);
5     console.log(data.toString());
6 })
7 console.log("end!!");
非阻塞代码

事件循环  &&  事件驱动编程

Node JS是单线程应用程序,但它通过事件和回调的概念,支持并发。NodeJS的每一个API都是异步的,作为一个单独的线程,它使用异步函数调用来维护并发。Node使用观察者模式。Node线程保持一个事件循环,每当任何任务完成后得到结果,它触发通知事件侦听函数来执行相应的事件。

Node.js使用大量事件,这也是为什么Node.js相对于其他类似技术比较快的原因之一。当Node启动其服务器,就可以简单地初始化其变量,声明函数,然后等待事件的发生。

技术分享图片
 1 // 声明需要事件
 2 var events = require(‘events‘);
 3 // 创建事件对象
 4 var eventEmitter = new events.EventEmitter();
 5 // 声明触发事件执行的函数
 6 var connected = function connected() {
 7     console.log(‘connection succesful!‘)
 8     eventEmitter.emit(‘data_received.‘);
 9 }
10 // 绑定事件
11 eventEmitter.on("connection",connected);
12 eventEmitter.on("data_received",function(){
13     console.log(‘data received succesfully.‘);
14 });
15 // 事件触发
16 eventEmitter.emit(‘connection‘);
17 console.log(‘code end!‘);
node事件驱动

错误处理:

技术分享图片
 1 var fs = require("fs");
 2 
 3 fs.readFile(‘test.txt‘, function (err, data) {
 4     if (err){
 5        console.log(err.stack);
 6        return;
 7     }
 8     console.log(data.toString());
 9 });
10 console.log("Program Ended");
readFile err 处理

事件监听的添加移除与触发

技术分享图片
 1 // 需要事件
 2 var events = require(‘events‘); 
 3 // 创建事件对象
 4 var eventEmitter = new events.EventEmitter();
 5 // 事件1
 6 var listner1 = function listner1() {
 7     console.log(‘this is 11111‘);
 8 }
 9 // 事件2
10 var listner2 = function listner2() {
11     console.log(‘this is 22222‘);
12 }
13 // 事件监听addListener与on效果相同
14 eventEmitter.addListener(‘connection‘,listner1);
15 eventEmitter.on(‘connection‘,listner2);
16 // 另一种写法
17 var eventListeners = require(‘events‘).EventEmitter.listenerCount(eventEmitter,‘connection‘);
18 console.log(eventListeners + " Listner(s) listening to connection event");
19 // 触发事件
20 eventEmitter.emit(‘connection‘);
21 // 移除事件监听
22 eventEmitter.removeListener(‘connection‘, listner1);
23 console.log("Listner111 will not listen now. removeListener");
24 // 再触发事件
25 eventEmitter.emit(‘connection‘);
26 // 添加事件监听
27 eventListeners = require(‘events‘).EventEmitter.listenerCount(eventEmitter,‘connection‘);
28 console.log(eventListeners + " Listner(s) listening to connection event");
29 
30 console.log("Program Ended.");
事件监听add+remove...

Buffer 类 缓冲器

Buffer类是一个全局类,可以在应用程序,无需导入缓冲模块进行访问。缓冲区是一种整数数组并对应于原始存储器V8堆以外分配。 缓冲区不能调整大小。

在 ECMAScript 2015 引入 TypedArray 之前,JavaScript 语言没有读取或操作二进制数据流的机制。 Buffer 类被引入作为 Node.js API 的一部分,使其可以在 TCP 流或文件系统操作等场景中处理二进制数据流。

TypedArray 现已被添加进 ES6 中,Buffer 类以一种更优化、更适合 Node.js 用例的方式实现了 Uint8Array API。

技术分享图片
 1 var buffer = new Buffer(26);
 2 console.log("buffer length: " + buffer.length);
 3 var data = "YiiBai.com";
 4 
 5 buffer.write(data);
 6 console.log(data + ": " + data.length + " characters, " + Buffer.byteLength(data, ‘utf8‘) + " bytes");
 7 
 8 var buffer1 = buffer.slice(0,14);
 9 console.log("buffer1 length: " + buffer1.length);
10 console.log("buffer1 content: " + buffer1.toString());
11 
12 for (var i = 0 ; i < 26 ; i++) {
13     buffer[i] = i + 97; // 97 is ASCII a
14   }
15   console.log("buffer content: " + buffer.toString(‘ascii‘));
16   
17   var buffer2 = new Buffer(4);
18 
19   buffer2[0] = 0x3;
20   buffer2[1] = 0x4;
21   buffer2[2] = 0x23;
22   buffer2[3] = 0x42;
23 
24 //reading from buffer
25 console.log(buffer2.readUInt16BE(0));
26 console.log(buffer2.readUInt16LE(0));
27 console.log(buffer2.readUInt16BE(1));
28 console.log(buffer2.readUInt16LE(1));
29 console.log(buffer2.readUInt16BE(2));
30 console.log(buffer2.readUInt16LE(2));
31 
32 var buffer3 = new Buffer(4);
33 buffer3.writeUInt16BE(0xdead, 0);
34 buffer3.writeUInt16BE(0xbeef, 2);
35 console.log(buffer3);
36 
37 buffer3.writeUInt16LE(0xdead, 0);
38 buffer3.writeUInt16LE(0xbeef, 2);
39 
40 console.log(buffer3);
41 
42 //convert to a JSON Object
43 var json = buffer3.toJSON();
44 console.log("JSON Representation : ");
45 console.log(json);
46 
47 //Get a buffer from JSON Object
48 var buffer6 = new Buffer(json);
49 console.log(buffer6);
50 
51 //copy a buffer
52 var buffer4 = new Buffer(26);
53 buffer.copy(buffer4);
54 console.log("buffer4 content: " + buffer4.toString());
55 
56 //concatenate a buffer
57 var buffer5 = Buffer.concat([buffer,buffer4]);
58 console.log("buffer5 content: " + buffer5.toString());
Buffer

 

node.js 数据流

数据流是从源数据读取或写入数据到目标对象以。在节点中,有四种类型的流:

  • Readable - 数据流,其是用于读操作

  • Writable - 数据流,用在写操作

  • Duplex - 数据流,其可以用于读取和写入操作

  • Transform - 双相类型流,输出基于输入进行计算

每种类型的流是EventEmitter,并且一次引发几个事件。例如,一些常用的事件是:

  • data - 当有数据可读取时触发此事件

  • end - 当没有更多的数据读取时触发此事件

  • error - 当有错误或接收数据写入时触发此事件

  • finish - 当所有数据已刷新到底层系统时触发此事件

技术分享图片
 1 var fs = require("fs");
 2 var data = ‘‘;
 3 //create a readable stream
 4 var readerStream = fs.createReadStream(‘text.txt‘);
 5 
 6 //set the encoding to be utf8. 
 7 readerStream.setEncoding(‘UTF8‘);
 8 
 9 //handle stream events
10 readerStream.on(‘data‘, function(chunk) {
11    data += chunk;
12 });
13 
14 readerStream.on(‘end‘,function(){
15    console.log(data);
16 });
17 
18 readerStream.on(‘error‘, function(err){
19    console.log(err.stack);
20 });
21 console.log("-------------Program Ended---------------");
readerStream
技术分享图片
 1 var fs = require("fs");
 2 var data = ‘Yiibai.Com‘;
 3 //create a writable stream
 4 var writerStream = fs.createWriteStream(‘text1.txt‘);
 5 
 6 //write the data to stream
 7 //set the encoding to be utf8. 
 8 writerStream.write(data,‘UTF8‘);
 9 
10 //mark the end of file
11 writerStream.end();
12 
13 //handle stream events
14 writerStream.on(‘finish‘, function() {
15     console.log("Write completed.");
16 });
17 
18 writerStream.on(‘error‘, function(err){
19    console.log(err.stack);
20 });
21 console.log("--------------Program Ended---------------");
writeStream

 

node.js 文件系统

--同步&异步  

每一个fs模块的方法都有同步和异步形式。异步方法接受一个最后的参数为完成回调函数,而回调函数的第一个参数是错误。它优选使用异步方法来代替同步方法,前者从未阻塞程序执行,而后者则会阻塞。

  1 var fs = require("fs");
  2 var buffer = new Buffer(1024);
  3 
  4 //Example: Opening File打开文件
  5 function openFile(){
  6    console.log("\nOpen file--------");
  7    fs.open(‘test.txt‘, ‘r+‘, function(err,fd) {
  8       if (err) console.log(err.stack);
  9       console.log("File opened");     
 10    });
 11 }
 12 
 13 //Example: Getting File Info 统计信息
 14 function getStats(){
 15    console.log("\nGetting File Info---------");
 16    fs.stat(‘test.txt‘, function (err, stats) {
 17       if (err) console.log(err.stack);
 18       console.log(stats);
 19       console.log("isFile ? "+stats.isFile());
 20       console.log("isDirectory ? "+stats.isDirectory());
 21    });
 22 }
 23 
 24 //Example: Writing File 写
 25 function writeFile(){
 26    console.log("\nWrite file-----------");
 27    fs.open(‘test2.txt‘, ‘w+‘, function(err,fd) {
 28       var data = "Yiibai.com - Simply Easy Learning!";
 29       buffer.write(data); 
 30       
 31       fs.write(fd, buffer,0,data.length,0,function(err, bytes){
 32          if (err) console.log(err.stack);
 33          console.log(bytes + " written!");         
 34       });    
 35    });
 36 }
 37 
 38 //Example: Read File 读取
 39 function readFile(){
 40    console.log("\nRead file----------");
 41    fs.open(‘test1.txt‘, ‘r+‘, function(err,fd) {
 42       if (err) console.log(err.stack);
 43       fs.read(fd, buffer,0,buffer.length,0,function(err, bytes){
 44          if (err) console.log(err.stack);
 45          console.log(bytes + " read!");
 46          if(bytes > 0){
 47             console.log(buffer.slice(0,bytes).toString());
 48          }
 49       });    
 50    });
 51 }
 52 // 关闭
 53 function closeFile(){
 54    console.log("\nClose file-------------");
 55    fs.open(‘test.txt‘, ‘r+‘, function(err,fd) {
 56       if (err) console.log(err.stack);      
 57       fs.close(fd,function(){
 58          if (err) console.log(err.stack);      
 59          console.log("File closed!");
 60       });
 61    });
 62 }
 63 // 删除
 64 function deleteFile(){
 65    console.log("\nDelete file-----------");
 66    fs.open(‘test1.txt‘, ‘r+‘, function(err,fd) {
 67        fs.unlink(‘test1.txt‘, function(err) {
 68           if (err) console.log(err.stack);                  
 69           console.log("File deleted!");     
 70        });
 71    });
 72 }
 73 // 缩短,删节?
 74 function truncateFile(){
 75    console.log("\nTruncate file------------");
 76    fs.open(‘test.txt‘, ‘r+‘, function(err,fd) {
 77        fs.ftruncate(fd, function(err) {
 78           if (err) console.log(err.stack);                  
 79           console.log("File truncated!");     
 80        });
 81    });
 82 }
 83 
 84 function createDirectory(){
 85     console.log("\nCreate Directory--------------");
 86     fs.mkdir(‘test‘,function(err){
 87       if(!err){
 88          console.log("Directory created!");
 89       }
 90       if(err && err.code === ‘EEXIST‘){
 91          console.log("Directory exists!");    
 92       } else if (err) {       
 93          console.log(err.stack);           
 94       }
 95     });
 96 }
 97 // 移除
 98 function removeDirectory(){
 99     console.log("\nRemove Directory---------------");
100     fs.rmdir(‘test‘,function(err){
101       if(!err){
102          console.log("Directory removed!");
103       }
104       if (err) {      
105          console.log("Directory do not exist!");                   
106       }
107     });
108 }
109 // 监听
110 function watchFile(){
111    fs.watch(‘test.txt‘, function (event, filename) {
112       console.log(‘event is: ‘ + event);   
113    });
114 }
115 
116 //Opening file
117 openFile();
118 
119 //Writing File
120 writeFile();
121 
122 //Reading File   
123 readFile();
124 
125 //Closing Files
126 closeFile();
127 
128 //Getting file information
129 getStats();
130    
131 //Deleting Files
132 deleteFile();
133    
134 //Truncating Files
135 truncateFile();
136    
137 //Creating Directories
138 createDirectory();
139 
140 //Removing Directories
141 removeDirectory();
142    
143 //Watching File Changes
144 watchFile();

 

 node.js - 进程 (process)

 process 是一个全局性对象,并用于表示Node进程。

 Process(进程)是一个eventEmitter,并且它发出下列事件

 Process(进程)提供了许多有用的特性,以更好地控制系统的相互作用。

 Process(进程)提供了许多有用的方法,以更好的控制系统的相互作用。

 

技术分享图片
 1 var util = require(‘util‘);
 2 
 3 //printing to console
 4 process.stdout.write("Hello World!" + "\n");
 5 
 6 //reading passed parameter
 7 process.argv.forEach(function(val, index, array) {
 8    console.log(index + ‘: ‘ + val);
 9 });
10 
11 //executable path
12 console.log(process.execPath);
13 
14 //print the current directory
15 console.log(‘Current directory: ‘ + process.cwd());
16     
17 //print the process version
18 console.log(‘Current version: ‘ + process.version);
19 
20 //print the memory usage
21 console.log(util.inspect(process.memoryUsage()));
process

node.js - psth

path 模块用于处理和转换文件路径。path模块可以使用以下语法导入。

var path = require("path")

 1 var path = require("path");
 2 
 3 //normalization
 4 console.log(‘normalization : ‘ + path.normalize(‘/test/test1//2slashes/1slash/tab/..‘));
 5 
 6 //join
 7 console.log(‘joint path : ‘ + path.join(‘/test‘, ‘test1‘, ‘2slashes/1slash‘, ‘tab‘, ‘..‘));
 8 
 9 //resolve
10 console.log(‘resolve : ‘ + path.resolve(‘test.js‘));
11 
12 //extName
13 console.log(‘ext name : ‘ + path.extname(‘test.js‘));

node.js - Net 

net 模块是用来创建服务器和客户端。它提供了一个异步网络包装。 net模块可以使用以下语法导入。

var net = require("net")

node.js - DNS 

dns 模块是用来做实际的DNS查找,以及使用底层操作系统的名称解析功能..它提供了一个异步网络包装。dns模块可以使用以下语法导入。

var dns = require("dns")

node.js - Domain

domain 模块是用于拦截未处理的错误。这些未处理的错误可以使用内部绑定或外部绑定来拦截。如果错误都那么不处理,那么Node应用会崩溃。

  • 内部绑定 - 错误发生执行代码是在一个域的run方法。

  • 外部绑定 - 使用它的add方法将错误发生明确地加入到域。

domain(域)模块可以使用以下语法导入。

var domain = require("domain")

域模块的Domain类是用来提供路由错误以及未捕获异常活动域对象的功能。 这是一个EventEmitter的子类。为了处理它捕获错误,监听它的错误事件。它使用如下的语法创建:

var domain = require("domain");
var domain1 = domain.create();

 

一点基础内容,没深入研究,了解基础,创建文本服务应用,以后再进行跟深层次的挖掘!!

node.js基础内容

标签:delete   cpu   mkdir   调整   listening   通知   编写   移动   each   

原文地址:https://www.cnblogs.com/bacydm/p/9795154.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!