先生と生徒の会話形式で理解しよう

生徒

「QuarkusのReactiveプログラミングって、何がそんなに便利なんですか？」

先生

「処理を止めずに、たくさんのリクエストを効率よくさばける点が特徴です。特にMutinyという仕組みが重要になります。」

生徒

「Mutinyって聞いたことがないです。難しそうで不安です……」

先生

「考え方さえ押さえればシンプルです。順番に見ていきましょう。」

1. QuarkusにおけるReactiveプログラミングとは

QuarkusのReactiveプログラミングとは、ノンブロッキング処理を前提としたアプリケーション開発手法です。従来のJavaでは、処理が終わるまで待つ同期処理が一般的でしたが、それでは同時アクセスが増えたときに性能が落ちやすくなります。 Quarkus Reactiveでは、待ち時間を有効活用しながら処理を進めるため、高速でスケーラブルなアプリケーションを実現できます。

2. Mutinyとは何かをイメージで理解する

MutinyはQuarkus標準のReactiveライブラリです。非同期処理の結果を「あとで届くデータ」として扱う考え方が特徴です。すぐに値が返らなくても、将来届くことを前提に処理を組み立てていきます。これにより、コードの流れが分かりやすくなり、初心者でもReactiveプログラミングを理解しやすくなっています。

3. Uniを使った単一データの非同期処理

Mutinyで最もよく使われるのがUniです。 Uniは「結果がひとつ返ってくる非同期処理」を表します。 REST APIのレスポンスや、データ取得結果などに向いています。 Quarkus Reactive RESTでも頻繁に登場する重要な概念です。


import io.smallrye.mutiny.Uni;

public class UniExample {
    public static void main(String[] args) {
        Uni<String> uni = Uni.createFrom().item("Hello Quarkus Reactive");
        uni.subscribe().with(
            item -> System.out.println(item)
        );
    }
}


Hello Quarkus Reactive

4. 非同期処理をつなげるtransformの考え方

Reactiveプログラミングでは、処理を小さく分けてつなげることが重要です。 Mutinyではtransformを使うことで、前の処理結果を次の処理へ自然につなげられます。 if文や一時変数を減らし、読みやすいコードを書くことができます。


import io.smallrye.mutiny.Uni;

public class TransformExample {
    public static void main(String[] args) {
        Uni<Integer> uni = Uni.createFrom().item(10)
            .onItem().transform(value -> value * 2);

        uni.subscribe().with(
            result -> System.out.println(result)
        );
    }
}

5. 失敗時の処理を考えるReactiveの基本姿勢

非同期処理では、エラーへの対応がとても大切です。 Mutinyでは、失敗した場合の処理も宣言的に書けます。 try-catchを多用するのではなく、処理の流れとしてエラーを扱える点が特徴です。 Quarkus Reactiveを使うことで、安全で安定したアプリケーションが作れます。


import io.smallrye.mutiny.Uni;

public class FailureExample {
    public static void main(String[] args) {
        Uni<Integer> uni = Uni.createFrom().failure(new RuntimeException("error"))
            .onFailure().recoverWithItem(0);

        uni.subscribe().with(
            item -> System.out.println(item)
        );
    }
}

6. Quarkus ReactiveとREST APIの関係

QuarkusではReactive REST APIとMutinyが密接に連携しています。 RESTエンドポイントの戻り値にUniを指定するだけで、ノンブロッキングなAPIが完成します。特別な設定をしなくてもReactiveが使える点は、Quarkusの大きな魅力です。初心者でもモダンなJava Web開発を体験できます。


import io.smallrye.mutiny.Uni;
import jakarta.ws.rs.GET;
import jakarta.ws.rs.Path;

@Path("/reactive")
public class ReactiveResource {

    @GET
    public Uni<String> hello() {
        return Uni.createFrom().item("Reactive REST with Quarkus");
    }
}