Redisクライアントの使用

package org.acme.redis; public class Increment { public String key; (1) public long value; (2) public Increment(String key, long value) { this.key = key; this.value = value; } public Increment() { } }

package org.acme.redis; import jakarta.enterprise.context.ApplicationScoped; import jakarta.inject.Inject; import io.quarkus.redis.datasource.ReactiveRedisDataSource; import io.quarkus.redis.datasource.RedisDataSource; import io.quarkus.redis.datasource.keys.KeyCommands; import io.quarkus.redis.datasource.keys.ReactiveKeyCommands; import io.quarkus.redis.datasource.string.StringCommands; import io.smallrye.mutiny.Uni; @ApplicationScoped public class IncrementService { // This quickstart demonstrates both the imperative // and reactive Redis data sources // Regular applications will pick one of them. private ReactiveKeyCommands<String> keyCommands; (1) private ValueCommands<String, Long> countCommands; (2) public IncrementService(RedisDataSource ds, ReactiveRedisDataSource reactive) { (3) countCommands = ds.value(Long.class); (4) keyCommands = reactive.key(); (5) } long get(String key) { Long value = countCommands.get(key); (6) if (value == null) { return 0L; } return value; } void set(String key, Long value) { countCommands.set(key, value); (7) } void increment(String key, Long incrementBy) { countCommands.incrby(key, incrementBy); (8) } Uni<Void> del(String key) { return keyCommands.del(key) (9) .replaceWithVoid(); } Uni<List<String>> keys() { return keyCommands.keys("*"); (10) } }

package org.acme.redis; import jakarta.inject.Inject; import jakarta.ws.rs.GET; import jakarta.ws.rs.PUT; import jakarta.ws.rs.Path; import jakarta.ws.rs.POST; import jakarta.ws.rs.DELETE; import java.util.List; import io.smallrye.mutiny.Uni; @Path("/increments") public class IncrementResource { @Inject IncrementService service; @GET public Uni<List<String>> keys() { return service.keys(); } @POST public Increment create(Increment increment) { service.set(increment.key, increment.value); return increment; } @GET @Path("/{key}") public Increment get(String key) { return new Increment(key, service.get(key)); } @PUT @Path("/{key}") public void increment(String key, long value) { service.increment(key, value); } @DELETE @Path("/{key}") public Uni<Void> delete(String key) { return service.del(key); } }

<dependency> <groupId>io.rest-assured</groupId> <artifactId>rest-assured</artifactId> <scope>test</scope> </dependency>

package org.acme.redis; import static org.hamcrest.Matchers.is; import org.junit.jupiter.api.Test; import io.quarkus.test.junit.QuarkusTest; import static io.restassured.RestAssured.given; import io.restassured.http.ContentType; @QuarkusTest public class IncrementResourceTest { @Test public void testRedisOperations() { // verify that we have nothing given() .accept(ContentType.JSON) .when() .get("/increments") .then() .statusCode(200) .body("size()", is(0)); // create a first increment key with an initial value of 0 given() .contentType(ContentType.JSON) .accept(ContentType.JSON) .body("{\"key\":\"first-key\",\"value\":0}") .when() .post("/increments") .then() .statusCode(200) .body("key", is("first-key")) .body("value", is(0)); // create a second increment key with an initial value of 10 given() .contentType(ContentType.JSON) .accept(ContentType.JSON) .body("{\"key\":\"second-key\",\"value\":10}") .when() .post("/increments") .then() .statusCode(200) .body("key", is("second-key")) .body("value", is(10)); // increment first key by 1 given() .contentType(ContentType.JSON) .body("1") .when() .put("/increments/first-key") .then() .statusCode(204); // verify that key has been incremented given() .accept(ContentType.JSON) .when() .get("/increments/first-key") .then() .statusCode(200) .body("key", is("first-key")) .body("value", is(1)); // increment second key by 1000 given() .contentType(ContentType.JSON) .body("1000") .when() .put("/increments/second-key") .then() .statusCode(204); // verify that key has been incremented given() .accept(ContentType.JSON) .when() .get("/increments/second-key") .then() .statusCode(200) .body("key", is("second-key")) .body("value", is(1010)); // verify that we have two keys in registered given() .accept(ContentType.JSON) .when() .get("/increments") .then() .statusCode(200) .body("size()", is(2)); // delete first key given() .accept(ContentType.JSON) .when() .delete("/increments/first-key") .then() .statusCode(204); // verify that we have one key left after deletion given() .accept(ContentType.JSON) .when() .get("/increments") .then() .statusCode(200) .body("size()", is(1)); // delete second key given() .accept(ContentType.JSON) .when() .delete("/increments/second-key") .then() .statusCode(204); // verify that there is no key left given() .accept(ContentType.JSON) .when() .get("/increments") .then() .statusCode(200) .body("size()", is(0)); } }

docker run --ulimit memlock=-1:-1 -it --rm=true --memory-swappiness=0 --name redis_quarkus_test -p 6379:6379 redis:5.0.6

%prod.quarkus.redis.hosts=redis://localhost:6379

java -jar target/quarkus-app/quarkus-run.jar

./target/redis-quickstart-1.0.0-SNAPSHOT-runner