如何为Spring Boot注解式RSocket控制器添加服务端响应式拦截器

Spring Boot RSocket 提供了RSocketServerCustomizer扩展点，可直接通过注册该类型Bean实现服务端拦截器注入，无需手动控制Connector实例。

配置示例 #

第一步：注入配置Bean #

以下为Java版本的配置代码，和客户端的拦截器配置逻辑完全对齐：

import io.rsocket.micrometer.MicrometerDuplexConnectionInterceptor;
import io.rsocket.micrometer.MicrometerRSocketInterceptor;
import io.micrometer.core.instrument.MeterRegistry;
import io.micrometer.core.instrument.Tag;
import org.springframework.boot.rsocket.server.RSocketServerCustomizer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RSocketServerMetricsConfig {

    @Bean
    public RSocketServerCustomizer metricsCustomizer(MeterRegistry meterRegistry) {
        // 自定义服务端指标标签，可按需和客户端标签对齐
        Tag[] serverTags = new Tag[]{
            Tag.of("role", "rsocket-server"),
            Tag.of("app", "your-app-name")
        };

        return rSocketServer -> rSocketServer.interceptors(interceptorRegistry -> {
            // 生成服务端作为请求响应方的rsocket.*指标
            interceptorRegistry.forResponder(new MicrometerRSocketInterceptor(meterRegistry, serverTags));
            // 若服务端需要作为请求方调用其他RSocket服务可保留，否则可删除
            interceptorRegistry.forRequester(new MicrometerRSocketInterceptor(meterRegistry, serverTags));
            // 生成连接层面的rsocket.*指标
            interceptorRegistry.forConnection(new MicrometerDuplexConnectionInterceptor(meterRegistry, serverTags));
        });
    }
}

注意事项 #

• 需保证项目依赖中已引入io.rsocket:rsocket-micrometer组件，版本和项目使用的RSocket核心版本保持一致
• 配置添加后重启服务，即可在指标端点看到和客户端逻辑一致的rsocket.*前缀统计指标，包括请求次数、帧计数、连接数等数据

内容的提问来源于stack exchange，提问作者Eric J Turley