Downloaded 33 times
![Project Reactor • Library for building non-blocking apps • Interacts with Java 8 functional API • Offers two reactive composable API • Flux[N] and Mono[0|1] • Supports scalable in-memory routing with Bus extensions • Ported to support microservices](https://image.slidesharecdn.com/javaone2016-reactivemicroserviceswithjavaandjavaee-160919055851/75/JavaOne-2016-Reactive-Microservices-with-Java-and-Java-EE-19-2048.jpg)
Uploaded byRodrigo Cândido da Silva
JavaOne 2016 - Reactive Microservices with Java and Java EE
The document discusses the transition from monolithic architectures to microservices, emphasizing reactive programming as a vital approach for building resilient microservices in Java using frameworks like Spring Cloud and Netflix OSS. It covers topics such as configuration management, service registration, asynchronous communication, and implementing reactive streams with Project Reactor. A demonstration of implementing a reactive microservices architecture is included, along with references for further exploration.
JavaOne 2016 - Reactive Microservices with Java and Java EE
- 1. Reactive Microservices withJava and Java EE Rodrigo Cândido da Silva @rcandidosilva Israel Boza Rodriguez @IsraKaos
- 2. Agenda • Monolithic vs.Microservices • Reactive Manifesto • Resilience • Message-driven • Demo • Q&A
- 3.
- 4. Microservices • Small components •Isolated deployment • Independent technology • Separate infrastructure "Small independent component with well- defined boundaries that’s doing one thing, but doing it well"
- 5.
- 6. Resilient • How tosupport it on microservices? • Central point of configuration • Service registry and discovery • Routing features • Load balancing • Failover • Monitoring
- 7. Spring BootSpring Cloud SpringCloud + Netflix OSS
- 8. Spring Cloud +Netflix OSS “Nice match to build resilient microservices with Java" Configuration Management Spring Cloud Config + Bus Service Registration and Discovery Netflix Eureka Load Balacing Netflix Ribbon Circuit Breaker Netflix Hystrix + Turbine Proxy Server Netflix Zuul Autenthication Spring Cloud Security
- 9.
- 10.
- 11.
- 12. Netflix Hystrix • CircuitBreaker Pattern
- 13.
- 14.
- 15. Spring Cloud Security Discovery Client RelyingParty Resource Server Get an access token & an ID Token (JWT) Use an access token Authorization Server Iden.ty Provider or IDP or OpenID Provider or OP Authorization Endpoint Token Endpoint Important Stuff Userinfo Endpoint Registration Endpoint JWKS Endpoint JWKS Endpoint Validate (JWT) ID Token /.well-known /webfinger /openid-configura.on Check Session IFrame End Session Endpoint
- 16. Message-Driven • How tosupport it on microservices? • Asynchronous communication • Non blocking I/O • Distributed • Consistency • Event sourcing • CQRS
- 17. Reactive Programming • Asynchronouscommunication and data streams • reactive-streams.org
- 18. Reactive Alternatives atJava EE JMS EJB 3 Message-Driven Beans Asynchronous Session Beans CDI Events Observers Servlet Asynchronous NIO JAX-RS Async on Server Async on Client WebSocket Async Remote Endpoints Concurrency Utilities
- 19. Project Reactor • Libraryfor building non-blocking apps • Interacts with Java 8 functional API • Offers two reactive composable API • Flux[N] and Mono[0|1] • Supports scalable in-memory routing with Bus extensions • Ported to support microservices
- 20. REST Endpoint @RestController public classUserRestController { private static final List<User> users = new ArrayList<>(); static { users.add(new User(1, "Rodrigo", "C", "da Silva")); users.add(new User(2, "Israel", "B", "Rodriguez")); users.add(new User(3, "Bruno", "", "Souza")); users.add(new User(4, "Edson", "", "Yanaga")); } @RequestMapping(method = RequestMethod.GET, value = "/users") public List<User> getUsers() { return users; } @RequestMapping(method = RequestMethod.GET, value = "/user/{id}") public User getUser(@PathVariable("id") Integer id) { return users.stream().filter(g -> g.getId() == id) .collect(Collectors.toList()).get(0); } }
- 21. REST Proxy @Component public classUserServiceProxy { @Autowired UserService service; @HystrixCommand(fallbackMethod = "defaultUsersObservable") public Observable<List<User>> getUsersObservable() { return new ObservableResult<List<User>>() { @Override public List<User> invoke() { return service.getUsers(); } }; } public Observable<User> defaultUsersObservable() { return null; } } @FeignClient("USER-SERVICE") public interface UserService { @RequestMapping(value = "/users", method = RequestMethod.GET) List<User> getUsers(); @RequestMapping(value = "/user/{id}", method = RequestMethod.GET) User getUser(@PathVariable("id") Integer id); }
- 22. REST Async Client @RestController publicclass APIController { @Autowired GroupServiceProxy groupService; @Autowired UserServiceProxy userService; @RequestMapping(method = RequestMethod.GET, value = "/userGroups") public UserGroup getUserGroups() { Observable<List<Group>> groups = groupService.getGroupsObservable(); Observable<List<User>> users = userService.getUsersObservable(); Observable<UserGroup> userGroupObservable = Observable.zip(groups, users, (g, u) -> new UserGroup(u, g)); return userGroupObservable.toList().toBlocking().single().get(0); } }
- 23. Demo • Reactive Microservices •https://github.com/rcandidosilva/reactive-microservices
- 24.
- 25.
- 26. References • http://projects.spring.io/spring-boot/ • http://projects.spring.io/spring-cloud/ •https://netflix.github.io/ • http://www.reactive-streams.org/ • http://www.reactivemanifesto.org/ • https://github.com/reactivemanifesto/website-manifesto/tree/master/public/pdf • https://projectreactor.io/ • http://reactivex.io/ • http://www.kennybastani.com/2016/04/event-sourcing-microservices-spring- cloud.html
- 27.