learningbyexample / reactive-ms-example Goto Github PK

View Code? Open in Web Editor NEW

175.0 11.0 74.0 687 KB

An educational project to learn reactive programming with Spring 5

License: MIT License

Shell 6.84% Batchfile 4.85% Java 83.24% HTML 5.06%

reactive-microservices spring-webflux spring-boot reactor api-rest apis java microservices reactive spring

reactive-ms-example's Introduction

Reactive Micro Services Example

info

This is an example of doing reactive MicroServices using spring 5 functional web framework and spring boot 2.

There is a Kotlin fork of this service.

This service provide and API that will get the geo location and the sunrise and sunset times from an address.

Scenario: Get Location
  Given I've an address
  When I call the location service
  Then I should get a geo location
  And I should get the sunrise and sunset times

To implement this example we consume a couple of REST APIs.

This example cover several topics:

Functional programing.
Reactive types.
Router Functions.
Static Web-Content.
Creation on Reactive Java Services/Components.
Error handling in routes and services.
Reactive Web Client to consume external REST Services.
Organizing your project in manageable packaging.

Includes and in depth look to testing using JUnit5:

Unit, Integration and System tests.
Mocking, including reactive functions and JSON responses.
BDD style assertions.
Test tags with maven profiles.

usage

To run this service:

$ mvnw spring-boot:run

Sample requests

Get from address

$ curl -X GET "http://localhost:8080/api/location/Trafalgar%20Square%2C%20London%2C%20England" -H  "accept: application/json"

Post from JSON

$ curl -X POST "http://localhost:8080/api/location" -H  "accept: application/json" -H  "content-type: application/json" -d "{  \"address\": \"Trafalgar Square, London, England\"}"

Both will produce something like:

{
  "geographicCoordinates": {
    "latitude": 51.508039,
    "longitude": -0.128069
  },
  "sunriseSunset": {
    "sunrise": "2017-05-21T03:59:08+00:00",
    "sunset": "2017-05-21T19:55:11+00:00"
  }
}

All date and times are ISO 8601 UTC without summer time adjustment

API

View in the embedded Swagger UI

Run in Postman

Project Structure

main/java
- /application : Main Spring boot application and context configuration.
- /routers : Reactive routing functions.
- /handlers : Handlers used by the routers.
- /services : Services for the business logic needed by handlers.
- /exceptions : Businesses exceptions.
- /model : POJOs.
test/java
- /application : Application system and unit tests.
- /routers : Integration tests for routes.
- /handlers : Unit tests for handlers.
- /services : Unit tests for services.
- /model : POJOs used by the test.
- /test : Helpers and base classes for testing.

References

reactive-ms-example's People

Contributors

Stargazers

Watchers

Forkers

jabrena bluebird702 tjanh123 nikhilagrwl07 wanglinsong john0xff boojongmin killthatbird sferrazzi chetkhatri schatterjee4 alfathsyahrian uday1bhanu elfinxx ahmad-saleem vcuca amanurat pcastelo kioyong rtincar ggarg2 locht710 shimaomao pedromonad pinakim11 sgaraba a1164714 tunks lasalazarr sleyzerzon locnguyenhuu daviarimateia93 yuanyeguishu celestii marcoskichel mbahhalim ddhabak1 vsingh13 zjqian908 oterrien taeunchoi brajput24 snehil007 gamefoundation chandaku h-hub caratacus vsoltys dark2walker olantobi d1medeiros tianlucode fhabumugisha yinian jonnhyaxe maxiplux souravmojumder89 marcos-fdez-alrez wukongqc jestevez marciopocebon anish124 flippii 156420591 shanoo12 ashishpaghdar brunobmonteiro abkkm quantumbits1 madmax102 jellitbarack xipingl roopguron raneeshakdev

reactive-ms-example's Issues

Update Docs

Update:

Readme MD
Swagger Docs
Postman Request

Clear old Services and Methods

Clear old services and methods not used anymore

compile issues when upgrade the starter-parent from 2.0.0.M1 to 2.0.0.RELEASE

Thanks for your excellent examples!
I can not compile the original project duo to missing some snapshot jars, so I upgrade the pom from M1 to release.
But then there are some errors:

//org.learning.by.example.reactive.microservices.handlers.ApiHandler L45

 return address
                .transform(geoLocationService::fromAddress)
                .and(this::sunriseSunset, LocationResponse::new)
                .transform(this::serverResponse);

in the documents:
public final Mono<Void> and(Publisher<?> other)

So, I think the method and should only have one param, so it is failed to compile.