可以粘贴你的一个完整的演示。

rSocketRequester.route("...")
                .metadata(token,  MimeTypeUtils.parseMimeType(WellKnownMimeType.MESSAGE_RSOCKET_AUTHENTICATION.getString()))

您需要使用 WellKnownMimeType.MESSAGE_RSOCKET_AUTHENTICATION，因为不推荐使用BearerTokenMetadata.BEARER_AUTHENTICATION_MIME_TYPE。

RSocketRequesterbean配置可以是：

@Bean
fun getRsocketRequester(strategies: RSocketStrategies): RSocketRequester {

    val authenticationMimeType =
        MimeTypeUtils.parseMimeType(WellKnownMimeType.MESSAGE_RSOCKET_AUTHENTICATION.string)

    //build you bearer token
    val bearerMetadata = BearerTokenMetadata(token)

    // add bearer encoder so you will be able to build auth header properly
    val extendedStrategies = strategies.mutate().encoder(BearerTokenAuthenticationEncoder()).build()

    return RSocketRequester.builder()
        .rsocketConnector { rSocketConnector: RSocketConnector ->
            rSocketConnector.reconnect(
                Retry.fixedDelay(
                    2,
                    Duration.ofSeconds(2)
                )
            )
        }
        // pass updated strategy to rsocket builder
        .rsocketStrategies(extendedStrategies)
        // pass your bearer token with up-to-date auth mime type
        .setupMetadata(bearerMetadata, authenticationMimeType)
        .websocket(URI.create("ws://localhost:8090/rsocket"))
}

Petro Prydorozhnyi的答案的java等价物。重要的是token不应该包含Bearer前缀。

String token = "";

    MimeType authenticationMimeType =
            MimeTypeUtils.parseMimeType(WellKnownMimeType.MESSAGE_RSOCKET_AUTHENTICATION.getString());
    
    BearerTokenMetadata bearerMetadata = new BearerTokenMetadata(token);

    RSocketRequester requester = RSocketRequester.builder()
            .rsocketConnector(connector -> {
                connector.reconnect(Retry.fixedDelay(2, Duration.ofSeconds(2)));
            })
            .rsocketStrategies(RSocketStrategies
                    .builder()
                    .encoder(new BearerTokenAuthenticationEncoder())
                    .build())
            .setupMetadata(bearerMetadata, authenticationMimeType)
            .websocket(URI.create("ws://address:7000"));

    requester.rsocketClient().connect(); //Don't forget to connect.

    Thread.sleep(10000);