کتاب کار با Streams در دارت: پردازش داده‌های جریانی

## کتاب کار با Streams در دارت: پردازش داده‌های جریانی **مقدمه** در دنیای مدرن توسعه نرم‌افزار، پردازش داده‌های جریانی (Streaming Data) به یک نیاز اساسی تبدیل شده است. این نوع پردازش، امکان کار با حجم عظیمی از داده‌ها را به صورت پیوسته و در لحظه فراهم می‌کند. زبان برنامه‌نویسی دارت (Dart) نیز با ارائه مفهوم Streams، ابزارهای قدرتمندی را برای مدیریت و پردازش این نوع داده‌ها در اختیار توسعه‌دهندگان قرار می‌دهد. این مقاله، به عنوان یک کتاب کار، به بررسی عمیق Streams در دارت، مفاهیم کلیدی، کاربردها و مثال‌های عملی می‌پردازد تا شما را در استفاده موثر از این قابلیت دارت یاری رساند. **1. Streams چیست؟** Streams در دارت، یک جریان از داده‌ها را در طول زمان نشان می‌دهند. این داده‌ها می‌توانند از منابع مختلفی مانند فایل‌ها، شبکه‌ها، ورودی کاربر یا حتی محاسبات در داخل برنامه آمده باشند. برخلاف داده‌های معمولی که به صورت یکجا در دسترس هستند، Streams داده‌ها را به صورت تدریجی و در طول زمان ارسال می‌کنند. 1.1. **تفاوت Streams با List و Future** * **List:** لیست یک مجموعه ثابت از داده‌هاست که همه عناصر آن در یک لحظه در دسترس هستند. * **Future:** Future یک عملیات ناهمزمان است که در نهایت یک مقدار را برمی‌گرداند. Future یک بار مقدار را برمی‌گرداند، در حالی که Stream داده‌ها را به صورت مداوم ارسال می‌کند. * **Stream:** Stream یک جریان پیوسته از داده‌هاست که می‌تواند به طور نامحدود ادامه داشته باشد. 1.2. **مفاهیم کلیدی Streams** * **StreamController:** این کلاس مسئول ایجاد و مدیریت Stream است. با استفاده از StreamController می‌توان داده‌ها را به Stream اضافه کرد، Stream را بست و به Stream گوش داد. * **Stream:** خود جریان داده است. گوش‌دهندگان (Listeners) می‌توانند به Stream متصل شوند و داده‌ها را دریافت کنند. * **Sink:** سینک، نقطه‌ای است که داده‌ها به Stream وارد می‌شوند. StreamController یک Sink را برای افزودن داده‌ها فراهم می‌کند. * **Listener:** شنونده، کدی است که به Stream متصل شده و داده‌های ارسالی را دریافت و پردازش می‌کند. **2. ایجاد و استفاده از Streams** 2.1. **ایجاد یک Stream ساده** ```dart import 'dart:async'; void main() { final controller = StreamController<String>(); controller.stream.listen((data) { print('داده دریافت شد: $data'); }); controller.sink.add('سلام'); controller.sink.add('به دارت'); controller.sink.close(); // بستن Stream } ``` در این مثال، یک StreamController با نوع داده String ایجاد شده است. سپس یک Listener به Stream متصل شده و هر بار که داده‌ای به Stream اضافه می‌شود، آن را چاپ می‌کند. در نهایت، Stream بسته می‌شود تا دیگر داده‌ای به آن اضافه نشود. 2.2. **استفاده از Stream.fromIterable** می‌توان از `Stream.fromIterable` برای تبدیل یک لیست یا iterable به یک Stream استفاده کرد. ```dart import 'dart:async'; void main() { final numbers = [1, 2, 3, 4, 5]; final stream = Stream.fromIterable(numbers); stream.listen((number) { print('عدد دریافت شد: $number'); }); } ``` 2.3. **استفاده از StreamBuilder در Flutter** در Flutter، `StreamBuilder` یک ویجت قدرتمند برای نمایش داده‌های ارسالی از یک Stream است. این ویجت به طور خودکار به Stream متصل می‌شود و هر بار که داده جدیدی دریافت می‌کند، رابط کاربری را به‌روزرسانی می‌کند. **3. عملیات روی Streams** دارت ابزارهای مختلفی را برای انجام عملیات روی Streams فراهم می‌کند. 3.1. **Transform Streams** Transform Streams به شما امکان می‌دهند داده‌های یک Stream را تغییر دهید. این عملیات می‌تواند شامل تبدیل نوع داده، فیلتر کردن داده‌ها یا انجام محاسبات روی داده‌ها باشد. ```dart import 'dart:async'; void main() { final controller = StreamController<int>(); final stream = controller.stream.map((number) => number * 2); // دو برابر کردن اعداد stream.listen((number) { print('عدد دو برابر شده: $number'); }); controller.sink.add(1); controller.sink.add(2); controller.sink.add(3); controller.sink.close(); } ``` 3.2. **Combine Streams** می‌توان چندین Stream را با هم ترکیب کرد. * **`Stream.concat`:** Streams را به ترتیب پشت سر هم به هم متصل می‌کند. * **`Stream.merge`:** Streams را به صورت همزمان با هم ترکیب می‌کند. 3.3. **Error Handling** Streams امکان مدیریت خطاها را نیز فراهم می‌کنند. با استفاده از `listen` می‌توان به خطاهای احتمالی در Stream گوش داد و آن‌ها را مدیریت کرد. ```dart import 'dart:async'; void main() { final controller = StreamController<int>(); controller.stream.listen( (data) => print('داده دریافت شد: $data'), onError: (error) => print('خطا: $error'), onDone: () => print('Stream بسته شد'), ); controller.sink.add(1); controller.sink.addError(Exception('خطای نمونه')); // ارسال خطا controller.sink.close(); } ``` **4. کاربردهای Streams** Streams در دارت کاربردهای فراوانی دارند: * **پردازش فایل‌های بزرگ:** خواندن و پردازش فایل‌های بزرگ به صورت تکه تکه بدون بارگذاری کل فایل در حافظه. * **شبکه‌سازی:** دریافت و پردازش داده‌ها از طریق شبکه‌های TCP/IP یا WebSocket. * **رابط کاربری تعاملی:** پاسخ به رویدادهای ورودی کاربر (مانند کلیک‌های ماوس یا لمس صفحه) به صورت بلادرنگ. * **پردازش داده‌های سنسورها:** دریافت و پردازش داده‌ها از سنسورها به صورت پیوسته. * **ارتباطات بلادرنگ:** ایجاد برنامه‌های چت یا برنامه‌هایی که نیاز به ارتباط بلادرنگ دارند. **5. نکات تکمیلی و بهترین روش‌ها** * همیشه Stream را پس از اتمام کار ببندید تا منابع سیستم آزاد شوند. * از `StreamController` برای ایجاد و مدیریت Streams استفاده کنید. * برای انجام عملیات روی Streams از `transform`، `combine` و `error handling` استفاده کنید. * در Flutter از `StreamBuilder` برای نمایش داده‌های ارسالی از یک Stream در رابط کاربری استفاده کنید. * به مدیریت حافظه در هنگام کار با Streams بزرگ توجه کنید. **نتیجه‌گیری** Streams در دارت یک ابزار قدرتمند برای پردازش داده‌های جریانی هستند. با استفاده از Streams می‌توان برنامه‌هایی را ایجاد کرد که به طور موثر با حجم عظیمی از داده‌ها کار می‌کنند و در لحظه به تغییرات داده‌ها پاسخ می‌دهند. این مقاله، یک راهنمای جامع برای شروع کار با Streams در دارت بود. با تمرین و آزمایش، می‌توانید از این قابلیت قدرتمند در پروژه‌های خود استفاده کنید و برنامه‌هایی با کارایی و انعطاف‌پذیری بالا ایجاد کنید.