RxPY - Tổng quan
Chương này giải thích lập trình phản ứng là gì, RxPY là gì, các toán tử, tính năng, ưu điểm và nhược điểm của nó.
Lập trình phản ứng là gì?
Lập trình phản ứng là một mô hình lập trình, xử lý luồng dữ liệu và sự lan truyền của sự thay đổi. Nó có nghĩa là, khi một luồng dữ liệu được phát ra bởi một thành phần, sự thay đổi sẽ được truyền đến các thành phần khác bởi một thư viện lập trình phản ứng. Sự lan truyền sự thay đổi sẽ tiếp tục cho đến khi nó đến người nhận cuối cùng.
Bằng cách sử dụng RxPY, bạn có quyền kiểm soát tốt các luồng dữ liệu không đồng bộ, ví dụ: yêu cầu được gửi đến URL có thể được theo dõi bằng cách sử dụng có thể quan sát và sử dụng trình quan sát để lắng nghe khi yêu cầu hoàn tất để phản hồi hoặc có lỗi.
RxPY cung cấp cho bạn khả năng xử lý các luồng dữ liệu không đồng bộ bằng cách sử dụng Observables, truy vấn các luồng dữ liệu bằng cách sử dụng Operators tức là lọc, tính tổng, kết hợp, ánh xạ và cũng sử dụng đồng thời cho các luồng dữ liệu bằng cách sử dụng Schedulers. Tạo một Observable, cung cấp một đối tượng quan sát với các phương thức on_next (v), on_error (e) và on_completed (), cần phảisubscribed để chúng tôi nhận được thông báo khi một sự kiện xảy ra.
Có thể truy vấn Observable bằng nhiều toán tử trong một định dạng chuỗi bằng cách sử dụng toán tử ống.
RxPY cung cấp các toán tử trong các danh mục khác nhau như: -
Toán tử toán học
Toán tử chuyển đổi
Lọc toán tử
Các toán tử xử lý lỗi
Các nhà khai thác tiện ích
Toán tử có điều kiện
Toán tử tạo
Các toán tử có thể kết nối
Các toán tử này được giải thích chi tiết trong hướng dẫn này.
RxPy là gì?
RxPY được định nghĩa là a library for composing asynchronous and event-based programs using observable collections and pipable query operators in Python theo trang web chính thức của RxPy, https://rxpy.readthedocs.io/en/latest/.
RxPY là một thư viện python để hỗ trợ Lập trình phản ứng. RxPy là viết tắt củaReactive Extensions for Python. Đó là một thư viện sử dụng các khả năng quan sát để làm việc với lập trình phản ứng xử lý các cuộc gọi dữ liệu không đồng bộ, lệnh gọi lại và các chương trình dựa trên sự kiện.
Đặc điểm của RxPy
Trong RxPy, các khái niệm sau sẽ xử lý tác vụ không đồng bộ:
Có thể quan sát được
Có thể quan sát là một hàm tạo một trình quan sát và gắn nó vào nguồn có các luồng dữ liệu được mong đợi từ đó, ví dụ: Tweet, các sự kiện liên quan đến máy tính, v.v.
Người quan sát
Nó là một đối tượng có các phương thức on_next (), on_error () và on_completed (), sẽ được gọi khi có tương tác với phương thức có thể quan sát được, tức là nguồn tương tác với một Tweet đến, v.v.
Đăng ký
Khi có thể quan sát được tạo, để thực thi có thể quan sát, chúng ta cần đăng ký với nó.
Các nhà khai thác
Toán tử là một hàm thuần túy lấy đầu vào có thể quan sát được và đầu ra cũng là một hàm có thể quan sát được. Bạn có thể sử dụng nhiều toán tử trên một dữ liệu quan sát được bằng cách sử dụng toán tử ống.
Môn học
Chủ thể là một chuỗi có thể quan sát được cũng như một người quan sát có thể phát đa hướng, tức là nói chuyện với nhiều người quan sát đã đăng ký. Đối tượng là một người quan sát lạnh, tức là các giá trị sẽ được chia sẻ giữa những người quan sát đã được đăng ký.
Người lên lịch
Một tính năng quan trọng của RxPy là đồng thời tức là cho phép nhiệm vụ thực thi song song. Để điều đó xảy ra, RxPy có hai toán tử subscribe_on () và Obser_on () hoạt động với các bộ lập lịch và sẽ quyết định việc thực thi tác vụ đã đăng ký.
Ưu điểm của việc sử dụng RxPY
Sau đây là những ưu điểm của RxPy:
RxPY là một thư viện tuyệt vời khi nói đến việc xử lý các sự kiện và luồng dữ liệu không đồng bộ. RxPY sử dụng khả năng quan sát để làm việc với lập trình phản ứng xử lý các cuộc gọi dữ liệu không đồng bộ, lệnh gọi lại và các chương trình dựa trên sự kiện.
RxPY cung cấp một bộ sưu tập khổng lồ các toán tử trong các danh mục toán học, biến đổi, lọc, tiện ích, điều kiện, xử lý lỗi, nối giúp dễ dàng sử dụng với lập trình phản ứng.
Đồng thời tức là làm việc nhiều tác vụ với nhau đạt được bằng cách sử dụng bộ lập lịch trong RxPY.
Hiệu suất được cải thiện bằng cách sử dụng RxPY vì việc xử lý tác vụ không đồng bộ và xử lý song song được thực hiện dễ dàng.
Bất lợi khi sử dụng RxPY
Gỡ lỗi mã bằng các vật có thể quan sát là một chút khó khăn.