Node.js இல் படிக்கக்கூடிய ஸ்ட்ரீம்களை எவ்வாறு பயன்படுத்துவது?

Node Js Il Patikkakkutiya Strimkalai Evvaru Payanpatuttuvatu



அனுப்புநர் அல்லது ஆதாரம் மற்றும் இலக்கு அல்லது பெறுநர் பக்கங்களுக்கு இடையே ஸ்ட்ரீம்கள் வடிவில் நெட்வொர்க்கில் தரவு மாற்றப்படுகிறது. இந்த ஸ்ட்ரீம்களை உருவாக்கி, பல முறைகளின் பயன்பாட்டுடன் இணைக்கலாம், மேலும் ஆடியோ அல்லது வீடியோ கோப்புகளை ஸ்ட்ரீம் வழியாக அனுப்பலாம். ''ஐப் பயன்படுத்தி மற்ற இலக்குக் கோப்புகளில் வாசிப்புத் தரவைச் செருகலாம். எழுது() 'மற்றும்' மிகுதி() ” முறைகளும்.

இந்த வழிகாட்டி Node.js இல் படிக்கக்கூடிய ஸ்ட்ரீம்களின் பயன்பாட்டை விளக்கும்.

Node.js இல் படிக்கக்கூடிய ஸ்ட்ரீம்களை எவ்வாறு பயன்படுத்துவது?

' படிக்கக்கூடியது 'நீரோடைகள்' ஐ அழைப்பதன் மூலம் உருவாக்கப்படுகின்றன CreateReadStream() ” மற்றும் படித்த தரவு பின்னர் உள்ளூர் சேவையகத்தை உருவாக்குவதன் மூலம் வலைப்பக்கத்தில் காட்டப்படும். நிகழ்வைக் கேட்பவர்கள் உதவியுடன் ' அன்று() கோப்பின் வாசிப்பு தொடங்கும் போது அல்லது முடிவடையும் போது செய்திகளைக் காண்பிக்க அல்லது குறிப்பிட்ட செயல்களைச் செய்ய படிக்கக்கூடிய ஸ்ட்ரீம்களில் முறைகள் இணைக்கப்படலாம்.







ஒரு நடைமுறை விளக்கத்திற்கான உதாரணத்தைப் பாருங்கள்.



எடுத்துக்காட்டு: படிக்கக்கூடிய ஸ்ட்ரீம்களைப் பயன்படுத்தி சர்வரில் உள்ளடக்கத்தைப் படித்தல் மற்றும் காண்பித்தல்

இந்த எடுத்துக்காட்டில், வழங்கப்பட்ட கோப்பின் உள்ளடக்கம் வாசிக்கப்பட்டு பின்னர் இணைய உலாவியில் காட்டப்படும்:



நிலையான fsObj = தேவை ( 'fs' ) ;

நிலையான httpObj = தேவை ( 'http' ) ;

நிலையான உள்ளூர் சர்வர் = httpObj. உருவாக்கு சேவையகம் ( ( கோரிக்கை, பதில் ) => {

முயற்சி {
// படிக்க இலக்கு கோப்பு
நிலையான தரவு ஸ்ட்ரீம் = fsObj. ரீட்ஸ்ட்ரீமை உருவாக்கவும் ( 'usecase.txt' ) ;
// பதிலளிக்க கோப்பை பைப் செய்யவும்
தரவு ஸ்ட்ரீம். குழாய் ( பதில் ) ;
} பிடி ( பிழைகள் ) {
பணியகம். பிழை ( பிழைகள் ) ;
}
} ) ;

உள்ளூர் சர்வர். கேளுங்கள் ( 8080 , ( ) => {
பணியகம். பதிவு ( லோக்கல் ஹோஸ்ட் போர்ட் எண்ணில் சர்வர் இயங்குகிறது: '8080' ' )
} ) ;

மேலே உள்ள குறியீட்டின் விளக்கம் பின்வருமாறு:





  • முதலில், தேவையானவற்றை இறக்குமதி செய்யவும் ' fs 'மற்றும்' http 'தொகுதிகள் மற்றும் அவற்றின் பொருட்களை சேமிக்கவும்' fsObj 'மற்றும்' httpObj ” மாறிகள் முறையே.
  • அடுத்து, '' ஐ அழைப்பதன் மூலம் சேவையகம் உருவாக்கப்பட்டது createServer() 'முறை மற்றும் புதிதாக உருவாக்கப்பட்ட இந்த சர்வரை ஒரு ' இல் சேமித்தல் உள்ளூர் சர்வர் ” மாறி.
  • பின்னர், '' பயன்படுத்தவும் முயற்சி 'முறை கால்பேக் செயல்பாட்டிற்குள் தடுக்கவும் மற்றும் ' CreateReadStream() 'பயன்படுத்தும் முறை' fsObj ” மாறி.
  • இந்த முறை அடைப்புக்குறிக்குள் படிக்க வேண்டிய இலக்கு கோப்பு உள்ளடக்கத்தை அனுப்பவும் மற்றும் முடிவை சேமிக்கவும் ' தரவு ஸ்ட்ரீம் ” மாறி.
  • செருகு ' தரவு ஸ்ட்ரீம் ' மாறி ' .குழாய்() ” பதிலை அனுப்பும் முறை.
  • பயன்படுத்தவும் ' பிடி 'ஏதேனும் ஏற்பட்ட பிழைகளைக் கையாள தடை.
  • இறுதியாக, போர்ட் எண்ணில் சேவையகத்தைக் கேளுங்கள் அல்லது அமைக்கவும் ' 8080 ” மற்றும் வெற்றிச் செய்தியை அதன் கால்பேக் செயல்பாட்டின் உதவியுடன் காண்பிக்கவும்.

கீழே உள்ள கட்டளையின் மூலம் மேலே உள்ள குறியீட்டின் கொண்டிருக்கும் கோப்பை (controlFlow.js) இயக்கவும்:

முனை கட்டுப்பாடு ஓட்டம். js

உருவாக்கப்பட்ட வெளியீடு 'இன் உதவியுடன் காட்டுகிறது .குழாய்() 'மற்றும்' படிக்கக்கூடிய ஸ்ட்ரீம் ”, கோப்பு தரவு படிக்கப்பட்டு, வலைப்பக்கத்தில் காண்பிக்க இலக்கு ஸ்ட்ரீமுக்கு அனுப்பப்பட்டது:



எடுத்துக்காட்டு 2: ரீட்ஸ்ட்ரீமைப் பயன்படுத்தி உள்ளூரில் நிலையான கோப்புகளைப் படித்தல்

இந்த வழக்கில், ஸ்ட்ரீமில் வழங்கப்பட்ட கோப்பு தேர்ந்தெடுக்கப்பட்டது மற்றும் அதன் உள்ளடக்கம் நிகழ்வு கேட்பவர்களின் உதவியுடன் கன்சோல் சாளரத்தில் காட்டப்படும்:

நிலையான fsObj = தேவை ( 'fs' ) ;

நிலையான streamObj = fsObj. ரீட்ஸ்ட்ரீமை உருவாக்கவும் ( 'usecase.txt' ) ;

streamObj. அன்று ( 'தகவல்கள்' , ( உள்ளடக்கம் ) => {

பணியகம். பதிவு ( உள்ளடக்கம். toString ( ) ) ;

} ) ;

streamObj. அன்று ( 'முடிவு' , ( ) => {

பணியகம். பதிவு ( ' \n கோப்பைப் படித்து முடித்தேன்.' ) ;

} ) ;

streamObj. குழாய் ( செயல்முறை. stdout ) ;

மேலே உள்ள குறியீட்டின் விளக்கம் பின்வருமாறு:

  • முதலில், ' fs 'தொகுதி இறக்குமதி செய்யப்பட்டு அதன் பொருள் சேமிக்கப்படுகிறது' fsObj ” மாறி.
  • அடுத்து, ' fsObj 'என்று அழைக்கிறது' CreateReadStream() ” முறை மற்றும் உள்ளடக்கத்தை மீட்டெடுக்க வேண்டிய இலக்கு கோப்பின் பாதையை கடந்து செல்கிறது. முறையின் முடிவை ஒரு புதிய மாறியில் சேமிக்கவும் ' streamObj ”.
  • இணைக்கவும் ' அன்று() 'streamObj' உடன் முறை ' தகவல்கள் ” மீட்டெடுக்கப்பட்டது. மீட்டெடுக்கப்பட்ட தரவு, கால்பேக் செயல்பாட்டிற்கான அளவுருவாக அனுப்பப்படுகிறது, இது தரவை சரம் வடிவமாக மாற்றி கன்சோலில் காண்பிக்கும்.
  • மீண்டும் இணைக்கவும் ' அன்று() 'உடன் முறை' streamObj ” மற்றும் இந்த முறை அதன் கால்பேக் செயல்பாடு கோப்பின் வாசிப்பு முடிந்ததும் ஒரு முடிவு செய்தியைக் காட்டுகிறது.

மேலே உள்ள குறியீட்டைச் செயல்படுத்திய பிறகு உருவாக்கப்பட்ட வெளியீடு, இறுதிச் செய்தியுடன் படிக்கப்பட்ட தரவு கன்சோலில் காட்டப்படுவதைக் காட்டுகிறது:

Node.js இல் படிக்கக்கூடிய ஸ்ட்ரீம்களின் பயன்பாட்டைப் பற்றியது அவ்வளவுதான்.

முடிவுரை

Node.js இல் படிக்கக்கூடிய ஸ்ட்ரீம்களுடன் வேலை செய்ய, '' என்ற முறை CreateReadStream() '' வழியாக அழைக்கப்படுகிறது fs ” தொகுதி பொருள். உள்ளடக்கம் எழுதப்பட வேண்டிய இலக்கு கோப்பு பாதை பின்னர் முறை அளவுருவாக அனுப்பப்படும். இதைப் பயன்படுத்திக் கொள்ளலாம் ' .குழாய்() 'மற்றொரு கோப்பில் உள்ளடக்கத்தை எழுதுவது போன்ற மீட்டெடுக்கப்பட்ட தரவுகளில் மேலும் பணிகளைச் செய்வதற்கான முறை. இந்த இடுகை படிக்கக்கூடிய ஸ்ட்ரீம்களுடன் பணிபுரியும் செயல்முறையை விளக்குகிறது.