java - コールバック メソッドを使用して、Quarkus/Mutiny で MyRequestService を Reactive REST GET エンドポイントに接続します。

Question

QuarkusプロジェクトでReactive REST エンドポイントが必要だったので、先週、 Mutinyライブラリで初めて ✨ ラウンドを行いました。これは思ったほど明白ではなかったので、 QuarkusのMutinyライブラリに関する私の新しい洞察を共有しようと思いました。

Quarkusのドキュメントでは、Mutiny ライブラリが Reactive ユースケースの優先ライブラリとして指定されています。

例えば;

目立ったのは、ほとんどの Mutiny の例が新しい String を例として使用していることです。それで、私の質問は残りました。

Quarkus で MyRequestService と Mutiny を接続する方法

これは次のようになります。

Uni<MyRequestService> lMyRequestServiceUni = Uni.createFrom().item( ... ) ...

MyRequestService はすでにコールバック構造を使用しているため、Mutiny へのコールバック メソッドを試してみました。

Answer 1

Mutinyは、コールバック ベースの APIと統合するときにEmitterを使用します。

https://smallrye.io/smallrye-mutiny/getting-started/creating-unis

そのため、MyRequestService、または基礎となるコールバック オブジェクトは、UniEmitter Consumer を実装する必要があります。しかし、最初にReactiveになるには、古いブロッキング REST エンドポイントが MyJsonResult ではなく Uni<MyJsonResult> を返す必要があります。

ServiceResource は、呼び出しを Service に転送するだけです。

MyRequestService は MyJsonResultConsumer を作成し、これを Mutiny Emitter に配信します。結果の Uni<MyJsonResult> が ServiceResource に返されます。

最後に、MyJsonResultConsumer は実際のコールバック オブジェクトです。メソッド ready() は、Mutiny へのコールバックを終了する UniEmitter で complete() を呼び出します。

Mutiny は UniEmitter に accept() への call(back) を提供する必要があるため、null ポインターをチェックする (またはセマフォoid を使用する) 必要があることに注意してください。‍♂️</p>