Samouczek dotyczący strumieni Node js: strumień plików, potoki
Jamesa Hartmana
Strumień plików w Node.js
Węzeł szeroko wykorzystuje strumienie jako mechanizm przesyłania danych.
Na przykład, gdy wysyłasz cokolwiek do konsoli za pomocą funkcji console.log, w rzeczywistości używasz strumienia do wysyłania danych do konsoli.
Node.js ma także możliwość strumieniowego przesyłania danych z plików, dzięki czemu można je odpowiednio odczytać i zapisać. Przyjrzymy się teraz przykładowi wykorzystania strumieni do odczytu i zapisu plików. W tym przykładzie musimy wykonać poniższe kroki
Krok 1) Utwórz plik o nazwie data.txt zawierający poniższe dane. Załóżmy, że plik ten jest przechowywany na dysku D naszej lokalnej maszyny.
Samouczek dotyczący Node.js
Wprowadzenie
Wydarzenia
Łączność danych
Używanie jaśminu
Krok 2) Napisz odpowiedni kod, który będzie korzystał ze strumieni do odczytania danych z pliku.
var fs = require("fs");
var stream;
stream = fs.createReadStream("D://data.txt");
stream.on("data", function(data) {
var chunk = data.toString();
console.log(chunk);
});
Wyjaśnienie kodu: -
- Najpierw musimy dołączyć moduły „fs”, które zawierają całą funkcjonalność wymaganą do tworzenia strumieni.
- Następnie tworzymy czytelny strumień, używając metody – createReadStream. Jako dane wejściowe podajemy lokalizację naszego pliku data.txt.
- Funkcja steam.on jest obsługą zdarzeń i w niej określamy pierwszy parametr jako „data”. Oznacza to, że za każdym razem, gdy dane napływają do strumienia z pliku, należy wykonać funkcję wywołania zwrotnego. W naszym przypadku definiujemy funkcję wywołania zwrotnego, która wykona 2 podstawowe kroki. Pierwsza polega na konwersji danych odczytanych z pliku na ciąg znaków. Drugim byłoby wysłanie przekonwertowanego ciągu jako danych wyjściowych do konsoli.
- Pobieramy każdy fragment danych odczytany ze strumienia danych i konwertujemy go na ciąg znaków.
- Na koniec wysyłamy dane wyjściowe każdego fragmentu skonwertowanego ciągu znaków do konsoli.
Wyjście:
- Jeśli kod zostanie wykonany poprawnie, w konsoli zobaczysz powyższe dane wyjściowe. Dane wyjściowe będą takie same, jak w pliku data.txt.
Zapis do pliku
W ten sam sposób, w jaki tworzymy strumień odczytu, możemy również utworzyć strumień zapisu do zapisu danych do pliku. Najpierw utwórzmy pusty plik bez zawartości o nazwie data.txt. Załóżmy, że plik ten znajduje się na dysku D naszego komputera.
Poniższy kod pokazuje w jaki sposób możemy zapisać dane do pliku.
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")
Wyjaśnienie kodu: -
- Tworzymy zapisywalny strumień metodą createWriteStream. Jako dane wejściowe podajemy lokalizację naszego pliku data.txt.
- Następnie użyliśmy metody stream.write do zapisania różnych linii tekstu do naszego pliku tekstowego. Strumień zajmie się zapisaniem tych danych do pliku data.txt.
Jeśli otworzysz plik data.txt, zobaczysz teraz w pliku następujące dane
Samouczek dotyczący Node.js
Wprowadzenie
Wydarzenia
Generators
Łączność danych
Korzystanie z Jaśmin
Potoki w Node.js
W aplikacjach Node strumienie można łączyć za pomocą metody pipe(), która przyjmuje dwa argumenty:
- Wymagany zapisywalny strumień, który działa jako miejsce docelowe danych i
- Opcjonalny obiekt używany do przekazywania opcji.
Typowy przykład użycia potoków, jeśli chcesz przenieść dane z jednego pliku do drugiego.
Zobaczmy więc przykład, jak możemy przenieść dane z jednego pliku do drugiego za pomocą potoków.
Krok 1) Utwórz plik o nazwie datainput.txt zawierający poniższe dane. Załóżmy, że plik ten jest przechowywany na dysku D naszej lokalnej maszyny.
Samouczek dotyczący Node.js
Wprowadzenie
Wydarzenia
Generators
Łączność danych
Używanie jaśminu
Krok 2) Utwórz pusty plik o nazwie dataOutput.txt i umieść go na dysku D komputera lokalnego.
Krok 3) Napisz poniższy kod realizujący transfer danych z pliku datainput.txt do pliku dataOutput.txt.
var fs = require("fs");
var readStream = fs.createReadStream("D://datainput.txt");
var writeStream = fs.createWriteStream("D://dataOutput.txt");
readStream.pipe(writeStream);
Wyjaśnienie kodu: -
- Najpierw tworzymy „readstream” do naszego pliku datainput.txt, który zawiera wszystkie nasze dane, które należy przenieść do nowego pliku.
- Następnie musimy utworzyć „writestream” do naszego pliku dataOutput.txt, który jest naszym pustym plikiem i jest miejscem docelowym przesyłania danych z pliku datainput.txt.
- Następnie używamy polecenia potoku, aby przesłać dane ze strumienia odczytu do strumienia zapisu. Polecenie potok pobierze wszystkie dane, które przyjdą do strumienia odczytu i wypchnie je do strumienia zapisu.
Jeśli teraz otworzysz plik dataOutput.txt, zobaczysz wszystkie dane, które znajdowały się w pliku datainput.txt.
Zdarzenia w Node.js
Zdarzenia stanowią jedną z kluczowych koncepcji Node.js i czasami Node.js jest określany jako framework oparty na zdarzeniach.
Zasadniczo wydarzenie to coś, co się dzieje. Na przykład, jeśli zostanie nawiązane połączenie z bazą danych, wyzwalane jest zdarzenie połączenia z bazą danych. Programowanie sterowane zdarzeniami polega na tworzeniu funkcji, które będą uruchamiane w przypadku wyzwolenia określonych zdarzeń.
Spójrzmy na podstawowy przykład definiowania zdarzenia w Node.js.
Stworzymy wydarzenie o nazwie „data_received”. Po wywołaniu tego zdarzenia do konsoli zostanie wysłany tekst „dane otrzymane”.
var events = require('events');
var eventEmitter = new events.EventEmitter();
eventEmitter.on('data_received', function() {
console.log('data received succesfully.');
});
eventEmitter.emit('data_received');
Wyjaśnienie kodu: -
- Użyj funkcji require, aby uwzględnić moduł „zdarzenia”. Dzięki temu modułowi będziesz mógł tworzyć zdarzenia w Node.js.
- Utwórz nowy emiter zdarzeń. Służy do powiązania zdarzenia, którym w naszym przypadku jest „data_received” z funkcją wywołania zwrotnego zdefiniowaną w kroku 3.
- Definiujemy funkcję sterowaną zdarzeniami, która mówi, że jeśli w przypadku wywołania zdarzenia „data_received” powinniśmy wypisać na konsolę tekst „data_received”.
- Wreszcie mamy ręczne wyzwalanie naszego zdarzenia za pomocą funkcji eventEmiter.emit. Spowoduje to wyzwolenie zdarzenia data_received.
Po uruchomieniu programu do konsoli zostanie wysłany tekst „dane otrzymane”, jak pokazano poniżej.
Emisja zdarzeń
Podczas definiowania zdarzeń istnieją różne metody wywoływania zdarzeń. W tym temacie skupimy się na szczegółowym omówieniu każdego z nich.
- Jednorazowe procedury obsługi zdarzeń
Czasami możesz chcieć zareagować na wydarzenie dopiero za pierwszym razem, gdy ono nastąpi. W takich sytuacjach można użyć metody Once().
Zobaczmy, jak możemy wykorzystać metodę Once do obsługi zdarzeń.
Wyjaśnienie kodu: -
- Tutaj używamy metody „once”, aby powiedzieć, że w przypadku zdarzenia „data_received” funkcja wywołania zwrotnego powinna zostać wykonana tylko raz.
- Tutaj ręcznie wyzwalamy zdarzenie „data_received”.
- Gdy zdarzenie „data_received” zostanie ponownie wywołane, tym razem nic się nie stanie. Dzieje się tak ze względu na pierwszy krok, w którym powiedzieliśmy, że zdarzenie może zostać wywołane tylko raz.
Jeśli kod zostanie wykonany poprawnie, w dzienniku pojawi się komunikat „data_received pomyślnie”. Komunikat ten pojawi się w konsoli tylko raz.
- Sprawdzanie detektorów zdarzeń
W dowolnym momencie swojego istnienia do emitera zdarzeń może być podłączonych zero lub więcej słuchaczy. Elementy nasłuchujące dla każdego typu zdarzenia można sprawdzić na kilka sposobów.
Jeśli interesuje Cię tylko określenie liczby podłączonych słuchaczy, nie szukaj dalej niż metoda EventEmitter.listenerCount().
(Uwaga: Słuchacze są ważni, ponieważ główny program powinien wiedzieć, czy słuchacze są dodawani na bieżąco do wydarzenia, w przeciwnym razie program będzie działać nieprawidłowo, ponieważ zostaną wywołani dodatkowi słuchacze.)
Wyjaśnienie kodu: -
- Definiujemy typ eventEmitter, który jest wymagany do korzystania z metod związanych ze zdarzeniami.
- Następnie definiujemy obiekt zwany emiterem, który będzie używany do definiowania naszych procedur obsługi zdarzeń.
- Tworzymy 2 procedury obsługi zdarzeń, które w zasadzie nic nie robią. W naszym przykładzie jest to proste, aby pokazać, jak działa metoda ListenerCount.
- Teraz, gdy wywołasz metodę ListenerCount dla naszego zdarzenia data_received, wyśle ona liczbę detektorów zdarzeń dołączonych do tego zdarzenia w dzienniku konsoli.
Jeżeli kod zostanie wykonany poprawnie, w logu konsoli pojawi się wartość 2.
- Wydarzenie nowego słuchacza
Za każdym razem, gdy rejestrowana jest nowa procedura obsługi zdarzenia, emiter zdarzeń emituje zdarzenie newListener. To zdarzenie służy do wykrywania nowych programów obsługi zdarzeń. Zwykle używasz zdarzenia newListener, gdy musisz przydzielić zasoby lub wykonać jakąś akcję dla każdego nowego modułu obsługi zdarzenia.
var events = require('events');
var eventEmitter = events.EventEmitter;
var emitter = new eventEmitter();
emitter.on("newListener", function(eventName, listener) {
console.log("Added listener for " + eventName + " events");
});
emitter.on('data_received', function() {});
emitter.on('data_received', function() {});
Wyjaśnienie kodu: -
- Tworzymy nowy moduł obsługi zdarzeń dla zdarzenia 'newListener'. Tak więc za każdym razem, gdy rejestrowany jest nowy moduł obsługi zdarzeń, w konsoli wyświetlany jest tekst „Added listener for” + nazwa zdarzenia.
- Tutaj zapisujemy do konsoli tekst „Dodano słuchacza dla” + nazwę zdarzenia dla każdego zarejestrowanego zdarzenia.
- Definiujemy 2 procedury obsługi zdarzeń dla naszego zdarzenia „data_received”.
Jeżeli powyższy kod zostanie wykonany poprawnie, w konsoli wyświetli się poniższy tekst. Pokazuje tylko, że procedura obsługi zdarzenia „newListener” została uruchomiona dwukrotnie.
Dodano detektor zdarzeń data_received
Dodano detektor zdarzeń data_received
Podsumowanie
- Strumienie są używane w Node.js do odczytu i zapisu danych z urządzeń wejścia-wyjścia. node.js korzysta z biblioteki 'fs' do tworzenia czytelnych i zapisywalnych strumieni do plików. Strumienie te mogą być używane do odczytu i zapisu danych z plików.
- Rur można używać do łączenia ze sobą wielu strumieni. Jednym z najczęstszych przykładów jest połączenie strumieni odczytu i zapisu w celu przesłania danych z jednego pliku do drugiego.
- Node.js jest często oznaczany jako framework sterowany zdarzeniami, a definiowanie zdarzeń w Node.js jest bardzo łatwe. Można zdefiniować funkcje reagujące na te zdarzenia.
- Zdarzenia ujawniają także metody reagowania na kluczowe zdarzenia. Na przykład widzieliśmy procedurę obsługi zdarzenia Once(), której można użyć, aby upewnić się, że funkcja wywołania zwrotnego zostanie wykonana tylko raz po wyzwoleniu zdarzenia.
