Bộ điều khiển Stream

Thuộc phần Lập trình hướng đối tượng trong hành trình Dart của Coddy. Bài học 78 trên 110.

Dù generator async* rất hữu ích để tạo luồng với dữ liệu được xác định trước, đôi khi bạn cần kiểm soát nhiều hơn, chẳng hạn như thêm dữ liệu vào luồng từ nhiều phần khác nhau trong code. Khi đó, bạn có thể dùng StreamController.

StreamController đóng vai trò quản lý một luồng. Nó cung cấp cho bạn một "sink" để thêm dữ liệu và một "stream" mà các trình nghe có thể đăng ký:

import 'dart:async';

void main() {
  var controller = StreamController<String>();
  
  // Lắng nghe luồng dữ liệu
  controller.stream.listen((data) {
    print('Received: $data');
  });
  
  // Thêm dữ liệu qua sink
  controller.add('Hello');
  controller.add('World');
  
  controller.close();  // Luôn đóng sau khi dùng xong
}

Phương thức add() đẩy các giá trị mới vào luồng và mọi trình lắng nghe nhận được chúng ngay lập tức. Bạn luôn nên gọi close() khi hoàn tất để giải phóng tài nguyên.

Theo mặc định, một luồng (stream) chỉ có thể có một bộ lắng nghe (listener). Để có nhiều bộ lắng nghe, hãy dùng bộ điều khiển phát sóng (broadcast controller):

import 'dart:async';

void main() {
  var controller = StreamController<int>.broadcast();
  
  controller.stream.listen((n) => print('Listener 1: $n'));
  controller.stream.listen((n) => print('Listener 2: $n'));
  
  controller.add(42);
  controller.close();
}

StreamControllers rất quan trọng trong lập trình hướng đối tượng (OOP) để xây dựng các lớp hướng sự kiện, chẳng hạn như thông báo cho nhiều phần trong ứng dụng khi dữ liệu thay đổi, xử lý thao tác của người dùng hoặc quản lý các bản cập nhật theo thời gian thực bên trong đối tượng.

Thử thách

Dễ

Hãy xây dựng một hệ thống trung tâm tin nhắn cho phép nhiều người đăng ký nhận tin nhắn theo thời gian thực! Bạn sẽ dùng StreamController để quản lý luồng tin nhắn và minh họa cách luồng phát sóng cho phép nhiều trình nghe cùng nhận tin.

Bạn sẽ sắp xếp code thành hai tệp:

message_hub.dart: Tạo lớp MessageHub để quản lý việc phân phối tin nhắn bằng StreamController. Trung tâm tin nhắn của bạn cần:
- Dùng StreamController<String> phát sóng ở bên trong để nhiều trình nghe có thể đăng ký
- Cung cấp getter tên là messages, trả về luồng để các trình nghe đăng ký
- Có phương thức broadcast(String message) để thêm tin nhắn vào luồng
- Có phương thức shutdown() để đóng bộ điều khiển
main.dart: Nhập trung tâm tin nhắn và thiết lập tình huống có nhiều người đăng ký cùng nghe một luồng:
- Tạo một đối tượng MessageHub
- Thêm trình nghe đầu tiên để in tin nhắn theo định dạng: Subscriber A: [message]
- Thêm trình nghe thứ hai để in tin nhắn theo định dạng: Subscriber B: [message]
- Phát sóng ba tin nhắn: Hello everyone, Welcome to the hub và Goodbye
- Tắt trung tâm tin nhắn

Nhớ nhập dart:async trong tệp trung tâm tin nhắn để dùng StreamController. Hãy chú ý cách cả hai người đăng ký đều nhận được mọi tin nhắn được phát sóng. Đó chính là sức mạnh của luồng phát sóng!

Đầu ra dự kiến:

Subscriber A: Hello everyone
Subscriber B: Hello everyone
Subscriber A: Welcome to the hub
Subscriber B: Welcome to the hub
Subscriber A: Goodbye
Subscriber B: Goodbye

Tự làm thử

import 'message_hub.dart';

void main() {
  // TODO: Tạo một instance của MessageHub
  
  // TODO: Thêm listener đầu tiên in ra: Subscriber A: [message]
  
  // TODO: Thêm listener thứ hai in ra: Subscriber B: [message]
  
  // TODO: Phát ba thông điệp:
  // - "Hello everyone"
  // - "Welcome to the hub"
  // - "Goodbye"
  
  // TODO: Tắt hub
}