Trending September 2023 # Node Js Streams Tutorial: Filestream, Pipes # Suggested October 2023 # Top 13 Popular

You are reading the article Node Js Streams Tutorial: Filestream, Pipes updated in September 2023 on the website Lanphuongmhbrtower.com. We hope that the information we have shared is helpful to you. If you find the content interesting and meaningful, please share it with your friends and continue to follow and support us for the latest updates. Suggested October 2023 Node Js Streams Tutorial: Filestream, Pipes

In this tutorial, you will learn

Filestream in Node.js

Node makes extensive use of streams as a data transfer mechanism.

For example, when you output anything to the console using the chúng tôi function, you are actually using a stream to send the data to the console.

Node.js also has the ability to stream data from files so that they can be read and written appropriately. We will now look at an example of how we can use streams to read and write from files. We need to follow the below-mentioned steps for this example

Step 1) Create a file called chúng tôi which has the below data. Let assume this file is stored on the D drive of our local machine.

Tutorial on Node.js

Introduction

Events

Generators

Data Connectivity

Using Jasmine

Step 2) Write the relevant code which will make use of streams to read data from the file.

var fs = require("fs"); var stream; stream = fs.createReadStream("D://data.txt"); stream.on("data", function(data) { var chunk = data.toString(); console.log(chunk); });

Code Explanation:-

We first need to include the ‘fs’ modules which contain all the functionality required to create streams.

Next we create a readable stream by using the method – createReadStream. As an input, we give the location of our chúng tôi file.

The chúng tôi function is an event handler and in it, we are specifying the first parameter as ‘data.’ This means that whenever data comes in the stream from the file, then execute a callback function. In our case, we are defining a callback function which will carry out 2 basic steps. The first is to convert the data read from the file as a string. The second would be to send the converted string as an output to the console.

We are taking each chunk of data which is read from the data stream and converting it to a string.

Finally, we are sending the output of each string converted chunk to the console.

Output:

If the code is executed properly, you will see the above output in the console. This output will be the same as that in the chúng tôi file.

Writing to a file

In the same way, that we create a read stream, we can also create a write stream to write data to a file. Let’s first create an empty file with no contents called chúng tôi Let’s assume this file is placed in the D drive of our computer.

The below code shows how we can write data to the file.

var fs = require("fs"); var stream; stream = fs.createWriteStream("D://data.txt"); stream.write("Tutorial on Node.js") stream.write("Introduction") stream.write("Events") stream.write("Generators") stream.write("Data Connectivity") stream.write("Using Jasmine")

Code Explanation:-

We are creating a writable stream by using the method – createWriteStream. As an input, we give the location of our chúng tôi file.

Next we used the stream.write a method to write the different lines of text to our text file. The stream will take care of writing this data to the chúng tôi file.

If you open the chúng tôi file, you will now see the following data in the file

Tutorial on Node.js

Introduction

Events

Generators

Data Connectivity

Using Jasmine

Pipes in Node.js

Within Node applications, streams can be piped together using the pipe() method, which takes two arguments:

A Required writable stream that acts as the destination for the data and

An optional object used to pass in options.

A typical example of using pipes, if you want to transfer data from one file to the other.

So let’s see an example of how we can transfer data from one file to the other using pipes.

Step 1) Create a file called chúng tôi which has the below data. Let assume this file is stored on the D drive of our local machine.

Tutorial on Node.js

Introduction

Events

Generators

Data Connectivity

Using Jasmine

Step 2) Create a blank empty file called chúng tôi and placed it on the D drive of your local machine.

Step 3) Write the below code to carry out the transfer of data from the chúng tôi file to the chúng tôi file.

var fs = require("fs"); var readStream = fs.createReadStream("D://datainput.txt"); var writeStream = fs.createWriteStream("D://dataOutput.txt"); readStream.pipe(writeStream);

Code Explanation:-

We then need to create a “writestream” to our chúng tôi file, which is our empty file and is the destination for the transfer of data from the chúng tôi file.

If you now open the chúng tôi file, you will see all the data which was present in the chúng tôi file.

Events in Node.js

Events are one of the key concepts in chúng tôi and sometimes chúng tôi is referred to as an Event-driven framework.

Basically, an event is something that happens. For example, if a connection is established to a database, then the database connection event is triggered. Event driven programming is to create functions that will be triggered when specific events are triggered.

Let’s look at a basic example of defining an event in Node.js.

We are going to create an event called ‘data_received’. When this event is triggered, the text “data received” will be sent to the console.

var events = require('events'); var eventEmitter = new events.EventEmitter(); eventEmitter.on('data_received', function() { console.log('data received succesfully.'); }); eventEmitter.emit('data_received');

Code Explanation:-

Use the require function to include the ‘events’ module. With this module, you will be able to create events in Node.js.

Create a new events emitter. This is used to bind the event, which in our case is “data_received” to a callback function which is defined in step3.

We define an event-driven function which says that if in case the “data_received” event is triggered then we should output the text “data_received” to the console.

Finally, we do have a manual trigger of our event using the chúng tôi function. This will trigger the data_received event.

When the program is run, the text “data received” will be sent to the console as shown below.

Emitting Events

When defining events, there are different methods for events which can be invoked. This topic focuses on looking at each one of them in detail.

One time event handlers

Sometimes you may be interested in reacting to an event only the first time it occurs. In these situations, you can use the once() method.

Let’s see how we can make use of the once method for event handlers.

Code Explanation:-

Here we are using the ‘once’ method to say that for the event ‘data_received,’ the callback function should only be executed once.

Here we are manually triggering the ‘data_received’ event.

When the ‘data_received’ event is triggered again, this time, nothing will happen. This is because of the first step where we said that the event could only be triggered once.

If the code is executed properly, the output in the log will be ‘data_received successfully’. This message will only appear once in the console.

Inspecting Event Listeners

At any point in its lifetime, an event emitter can have zero or more listeners attached to it. The listeners for each event type can be inspected in several ways.

If you are interested in only determining the number of attached listeners, then look no further than the EventEmitter.listenerCount() method.

(Note: Listeners are important because the main program should know if listeners are being added on the fly to an event, else the program will malfunction because additional listeners will get called.)

Code Explanation:-

We are defining an eventEmitter type which is required for using the event-related methods.

We are then defining an object called emitter which will be used to define our event handlers.

We are creating 2 events handlers which basically do nothing. This is kept simple for our example just to show how the listenerCount method works.

Now when you invoke the listenerCount method on our data_received event, it will send the number of event listeners attached to this event in the console log.

If the code is executed properly, the value of 2 will be shown in the console log.

The newListener Event

Each time a new event handler is registered, the event emitter emits a newListener event. This event is used to detect new event handlers. You typically use newListener event when you need to allocate resources or perform some action for each new event handler.

Code Explanation:-

We are creating a new event handler for the ‘newListener’ event. So whenever a new event handler is registered, the text “Added listener for” + the event name will be displayed in the console.

Here we are writing to the console the text “Added listener for” + the event name for each event registered.

We are defining 2 event handlers for our event ‘data_received’.

If the above code is executed properly, the below text will be shown in the console. It just shows that the ‘newListener’ event handler was triggered twice.

Added listener for data_received events

Streams are used in chúng tôi to read and write data from Input-Output devices. chúng tôi makes use of the ‘fs’ library to create readable and writable streams to files. These streams can be used to read and write data from files.

Pipes can be used to connect multiple streams together. One of the most common example is to pipe the read and write stream together for the transfer of data from one file to the other.

Node.js is often also tagged as an event driven framework, and it’s very easy to define events in chúng tôi Functions can be defined which respond to these events.

Events also expose methods for responding to key events. For example, we have seen the once() event handler which can be used to make sure that a callback function is only executed once when an event is triggered.

You're reading Node Js Streams Tutorial: Filestream, Pipes

Update the detailed information about Node Js Streams Tutorial: Filestream, Pipes on the Lanphuongmhbrtower.com website. We hope the article's content will meet your needs, and we will regularly update the information to provide you with the fastest and most accurate information. Have a great day!