Browse Library
Sign In Start Free Trial
Close icon Search icon
Account
Browse Library Advanced Search Sign In Start Free Trial

Add to playlist

Create a Playlist

Modal Close icon
You need to login to use this feature.
  • Scala Reactive Programming
  • Toc
  • feedback
Scala Reactive Programming

Scala Reactive Programming

By : Rambabu Posa
2.8 (10)
close
Scala Reactive Programming

Scala Reactive Programming

2.8 (10)
By: Rambabu Posa

Overview of this book

Reactive programming is a scalable, fast way to build applications, and one that helps us write code that is concise, clear, and readable. It can be used for many purposes such as GUIs, robotics, music, and others, and is central to many concurrent systems. This book will be your guide to getting started with Reactive programming in Scala. You will begin with the fundamental concepts of Reactive programming and gradually move on to working with asynchronous data streams. You will then start building an application using Akka Actors and extend it using the Play framework. You will also learn about reactive stream specifications, event sourcing techniques, and different methods to integrate Akka Streams into the Play Framework. This book will also take you one step forward by showing you the advantages of the Lagom framework while working with reactive microservices. You will also learn to scale applications using multi-node clusters and test, secure, and deploy your microservices to the cloud. By the end of the book, you will have gained the knowledge to build robust and distributed systems with Scala and Akka.
Table of Contents (16 chapters)
close
close
Preface
Preface
Who this book is for
What this book covers
To get the most out of this book
Get in touch
Free Chapter
1
Getting Started with Reactive and Functional Programming
Getting Started with Reactive and Functional Programming
Introduction to Reactive
Functional programming
Reactive Manifesto
The Java 9 Flow API
Implementations of Reactive Streams
How are Reactive Streams born?
Marble diagrams
Summary
2
Functional Scala
Functional Scala
Introduction to Scala
Principles of Scala FP
Scala anonymous functions
Everything is an expression
Referential transparency
Functions are first-class citizens
Scala tail-recursion
Scala Type class
Scala Collections in action
Scala Functional Design Patterns
Scala Traits in action
Summary
3
Asynchronous Programming with Scala
Asynchronous Programming with Scala
Introduction to Scala AP
The Scala Future API
The Scala Future
The Scala Promise
Scala ExecutionContext
The relationship between Scala Future components
Scala Future API callbacks
Scala Future API combinators
Scala Future.sequence()
The Scala Async Library
The Scala Future API in Play Framework
The Scala Future API in the Akka Toolkit
A Scala Future versus a Java Future
Summary
4
Building Reactive Applications with Akka
Building Reactive Applications with Akka
Introduction to Akka
Actor Model in-depth
Akka ActorSystem
Akka Actors
Actor basic operations
Akka Supervision
What is Akka's Let It Crash model?
Akka Actors communicate example
Akka Actor's lifecycle example
Akka parent-child Actors example
Actor's Path versus Reference
When we execute actorRef.tell (message), what happens internally?
How to configure a dispatcher?
Akka Configuration
Akka SBT Templates
Akka Logging
Business problem
Akka Actor's implementation
Summary
5
Adding Reactiveness with RxScala
Adding Reactiveness with RxScala
Introduction to RxScala
Building blocks of RxScala
RxScala Marble diagrams
Summary
6
Extending Applications with Play
Extending Applications with Play
Introduction to Play Framework
View Templates
Model and Forms
Configuration
Play Framework View Template constructs
Architecture of Play Framework
What is Play Dependency Injection (DI)
Extend HelloWorld Example With DI
Extending HelloWorld example with Scala Futures
Play Form – Data Model
Extending Play/Scala HelloWorld example with Akka Toolkit
Play Fileupload web application
Summary
7
Working with Reactive Streams
chevron up
Working with Reactive Streams
Introduction to Akka Streams
Other Reactive Streams implementations
Components of Akka Streams
The Akka Streams API
Modules of Akka Streams
Akka Materialization
Backpressure
Akka Streams programming basics
Why do we need ActorSystem and ActorMaterializer?
Akka Streams HelloWorld example
Extending the Akka Streams HelloWorld example with the Flow component
Akka Streams GraphDSL
An Akka Streams GraphDSL example
Akka Persistence
The CQRS pattern
How to develop Akka Persistence Actors
Akka Persistence MongoDB Weather example
Summary
8
Integrating Akka Streams to Play Application
Integrating Akka Streams to Play Application
Akka Streams
Developing Akka Dynamic Streams
Integrating Akka Streams into Play
Akka Persistence Query
Summary
9
Reactive Microservices with Lagom
Reactive Microservices with Lagom
Introduction to Lagom Framework
Drawbacks of monolith architecture
Benefits of microservice architecture
Principles of microservices
Lagom Reactive Platform architecture
Modules of Lagom Framework
Kafka with ZooKeeper
Lagom project structure
Lagom System API
Lagom System – implementation
Lagom System – frontend
Lagom Hello Reactive System
Lagom Hello Reactive System microservices
Understanding the Hello Service API code
Understanding HelloService implementation code
Developing Lagom WF Reactive System
Summary
10
Testing Reactive Microservices
Testing Reactive Microservices
Introduction to TDD
Unit testing frameworks
Unit testing Play Framework components
Unit testing Lagom services
Summary
11
Managing Microservices in ConductR
Managing Microservices in ConductR
Introduction to Lightbend's ConductR
Installing Lightbend ConductR
Preparing WF Reactive System for ConductR
Deploying the WF Reactive System on ConductR
Starting ConductR Sandbox with a single node
Observing the WF Reactive System bundles
Running and testing WF Reactive System bundles
Useful ConductR commands
Summary
12
Reactive Design Patterns and Best Practices
Reactive Design Patterns and Best Practices
Understanding Design Patterns
The Circuit Breaker pattern
The Sharding Pattern
The Event Sourcing pattern
The Event Streaming Pattern
The Active-Passive Replication Pattern
The Resource Management Design Patterns
Message Flow Patterns
The Request-Response Design Pattern
Understanding the Reactive Design Pattern
Ask Reactive Design Pattern
The Throttling Pattern
The Pull pattern
Reactive System's best practices and tools
Summary
13
Scala Plugin for IntelliJ IDEA
Scala Plugin for IntelliJ IDEA
Understanding Scala Plugin
How to set up Scala Plugin for IntelliJ IDE
Summary
14
Installing Robomongo
Installing Robomongo
What is Robomongo?
Summary
15
Other Books You May Enjoy
Other Books You May Enjoy
Leave a review - let other readers know what you think

Akka Streams programming basics

Before we develop some Akka Streams applications in this chapter, we will first take some baby steps to understand the Streams API very well.

Creating a Source

To create an Akka Stream's Source, we need to use one of its functions, such as single, by providing some input elements. For instance, create a Source that contains the numbers 1 to 10 as shown here:

val numbersSource = Source.single(1 to 10)

If we add this code snippet to a Scala App and run it from your favorite IDE or using the sbt command, we don't see any output. This is because Akka Streams components are executed only when we run them manually:

package com.packt.publishing.akka.streams.hello 
import akka.stream.scaladsl...
End of Section 9
Next Section
bookmark search playlist download
font-size

Change the font size

margin-width

Change margin width

day-mode

Change background colour

Close icon Search
Country selected
Close icon Your notes and bookmarks

Delete Bookmark

Modal Close icon
Are you sure you want to delete it?
Cancel
Yes, Delete