com.alibaba.spring.boot.rsocket

Class RSocketAutoConfiguration

java.lang.Object

com.alibaba.spring.boot.rsocket.RSocketAutoConfiguration

@Configuration
 @EnableConfigurationProperties(value=RSocketProperties.class)
public class RSocketAutoConfiguration
extends Object

RSocket Auto configuration: listen, upstream manager, handler etc

Author:

leijuan

Constructor Summary

Constructors

Constructor and Description
RSocketAutoConfiguration()

Method Summary

Modifier and Type	Method and Description
MetricsService	metricsService(io.micrometer.prometheus.PrometheusMeterRegistry meterRegistry)
reactor.extra.processor.TopicProcessor<io.cloudevents.v1.CloudEventImpl>	reactiveCloudEventProcessor()
RequesterCloudEventProcessor	requesterCloudEventProcessor()
RSocketBrokerHealthIndicator	rsocketBrokerHealth(RSocketEndpoint rsocketEndpoint, UpstreamManager upstreamManager, String brokers)
RSocketEndpoint	rsocketEndpoint(UpstreamManager upstreamManager, RSocketRequesterSupport rsocketRequesterSupport)
RSocketRequesterSupport	rsocketRequesterSupport(RSocketProperties properties, org.springframework.core.env.Environment environment, io.rsocket.SocketAcceptor socketAcceptor, org.springframework.beans.factory.ObjectProvider<RSocketRequesterSupportCustomizer> customizers)
RSocketResponderHandlerFactory	rsocketResponderHandlerFactory(LocalReactiveServiceCaller serviceCaller, reactor.extra.processor.TopicProcessor<io.cloudevents.v1.CloudEventImpl> eventProcessor) socket responder handler as SocketAcceptor bean.
RSocketResponderHandlerFactory	rsocketResponderHandlerFactoryWithZipkin(LocalReactiveServiceCaller serviceCaller, reactor.extra.processor.TopicProcessor<io.cloudevents.v1.CloudEventImpl> eventProcessor)
RSocketServiceAnnotationProcessor	rSocketServiceAnnotationProcessor(RSocketProperties rsocketProperties)
RSocketServiceHealth	rsocketServiceHealth()
RSocketServicesPublishHook	rsocketServicesPublishHook()
UpstreamManager	rsocketUpstreamManager(RSocketRequesterSupport rsocketRequesterSupport)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RSocketAutoConfiguration

public RSocketAutoConfiguration()

Method Detail

reactiveCloudEventProcessor

@Bean
public reactor.extra.processor.TopicProcessor<io.cloudevents.v1.CloudEventImpl> reactiveCloudEventProcessor()

requesterCloudEventProcessor

@Bean(initMethod="init")
public RequesterCloudEventProcessor requesterCloudEventProcessor()

rsocketResponderHandlerFactory

@Bean
 @ConditionalOnMissingBean(type={"brave.Tracing","com.alibaba.rsocket.listen.RSocketResponderHandlerFactory"})
public RSocketResponderHandlerFactory rsocketResponderHandlerFactory(@Autowired
                                                                                                                                                                                          LocalReactiveServiceCaller serviceCaller,
                                                                                                                                                                                          @Autowired @Qualifier(value="reactiveCloudEventProcessor")
                                                                                                                                                                                          reactor.extra.processor.TopicProcessor<io.cloudevents.v1.CloudEventImpl> eventProcessor)

socket responder handler as SocketAcceptor bean. To validate connection, please use RSocketListenerCustomizer and add AcceptorInterceptor by addSocketAcceptorInterceptor api

Parameters:

serviceCaller - service caller

eventProcessor - event processor

Returns:

handler factor

rsocketResponderHandlerFactoryWithZipkin

@Bean
 @ConditionalOnMissingBean
 @ConditionalOnBean(type="brave.Tracing")
public RSocketResponderHandlerFactory rsocketResponderHandlerFactoryWithZipkin(@Autowired
                                                                                                                                                          LocalReactiveServiceCaller serviceCaller,
                                                                                                                                                          @Autowired @Qualifier(value="reactiveCloudEventProcessor")
                                                                                                                                                          reactor.extra.processor.TopicProcessor<io.cloudevents.v1.CloudEventImpl> eventProcessor)

rsocketRequesterSupport

@Bean
public RSocketRequesterSupport rsocketRequesterSupport(@Autowired
                                                             RSocketProperties properties,
                                                             @Autowired
                                                             org.springframework.core.env.Environment environment,
                                                             @Autowired
                                                             io.rsocket.SocketAcceptor socketAcceptor,
                                                             @Autowired
                                                             org.springframework.beans.factory.ObjectProvider<RSocketRequesterSupportCustomizer> customizers)

rSocketServiceAnnotationProcessor

@Bean
public RSocketServiceAnnotationProcessor rSocketServiceAnnotationProcessor(RSocketProperties rsocketProperties)

rsocketUpstreamManager

@Bean(initMethod="init",
      destroyMethod="close")
public UpstreamManager rsocketUpstreamManager(@Autowired
                                                                                                    RSocketRequesterSupport rsocketRequesterSupport)
                                                                                             throws JwtTokenNotFoundException

Throws:

JwtTokenNotFoundException

rsocketBrokerHealth

@Bean
 @ConditionalOnProperty(value="rsocket.brokers")
public RSocketBrokerHealthIndicator rsocketBrokerHealth(RSocketEndpoint rsocketEndpoint,
                                                                                                               UpstreamManager upstreamManager,
                                                                                                               @Value(value="${rsocket.brokers}")
                                                                                                               String brokers)

rsocketEndpoint

@Bean
public RSocketEndpoint rsocketEndpoint(@Autowired
                                             UpstreamManager upstreamManager,
                                             @Autowired
                                             RSocketRequesterSupport rsocketRequesterSupport)

metricsService

@Bean
 @ConditionalOnClass(value=io.micrometer.prometheus.PrometheusMeterRegistry.class)
public MetricsService metricsService(io.micrometer.prometheus.PrometheusMeterRegistry meterRegistry)

rsocketServicesPublishHook

@Bean
public RSocketServicesPublishHook rsocketServicesPublishHook()

rsocketServiceHealth

@Bean
 @ConditionalOnMissingBean
public RSocketServiceHealth rsocketServiceHealth()