এই নির্দেশিকাটি Node.js-এ পঠনযোগ্য স্ট্রিমগুলির ব্যবহার ব্যাখ্যা করবে।
কিভাবে Node.js-এ পঠনযোগ্য স্ট্রীম ব্যবহার করবেন?
দ্য ' পাঠযোগ্য 'প্রবাহগুলিকে আহ্বান করে তৈরি করা হয়' CreateReadStream() এবং পঠিত ডেটা স্থানীয় সার্ভার তৈরি করে ওয়েব পৃষ্ঠায় প্রদর্শিত হতে পারে। অনুষ্ঠান শ্রোতাদের সহায়তায় ' চালু() ফাইলের পড়া শুরু বা শেষ হলে বার্তাগুলি প্রদর্শন করতে বা নির্দিষ্ট ক্রিয়া সম্পাদন করতে পঠনযোগ্য স্ট্রিমগুলির সাথেও ' পদ্ধতিগুলি সংযুক্ত করা যেতে পারে৷
একটি ব্যবহারিক প্রদর্শনের জন্য উদাহরণটি দেখুন।
উদাহরণ: পঠনযোগ্য স্ট্রীম ব্যবহার করে সার্ভারে বিষয়বস্তু পড়া এবং প্রদর্শন করা
এই উদাহরণে, একটি প্রদত্ত ফাইলের বিষয়বস্তু পড়া হচ্ছে এবং তারপর ওয়েব ব্রাউজারে প্রদর্শিত হচ্ছে:
const fsObj = প্রয়োজন ( 'এফএস' ) ;
const httpObj = প্রয়োজন ( 'http' ) ;
const স্থানীয় সার্ভার = httpObj. সার্ভার তৈরি করুন ( ( অনুরোধ প্রতিক্রিয়া ) => {
চেষ্টা করুন {
// পড়ার জন্য টার্গেটেড ফাইল
const তথ্য প্রবাহ = fsObj. রিডস্ট্রিম তৈরি করুন ( 'usecase.txt' ) ;
// প্রতিক্রিয়া জানাতে ফাইলটি পাইপ করুন
তথ্য প্রবাহ. পাইপ ( প্রতিক্রিয়া ) ;
} ধরা ( ত্রুটি ) {
কনসোল ত্রুটি ( ত্রুটি ) ;
}
} ) ;
স্থানীয় সার্ভার। শুনুন ( 8080 , ( ) => {
কনসোল লগ ( 'সার্ভার লোকালহোস্ট পোর্ট নম্বরে চলছে: '8080'' )
} ) ;
উপরের কোডের বর্ণনা নিম্নরূপ:
- প্রথমে প্রয়োজনীয় আমদানি করুন ' fs ' এবং ' http ' মডিউল এবং তাদের বস্তু সংরক্ষণ করুন ' fsObj ' এবং ' httpObj ” ভেরিয়েবল যথাক্রমে।
- এর পরে, সার্ভার তৈরি করা হয়েছে ' CreateServer() ' পদ্ধতি এবং এই নতুন তৈরি সার্ভারটিকে একটি 'এ সংরক্ষণ করা স্থানীয় সার্ভার ' পরিবর্তনশীল।
- তারপর, একটি ব্যবহার করুন ' চেষ্টা করুন ' পদ্ধতি কলব্যাক ফাংশনের ভিতরে ব্লক করুন এবং ' CreateReadStream() 'পদ্ধতি ব্যবহার করে' fsObj ' পরিবর্তনশীল।
- এই পদ্ধতির বন্ধনীর ভিতরে যে টার্গেট করা ফাইলের বিষয়বস্তু পড়তে হবে তা পাস করুন এবং ফলাফলটি “ তথ্য প্রবাহ ' পরিবর্তনশীল।
- ঢোকান ' তথ্য প্রবাহ ' পরিবর্তনশীল ' পাইপ() প্রতিক্রিয়া পাঠানোর পদ্ধতি।
- ব্যবহার করুন ' ধরা ” যেকোন ত্রুটি দেখা দেওয়ার জন্য ব্লক করুন।
- অবশেষে, পোর্ট নম্বরের উপর সার্ভারটি শুনুন বা সেট আপ করুন “ 8080 এবং এর কলব্যাক ফাংশনের সাহায্যে সাফল্যের বার্তা প্রদর্শন করুন।
উপরের কোডের ফাইলটি (controlFlow.js) এক্সিকিউট করুন যা নিচের কমান্ডের মাধ্যমে:
নোড নিয়ন্ত্রণ প্রবাহ। jsউৎপন্ন আউটপুট দেখায় যে 'এর সাহায্যে পাইপ() ' এবং ' পঠনযোগ্য স্ট্রীম ”, ফাইলের ডেটা পড়া হয়েছে এবং ওয়েবপেজে প্রদর্শনের জন্য গন্তব্য স্ট্রিমে পাঠানো হয়েছে:
উদাহরণ 2: রিডস্ট্রিম ব্যবহার করে স্থানীয়ভাবে স্ট্যাটিক ফাইল পড়া
এই ক্ষেত্রে, স্ট্রীমের উপরে প্রদত্ত ফাইলটি নির্বাচন করা হয় এবং এর বিষয়বস্তু ইভেন্ট শ্রোতাদের সাহায্যে কনসোল উইন্ডোতে প্রদর্শিত হয়:
const fsObj = প্রয়োজন ( 'এফএস' ) ;const streamObj = fsObj. রিডস্ট্রিম তৈরি করুন ( 'usecase.txt' ) ;
streamObj চালু ( 'তথ্য' , ( বিষয়বস্তু ) => {
কনসোল লগ ( বিষয়বস্তু স্ট্রিং ( ) ) ;
} ) ;
streamObj চালু ( 'শেষ' , ( ) => {
কনসোল লগ ( ' \n ফাইল পড়া শেষ।' ) ;
} ) ;
streamObj পাইপ ( প্রক্রিয়া stdout ) ;
উপরের কোডের বর্ণনা নিম্নরূপ:
- প্রথমত, ' fs 'মডিউল আমদানি করা হয় এবং এর বস্তুটি 'এ সংরক্ষণ করা হয় fsObj ' পরিবর্তনশীল।
- পরবর্তী, ব্যবহার করে ' fsObj 'আহ্বান করে' CreateReadStream() ” পদ্ধতি এবং টার্গেট করা ফাইলের পাথ পাস করে যার বিষয়বস্তু পুনরুদ্ধার করা প্রয়োজন। পদ্ধতির ফলাফল একটি নতুন ভেরিয়েবলে সংরক্ষণ করুন ' streamObj ”
- সংযুক্ত করুন ' চালু() 'স্ট্রিমওবিজে' এর সাথে পদ্ধতি যা একটি কলব্যাক ফাংশন আহ্বান করে যখন ' তথ্য ” পুনরুদ্ধার করা হয়। পুনরুদ্ধার করা ডেটা কলব্যাক ফাংশনের জন্য একটি প্যারামিটার হিসাবে পাস করা হয় যা ডেটাকে স্ট্রিং ফর্ম্যাটে রূপান্তর করে এবং এটি কনসোলে প্রদর্শন করে।
- আবার সংযুক্ত করুন ' চালু() 'সহ পদ্ধতি' streamObj এবং এই সময় ফাইলের রিডিং সম্পূর্ণ হলে এর কলব্যাক ফাংশন একটি শেষ বার্তা প্রদর্শন করে।
উপরের কোডটি কার্যকর করার পরে উত্পন্ন আউটপুট দেখায় যে শেষ বার্তা বরাবর পঠিত ডেটা কনসোলে প্রদর্শিত হয়েছে:
এটি Node.js-এ পঠনযোগ্য স্ট্রিমগুলির ব্যবহার সম্পর্কে।
উপসংহার
Node.js-এ পঠনযোগ্য স্ট্রিমগুলির সাথে কাজ করতে, 'এর পদ্ধতি CreateReadStream() 'এর মাধ্যমে আহ্বান করা হয়' fs ” মডিউল অবজেক্ট। টার্গেট করা ফাইল পাথ যার উপর বিষয়বস্তু লিখতে হবে তারপর পদ্ধতি প্যারামিটার হিসাবে পাস করা হয়। এটি ব্যবহার করা যেতে পারে ' পাইপ() অন্য ফাইলে বিষয়বস্তু লেখার মতো পুনরুদ্ধার করা ডেটার উপর আরও কাজ সম্পাদন করার পদ্ধতি। এই পোস্টটি পঠনযোগ্য স্ট্রিমগুলির সাথে কাজ করার পদ্ধতিটি চিত্রিত করেছে।