Microservices with Quarkus

java -version

openjdk version "17" 2021-09-14
OpenJDK Runtime Environment Temurin-17+35 (build 17+35)
OpenJDK 64-Bit Server VM Temurin-17+35 (build 17+35, mixed mode, sharing)

ln -s /opt/graalvm-ce-java16-21.2.0 /opt/graalvm

export GRAALVM_HOME=/opt/graalvm/Contents/Home
env | grep GRAAL
$GRAALVM_HOME/bin/java -version
$GRAALVM_HOME/bin/native-image --version

$GRAALVM_HOME/bin/gu install native-image

sudo xattr -r -d com.apple.quarantine path/to/graalvm/folder/

sudo apt install maven

mvn -version

docker version

package at.htl.microservices.number;

import java.time.Instant;

public class IsbnNumbers {

    public String isbn10;
    public String isbn13;
    public Instant generationDate;

    @Override
    public String toString() {
        return "IsbnNumbers{" +
                "isbn10='" + isbn10 + '\'' +
                ", isbn13='" + isbn13 + '\'' +
                ", generationDate=" + generationDate +
                '}';
    }
}

package at.htl.microservices.number;

import org.jboss.logging.Logger;

import javax.inject.Inject;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;
import java.time.Instant;
import java.util.Random;

@Path("/api/numbers")
public class NumberResource {

    @Inject
    Logger logger; (1)

    @GET
    @Produces(MediaType.APPLICATION_JSON)
    public IsbnNumbers generateIsbnNumbers() {
        IsbnNumbers isbnNumbers = new IsbnNumbers();
        isbnNumbers.isbn13 = "13-" + new Random().nextInt(100_000_000);
        isbnNumbers.isbn10 = "10-" + new Random().nextInt(100_000);
        isbnNumbers.generationDate = Instant.now();
        logger.info("Numbers generated " + isbnNumbers); (2)

        return isbnNumbers;
    }
}

http localhost:8080/api/numbers

public class IsbnNumbers {

    @JsonbProperty("isbn_13")
    public String isbn13;
    @JsonbProperty("isbn_10")
    public String isbn10;
    @JsonbTransient
    public Instant generationDate;

    // toString()
}

HTTP/1.1 200 OK
Content-Length: 46
Content-Type: application/json

{
    "isbn_10": "10-76318",
    "isbn_13": "13-70991667"
}

package at.htl.microservices.number;

import org.eclipse.microprofile.openapi.annotations.media.Schema;

import javax.json.bind.annotation.JsonbProperty;
import javax.json.bind.annotation.JsonbTransient;
import java.time.Instant;

@Schema(description = "Several ISBN numbers for books")
public class IsbnNumbers {

    @Schema(required = true)
    @JsonbProperty("isbn_13")
    public String isbn13;
    @Schema(required = true)
    @JsonbProperty("isbn_10")
    public String isbn10;
    @JsonbTransient
    public Instant generationDate;

    @Override
    public String toString() {
        return "IsbnNumbers{" +
                "isbn10='" + isbn10 + '\'' +
                ", isbn13='" + isbn13 + '\'' +
                ", generationDate=" + generationDate +
                '}';
    }
}

package at.htl.microservices.number;

import org.eclipse.microprofile.openapi.annotations.Operation;
import org.eclipse.microprofile.openapi.annotations.tags.Tag;
import org.jboss.logging.Logger;

import javax.inject.Inject;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;
import java.time.Instant;
import java.util.Random;

@Path("/api/numbers")
@Tag(name="")
public class NumberResource {

    @Inject
    Logger logger;

    @GET
    @Produces(MediaType.APPLICATION_JSON)
    @Operation(
            summary = "Generate book numbers",
            description = "ISBN 13 and ISBN 10 numbers"
    )
    public IsbnNumbers generateIsbnNumbers() {
        IsbnNumbers isbnNumbers = new IsbnNumbers();
        isbnNumbers.isbn13 = "13-" + new Random().nextInt(100_000_000);
        isbnNumbers.isbn10 = "10-" + new Random().nextInt(100_000);
        isbnNumbers.generationDate = Instant.now();
        logger.info("Numbers generated " + isbnNumbers);

        return isbnNumbers;
    }
}

package at.htl.microservices.number;

import org.eclipse.microprofile.openapi.annotations.ExternalDocumentation;
import org.eclipse.microprofile.openapi.annotations.OpenAPIDefinition;
import org.eclipse.microprofile.openapi.annotations.info.Contact;
import org.eclipse.microprofile.openapi.annotations.info.Info;
import org.eclipse.microprofile.openapi.annotations.tags.Tag;

import javax.ws.rs.core.Application;

@OpenAPIDefinition(
        info = @Info(
                title = "Number API",
                description = "Generates ISBN book numbers",
                version = "1.0",
                contact = @Contact(name = "@my-name", url = "bit.ly/htl-leonding")
        ),
        externalDocs = @ExternalDocumentation(url = "bit.ly/htl-leonding"),
        tags = {
                @Tag(name = "api", description = "Public API"),
                @Tag(name = "numbers", description = "Interested in numbers")
        }
)
public class NumberMicroservice extends Application {
}

http localhost:8080/q/openapi

openapi: 3.0.3
info:
  title: Number API
  description: Generates ISBN book numbers
  contact:
    name: '@my-name'
    url: bit.ly/htl-leonding
  version: "1.0"
externalDocs:
  url: bit.ly/htl-leonding
tags:
- name: api
  description: Public API
- name: numbers
  description: Interested in numbers
- name: ""
paths:
  /api/numbers:
    get:
      tags:
      - ""
      summary: Generate book numbers
      description: ISBN 13 and ISBN 10 numbers
      responses:
        "200":
          description: OK
          content:
            application/json:
              schema:
                $ref: '#/components/schemas/IsbnNumbers'
components:
  schemas:
    IsbnNumbers:
      description: Several ISBN numbers for books
      required:
      - isbn_10
      - isbn_13
      type: object
      properties:
        isbn_10:
          type: string
        isbn_13:
          type: string

http localhost:8080/q/openapi Accept:application/json

{
    "components": {
        "schemas": {
            "IsbnNumbers": {
                "description": "Several ISBN numbers for books",
                "properties": {
                    "isbn_10": {
                        "type": "string"
                    },
                    "isbn_13": {
                        "type": "string"
                    }
                },
                "required": [
                    "isbn_10",
                    "isbn_13"
                ],
                "type": "object"
            }
        }
    },
    "externalDocs": {
        "url": "bit.ly/htl-leonding"
    },
    "info": {
        "contact": {
            "name": "@my-name",
            "url": "bit.ly/htl-leonding"
        },
        "description": "Generates ISBN book numbers",
        "title": "Number API",
        "version": "1.0"
    },
    "openapi": "3.0.3",
    "paths": {
        "/api/numbers": {
            "get": {
                "description": "ISBN 13 and ISBN 10 numbers",
                "responses": {
                    "200": {
                        "content": {
                            "application/json": {
                                "schema": {
                                    "$ref": "#/components/schemas/IsbnNumbers"
                                }
                            }
                        },
                        "description": "OK"
                    }
                },
                "summary": "Generate book numbers",
                "tags": [
                    ""
                ]
            }
        }
    },
    "tags": [
        {
            "description": "Public API",
            "name": "api"
        },
        {
            "description": "Interested in numbers",
            "name": "numbers"
        },
        {
            "name": ""
        }
    ]
}

quarkus.http.port=8701

http :8701/api/numbers

HTTP/1.1 200 OK
Content-Length: 46
Content-Type: application/json

{
    "isbn_10": "10-86168",
    "isbn_13": "13-67790513"
}

███╗   ██╗██╗   ██╗███╗   ███╗██████╗ ███████╗██████╗
████╗  ██║██║   ██║████╗ ████║██╔══██╗██╔════╝██╔══██╗
██╔██╗ ██║██║   ██║██╔████╔██║██████╔╝█████╗  ██████╔╝
██║╚██╗██║██║   ██║██║╚██╔╝██║██╔══██╗██╔══╝  ██╔══██╗
██║ ╚████║╚██████╔╝██║ ╚═╝ ██║██████╔╝███████╗██║  ██║
╚═╝  ╚═══╝ ╚═════╝ ╚═╝     ╚═╝╚═════╝ ╚══════╝╚═╝  ╚═╝

package at.htl.microservices.number;

import io.quarkus.test.junit.QuarkusTest;
import org.junit.jupiter.api.Test;

import static io.restassured.RestAssured.given;
import static org.hamcrest.CoreMatchers.is;
import static org.hamcrest.CoreMatchers.startsWith;
import static org.hamcrest.Matchers.hasKey;
import static org.hamcrest.Matchers.not;

@QuarkusTest
public class NumberResourceTest {

    @Test
    public void testHelloEndpoint() {
        given()
          .when().get("/api/numbers")
          .then()
             .statusCode(200)
             .body("isbn_13", startsWith("13-"))
             .body("isbn_10", startsWith("10-"))
             .body(not(hasKey("generationDate")));
    }
}

public class Book {

    @JsonbProperty("isbn_13") (1)
    public String isbn13;
    public String title;
    public String author;
    @JsonbProperty("year_of_publication")  (2)
    public int yearOfPublication;
    public String genre;
    @JsonbProperty("creation_date") (3)
    @JsonbDateFormat("yyyy-MM-dd") (4)
    public Instant creationTime;

    // ...
}

curl -X POST http://localhost:8080/api/books \
     -d "title=Quarkus&author=Susi&year=2021&genre=IT"

{"author":"Susi","creation_date":"2021-10-07","genre":"IT","isbn_13":"We will get it from the Number Microservice","title":"Quarkus","year_of_publication":2021}

http --form POST :8080/api/books title='Quarkus' author='Susi' year=2021 genre='IT'

HTTP/1.1 201 Created
Content-Length: 163
Content-Type: application/json

{
    "author": "Susi",
    "creation_date": "2021-10-11",
    "genre": "IT",
    "isbn_13": "13-we will get it from the number microservice",
    "title": "Quarkus",
    "year_of_publication": 2021
}

@Path("/api/books")
@Tag(name = "Book REST endpoint")
public class BookResource {

    @Inject
    Logger logger;

    @POST
    @Produces(MediaType.APPLICATION_JSON)
    @Consumes(MediaType.APPLICATION_FORM_URLENCODED)
    @Operation(
            summary = "Creates a book",
            description = "Creates a book with an ISBN number"
    )
    public Response createABook(
            @FormParam("title") String title,
            @FormParam("author") String author,
            @FormParam("year") int yearOfPubication,
            @FormParam("genre") String genre
    ) {
         // ...
    }
}

@Schema(description = "This is a book")
public class Book {

    @JsonbProperty("isbn_13")
    @Schema(required = true)
    public String isbn13;
    @Schema(required = true)
    public String title;
    public String author;
    @JsonbProperty("year_of_publication")
    public int yearOfPublication;
    public String genre;
    @JsonbProperty("creation_date")
    @JsonbDateFormat("yyyy-MM-dd")
    @Schema(implementation = String.class, format = "date")
    public Instant creationTime;

    //...
}

mp.openapi.extensions.smallrye.info.title=Book API
mp.openapi.extensions.smallrye.info.version=1.0
mp.openapi.extensions.smallrye.info.description=Creates books
mp.openapi.extensions.smallrye.info.contact.name=@susi
mp.openapi.extensions.smallrye.info.contact.url=https://twitter.com/susi

██████╗  ██████╗  ██████╗ ██╗  ██╗
██╔══██╗██╔═══██╗██╔═══██╗██║ ██╔╝
██████╔╝██║   ██║██║   ██║█████╔╝
██╔══██╗██║   ██║██║   ██║██╔═██╗
██████╔╝╚██████╔╝╚██████╔╝██║  ██╗
╚═════╝  ╚═════╝  ╚═════╝ ╚═╝  ╚═╝

quarkus.http.port=8702

mp.openapi.extensions.smallrye.info.title=Book API
mp.openapi.extensions.smallrye.info.version=1.0
mp.openapi.extensions.smallrye.info.description=Creates books
mp.openapi.extensions.smallrye.info.contact.name=@susi
mp.openapi.extensions.smallrye.info.contact.url=https://twitter.com/susi

package at.htl.microservices.book;

import io.quarkus.test.junit.QuarkusTest;
import org.junit.jupiter.api.Test;

import static io.restassured.RestAssured.given;
import static org.hamcrest.CoreMatchers.is;
import static org.hamcrest.CoreMatchers.startsWith;

@QuarkusTest
public class BookResourceTest {

    @Test
    public void shouldCreateABook() {
        given()
                .formParam("title", "Understanding Quarkus")
                .formParam("author","Susi")
                .formParam("year",2020)
                .formParam("genre", "IT")
          .when()
                .post("/api/books")
          .then()
                .statusCode(201)
                .body("isbn_13", startsWith("13-"))
                .body("title", is("Understanding Quarkus"))
                .body("author", is("Susi"))
                .body("year_of_publication", is(2020))
                .body("genre", is("IT"))
                .body("creation_date", startsWith("2021"));
    }
}

package at.htl.microservices.book;

import org.eclipse.microprofile.rest.client.inject.RegisterRestClient;

import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;

@RegisterRestClient
@Path("/api/numbers")
public interface NumberProxy {

    @GET
    @Produces(MediaType.APPLICATION_JSON)
    IsbnThirteen generateIsbnNumbers();

}

package at.htl.microservices.book;

import javax.json.bind.annotation.JsonbProperty;

public class IsbnThirteen {

    @JsonbProperty("isbn_13") (1)
    public String isbn13;

}

package at.htl.microservices.book;

import org.eclipse.microprofile.openapi.annotations.Operation;
import org.eclipse.microprofile.openapi.annotations.tags.Tag;
import org.eclipse.microprofile.rest.client.inject.RestClient;

// import ...

@Path("/api/books")
@Tag(name="Book REST endpoint")
public class BookResource {

    @Inject
    Logger logger;

    @RestClient
    NumberProxy proxy;

    @POST
    @Produces(MediaType.APPLICATION_JSON)
    @Consumes(MediaType.APPLICATION_FORM_URLENCODED)
    //  @Operation(...)
    public Response createABook(
            //...
    ) {
        Book book = new Book();
        book.isbn13 = proxy.generateIsbnNumbers().isbn13;
        book.title = title;
        book.author = author;
        book.yearOfPublication = yearOfPublication;
        book.genre = genre;
        book.creationTime = Instant.now();

        logger.infof("Book created: %s", book);
        return Response.status(201).entity(book).build();
    }
}

quarkus.http.port=8702

at.htl.microservices.book.NumberProxy/mp-rest/url=http://localhost:8701

POST localhost:8702/api/books
Content-Type: application/x-www-form-urlencoded

title=Quarkus&author=Susi&year=2021&genre=IT

http://localhost:8702/api/books

HTTP/1.1 201 Created
Content-Length: 128
Content-Type: application/json

{
  "author": "Susi",
  "creation_date": "2021-10-14",
  "genre": "IT",
  "isbn_13": "13-14543507",
  "title": "Quarkus",
  "year_of_publication": 2021
}

quarkus.http.port=8702

number.proxy/mp-rest/url=http://localhost:8701

// ...

@RegisterRestClient(configKey = "number.proxy")
@Path("/api/numbers")
public interface NumberProxy {

    // ...

}

package at.htl.microservices.book;

import io.quarkus.test.Mock;
import org.eclipse.microprofile.rest.client.inject.RestClient;

@Mock
@RestClient
public class MockNumberProxy implements NumberProxy {

    @Override
    public IsbnThirteen generateIsbnNumbers() {
        IsbnThirteen isbnThirteen = new IsbnThirteen();
        isbnThirteen.isbn13 = "13-mock";
        return isbnThirteen;
    }

}

mvn package -Dquarkus.package.type=native -Dmaven.test.skip=true

ls -lh target

target/rest-number-1.0.0-SNAPSHOT-runner

███╗   ██╗██╗   ██╗███╗   ███╗██████╗ ███████╗██████╗
████╗  ██║██║   ██║████╗ ████║██╔══██╗██╔════╝██╔══██╗
██╔██╗ ██║██║   ██║██╔████╔██║██████╔╝█████╗  ██████╔╝
██║╚██╗██║██║   ██║██║╚██╔╝██║██╔══██╗██╔══╝  ██╔══██╗
██║ ╚████║╚██████╔╝██║ ╚═╝ ██║██████╔╝███████╗██║  ██║
╚═╝  ╚═══╝ ╚═════╝ ╚═╝     ╚═╝╚═════╝ ╚══════╝╚═╝  ╚═╝



                        Powered by Quarkus 2.3.1.Final
2021-10-27 18:27:59,799 INFO  [io.quarkus] (main) rest-number 1.0.0-SNAPSHOT native (powered by Quarkus 2.3.1.Final) started in 0.017s. Listening on: http://0.0.0.0:8701
2021-10-27 18:27:59,804 INFO  [io.quarkus] (main) Profile prod activated.
2021-10-27 18:27:59,804 INFO  [io.quarkus] (main) Installed features: [cdi, resteasy, resteasy-jsonb, smallrye-context-propagation, smallrye-openapi, vertx]

curl localhost:8701/api/numbers

{"isbn_10":"10-34614","isbn_13":"13-82953702"}%

  <dependencies>
    ...
    <dependency>
      <groupId>io.quarkus</groupId>
      <artifactId>quarkus-container-image-docker</artifactId>
    </dependency>
  </dependencies>

FROM registry.access.redhat.com/ubi8/ubi-minimal:8.4  (1)
WORKDIR /work/
RUN chown 1001 /work \
    && chmod "g+rwX" /work \
    && chown 1001:root /work
COPY --chown=1001:root target/*-runner /work/application

EXPOSE 8080  (2)
USER 1001

CMD ["./application", "-Dquarkus.http.host=0.0.0.0"]

mvn package -Dquarkus.package.type=native \
            -Dquarkus.native.container-build=true \
            -Dquarkus.container-image.build=true

...
[INFO] [io.quarkus.deployment.QuarkusAugmentor] Quarkus augmentation completed in 133937ms
[INFO] ------------------------------------------------------------------------
[INFO] BUILD SUCCESS
[INFO] ------------------------------------------------------------------------
[INFO] Total time:  02:22 min
[INFO] Finished at: 2021-10-27T20:59:52+02:00
[INFO] ------------------------------------------------------------------------

docker image ls | grep stuetz

stuetz/rest-book                           1.0.0-SNAPSHOT   866272ea114f   2 minutes ago   158MB
stuetz/rest-number                         1.0.0-SNAPSHOT   ff6976b0370f   5 minutes ago   151MB

version : "3"
services:
  rest-number:
    image: "stuetz/rest-number:1.0.0-SNAPSHOT"
    ports:
      - "8701:8701"
  rest-book:
    image: "stuetz/rest-book:1.0.0-SNAPSHOT"
    ports:
      - "8702:8702"
    environment:
      - NUMBER_PROXY_MP_REST_URL=http://rest-number:8701

docker-compose -f vintage-docker-compose.yml up

docker container kill vintage-store-rest-number-1

 curl -X POST http://localhost:8702/api/books -d "title=Quarkus&author=Susi&year=2021&genre=IT"

{"author":"Susi","creation_date":"2021-10-28","genre":"IT","isbn_13":"Will be set later","title":"Quarkus","year_of_publication":2021}%

docker-compose -f vintagestore-docker-compose.yml down

[+] Running 3/3
 ⠿ Container vintage-store-rest-book-1    Remove...                                       0.2s
 ⠿ Container vintage-store-rest-number-1  Remo...                                         0.1s
 ⠿ Network vintage-store_default          Removed                                         0.1s