Nodejs의 이중 스트림에 대한 간략한 토론-JS 튜토리얼-php.cn

Nodejs의 이중 스트림에 대한 간략한 토론

Duplex

구현 Duplex

에는 두 가지 일반적으로 사용되는 이중 스트림이 있습니다.

읽기 가능, 쓰기 가능 구현 방법 마찬가지로 Duplex 스트림 구현은 매우 간단하지만 Duplex는 Readable과 Writable을 모두 구현합니다. NodeJS는 다중 상속을 지원하지 않으므로 Duplex 클래스를 상속해야 합니다

Duplex 클래스 상속
_read() 메서드를 구현합니다.
_write() 메소드 구현

read() 및 write() 메소드 구현은 모두가 읽기 및 쓰기 가능과 동일하기 때문에 익숙하다고 생각합니다.

const Duplex = require('stream').Duplex;

const myDuplex = new Duplex({
  read(size) {
    // ...
  },
  write(chunk, encoding, callback) {
    // ...
  }
});

로그인 후 복사

생성자 매개변수

Duplex 인스턴스에는 읽기 가능하고 쓰기 가능한 스트림이 모두 포함되어 있습니다. Duplex 클래스를 인스턴스화할 때 여러 매개변수를 전달할 수 있습니다.

readableObjectMode: 읽기 가능한 스트림이 ObjectMode로 설정되어 있는지 여부, 기본값은 false
writableObjectMode: 쓰기 가능한 스트림이 ObjectMode로 설정되었는지 여부, 기본값은 false
allowHalfOpen: 기본값은 true입니다. false로 설정하면 쓰기 끝이 끝나면 스트림이 자동으로 읽기 끝을 종료하고 그 반대의 경우도 마찬가지입니다. 물론.

작은 예제

Readable과 Writable을 이해한 후 Duplex를 보면 매우 간단합니다. 공식 홈페이지에 있는 예제를 사용하면 됩니다

 const Duplex = require('stream').Duplex;
const kSource = Symbol('source');

class MyDuplex extends Duplex {
  constructor(source, options) {
    super(options);
    this[kSource] = source;
  }

  _write(chunk, encoding, callback) {
    // The underlying source only deals with strings
    if (Buffer.isBuffer(chunk))
      chunk = chunk.toString();
    this[kSource].writeSomeData(chunk);
    callback();
  }

  _read(size) {
    this[kSource].fetchSomeData(size, (data, encoding) => {
      this.push(Buffer.from(data, encoding));
    });
  }
}

로그인 후 복사

물론 실행할 수 없는 의사 코드이지만, Duplex의 역할을 볼 수 있고, 데이터를 생산할 수도 있고, 데이터를 소비할 수도 있으므로 데이터 흐름 파이프라인의 중간에 있을 수 있습니다. Transform

읽을 수 있는 스트림에서 쓰기 가능한 스트림으로 바뀌더라도 둘 사이의 데이터 양이 동일하다는 의미는 아닙니다. 위에서 언급한 특정 처리 로직에 따라 읽기 가능한 스트림을 변환한 후 데이터에 넣을지 여부가 결정됩니다. 쓰기 가능한 스트림 변환 원래 의미 변환 흐름 기능을 매우 적절하게 설명하는 변환입니다.
압축 및 압축 해제를 위한 가장 일반적인 zlib는 변환 스트림입니다. 압축 및 압축 해제 전과 후의 데이터 양은 분명히 다릅니다. zlib의 기능은 zip 패키지와 압축 해제된 파일을 입력하거나 그 반대로 하는 것입니다. 우리가 일반적으로 사용하는 대부분의 이중 스트림은 변환입니다.

Tranform 구현

Transform 클래스는 내부적으로 Duplex를 상속하고 writable.write() 및 readable._read() 메서드를 구현합니다. Transform 스트림을 사용자 정의하려면

Transform 클래스만 상속하면 됩니다.

_transform() 메서드 구현

_transform() 메서드 내에서 this.push(data)를 호출하여 데이터를 생성하고 쓰기 가능한 스트림에 넘겨주거나 호출할 수 없습니다. 즉, 입력이 출력을 생성하지 않음을 의미합니다.
```
 transform.prototype._transform = function (data, encoding, callback) {
  this.push(data);
  callback();
};

transform.prototype._transform = function (data, encoding, callback) {
  callback(null, data);
};
```
로그인 후 복사
때로는 변환 작업에서 스트림 끝의 쓰기 가능한 스트림에 더 많은 데이터를 써야 할 수도 있습니다. 예를 들어 Zlib 스트림은 압축된 출력을 최적화하기 위해 일부 내부 상태를 저장합니다. 이 경우, 작성된 모든 데이터가 소비되기 전에 호출되어 '종료'를 트리거하는 _flush() 메서드를 사용할 수 있습니다.

Transform 스트림에는 일반적으로 사용되는 두 가지 이벤트가 있습니다.

finish from Writable

end from Readable

비교
두 가지 간단한 예를 보면 Duplex와 Transform의 차이점을 직관적으로 이해할 수 있습니다

TCP 소켓

net 模块可以用来创建 socket，socket 在 NodeJS 中是一个典型的 Duplex，看一个 TCP 客户端的例子

var net = require('net');

//创建客户端
var client = net.connect({port: 1234}, function() {
    console.log('已连接到服务器');
    client.write('Hi!');
});

//data事件监听。收到数据后，断开连接
client.on('data', function(data) {
    console.log(data.toString());
    client.end();
});

//end事件监听，断开连接时会被触发
client.on('end', function() {
    console.log('已与服务器断开连接');
});

로그인 후 복사

可以看到 client 就是一个 Duplex，可写流用于向服务器发送消息，可读流用于接受服务器消息，两个流内的数据并没有直接的关系。

gulp

gulp 非常擅长处理代码本地构建流程，看一段官网的示例代码

gulp.src('client/templates/*.jade')
  .pipe(jade())
  .pipe(minify())
  .pipe(gulp.dest('build/minified_templates'));

로그인 후 복사

其中 jada() 和 minify() 就是典型的 Transform，处理流程大概是

.jade 模板文件 -> jada() -> html 文件 -> minify -> 压缩后的 html

로그인 후 복사

可以看出来，jade() 和 minify() 都是对输入数据做了些特殊处理，然后交给了输出数据。

这样简单的对比就能看出 Duplex 和 Transform 的区别，在平时实用的时候，当一个流同事面向生产者和消费者服务的时候我们会选择 Duplex，当只是对数据做一些转换工作的时候我们便会选择使用 Tranform。

更多编程相关知识，请访问：编程学习网站！！

위 내용은 Nodejs의 이중 스트림에 대한 간략한 토론의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!