RSocket AsyncAPI

分析 RSocket 控制器與 MessageMapping 路由以生成 AsyncAPI 2.6.0 JSON。

分析的端點

CourtCaseRSocketController.java

java

@Controller
public class CourtCaseRSocketController {

  @MessageMapping("court-case.detail.stream")
  public Flux<CourtCaseDetailEvent> stream(CourtCaseDetailRequest request) {
    return service.stream(request);
  }
}

Watcher 設定

java

var asyncConfig = RsoketAsyncApiJsonFileWatcher.Config.builder()
    .watchDirectory("src/main/java")
    .asyncApiOutputFile("src/main/resources/static/asyncapi-rsocket.json")
    .build();

watchDirectory

基本來源根目錄

asyncApi輸出檔案

基本 static asyncapi-rsocket.json

當前類別名稱

保留 Rsoket 拼寫

目前公開的類別是以 RsoketAsyncApiJsonFileWatcher 的形式宣告為 Rsoket 而非 Rsocket。文件範例也保持實際可導入的名稱。

前端生成器連接

生成的 AsyncAPI JSON 可用於 @byeolnaerim/typed-rx-http/auto-node-script/asyncapi 生成器，作為路由請求/響應類型和 RSocket 服務函數的輸入。