关于RSocketFactory替换为RSocketConnectorConfigurer的配置示例求助

我懂你这种找了一堆过时示例的痛苦——旧的RSocketFactory API确实已经被标记为废弃，现在Spring官方推荐用RSocketRequester配合RSocketConnectorConfigurer来配置客户端连接。下面是适配最新Spring Boot RSocket版本的完整示例：

基础配置示例 #

创建一个Spring配置类，通过RSocketConnectorConfigurer来配置RSocket客户端：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.rsocket.RSocketConnectorConfigurer;
import org.springframework.messaging.rsocket.RSocketRequester;
import org.springframework.util.MimeTypeUtils;

@Configuration
public class RSocketClientConfig {

    @Bean
    RSocketRequester rSocketRequester(RSocketConnectorConfigurer connectorConfigurer) {
        return RSocketRequester.builder()
                // 设置数据格式，对应原来的dataMimeType
                .dataMimeType(MimeTypeUtils.APPLICATION_JSON)
                // 使用RSocketConnectorConfigurer配置连接属性
                .rsocketConnector(connector -> {
                    // 应用配置器的默认全局配置
                    connectorConfigurer.configure(connector);
                    // 保留你原来需要的零拷贝解码器
                    connector.frameDecoder(PayloadDecoder.ZERO_COPY);
                })
                // 指定TCP连接地址和端口，替代原来的transport配置
                .tcp("localhost", 7000);
    }
}

关键变化说明 #

• 原来的RSocketFactory.connect()被替换为RSocketRequester.builder()，这是Spring官方主推的客户端API，更贴合Spring生态，用法也更简洁。
• RSocketConnectorConfigurer是Spring提供的配置器，用于统一管理RSocket连接的通用属性（比如超时、拦截器、编码器等）。你可以直接注入它来应用默认配置，也可以在rsocketConnector()的lambda中添加自定义配置。
• TCP传输的配置被简化为.tcp("localhost", 7000)，内部已经封装了TcpClientTransport的创建逻辑，无需手动实例化。

自定义全局配置（可选） #

如果需要给所有RSocket客户端设置全局通用配置，可以自定义一个RSocketConnectorConfigurer Bean：

import java.time.Duration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.rsocket.RSocketConnectorConfigurer;
import org.springframework.messaging.rsocket.RSocketInterceptor;

@Configuration
public class GlobalRSocketConfig {

    @Bean
    RSocketConnectorConfigurer customRSocketConnectorConfigurer() {
        return connector -> {
            // 设置全局连接超时
            connector.connectTimeout(Duration.ofSeconds(5));
            // 添加自定义拦截器
            connector.interceptors(registry -> {
                registry.forSocketAcceptor(new CustomRSocketInterceptor());
            });
        };
    }

    // 自定义拦截器示例
    private static class CustomRSocketInterceptor implements RSocketInterceptor {
        // 实现你的拦截逻辑
    }
}

依赖版本提醒 #

确保你的项目依赖了最新的Spring Boot RSocket Starter：

Maven

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-rsocket</artifactId>
</dependency>

Gradle

implementation 'org.springframework.boot:spring-boot-starter-rsocket'

内容的提问来源于stack exchange，提问作者Ahmedie-m