Reactive Programming with RxJava by Tomasz Nurkiewicz and Ben Christensen

Author:Tomasz Nurkiewicz and Ben Christensen
Language: eng
Format: epub
Publisher: O'Reilly Media, Inc.
Published: 2016-10-11T00:00:00+00:00

$ telnet localhost 8080 Trying 127.0.0.1... Connected to localhost. Escape character is '^]'. 2.5 2.5 EUR is 2.661200 USD 0.99 0.99 EUR is 1.0538352 USD 0.94 0.94 EUR is 1.0006112 USD 20 30 40 20 EUR is 21.28960 USD 30 EUR is 31.93440 USD 40 EUR is 42.57920 USD

We treat our server like a function of request data into response data. Because the TCP/IP connection is not just a simple function but a stream of sometimes interdependent chunks of data, RxJava works amazingly well in this scenario. A rich set of operators makes it easy to transform input to output in nontrivial ways. Of course, the output stream does not have to be based on input; for example, if you are implementing server-sent events, the server simply publishes data irrespective of incoming data.

The EurUsdCurrencyTcpServer is reactive because it only acts when data comes in. We do not have a dedicated thread per each client. This implementation can easily withstand thousands of concurrent connections, and vertical scalability is limited only by the amount of traffic it must handle, not the number of more-or-less idle connections.

Knowing how RxNetty works in principle, we can go back to the original HTTP server that returns OK responses. RxNetty has built-in support for HTTP clients and servers, but we will begin from a plain implementation based on TCP/IP:

Download

Copyright Disclaimer:
This site does not store any files on its server. We only index and link to content provided by other sites. Please contact the content providers to delete copyright contents if any and email us, we'll remove relevant links or contents immediately.