Book Image

Reactive Programming With Java 9

By : Tejaswini Mandar Jog
Book Image

Reactive Programming With Java 9

By: Tejaswini Mandar Jog

Overview of this book

<p>Reactive programming is an asynchronous programming model that helps you tackle the essential complexity that comes with writing such applications.</p> <p>Using Reactive programming to start building applications is not immediately intuitive to a developer who has been writing programs in the imperative paradigm. To tackle the essential complexity, Reactive programming uses declarative and functional paradigms to build programs. This book sets out to make the paradigm shift easy.</p> <p>This book begins by explaining what Reactive programming is, the Reactive manifesto, and the Reactive Streams specifi cation. It uses Java 9 to introduce the declarative and functional paradigm, which is necessary to write programs in the Reactive style. It explains Java 9’s Flow API, an adoption of the Reactive Streams specifi cation. From this point on, it focuses on RxJava 2.0, covering topics such as creating, transforming,fi ltering, combining, and testing Observables. It discusses how to use Java’s popular framework, Spring, to build event-driven, Reactive applications. You will also learn how to implement resiliency patterns using Hystrix. By the end, you will be fully equipped with the tools and techniques needed to implement robust, event-driven, Reactive applications.</p>

Related Content you might be interested in

Current Title:

Small book image
Reactive Programming With Java 9
Tejaswini Mandar Jog
Sep, 2017 | 402 pages
Small book image
Learning Spring 5.0
Tejaswini Mandar Jog
Jun, 2017 | 422 pages
Small book image
Reactive Programming in Kotlin
Rivu Chakraborty
Dec, 2017 | 322 pages
Small book image
Learning RxJava.
Thomas Nield | Nick Samoylov
Feb, 2020 | 412 pages
Table of Contents (12 chapters)
Preface
Preface
What this book covers
What you need for this book
Who this book is for
Conventions
Reader feedback
Customer support
Free Chapter
1
Introduction to Reactive Programming
Introduction to Reactive Programming
Asynchronous programming
Summary
2
Programming Paradigm Shift
Programming Paradigm Shift
Programming paradigm
Functional programming
Declarative programming
Operator fusion
Summary
3
Reactive Streams
Reactive Streams
Discussing the Collection framework
Understanding backpressure
Summary
4
Reactive Types in RxJava
Reactive Types in RxJava
ReactiveX
Observer design pattern
The Iterator design pattern
RxJava
Hot or cold Observables
Creating Observable emitting sequential data
Transforming Rx non-compatible sequences into Observables
Creating Observables for unrestricted infinite length
Types of observables
Understanding the Disposable interface
Subject
Summary
5
Operators
Operators
Demystifying RxMarbles using an Observable
Transforming Observables using operators
Filtering Observable
Combining Observables
Conditional operators
The mathematical and aggregate operators
Summary
6
Building Responsiveness
Building Responsiveness
Concurrency
Scheduling
Latency
Summary
7
Building Resiliency
Building Resiliency
Resilience
Error handling in RxJava
Exceptions specific to RxJava
Error handler
Summary
8
Testing
Testing
Testing the need and role of a developer
The traditional way of testing an Observable
The modern approach for testing an Observable
Testing the Subscriber
The test() operator
Testing notifications
Mockito testing
Summary
9
Spring Reactive Web
Spring Reactive Web
An introduction to Spring Framework
The Spring architecture
Project Reactor
Spring web Reactive Programming
Server-side support
Client side
Server-Sent Events (SSE)
Summary
10
Implementing Resiliency Patterns Using Hystrix
Implementing Resiliency Patterns Using Hystrix
Hystrix- an introduction
Demonstrating HystrixObservableCommand
Handling fallback
Design patterns in resiliency
Queue-based load leveling pattern
Patterns used by Hystrix
Request collapsing or request batching
Request caching
Summary
11
Reactive Data Access
Reactive Data Access
Spring Data
Spring Data repositories
Spring Data and Reactive Programming
Spring Data Reactive and Redis
Kafka
Running the Kafka application
Summary

Spring web Reactive Programming

The Spring Reactive framework is based on the Reactor project along with which it also supports the RxJava library to implement functional Reactive Programming. Spring 5 is based upon the dependencies of Project Reactor 3.x. The Spring Framework 5 incorporates Reactive Streams, which has the contract for communicating among the asynchronous components between the components and the libraries along with a good support for backpressure. The collaboration made between the APIs of Project Reactor, Spring, and ReactiveX is shown in the following figure:

Let's look at each of these components one by one:

  • ADDONS: The component ADDONS adds the support for RxJava1 and RxJava2. It enables the developers to use the reactive types such as Observable, Flowable, Single, and Scheduler which we have already used in earlier chapters while discussing RxJava2...
Previous Section
End of Section 5
Next Section