Spring Web Flux (反应式)功能路由与Kotlin不能按预期工作
Spring Web Flux是Spring Framework的一部分，它是一个基于反应式编程模型的Web框架。与传统的Servlet API相比，Spring Web Flux使用了非阻塞I/O和异步编程的方式来处理请求和响应，从而实现更高的并发性能和更低的资源消耗。
Spring Web Flux的核心组件是功能路由，它允许开发者通过定义路由规则来处理不同的HTTP请求。功能路由使用了函数式编程的方式，可以通过Lambda表达式或者Kotlin的协程来定义处理函数。开发者可以根据请求的路径、HTTP方法、请求头等条件来匹配路由规则，并执行相应的处理逻辑。
Kotlin是一种基于JVM的静态类型编程语言，它与Java语言高度兼容，并且提供了更简洁、安全、表达力强的语法。在Spring Web Flux中，Kotlin可以与功能路由无缝集成，开发者可以使用Kotlin的协程来编写异步的处理函数，从而简化异步编程的复杂性。
Spring Web Flux和Kotlin的结合可以带来以下优势：
- 高性能：Spring Web Flux使用了非阻塞I/O和异步编程的方式，可以处理大量并发请求，提供更高的性能和吞吐量。
- 响应式编程：Spring Web Flux基于反应式编程模型，可以处理大量的并发请求，并且能够轻松地处理异步操作和事件流。
- 简化异步编程：Kotlin的协程可以简化异步编程的复杂性，使代码更易于理解和维护。
- 更安全的编程：Kotlin提供了空安全和类型安全的特性，可以减少空指针异常和类型转换错误的风险。
Spring Web Flux和Kotlin的组合适用于以下场景：
- 高并发的Web应用程序：当需要处理大量并发请求时，Spring Web Flux可以提供更高的性能和吞吐量。
- 实时数据流应用程序：Spring Web Flux的反应式编程模型适用于处理实时数据流，如聊天应用、实时监控等。
- 异步操作和事件驱动应用程序：Kotlin的协程可以简化异步编程的复杂性，适用于处理异步操作和事件驱动的应用程序。
推荐的腾讯云相关产品和产品介绍链接地址：
- 云服务器（CVM）：https://cloud.tencent.com/product/cvm
- 云数据库MySQL版：https://cloud.tencent.com/product/cdb_mysql
- 云原生应用引擎（TKE）：https://cloud.tencent.com/product/tke
- 云存储（COS）：https://cloud.tencent.com/product/cos
- 人工智能机器学习平台（AI Lab）：https://cloud.tencent.com/product/ailab
请注意，以上推荐的腾讯云产品仅供参考，具体选择应根据实际需求和项目要求进行评估。
相关·内容
有一个新的http会话实现，用于spring新的reactive web flux api，位于。我想把最新的spring web会话集成到新的spring reactive web flux中。我似乎不能得到它，我试着将它作为bean注入，但它不起作用。我想像通常对HttpSession所做的那样注入它。
就像这样
@Autowired
Websession webSession;
浏览 18提问于2017-08-24得票数 3
回答已采纳
我已经开始学习Spring web flux了。我目前的需求是在我的项目中使用Spring web flux和AMQP。这个项目是使用rabbitmq发布-订阅AMQP消息传递和项目没有网络dependency.This项目将在纯粹的后端工作。
下面是我的demo服务文件，这个服务在消息负载中获取所需的数据，然后服务将根据负载数据进行处理，并完成需要的任务。
public class HandlerService {
@RabbitListener(queues = "${amqp.queue}")
public void consumeMessageFrom
浏览 18提问于2020-03-03得票数 0
1回答
在下面的示例中，从Spring Webflux反应式客户端的角度来看，调用非反应式和反应式远程web服务有什么区别吗？
客户端：
Flux<String> stringFlux = WebClient.create("http://localhost:8080/strings")
.get()
.retrieve()
.bodyToFlux(String.class);
反应式服务，生成常规的“文本/普通文本”，而不是“文本/事件流”：
@GetMapping("
浏览 0提问于2019-07-05得票数 2
1回答
我使用的是Spring Boot2.0.2，我想使用Spring Data将Flux的内容插入到MongoDB文档的数组中，并使用实现对mongodb的响应式支持。例如(Kotlin代码)：
val mongo : ReactiveMongoOperations = ...
data class Something(val data: String)
val flux = Flux.just(Something("A"), Something("B"))
mongo.upsert(query(where("_id").isEqualTo(
浏览 52提问于2018-05-30得票数 0
回答已采纳
我正在学习Spring，在编写示例应用程序的过程中，我发现了与Spring WebFlux结合使用的反应式类型(Mono/Flux)相关的一个问题。
考虑下面的代码片段(用Kotlin编写)：
@Repository
interface TaskRepository : ReactiveMongoRepository<Task, String>
@Service
class TaskService(val taskRepository: TaskRepository) {
@Cacheable("tasks")
fun get(id: Strin
浏览 4提问于2018-01-09得票数 25
回答已采纳
1回答
我有下面的协程函数，我想让一个邮递员请求端点。应用程序在上启动
@Configuration
class MerchantApi {
@Bean
fun routes(paymentHandler: paymentHandler) = coRouter {
"/payment-link".nest {
POST("/init") { serverRequest ->
//logic here
}
}
}
}
我试
浏览 0提问于2020-04-17得票数 1
我的spring boot应用程序配置为响应式。但是我的REST API端点配置为返回没有Mono或Flux的ResponseEntity。
@GetMapping("/wiki/test")
public ResponseEntity<?> test() {
log.info("TEST CALLED????");
return ResponseEntity.ok().body("HALLO");
}
我想实现过滤器，它将检查每个端点的传入报头。旧的Servlet过滤器当然不起作用，对
浏览 2提问于2019-01-16得票数 0
我的应用程序很大程度上依赖于异步web服务。它是用spring boot 1.5.x构建的，它允许我利用标准的Java8 CompletableFuture<T>来产生延迟的异步响应。有关更多信息，请参阅
Spring boot 2.0.x现在附带了可以利用reactive范例的入门包。Spring是实现反应式WebFlux的框架。
既然我已经实现了第一段中描述的API，那么通过重做我的服务来使用非阻塞反应式方法，我会获得很多好处吗？简而言之，我也将拥有非阻塞API，对吧？
有没有一个例子，如何将基于CompletableFuture<T>的异步API转换为Mono&l
浏览 3提问于2018-08-02得票数 7
假设我有一个带有spring boot的微服务，它的PersonsRestController输入如下： @GetMapping(value = "/world/{countryId}/persons", produces = APPLICATION_JSON_UTF8_VALUE)
public ResponseEntity<PersonSaverItem> getPublishPersonsByCountry(@PathVariable("countryId") Integer countryId,
浏览 29提问于2021-10-26得票数 1
1回答
我正在接近Spring Boot2及其实现web服务的响应式方法。由于几乎每个习惯于使用经典同步MVC模式进行编程的人，我对这种方法都有一些怀疑。我正在尝试实现一个some控制器，并开发一些反应式和非反应式方法作为示例的标题，以便更好地理解这些概念。例如，以编写的方式导入WebFlux (它使用Netty作为嵌入式服务器)，第二和第四种方法是反应性的，而第一种和第三种方法是否是非反应性的？
@org.springframework.web.bind.annotation.RestController
public class RestController {
@Autowired
N
浏览 24提问于2018-01-16得票数 1
Spring5引入了使用的rest的反应式编程风格。我自己也是个新手，我想知道将对数据库的同步调用包装到Flux或Mono中是否在性能方面有意义？如果是，是这样做的吗：
@RestController
public class HomeController {
private MeasurementRepository repository;
public HomeController(MeasurementRepository repository){
this.repository = repository;
}
@GetMapping
浏览 3提问于2017-02-17得票数 30
1回答
我已经开始尝试Spring Cloud Stream和它的云函数支持。
我在这里上传了一个示例项目来解释这个问题->
我有一个项目，它以一种被动的方式公开了一些功能，使用kafka作为消息代理。
该函数接收Flux并通过Reactive Mongo库保存元素。然后，它通过另一个flux返回更新后的资源。
@Service
public class ExampleCloudFunction {
@Autowired
private PlayerRepository playerRepository;
@Bean
public Function<Flux<Player>
浏览 14提问于2020-05-21得票数 0
在我的spring-boot springboot服务类中，我创建了以下代码，它不能按预期工作：
服务类别：
Flux<Workspace> mWorkspace = webClient.get().uri(WORKSPACEID)
.retrieve().bodyToFlux(Workspace.class);
ArrayList<String> newmWorkspace = new ArrayList();
newmWorkspace = mWorkspace.blockLast();
return newmWorkspace;
请谁帮我把json值的列表转换成
浏览 5提问于2021-03-25得票数 0
我把spring Boot中用于向客户端发送单向异步消息的SSEemitter和flux搞混了。 我想知道关于Spring boot这两个术语的用例
浏览 45提问于2019-12-19得票数 4
2回答
我对Spring WebFlux中的反应式编程非常陌生。请原谅我在这里的无知。 下面的代码没有将对象EyeCare添加到Flux eyeCares。我在这里读到了关于Flux.create和Flux.generate的信息，它们似乎是用来创建Flux的，我还读到了这篇文章 我需要采用Flux.create或Flux.generate来解决这个问题吗？ 如果是，则截取代码中的myEventProcessor所在位置 如何引入Flux.create或Flux.generate而不是eyeCares.concatWithValues
浏览 88提问于2021-02-27得票数 1
回答已采纳
我想知道是否有，或者我们是否可以利用任何功能来记录返回Mono/Flux的函数所用的实际时间？例如，创建一个@Timed注释来记录它所花费的实际时间。我知道函数的返回类型是Flux/Mono，所以它应该立即返回，这就是为什么我想知道我们是否真的可以做这样的事情，这样我们就可以知道哪些模块/子模块花费了多少时间？ 我们想要将我们的阻塞spring-boot服务迁移到spring webflux上，所以为了更好地理解，我们需要了解所有可能的选项。 附注:我对反应式编程是个新手，还在学习这个范例。
浏览 8提问于2020-12-10得票数 1
1回答
我正在学习Spring Cloud Function。我们为什么要学习这个呢？我在运行代码时出现以下错误
Exception in thread "main" java.lang.ClassCastException: class reactor.core.publisher.FluxPeekFuseable cannot be cast to class java.lang.String (reactor.core.publisher.FluxPeekFuseable is in unnamed module of loader 'app'; java.lan
浏览 108提问于2021-05-14得票数 1
我在修改Spring Cloud Gateway中的Flux响应时遇到了一些问题。我的设置(简化)如下:我有2个域对象：
@Data
@AllArgsConstructor
public class PersonV10 {
@NotNull
private String name;
}
@Data
@AllArgsConstructor
public class PersonV20 {
@NotNull
private String firstName;
@NotNull
private String lastName;
}
现在，我的服务
浏览 2提问于2020-06-23得票数 0
2回答
我试图理解spring 5的反应性部分。我创建了简单的rest端点，用于使用spring web-flux和spring数据反应性(mongo)查找所有实体，但不知道如何实现分页。
下面是我在Kotlin中的简单例子：
@GetMapping("/posts/")
fun getAllPosts() = postRepository.findAll()
是否意味着反应性端点不需要分页？是使用此堆栈实现服务器端分页的某种方式吗？
浏览 1提问于2017-08-28得票数 11
回答已采纳
我有一个常规的java Function；我试图绑定它：
它对web端点的输入
它的输出到一个卡夫卡主题。
当我在web上下文中使用我的函数时，它总是将Function的结果值单独返回给web客户机。我能做这样的事吗
spring.cloud.stream.bindings.input.binder=web
spring.cloud.stream.bindings.output.binder=kafka
我目前甚至试图将Function分解为2：
它的输入绑定到web客户端，其输出动态绑定到第二个函数(使用spring.cloud.stream.sendto.destina
浏览 1提问于2019-11-29得票数 4
回答已采纳
我开始学习Java的反应式编程。整个反应式范式对我来说都是新的。
在我的学习过程中，我遇到了一些术语/库，比如Spring和RxJava。我希望有人能解释一下区别是什么，你在你的项目中使用了哪一个，以及为什么你做出了这个选择。
我读到Spring实际上在内部使用了WebFlux的Flux/Mono。这将问题简化为Spring Webflux在RxJava上的利弊？
浏览 2提问于2019-06-05得票数 33
回答已采纳
3回答
我有一些微服务，它们应该工作在WebFlux框架之上。每台服务器都有自己的Mono或Flux API。我们使用的是Spring (Spring Data MongoDB Reactive)支持的MongoDb。
问题是外部阻塞API，我必须在我的系统中使用它。
我有一个解决方案。我可以将阻塞应用程序接口调用封装在专用线程池中，并将其与CompletableFuture一起使用。
还有没有别的办法可以解决我的问题？我想，那个全新的Rsocket不能解决我的问题。
浏览 1提问于2018-10-07得票数 4
2回答
在spring数据中，我可以轻松地执行以下查询：
Page<MyClass> findByX(String x, Pageable pageable);
在reactive Spring data (MongoDB)中，我找不到对结果进行分页的有效方法。
Mono<Page<MyClass>> findByX(String x, Pageable pageable);
看起来是一个很好的候选者，但失败了，出现了一个需要使用Flux.buffer(size, skip)的错误
如果没有有效的方法可以做到这一点，有没有一种方法可以在没有Page的情况下实际执行一
浏览 0提问于2021-06-28得票数 0
1回答
Spring-Core5.2具有带有诸如StringDecoder解码器的编解码器包，该解码器支持反应式编程。获取Publisher<DataBuffer>并返回解码后的Flux<String>。 我希望找到gzip的Publisher<DataBuffer>或Publisher<ByteArray>的GzipDecoder，并返回未压缩的Flux<ByteArray>，但我没有找到它。 我发现唯一符合我需求库是https://github.com/kptfh/gzip-reactive，但它非常不成熟 熟悉成熟的代码吗？
浏览 12提问于2020-01-20得票数 2
当我在Spring Cloud Stream Reactive中再次尝试时，出现了一个我不理解的情况，所以我问了一个问题。在每秒发送字符串型数据的情况下，在s-c-stream函数中处理后，我故意根据条件导致RuntimeException。 @Bean
fun test(): Function, Flux?> = Function{ input ->
input.map { sellerId ->
if(sellerId == "I-ZICGO")
throw RuntimeE
浏览 34提问于2021-02-25得票数 0
回答已采纳
我有一些关于通过HTTP从Play Framework应用程序消费Spring应用程序的问题，您能提供一些帮助吗？ 微服务A是一个反应式Spring，用Java8，SpringBoot 2.1.4编写，它公开了这个接口： @Autowired private ReactiveCustomerRepository customerRepository;
@GetMapping("/customers")
public Flux<Customer> getAllCustomers() {
Flux<Customer> c = customerRe
浏览 13提问于2019-05-12得票数 2
回答已采纳
我在下面的客户端-服务器交互中看到了一些奇怪的行为，我想知道我是遇到了HTTP/1.1语义，还是我的反应式编程技能需要努力(或者两者兼而有之)。 我正在尝试创建一个客户端-服务器交互，其中请求和响应主体都是长时间运行的数据流。 客户端是一个Spring Reactive WebClient，它在请求体中发送无限流。它期望接收(并记录)无限的结果流。 Flux<Long> requests = Flux.interval(Duration.ofSeconds(2));
return WebClient.create()
.post()
.u
浏览 29提问于2019-12-04得票数 2
1回答
Kotlin协同器允许通过返回Deferred值来执行非阻塞代码。在使用阻塞方法时(例如从库中)，这对于生成非阻塞代码非常有用。
Spring 5允许在框架中使用Mono和Flux。我看到的最大兴趣是能够序列化这两种类型的实例，并在某人调用控制器端点时将其作为响应发送回。
Spring 5的一个要点是对Kotlin (路由器，bean声明，.)有一个特定的支持，但是我找不到关于Kotlin协同和Spring 5反应类型之间可能的交互的信息。
有没有办法将这些特性的优点结合起来？
将Deferred转换为Mono/Flux
是否有一个Deferred作为Spring控制器方法的响应类型？
浏览 0提问于2017-10-11得票数 7
回答已采纳
1回答
我正在向我的java代码中注入一个kotlin类。kotlin类有两个签名几乎相同的方法：
fun <R> isFluxAuthorizedFor(
strings: List<StringRequest>,
then: (responses: List<StringResult>) -> Flux<R>
): Flux<R>
和
fun <R> isFluxAuthorizedFor(
string:
浏览 3提问于2019-12-17得票数 2
回答已采纳
我在我的项目中使用web flux，并尝试使用JPA存储库执行简单的CRUD操作。然而，我无法在数据库中持久化该对象。在DB中，对象始终使用空值进行持久化。请帮帮忙。提前谢谢。 这是我的pojo： @Entity
@Table(name="tbl_student")
@Data
public class Student {
@Id
@GeneratedValue(strategy= GenerationType.SEQUENCE,generator = "student_seq")
@SequenceGenerator(name=&#
浏览 25提问于2020-12-01得票数 1
回答已采纳
2回答
使用Spring Boot2，是否有可能以反应式风格(Mono、Flux和它们的运算符)编写代码，但保留JDBC线程池系统？
目标是在R2DBC驱动程序可以用于生产时切换到它们，而不需要更改控制器和服务层。
非常感谢!
Saveriu
浏览 0提问于2019-01-02得票数 0
我想在Spring Boot中实现服务器发送的事件。数据存在于SQL数据库中，这会导致连接阻塞。Web Flux是一个选项，但它只支持某些NoSQL数据库。
浏览 1提问于2018-09-29得票数 0
我正在测试如何从"jsonplaceholder“API查询数据，并将接收到的数据保存到本地Postgresql数据库中。当我从Postman打电话时，接收到的数据由“jsonplace夹子”正确地返回，但奇怪的是，数据库中没有存储任何数据。也许我只是在我的代码中遗漏了什么(见下面)，我不知道！这是一个Spring应用程序，它的and流量、Kotlin和Postgres的‘SQL作为本地数据库。提前感谢您的帮助！
/* The config file: WebfluxConfig.kt*/
package com.example.monoSubscribe.config
浏览 10提问于2022-11-03得票数 0
回答已采纳
1回答
我正在尝试用WebTestClient编写一个集成测试，它将只支持我用WebTestClient测试的控制器来发出请求。在开始一个测试时，我在控制台中得到以下内容：
14:33:50.435 [main] INFO org.hibernate.validator.internal.util.Version - HV000001: Hibernate Validator 6.0.9.Final
14:33:50.442 [main] DEBUG org.hibernate.validator.internal.engine.resolver.TraversableResolvers - Cann
浏览 0提问于2018-05-02得票数 0
1回答
我是第一次接触Project Reactor和R2DBC。如何使用Spring Data R2DBC反应式存储库正确地接收和合并Flux<Child>和Mono<Parent>？ 父级： @Table("parent")
public class Parent{
@Id
private Long id;
private String name;
@Transient
private Flux<Child> children; ParentRepository： interface ParentRepository extends Rea
浏览 20提问于2020-01-21得票数 4
回答已采纳
我有一个反应式rest应用程序，它使用了springboot。使用jetty作为后端。
如何通过Appengine公开flux和mono rest端点？有办法做到这一点吗？
google appengine是否支持自己的基于反应式java的api端点？
浏览 0提问于2019-01-16得票数 1
我看过，读过一些关于spring reactor的文章，但我不太理解它。
假设我已经激活了netty和spring reactor，那么让端点返回Flux/Mono实例(jacksonified)而不是直接返回dto对象(jacksonified)有什么好处？我最初假设，在http请求/响应上下文中，反应式流的工作方式更像websockets，其中服务器使用开放的通道将数据推送到接收器，但事实似乎并非如此。
另外，在反应式编程中，netty实际上比tomcat做得更好吗？
如果这些问题看起来很愚蠢，我很抱歉，但我不太理解这个新框架方向的目的。它为什么会出现，它是如何工作的，它解决了什么问题？
浏览 1提问于2016-12-05得票数 16
我们有一个集成了Project Reactor的Spring cloud Stream应用程序。我们通过在消息头和发布消息中设置spring.cloud.stream.sendto.destination来动态设置目标主题。我们正在寻求处理错误情况，如kafka服务器间歇性停机或主题在发布时不可用。我们已经实现了@ServiceActivator来处理所有错误。当主题是动态设置时，生产者错误不会被ServiceActivator捕获，只有消费者错误会命中ServiceActivator。如果我们将out.destination主题设置在前面，那么生产者错误也会被捕获。有没有办法也为动态目的地启
浏览 258提问于2021-05-13得票数 0
我有一个端点，它应该使用一个需要Java.Util.List的ExcelUtility类来获取excel文档。 我使用Mongodb来获取数据，但是Mongodb返回了一个Flux myList。 如何“给”ExcelUtility类List myList以生成可以在ResponseEntity中返回的Workbook类？ 到目前为止，我有以下代码： final Workbook myWorkBook = ExcelUtils
.pojo2xlsx(this.myMongoRepository.findAll()
.toStrea
浏览 24提问于2019-04-25得票数 0
回答已采纳
4回答
我有以下简化的处理函数(Spring和使用Kotlin的函数WebFlux )。但是，我需要一个提示，当Flux为空时，如何检测到一个空的Flux，然后对404使用noContent()。 fun findByLastname(request: ServerRequest): Mono<ServerResponse> {
val lastnameOpt = request.queryParam("lastname")
val customerFlux = if (lastnameOpt.isPresent) {
service.fi
浏览 50提问于2017-08-27得票数 11
回答已采纳
1回答
我最近开始与java和Spring一起使用反应式思维。 是否有可能创建一个具有动态数量的生产者的场景？我正在开发一个监听特定硬件事件的产品，如果我可以在不结束流的情况下动态添加(并可能删除)监听设备A，B...Z，那就太可怕了。 我想像这样的东西： @GetMapping("/")
public Flux<HardwareEvent> void test() {
return Flux.merge(
listenHardware(A),
listenHardware(B)
);
}
Flux<HardwareEvent> li
浏览 13提问于2021-10-13得票数 0
我在spring web flux中使用web reactive。我已经为POST请求实现了一个处理程序函数。我要服务器立即返回。因此，我实现了如下的处理程序-：
public class Sample implements HandlerFunction<ServerResponse>{
public Mono<ServerResponse> handle(ServerRequest request) {
Mono bodyMono = request.bodyToMono(String.class);
bodyMono.map(str -> {
Sy
浏览 0提问于2019-09-03得票数 0
我在我的项目中重写了SecurityExpressionRoot，公开了一个验证当前用户是否有权访问给定资源的方法。
然后我重写了GlobalMethodSecurityComfiguration.createExpressionHandler()，然后createSecurityExpressionRoot()返回被重写的SecurityExpressionRoot的实例。这在servlet场景中有效，不幸的是，这似乎在反应式场景中不起作用。
如何将下面的方法安全性设置转换为反应式场景？
在我的测试中，我得到了以下错误：
org.springframework.security.authen
浏览 0提问于2020-10-14得票数 2
我正在尝试在Spring Boot2和Spring Data Redis (都是最新版本)上使用Lettuce驱动程序。我无法连接到Redis，一直收到以下错误：
Caused by: java.lang.ClassNotFoundException: io.lettuce.core.KeyValue
at java.net.URLClassLoader.findClass(URLClassLoader.java:381) ~[na:1.8.0_111]
at java.lang.ClassLoader.loadClass(ClassLoader.java:424) ~[na:
浏览 2提问于2018-05-06得票数 1
我已经和Kotlin一起使用Spring的框架一个月了，并且一直很喜欢它。当我准备开始使用WebFlux和Kotlin编写生产代码时，我发现自己很难以一种简单、轻量级的方式对路由器进行单元测试。
是一个很好的框架，但是它的重量比我想要的要重，我正在寻找一个比传统的JUnit更有表现力的测试框架。JavaScript的摩卡里有什么东西。Kotlin的完全符合这一要求。
下面是我如何使用Spek对一个简单的路由器进行单元测试的例子。
浏览 2提问于2018-06-20得票数 0
回答已采纳
我使用spring web-flux在netty服务器上构建了如下反应式管道：
someService.getSettings(key) //Mono<Settings>
.filter(Settings::isEnabled)
.switchIfEmpty(Mono.error(
new Exception("Setting is disabled.")
)).then(/*Mono representing API fetch*/ someApi.fetch(param));
根据我的理解，
浏览 134提问于2020-02-06得票数 2
我有一个类型: A，它包含一个集合，即b： data class A(val b: List<B>,
val value_in_b: String)
data class B(value_in_b: String) 我从两个来源收到了一个Flux<A>和Flux<B>，我可以将一个字符串映射到B的许多实例中。我如何在Spring WebFlux中组合它们？ 欢迎使用Kotlin或java回答:)
浏览 33提问于2021-01-30得票数 0
我创建了一个新的示例，并将代码转移到客户端和服务器端。
完整的代码可以找到。
服务器端有3种版本。
服务器无Spring应用程序，使用Spring InboundGateway。
服务器-引导重用Spring RSocket自动配置，并通过ServerRSocketMessageHanlder创建ServerRSocketConnecter。
server-boot-messsagemapping不使用Spring，只使用Spring自动配置，以及@Controller和@MessageMapping。
有两个版本的客户端。
客户端，使用发送消息。
client-r
浏览 0提问于2020-02-29得票数 1
回答已采纳
当我们使用Spring的RSocket ()支持使用Kotlin流和反应堆流发出值时，IO流量有什么不同吗？
@MessageMapping("stream")
suspend fun send(): kotlinx.coroutines.flow.Flow<SomeClass> = ...
VS
@MessageMapping("stream")
fun send(): reactor.core.publisher.Flux<SomeClass> = ...
另外，客户端代码(带有rsocket-websocket-client的JS)
浏览 3提问于2021-03-26得票数 2
回答已采纳
我可以使用新的Kotlin DSL来设置路由，例如：
router {
("/blog" and accept(TEXT_HTML)).nest {
GET("/", fooHandler::findAllView)
GET("/{slug}", fooHandler::findOneView)
}
("/api/blog" and accept(APPLICATION_JSON)).nest {
GET("/", barHandler::fi
浏览 4提问于2017-10-23得票数 0
回答已采纳
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频
腾讯云开发者
