Все большее число программистов принимают идею реактивного программирования из-за его полезности в управлении потоками. Основными целями реактивного программирования являются управление изменениями и их распространение с помощью потоков данных. Пакет RxJava позволяет выполнять реактивное программирование на Java.
Онлайн-курс по Java может быть полезен для лучшего понимания этого предмета.
Программирование на основе ответов: что это такое?
Асинхронный поток данных лежит в основе реактивного программирования. Реактивное программирование получило свое название из-за того, как оно реагирует на события — своевременным и неблокирующим образом.
«Все является потоком и ведет себя неблокирующим образом, когда в потоке есть данные», — гласит руководящий принцип реактивного программирования.
Используя свой API, компания Netflix разработала новую парадигму программирования, называемую реактивным программированием на Java (Rx-Java).
Обоснование использования реактивных языков:
Зачем использовать реактивное программирование, если у нас уже есть проверенные методы создания полезных приложений?
Для плавного перехода к реактивному программированию вы можете положиться на эти четыре столпа.
Интуитивно понятный адаптивный на основе сообщений
Отзывчивый:
В высокопараллельных контекстах отзывчивость подразумевает, что любые события, которые мы вызываем в потоке, получат ответ за то же время, что и обработка сообщения.
Устойчивость:
Чтобы приложение считалось устойчивым, оно должно быть способно быстро адаптироваться к изменяющимся обстоятельствам в случае сбоя.
При интеграции многих модулей можно с уверенностью ожидать, что сбой любого из модулей повлияет на всю систему.
Эластичный:
Когда мы говорим, что наша система эластична, мы имеем в виду, что она может масштабироваться для обработки любого количества запросов и может динамически распределять эти запросы по своим ресурсам.
Информационная направленность:
Термин «управляемый сообщениями» относится к подходу к программированию, при котором запросы отправляются на сервер и обрабатываются асинхронно, без блокировки выполнения в ожидании ответа. Вместо этого ответ сервера на запрос обрабатывается методом «обратного вызова».
- Хорошие приложения реактивного программирования
- Несколько различных видов услуг по обработке транзакций, например, используемые банками.
- Функции уведомлений, предлагаемые популярными платформами электронной коммерции, такими как Amazon.
- Фондовая биржа, где цены покупки и продажи постоянно колеблются.
Объяснение библиотеки RxJava:
RxJava — это библиотека Java, реализующая библиотеку ReactiveX, которая используется для составления наблюдаемых последовательностей асинхронного и событийного кода. С помощью RxJava программисты получают доступ к надежному набору инструментов для обработки и преобразования потоков данных. Он поставляется с широким набором операторов для обработки, преобразования и объединения данных в режиме реального времени. Потоки данных могут обрабатываться разработчиками с большей функциональностью и более реактивным образом, что снижает нагрузку на сложные процессы обработки данных.
Продолжительность курса разработчика Java может достигать 12 месяцев.
RxJava использует парадигму Observer, в соответствии с которой Observable генерирует элементы или события, а один или несколько Observer подписываются на него. Любые наблюдатели, которые подписаны на Observable, будут получать любые элементы или события, которые он испускает.
Основные строительные блоки RxJava:
Observable — это своего рода структура данных, которая может отправлять данные в виде элементов или событий, на которые затем могут подписаться другие объекты, называемые наблюдателями.
Наблюдатель — это потребитель, подписавшийся на Observable, чтобы получать данные и события, которые он генерирует.
Связь между Observable и Observer представлена подпиской.
Операторы — это особый вид функций, которые можно применять к Observable для изменения данных или событий, которые он производит.
Планирование: планирование используется для координации работы Observables и Observers в нескольких потоках.
1. Использование RxJava для реактивного программирования:
Чтобы использовать RxJava для реактивного программирования в среде Java, вы должны сделать следующее.
Для начала мы должны сначала импортировать библиотеку RxJava.
Во-первых, ваш проект должен включать библиотеку RxJava. Для этого добавьте следующую зависимость в файл pom.xml вашего проекта.
php
Идентификатор группы зависимостей и соответствующая ему копия кода
io.reactivex.rxjava2 «ArtifactId» «rxjava» «версия» «2.2.20» «/зависимость»
2. Сделайте то, что будет видно
Следующее действие — создать Observable. Функцию Observable.create() можно использовать для создания нового Observable. Объект ObservableOnSubscribe указывает, как Observable будет генерировать элементы или события, и отправляется этой функции в качестве параметра. Пример Observable, который возвращает последовательность целых чисел
scss
Значения ObservableInteger› могут быть скопированы из исходного кода.
То, что можно увидеть, можно увидеть.
make(new ObservableOnSubscribeInteger›) () Чтобы переопределить это поведение, используйте @Override public void subscribe(ObservableEmitterInteger› emitter), который генерирует Exception Это выглядит так: ListInteger› numbers = Arrays.asList(1, 2, 3, 4, 5 ); for (Целое число: числа) Код: emitter.onNext(число); эмиттер.onComplete(); );
3. Подпишитесь на подписки Observable:
Когда Observable создан, можно использовать функцию subscribe() для получения обновлений о нем. Когда Observable отправляет элементы или события, функция subscribe() получает Observer в качестве аргумента. Пример подписки на numberObservable:
Typescript ObserverInteger› code ObserverInteger› numbers = new ObserverInteger› () Замените общедоступный нуль onSubscribe на @Override (Disposable d) Когда Observer подписывается на Observable, этот метод вызывается.
Аннулировать общедоступный консенсус по следующему @ (целое число) System.out.println(number); / Вызывается, когда Observable испускает предмет
Всякий раз, когда возникает ошибка, вызывается переопределенный public void onError(Throwable e).
Курс веб-разработки на Java может помочь лучше понять эту тему.
