官术网_书友最值得收藏!

Duplex streams

A duplex stream is both readable and writeable. For instance, a TCP server created in Node exposes a socket that can be both read from, and written to:

const stream = require("stream");
const net = require("net");

net.createServer(socket => {
socket.write("Go ahead and type something!");
socket.setEncoding("utf8");
socket.on("readable", function() {
process.stdout.write(this.read())
});
})
.listen(8080);

When executed, this code will create a TCP server that can be connected to via Telnet:

telnet 127.0.0.1 8080

Start the server in one terminal window, open a separate terminal, and connect to the server via telnet. Upon connection, the connecting terminal will print out Go ahead and type something!—writing to the socket. Any text entered in the connecting terminal (after hitting ENTER) will be echoed to the stdout of the terminal running the TCP server (reading from the socket), creating a sort of chat application.

This implementation of a bidirectional (duplex) communication protocol demonstrates clearly how independent processes can form the nodes of a complex and responsive application, whether communicating across a network or within the scope of a single process.

The options sent when constructing a Duplex instance merge those sent to Readable and Writable streams, with no additional parameters. Indeed, this stream type simply assumes both roles, and the rules for interacting with it follow the rules for the interactive mode being used.

As a Duplex stream assumes both read and write roles, any implementation is required to implement both -_write and _read methods, again following the standard implementation details given for the relevant stream type.

主站蜘蛛池模板: 平阴县| 顺平县| 洛南县| 新宾| 梧州市| 旌德县| 河曲县| 资中县| 滁州市| 云南省| 胶州市| 双流县| 社会| 衡阳市| 鞍山市| 监利县| 肇东市| 革吉县| 固镇县| 措美县| 太仆寺旗| 平罗县| 丹阳市| 博乐市| 新乡县| 澳门| 岫岩| 平潭县| 武邑县| 增城市| 蚌埠市| 宁南县| 天水市| 遂川县| 太仓市| 武山县| 云霄县| 黄陵县| 淮滨县| 赤壁市| 双鸭山市|