NodeJS 연구 노트 FS 파일 module_node.js

1, 오프닝 분석

파일 시스템 모듈은 일련의 표준 POSIX 파일 I/O 작업 방법에 대한 간단한 래퍼입니다. 모듈은 require("fs")를 호출하여 얻을 수 있습니다. 파일 시스템 모듈의 모든 메소드에는 비동기 버전과 동기 버전이 있습니다.

(1), 파일 시스템 모듈의 비동기 메서드에는 마지막 수신 형식 매개변수로 완료 콜백 함수가 필요합니다.

(2) 콜백 함수의 구성은 호출되는 비동기 메서드에 따라 결정됩니다. 일반적으로 콜백 함수의 첫 번째 형식 매개변수는 반환되는 오류 정보입니다.

(3), 비동기 작업이 올바르게 실행되어 반환되면 오류 매개변수는 null이거나 정의되지 않습니다. 작업 메서드의 동기 버전을 사용하는 경우 오류가 발생하면 해당 오류는 일반적으로 발생하는 오류 형식으로 반환됩니다.

(4), try 및 catch 문을 사용하여 오류를 차단하고 프로그램이 계속되도록 할 수 있습니다.

먼저 파일("bb.txt")을 읽는 간단한 예를 살펴보겠습니다.

(1) 다음 내용("안녕하세요 여러분, 저는 노비타입니다! (*^__^*) 희희...")을 포함하여 "bb.txt" 파일을 생성합니다.

(2)에서 파일 읽기 동작은 다음과 같습니다.

코드 복사 코드는 다음과 같습니다.

var fs = require("fs") ;
fs.readFile("bb.txt","utf8",함수(오류,데이터){
If(error) 오류 발생 ;
console.log(데이터) ;
}) ;

실행 결과:

여기서 주목해야 할 점은 파일을 읽을 때 인코딩을 설정해야 한다는 것입니다. 그렇지 않으면 기본적으로 "버퍼" 형식으로 나타납니다.

설정 없이 실행되는 효과를 보면 여전히 차이가 확연합니다. 다음과 같습니다:

다음과 같이 또 다른 쓰기 작업을 수행해 보겠습니다.

코드 복사 코드는 다음과 같습니다.

var fs = require("fs") ;
var txt = "누구나 NodeJS를 잘 배워야 합니다!!! ;
//파일 쓰기
fs.writeFile("bb.txt",txt,function (err) {
(err) throw err ;
console.log("파일이 저장되었습니다!"); //파일이 저장되었습니다
}) ;

실행 결과:

일반적으로 사용되는 예시 목록:

코드 복사 코드는 다음과 같습니다.

// 파일 삭제
fs.unlink('bb.txt', function(){
console.log('성공') ;
}) ;
// 파일명 수정
fs.rename('bb.txt','bigbear.txt',function(err){
console.log('이름 바꾸기 성공') ;
});
// 파일 상태 확인
fs.stat('bb.txt', function(err, stat){
console.log(stat);
});
// 파일이 존재하는지 확인
fs.exists('bb.txt', 함수( 존재함 ){
console.log( 존재함 ) ;
}) ;

2. Fs와 Stream의 연결

"스트림"은 비동기 특성을 갖습니다. 파일이나 콘텐츠를 읽기 위해 지정된 크기의 알 수 없는 "청크"로 나눌 수 있으며, "청크"를 읽을 때마다 이를 출력합니다. 파일을 읽을 때까지. 이는 "http1.1"에서 지원하는 "Transfer-Encoding: Chunked"와 같습니다. ("청크"는 어떤 형태로든 존재할 수 있지만 NodeJS는 기본적으로 "버퍼" 형태로 존재하므로 더 효율적입니다.) NodeJS의 "스트림"에는 Unix 시스템의 뛰어난 기능("파이프" ------ 파이프)이 있습니다.

아직도 "Http 모듈 기사", "Hello, Big Bear!"에서 첫 번째 NodeJS 프로그램을 기억하시나요? 이 작은 프로그램을 기반으로 다음과 같이 몇 가지 수정을 해보겠습니다.

(1), "bb.html" 생성

코드 복사 코드는 다음과 같습니다.

          

본문>


(2) 이전 프로그램을 다음과 같이 수정합니다.

코드 복사 코드는 다음과 같습니다.

var http = require('http') ;
var fs = require("fs") ;
var 서버 = http.createServer(function(req,res){
fs.readFile("bb.html","utf-8", function(err, data){
If(err) {
              res.writeHead(500, {'Context-Type': 'text/plain'});
             res.end('파일이 존재하지 않거나 서버 오류를 지정하세요!');
}
       그 외{
            res.writeHead(200, {'Context-Type': 'text/html'});
            res.write(data);
           res.end();
}
})
}) ;
server.listen(8888) ;
console.log("포트 8888에서 실행되는 http 서버 ...") ;

결과는 다음과 같습니다.

이제 간단한 텍스트 파일이 아닌 Google 2014 IO 컨퍼런스의 풀 HD 영상 파일과 같은 하이퍼미디어 파일을 보내고 싶다면 어떻게 해야 하는지 생각해 보아야 합니다. mp4 형식. 길이: 1080p 2시간 이상.

약 4GB 이상. "readFile"은 파일을 메모리로 읽어오는 방식으로 작동하는 것으로 알려져 있습니다. 따라서 이렇게 큰 파일의 경우에는 분명히 이 작업을 수행할 수 없습니다. 그럼 무엇을 해야 할까요? 그런 다음 스트림을 사용하여 이를 수행해야 합니다. 그게 다입니다.

코드는 다음과 같습니다.

코드 복사 코드는 다음과 같습니다.

fs.createReadStream(__dirname '/vedio.mp4').pipe(res) ;

요약하자면:

이러한 코드는 필요한 기능을 달성할 수 있지만 "bb.html" 파일이 매우 큰 경우 서비스는 파일 데이터를 전송하기 전에 전체 파일 데이터를 메모리에 캐시해야 합니다.

크기가 크고 동시성 양이 많으면 많은 메모리가 낭비됩니다. 사용자는 파일 데이터를 수락하기 전에 전체 파일이 메모리에 캐시될 때까지 기다려야 하기 때문에
사용자 경험은 상당히 나쁩니다. 하지만 다행히 "(req, res)"의 두 매개변수는 모두 Stream이므로 "fs.readFile()" 대신 fs.createReadStream()을 사용할 수 있습니다.

셋, 예시

다음은 파일 업로드의 간단한 예입니다.

(1), "server.js" 생성

코드 복사 코드는 다음과 같습니다.

 var http = require('http');
 var url = require('url');
 함수 시작(경로, 핸들러) {
     onRequest 함수(요청, 응답) {
         var 경로명 = url.parse(request.url).pathname;
         // 路由到相应的业务逻辑
         경로(경로 이름, 처리기, 응답, 요청);
     }
     http.createServer(onRequest).listen(3000);
     console.log('서버가 시작 중');
 }
 수출.시작 = 시작;

(2),建立“route.js”

复主代码 代码如下:

 함수 경로(경로 이름, 처리기, 응답, 요청) {
     console.log('' pathname에 대한 요청을 라우팅하려고 합니다);
     if (핸들러 유형[경로 이름] === '함수') {
         반환 처리기[경로 이름](응답, 요청);
     } 그 밖의 {
         console.log('' 경로명에 대한 요청 핸들러를 찾을 수 없습니다);
         response.writeHead(404, {'Content-Type': 'text/html'});
         response.write('404 찾을 수 없음!');
         response.end();
     }
 }
 수출.경로 = 경로;

(3),建立“requestHandler.js”

复主代码 代码如下:

var querystring = require('querystring'),
    fs = require('fs'),
    formidable = require('formidable');
함수 시작(응답, 요청) {
    console.log('모듈 시작');
  var body = ''
      ''
      '       'content="text/html; charset=UTF-8" />'
      '머리>'
      ''
      '

'
      ''
      ''
      '양식>'
      '본문>'
      '';
    response.writeHead(200, {'Content-Type': 'text/html'});
    response.write(본문);
    response.end();
}
함수 업로드(응답, 요청) {
    console.log('업로드 모듈');
    var form = new formidable.IncomingForm();
    form.parse(요청, 함수(오류, 필드, 파일) {
        fs.renameSync(files.upload.path, '/tmp/test.png');
        response.writeHead(200, {'Content-Type': 'text/html'});
        response.write('보낸 내용:
');
        response.write('');
        response.end();
    });
}
함수 표시(응답, 요청) {
    console.log('모듈 표시');
    fs.readFile('/tmp/test.png', '바이너리', 함수(오류, 파일) {
        if (오류) {
            response.writeHead(200, {'Content-Type': 'text/html'});
            response.write(오류);
            response.end();
        } 그 밖의 {
            response.writeHead(200, {'Content-Type': 'image/png'});
            response.write(파일, '바이너리');
            response.end();
        }
    });
}
수출.시작 = 시작;
수출.업로드 = 업로드;
내보내기.show=표시;

(4),建立“index.js”

复主代码 代码如下:

 var 서버 = require('./server');
 var router = require('./router');
 var requestHandler = require('./requestHandler');
 var formidable = require('formidable'); // 路径搜索算法이 필요합니까?
 var 핸들러 = {};
 핸들러['/'] = requestHandler.start;
 handler['/start'] = requestHandler.start;
 handler['/upload'] = requestHandler.upload;
 handler['/show'] = requestHandler.show;
 server.start(router.route, handler);

4，总结一下

(1) ，理解 "Fs与Stream 间的联系" 。
（2），熟练使사용 "FS" 상关的api。
(3) ，注意细节的把控，比如： 文件操事api同步方式与异步方式之间的处理细节。
(4) ，最后强调：理解文件上传例子中的代码组织方式，不断重构，不断总结。