CON4952 JavaOne: MicroServices on the JVM - a practical Overview

A description of the talk can be found at https://www.innoq.com/en/talks/2014/10/micro-services-on-the-jvm-javaone/

1. #javaone #con4952 MicroServices on the JVM a practical overview (JavaOne 2014) Martin Eigenbrodt — Senior Consultant Alexander Heusingfeld — Senior Consultant
2. #javaone #con4952 #MicroServices #buzz > Defined by LOC? > UI or not UI? > SOA in new clothes?
3. #javaone #con4952 Important for us > build around business capabilities > separate runtime processes > self-contained > loosely coupled > independent life cycles > decentralised management Self-Contained System
4. #javaone #con4952 We’re not talking about… > micro architecture > slicing howtos > communication protocol
5. #javaone #con4952 System A System B Persistence Logic UI System C HTTP HTTP Logic UI Persistence Logic
6. #javaone #con4952 Challenges > service registration & discovery > resilience > distributed configuration > fast, automated deployment > metrics
7. #javaone #con4952 A Business Use Case select product show cart place order buy something online
8. #javaone #con4952 order system cart system product system A Business Use Case select product show cart place order buy something online
9. #javaone #con4952 order system cart system product system A Business Use Case select product show cart place order buy something online Play 2 DropWizard Spring Boot
10. #javaone #con4952 Dropwizard the cart system
11. #javaone #con4952 Dropwizard > Glue Code for well known libraries > Java
12. #javaone #con4952 Dropwizard libraries > Jetty > Jersey > Metrics > Jackson > Guava > Logback > Hibernate Validator > Apache Http Client > JDBI > Liquibase > Freemarker & Mustache > Joda
13. #javaone #con4952 Dropwizard libraries > Jetty > Jersey > Metrics > Jackson > Guava > Logback > Hibernate Validator > Apache Http Client > JDBI > Liquibase > Freemarker & Mustache > Joda
14. #javaone #con4952
15. #javaone #con4952 Controller @Path ("/cart") public class ShoppingCartResource { @GET @Path("{id}") @Timed @Produces(MediaType.TEXT_HTML) public ShoppingCartView shoppingCart(@PathParam("id") String cartId, @Context UriInfo uriInfo) { ImmutableList<String> urls = dao.findItemsForCartId(cartId); ImmutableList<Product> products = catalog.resolveProducts(urls); return new ShoppingCartView(products, uriInfo.getAbsolutePath().toString() ); } ... }
16. #javaone #con4952 Http Client public ImmutableList<Product> resolveProducts(List<String> urls) { Builder<Product> products = ImmutableList.builder(); for (String url : urls) { Product product = client.resource(url) .accept(MediaType.APPLICATION_JSON).get(Product.class); products.add(product); } return products.build(); } Super Duper?
17. #javaone #con4952 Resilience > isolate Failure > apply graceful degradation > be responsive in case of failure
18. #javaone #con4952 Request service Request service http://en.wikipedia.org/wiki/Circuit_breaker Request service closed open half- open
19. #javaone #con4952 > Provides Command-oriented Integration of Services > Introduces Circuit Breaker, Bulkheads and Isolation > Decouples from Service-dependencies > Provides metrics-facility to protect from failures
20. #javaone #con4952 public class ResolveProductCommand extends TenacityCommand<Product> { private Client client; private String url; public ResolveProductCommand(Client client, String url) { super(DependencyKeys.RESOLVE_PRODUCT); this.client = client; this.url = url; } @Override protected Product run() throws Exception { Product product = client.resource(url) .accept(MediaType.APPLICATION_JSON).get(Product.class); return product; } protected Product getFallback() { return null } }
21. #javaone #con4952 public ImmutableList<Product> resolveProductsHystrix (List<String> urls) { Builder<Product> products = ImmutableList.builder(); for (String url : urls) { ResolveProductCommand command = new ResolveProductCommand(client, url); Product product = command.execute(); if (product != null) products.add(product); } return products.build(); }
22. #javaone #con4952 Metrics > Integrated with Dropwizard > @Timed on Resources > HTTP Client is already instrumented > JVM Data
23. #javaone #con4952 "org.apache.http.client.HttpClient.cart.get-requests": { "count": 11, "max": 0.062107, "mean": 0.013355909090909092, "min": 0.005750000000000001, "p50": 0.009454, "p75": 0.010427, "p95": 0.062107, "p98": 0.062107, "p99": 0.062107, "p999": 0.062107, "stddev": 0.016285873488729705, "m15_rate": 0, "m1_rate": 0, "m5_rate": 0, "mean_rate": 2.9714422786532126, "duration_units": "seconds", "rate_units": "calls/second" } "cart.resources.ShoppingCartResource.shoppingCart": { "count": 22, "max": 0.136162, "mean": 0.01208109090909091, "min": 0.00093, "p50": 0.008174500000000001, "p75": 0.011782250000000001, "p95": 0.11783499999999976, "p98": 0.136162, "p99": 0.136162, "p999": 0.136162, "stddev": 0.02813530239821426, "m15_rate": 1.8524577712890011, "m1_rate": 0.18057796798879996, "m5_rate": 1.315746847992022, "mean_rate": 0.133050618509084, "duration_units": "seconds", "rate_units": "calls/second" }
24. #javaone #con4952 Metrics > Exposed over HTTP (as Json) > Exposed as jmx > Others available: stdout, csv, slf4j, ganglia, graphite
25. #javaone #con4952 Dropwizard Roundup > Annotation Driven > Metrics included > Hystrix integration
26. #javaone #con4952 Spring Boot the order system
27. #javaone #con4952 Spring Boot > convention over configuration approach > Java, Groovy or Scala > self-contained jar or war > tackles dependency-hell via pre-packaging
28. #javaone #con4952 dependencies { compile ‘org.springframework.boot:spring-boot-starter-web:1.1.6.RELEASE' compile ‘org.springframework.boot:spring-boot-starter-test:1.1.6.RELEASE' } Spring Boot build.gradle Typical Spring build.gradle dependencies { compile 'org.springframework:spring-core:3.2.3.RELEASE' compile ‘org.springframework:spring-webmvc:3.2.3.RELEASE' // ... Jackson, Hibernate Validator, ... compile 'org.slf4j:slf4j-api:1.7.5' runtime 'org.slf4j:slf4j-log4j12:1.7.5' runtime 'log4j:log4j:1.2.16' testCompile 'org.springframework:spring-test:3.2.3.RELEASE' testCompile 'junit:junit:4.11' testCompile ‘org.hamcrest:hamcrest-library:1.3’ testCompile ‘org.mockito:mockito-core:1.9.5’ }
29. #javaone #con4952 Externalized Configuration > opinionated preset > HTTP resource “/autoconfig” shows all properties > overwrite via application.properties or CLI parameter @ComponentScan
 @EnableAutoConfiguration
 public class OrderApp {
 
 public static void main(String[] args) {
 SpringApplication.run(OrderApp.class, args);
 }
 }
30. #javaone #con4952 Spring Boot Metrics > Prepackaged Spring Boot starter module > enables HTTP resources for metrics > configurable via application.properties http://docs.spring.io/spring-boot/docs/current-SNAPSHOT/reference/htmlsingle/#production-ready
31. #javaone #con4952 { "counter.checkouts.withproducts.3": 4, ... } counterService.increment("checkouts.withproducts." + productUris.size());
 GET /metrics HTTP/1.1 Using a counter metric in your Java code… …will display it in the /metrics JSON
32. How does it look on the inside?
33. #javaone #con4952
34. #javaone #con4952 @Controller
 @RequestMapping(value = ORDERS_RESOURCE)
 public class OrderController {
 
 private @Autowired CounterService counterService;
 private @Autowired OrderRepository repository;
 
 @RequestMapping(method = RequestMethod.POST)
 public String checkoutCart(@RequestParam(value = "products") List<String> productUris) {
 counterService.increment("checkouts.withproducts." + productUris.size());
 
 final List<Product> products = productUris.stream()
 .map(productUri -> CompletableFuture.supplyAsync(() -> resolveProducts(productUri)))
 .map(CompletableFuture::join)
 .filter(res -> res.second.hasBody())
 .map(this::responsePairToProduct)
 .collect(Collectors.toList());
 
 final Order savedOrder = repository.save(new Order(products));
 return "redirect:" ORDERS_RESOURCE + savedOrder.getId();
 }
 
 private Pair<String, ResponseEntity<Product>> resolveProducts(String productUri) {
 final RestTemplate restTemplate = new RestTemplate();
 return new Pair(productUri, restTemplate.getForEntity(productUri, Product.class));
 }
 }
35. #javaone #con4952 Resilience final List<Product> products = productUris.stream()
 .map(productUri -> CompletableFuture.supplyAsync(() -> resolveProducts(productUri)))
 .map(CompletableFuture::join)
 .filter(res -> res.second.hasBody())
 .map(this::responsePairToProduct)
 .collect(Collectors.toList()); private Pair<String, ResponseEntity<Product>> resolveProducts(String productUri) {
 final RestTemplate restTemplate = new RestTemplate();
 return new Pair(productUri, restTemplate.getForEntity(productUri, Product.class));
 }
36. #javaone #con4952 Resilience final List<Product> products = productUris.stream()
 .map(productUri -> CompletableFuture.supplyAsync(() -> resolveProducts(productUri)))
 .map(CompletableFuture::join)
 .filter(res -> res.second.hasBody())
 .map(this::responsePairToProduct)
 .collect(Collectors.toList()); private Pair<String, ResponseEntity<Product>> resolveProducts(String productUri) {
 final RestTemplate restTemplate = new RestTemplate();
 return new Pair(productUri, restTemplate.getForEntity(productUri, Product.class));
 } Resilient?
37. #javaone #con4952 Spring Cloud > new umbrella project for cloud connectors > On top of Spring Boot > config server for distributed configuration > Eureka annotations for service-discovery > Hystrix annotations for resilience enhancements
38. #javaone #con4952 Spring Cloud Hystrix @HystrixCommand(fallbackMethod = “fallbackProduct") private Pair<String, ResponseEntity<Product>> resolveProduct(String productUri) {
 final RestTemplate restTemplate = new RestTemplate();
 return new Pair(productUri, restTemplate.getForEntity(productUri, Product.class));
 } private Pair<String, ResponseEntity<Product>> fallbackProduct(String productUri) {
 final Product product = new Product(productUri, null, BigDecimal.ZERO);
 final ResponseEntity<Product> response = new ResponseEntity<Product>(product, PARTIAL_CONTENT); return new Pair(productUri, response);
 } wrapped in command -> async!
39. #javaone #con4952 Spring Cloud Hystrix @HystrixCommand(fallbackMethod = “fallbackProduct") private Pair<String, ResponseEntity<Product>> resolveProduct(String productUri) {
 final RestTemplate restTemplate = new RestTemplate();
 return new Pair(productUri, restTemplate.getForEntity(productUri, Product.class));
 } private Pair<String, ResponseEntity<Product>> fallbackProduct(String productUri) {
 final Product product = new Product(productUri, null, BigDecimal.ZERO);
 final ResponseEntity<Product> response = new ResponseEntity<Product>(product, PARTIAL_CONTENT); return new Pair(productUri, response);
 } method reference? :(
40. #javaone #con4952 Spring Boot Roundup > focussed on Spring ecosystem > externalized configuration > metrics > Spring Cloud still beyond bleeding edge
41. #javaone #con4952 Play 2 the product catalog
42. #javaone #con4952 Play 2 > Java or Scala > based on Akka > strong async support
43. NY-Times Api Persistence
45. #javaone #con4952 Routing # Routes # List of all books GET / controllers.BooksController.books # A specific Book GET /books/:id controllers.BooksController.book(id:String)
46. #javaone #con4952 Controller object BooksController extends Controller { def books = Action.async { implicit request => val bestsellerFuture = Bestseller.getBestseller val booksFuture = Books.books for { bestseller <- bestsellerFuture books <- booksFuture } yield { Ok(views.html.books(books.values.toList, bestseller)) } } ... }
47. #javaone #con4952 Calling an external Service WS.url(apiUrl).get.map { response => response.json.as[List[Bestseller]] }
48. #javaone #con4952 Handle Failure WS.url(apiUrl).get.map { response => response.json.as[List[Bestseller]] }.recover { case e => List() }
49. #javaone #con4952 Circuit Breaker val apiUrl = "..." val breaker = CircuitBreaker(Akka.system().scheduler, maxFailures = 5, callTimeout = 2.seconds, resetTimeout = 1.minute) def getBestseller : Future[List[Bestseller]] = { breaker.withCircuitBreaker( WS.url(apiUrl).get.map { response => response.json.as[List[Bestseller]] }).recover { case e => List() } }
50. #javaone #con4952 Packaging sbt dist sbt debian:packageBin sbt rpm:packageBin
51. #javaone #con4952 Play roundup > smart syntax for async http, recovery, circuit breaker in scala > easy packaging > no build in support for metrics > no build in support service discovery or distributed config
52. Conclusion
53. #javaone #con4952 Take Aways > MicroServices aren’t micro! > Only “micro” regarding business scope > micro service = distributed systems deep dive > no framework is a silver bullet
54. Thank you! Questions?
    Comments? Martin Eigenbrodt, @eigenbrodtm Alexander Heusingfeld, @goldstift https://www.innoq.com/en/timeline/ innoQ Deutschland GmbH Krischerstr. 100 40789 Monheim am Rhein Germany Phone: +49 2173 3366-0 innoQ Schweiz GmbH Gewerbestr. 11 CH-6330 Cham Switzerland Phone: +41 41 743 0116 www.innoq.com Ohlauer Straße 43 10999 Berlin Germany Phone: +49 2173 3366-0 Robert-Bosch-Straße 7 64293 Darmstadt Germany Phone: +49 2173 3366-0 Radlkoferstraße 2 D-81373 München Germany Telefon +49 (0) 89 741185-270 #con4952