Jassif Team Institution

const fs = প্রয়োজন('fs'); const path = require('path'); // উদাহরণের জন্য একটি নমুনা ফাইল তৈরি করুন const sampleFile = path.join(__dirname, 'readstream-example.txt'); fs.writeFileSync(sampleFile, 'এটি একটি টেস্ট ফাইল।\nএটির একাধিক লাইন রয়েছে।\nপ্রতিটি লাইনের নিজস্ব বিষয়বস্তু রয়েছে।\nস্ট্রিমিং ফাইল পড়াকে দক্ষ করে তোলে।'); // ফাইল থেকে পড়ার জন্য একটি রিডস্ট্রিম তৈরি করুন const readStream = fs.createReadStream(sampleFile, { // বিকল্প এনকোডিং: 'utf8', // সেট এনকোডিং (utf8, ascii, বাইনারি, ইত্যাদি) highWaterMark: 64, // বাফার আকার বাইটে autoClose: true // স্ট্রীম শেষ হলে স্বয়ংক্রিয়ভাবে ফাইল বর্ণনাকারী বন্ধ করুন }); console.log('ফাইল রিডস্ট্রিম বৈশিষ্ট্য:'); console.log(`- পথ: ${readStream.path}`); console.log(`- মুলতুবি: ${readStream.pending}`); console.log(`- হাই ওয়াটার মার্ক: ${readStream.readableHighWaterMark} বাইটস`); // স্ট্রিম ইভেন্টগুলি পরিচালনা করতে readStream.on('open', (fd) => { console.log(`ফাইল বর্ণনাকারীর সাথে খোলা হয়েছে: ${fd}`); }); readStream.on('তৈরি', () => { console.log('রিডস্ট্রিম প্রস্তুত'); }); // ডেটা ইভেন্টগুলি পরিচালনা করুন readStream.on('ডেটা', (খণ্ড) => { console.log('\nপ্রাপ্ত খণ্ড:'); console.log('-'.রিপিট(20)); console.log(খণ্ড); console.log('-'.রিপিট(20)); console.log(`এখন পর্যন্ত পড়া বাইট: ${readStream.bytesRead}`); }); readStream.on('end', () => { console.log('\nফাইলের শেষে পৌঁছেছে'); console.log(`মোট বাইট রিড: ${readStream.bytesRead}`); // নমুনা ফাইল পরিষ্কার করুন fs.unlinkSync(sampleFile); console.log('নমুনা ফাইল সরানো'); }); readStream.on('close', () => { console.log('স্ট্রিম বন্ধ'); }); readStream.on('error', (err) => { console.error(`ত্রুটি: ${err.message}`); });

const fs = প্রয়োজন('fs'); const path = require('path'); // প্রবাহ নিয়ন্ত্রণ উদাহরণের জন্য একটি বড় নমুনা ফাইল তৈরি করুন const flowFile = path.join(__dirname, 'flow-control-example.txt'); যাক নমুনা বিষয়বস্তু = ''; জন্য (আলো i = 1; i <= 1000; i++) { sampleContent += `এটি পরীক্ষার ফাইলের ${i} লাইন।\n`; } fs.writeFileSync(flowFile, sampleContent); // একটি রিডস্ট্রিম তৈরি করুন const readStream = fs.createReadStream(flowFile, { এনকোডিং: 'utf8', হাইওয়াটারমার্ক: 1024 // 1KB বাফার }); যাক chunkCount = 0; যাক মোটবাইট = 0; let isPaused = মিথ্যা; // প্রবাহ নিয়ন্ত্রণের সাথে ডেটার খণ্ডগুলি পরিচালনা করতে readStream.on('ডেটা', (খণ্ড) => { chunkCount++; totalBytes += chunk.length; console.log(`খণ্ড #${chunkCount} প্রাপ্ত, আকার: ${chunk.length} bytes`); // প্রবাহ নিয়ন্ত্রণ প্রদর্শন করতে প্রতি 5 খণ্ডে স্ট্রীমটি থামান যদি (chunkCount % 5 === 0 && ! is Paused) { console.log('\n1 সেকেন্ডের জন্য স্ট্রিম থামানো হচ্ছে...'); isPaused = true; // প্রবাহ থামান readStream.pause(); // 1 সেকেন্ড পরে পুনরায় শুরু করুন setTimeout(() => { console.log('স্ট্রিম পুনরায় শুরু করা হচ্ছে...\n'); isPaused = মিথ্যা; readStream.resume(); }, 1000); } }); readStream.on('end', () => { console.log(`\nফাইল পড়া শেষ। ${chunkCount} খণ্ড, ${totalBytes} মোট বাইট।`); // নমুনা ফাইল পরিষ্কার করুন fs.unlinkSync(flowFile); console.log('নমুনা ফাইল সরানো'); }); readStream.on('error', (err) => { console.error(`ত্রুটি: ${err.message}`); });

const fs = প্রয়োজন('fs'); const path = require('path'); // একটি নমুনা ফাইল তৈরি করুন const readableFile = path.join(__dirname, 'readable-example.txt'); fs.writeFileSync(পঠনযোগ্য ফাইল, 'ABCDEFGHIJKLMNOPQRSTUVWXYZ'.রিপিট(100)); // স্বয়ংক্রিয়ভাবে প্রবাহিত ছাড়াই একটি রিডস্ট্রিম তৈরি করুন const readStream = fs.createReadStream(readableFile, { highWaterMark: 32 // একাধিক রিডিং প্রদর্শনের জন্য ছোট বাফার }); console.log('পঠনযোগ্য ইভেন্ট ব্যবহার করে এবং read() পদ্ধতি:'); // ম্যানুয়াল পড়ার জন্য 'পঠনযোগ্য' ইভেন্ট ব্যবহার করা readStream.on('পাঠযোগ্য', () => { যাক খণ্ড; পড়ার জন্য আর কোনো ডেটা না থাকলে // read() শূন্য দেয় যখন (শূন্য !== (খণ্ড = readStream.read(16))) { console.log(`${chunk.length} বাইট পড়ুন: ${chunk.toString('utf8').substring(0, 10)}...`); } }); readStream.on('end', () => { console.log('প্রবাহের শেষে পৌঁছেছে'); // নমুনা ফাইল পরিষ্কার করুন fs.unlinkSync(পঠনযোগ্য ফাইল); console.log('নমুনা ফাইল সরানো'); }); readStream.on('error', (err) => { console.error(`ত্রুটি: ${err.message}`); });

const fs = প্রয়োজন('fs'); const path = require('path'); const zlib = require('zlib'); // উৎস এবং গন্তব্য ফাইল পাথ const sourceFile = path.join(__dirname, 'pipe-source-example.txt'); const destFile = path.join(__dirname, 'pipe-destination.txt'); const compressedFile = path.join(__dirname, 'pipe-compressed.gz'); // নমুনা সামগ্রী তৈরি করুন fs.writeFileSync(sourceFile, 'এটি পাইপ উদাহরণের জন্য উৎস বিষয়বস্তু।\n'.repeat(100)); // একটি রিডস্ট্রিম এবং বিভিন্ন রাইটস্ট্রিম তৈরি করুন const readStream = fs.createReadStream(sourceFile); const writeStream = fs.createWriteStream(destFile); const compressStream = zlib.createGzip(); // বিমূর্ত রূপান্তর প্রবাহ const compressedWriteStream = fs.createWriteStream(compressedFile); // রিডস্ট্রিমটি সরাসরি রাইটস্ট্রিমে পাইপ করুন readStream.pipe(writeStream); // সমাপ্তির ইভেন্টের জন্য শুনুন writeStream.on('finish', () => { console.log(`ফাইল ${sourceFile} থেকে ${destFile}`-এ কপি করা হয়েছে); // ক্রমাগত পাইপ প্রদর্শন করতে একটি নতুন রিডস্ট্রিম তৈরি করুন const readStream2 = fs.createReadStream(sourceFile); // একাধিক পাইপ সংযুক্ত করুন: পড়ুন -> কম্প্রেস -> লিখুন readStream2.pipe(compressedstream).pipe(compressedWriteStream); compressedWriteStream.on('finish', () => { console.log(`ফাইল ${sourceFile} থেকে ${compressedFile}` পর্যন্ত সংকুচিত হয়েছে); // ফাইলের আকার তুলনা করুন const originalSize = fs.statSync(sourceFile).size; const compressedSize = fs.statSync(compressedFile).size; console.log(`মূল আকার: ${originalSize} বাইট`); console.log(`সংকুচিত আকার: ${compressedSize} বাইট`); console.log(`কম্প্রেশন অনুপাত: ${(compressedSize / originalSize * 100).toFixed(2)}%`); // প্রমাণের পরে ফাইলগুলি পরিষ্কার করুন [sourceFile, destFile, compressedFile].forEach(file => { fs.unlinkSync(ফাইল); }); console.log('সমস্ত নমুনা ফাইল মুছে ফেলা হয়েছে'); }); }); // ত্রুটিগুলি পরিচালনা করতে readStream.on('error', (err) => console.error(`Read error: ${err.message}`)); writeStream.on('error', (err) => console.error(`ত্রুটি লিখুন: ${err.message}`)); compressStream.on('error', (err) => console.error(`কম্প্রেশন ত্রুটি: ${err.message}`)); compressedWriteStream.on('error', (err) => console.error(`সংকুচিত লেখার ত্রুটি: ${err.message}`));

// process.stdin একটি রিডস্ট্রিম console.log('কিছু পাঠ্য লিখুন (ইনপুট শেষ করতে Ctrl+D বা Ctrl+C টিপুন):'); // বাফার অবজেক্টের পরিবর্তে স্ট্রিং পেতে utf8 এ এনকোডিং সেট করুন process.stdin.setEncoding('utf8'); let inputData = ''; // stdin থেকে ডেটা পরিচালনা করতে process.stdin.on('ডেটা', (খণ্ড) => { console.log(`প্রাপ্ত খণ্ড: "${chunk.trim()}"`); inputData += খণ্ড; }); // ইনপুটের ফলাফল পরিচালনা করতে process.stdin.on('end', () => { console.log('\nইনপুটের শেষ।'); console.log(`মোট ইনপুট প্রাপ্ত: ${inputData.length} অক্ষর'); console.log('আপনি প্রবেশ করেছেন:'); console.log('-'.রিপিট(20)); console.log(inputData); console.log('-'.রিপিট(20)); }); // পরিচালনা করতে Ctrl+C (SIGINT)। process.on('SIGINT', () => { console.log('\nCtrl+C' দিয়ে ইনপুট বাধাপ্রাপ্ত); process.exit(); }); // দ্রষ্টব্য: এই উদাহরণের জন্য একটি টার্মিনালে ব্যবহারকারীর ইনপুট প্রয়োজন // W3Schools TryIt সম্পাদকে কার্যকরভাবে প্রদর্শন করতে পারে না

const http = প্রয়োজন('http'); // একটি HTTP সার্ভার তৈরি করুন const সার্ভার = http.createServer((req, res) => { // req হল একটি http.IncomingMessage, যা একটি ReadStream console.log(${req.url}`-এর কাছে ${req.method} অনুরোধ গৃহীত হয়েছে); // প্রতিক্রিয়া শিরোনাম সেট করুন res.setHeader('কন্টেন্ট-টাইপ', 'টেক্সট/প্লেইন'); // বিভিন্ন ধরণের অনুরোধ পরিচালনা করতে যদি (req.method === 'GET') { res.end('রিডস্ট্রিম অ্যাকশনে দেখতে একটি বডির সাথে একটি POST অনুরোধ পাঠান'); } অন্যথায় যদি (req.method === 'পোস্ট') { // অনুরোধ স্ট্রীমের জন্য এনকোডিং সেট করুন req.setEncoding('utf8'); let body = ''; // অনুরোধ স্ট্রীম থেকে ডেটা ইভেন্ট পরিচালনা করতে req.on('data', (chunk) => { console.log(`${chunk.length} বাইটের খণ্ড প্রাপ্ত হয়েছে`); শরীর += খণ্ড; // একটি সাধারণ বন্যা সুরক্ষা প্রয়োগ করুন যদি (body.length > 1e6) { // শরীর খুব বড় হলে, স্রোত ধ্বংস করুন body = ''; res.writeHead(413, {'Content-Type': 'text/plain'}); res.end('রিকোয়েস্ট এন্টিটি খুব বড়'); req.destroy(); } }); // অনুরোধ স্ট্রীমের ফলাফল পরিচালনা করতে req.on('end', () => { console.log('অনুরোধের ডেটা শেষ'); চেষ্টা করুন { // JSON-এ পার্স করার চেষ্টা const data = JSON.parse(body); console.log('পার্সড JSON ডেটা:', ডেটা); // একটি প্রতিক্রিয়া পাঠান res.writeHead(200, {'Content-Type': 'application/json'}); res.end(JSON.stringify({ বার্তা: 'ডেটা গৃহীত', আকার: শরীরের দৈর্ঘ্য, ডেটা: ডেটা })); } ধরা (ই) { // বৈধ JSON না হলে, কাঁচা ডেটা ইকো ব্যাক করুন console.log('JSON হিসাবে পার্স করা যায়নি, প্লেইন টেক্সট হিসাবে আচরণ করা'); res.writeHead(200, {'Content-Type': 'text/plain'}); res.end(`প্রাপ্ত ${body.length} বাইট ডেটা:\n${body}`); } }); } অন্য { // অন্যান্য HTTP পদ্ধতির জন্য res.writeHead(405, {'Content-Type': 'text/plain'}); res.end('পদ্ধতি অনুমোদিত নয়'); } }); // সার্ভার শুরু করুন const PORT = 8080; server.listen(PORT, () => { console.log(`HTTP রিডস্ট্রিম উদাহরণ সার্ভার http://localhost:${PORT}` এ চলছে); console.log('পরীক্ষা করতে:'); console.log(`1. GET অনুরোধের জন্য একটি ব্রাউজারে http://localhost:${PORT} খুলুন'); console.log(`2. http://localhost:${PORT}`-এ বডি সহ POST অনুরোধ পাঠাতে কার্ল বা পোস্টম্যান ব্যবহার করুন); }); // দ্রষ্টব্য: কার্ল দিয়ে পরীক্ষা করতে: // curl -X POST -H "Content-Type: application/json" -d '{"name":"John","age":30}' http://localhost:8080

const fs = প্রয়োজন('fs'); const path = require('path'); // একটি ফাংশন যা সঠিক ত্রুটি হ্যান্ডলিং সহ একটি ReadStream তৈরি এবং পরিচালনা করে ফাংশন readWithErrorHandling(filePath) { console.log(`পড়ার চেষ্টা করা হচ্ছে: ${filePath}`); // রিডস্ট্রিম তৈরি করুন const readStream = fs.createReadStream(filePath); // ফলাফল বা ত্রুটি ধরার প্রতিশ্রুতি সেট করুন ফেরত নতুন প্রতিশ্রুতি((সমাধান, প্রত্যাখ্যান) => { let data = ''; // ডেটা ইভেন্টগুলি পরিচালনা করুন readStream.on('ডেটা', (খণ্ড) => { ডেটা += খণ্ড; }); // সফল সমাপ্তি পরিচালনা করতে readStream.on('end', () => { console.log(${filePath}` থেকে ${readStream.bytesRead} বাইট সফলভাবে পড়ুন); সমাধান (ডেটা); }); // ত্রুটিগুলি পরিচালনা করতে readStream.on('error', (err) => { console.error(`${filePath} পড়ার ত্রুটি: ${err.message}`); প্রত্যাখ্যান (ভ্রান্তি); }); // স্ট্রীম বন্ধ (একটি ত্রুটি থাকলেও সর্বদা ঘটবে) readStream.on('close', () => { console.log(`${filePath} বন্ধের জন্য স্ট্রিম`); }); }); } // বিদ্যমান এবং অ-বিদ্যমান উভয় ফাইলের সাথে পরীক্ষা করুন const existFile = path.join(__dirname, 'test-existing.txt'); const nonExistingFile = path.join(__dirname, 'non-existing-file.txt'); // টেস্ট ফাইল তৈরি করুন fs.writeFileSync(বিদ্যমান ফাইল, 'এটি ত্রুটি পরিচালনার উদাহরণের জন্য পরীক্ষার বিষয়বস্তু'); // উদাহরণ 1: একটি বিদ্যমান ফাইল পড়া console.log('উদাহরণ 1: একটি বিদ্যমান ফাইল পড়া'); ReadWithErrorHandling(বিদ্যমান ফাইল) তারপর (ডেটা => { console.log('ফাইল বিষয়বস্তু:', ডেটা); // উদাহরণ 2: বিদ্যমান নেই এমন একটি ফাইল পড়া console.log('\nউদাহরণ 2: একটি অ-বিদ্যমান ফাইল পড়া'); রিটার্ন readWithErrorHandling(nonExistingFile); }) .catch(err => { console.log('প্রোমিস ক্যাচ-এ ত্রুটি ধরা পড়েছে:', err.message); }) অবশেষে(() => { // পরীক্ষার ফাইলটি পরিষ্কার করুন যদি (fs.existsSync(existingFile)) { fs.unlinkSync(বিদ্যমান ফাইল); console.log('টেস্ট ফাইল সরানো'); } }); // উদাহরণ 3: ধ্বংসপ্রাপ্ত স্ট্রীম প্রমাণ করা console.log('\nউদাহরণ 3: ধ্বংস হওয়া স্ট্রীম প্রদর্শন করা'); const DestroyTestFile = path.join(__dirname, 'destroy-test.txt'); fs.writeFileSync(destroyTestFile, 'A'.repeat(10000)); const DestroyStream = fs.createReadStream(destroyTestFile); DestroyStream.on('data', (chunk) => { console.log(`প্রবাহটি ধ্বংস করার আগে ${chunk.length} বাইট প্রাপ্ত হয়েছে`); // প্রথম খণ্ডটি পাওয়ার পরে স্ট্রিমটি সাফ করুন console.log('ইচ্ছাকৃতভাবে স্ট্রিম ধ্বংস করা'); DestroyStream.destroy(নতুন ত্রুটি('স্ট্রিম ম্যানুয়ালি ধ্বংস')); }); DestroyStream.on('error', (err) => { console.error(`ধ্বংস ত্রুটি: ${err.message}`); }); DestroyStream.on('close', () => { console.log('নষ্ট প্রবাহ বন্ধ'); // পরিষ্কার করুন fs.unlinkSync(destroyTestFile); console.log('পরীক্ষা ফাইল মুছে ফেলা'); });