带有 Webflux 路由器的 RSocket

问题描述

我有一个使用 Spring boot webflux 的应用程序，并公开如下端点。

@Configuration
public class BusinessServiceConfiguration {

    @Autowired
    private final RequestHandler reqHandler;

    @Bean
    public RouterFunction<ServerResponse> createuser() {
        return route(POST("/api/v1/user/create").and(contentType(APPLICATION_JSON)),reqHandler::createuser);
    }

}

遇到了 RSocket，它很有前途。计划转而使用 RSocket。

使用 RSocket 暴露端点，

    @Controller
    public class RSocketController {
        @Autowired
        private final RequestService reqService;
    
        @MessageMapping("/api/v1/user/create")
        public Mono<String> createuser() {
            return reqService.createuser .....
        }
    }

在这里，我们公开 API 的方式与 b/w Webflux 和 RSocket 完全不同，需要一些努力。

有没有办法只添加 RSocket 而不改变我们暴露端点的方式？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）