com.alibaba.spring.boot.rsocket

Class RSocketAutoConfiguration

java.lang.Object

com.alibaba.spring.boot.rsocket.RSocketAutoConfiguration

@Configuration
 @ConditionalOnExpression(value="${rsocket.disabled:false}==false")
 @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
CloudEventsProcessor	cloudEventsProcessor(reactor.extra.processor.TopicProcessor<CloudEventImpl> eventProcessor, org.springframework.beans.factory.ObjectProvider<CloudEventsConsumer> consumers)
CloudEventToListenerConsumer	cloudEventToListenerConsumer()
MetricsService	metricsService(io.micrometer.prometheus.PrometheusMeterRegistry meterRegistry)
reactor.extra.processor.TopicProcessor<CloudEventImpl>	reactiveCloudEventProcessor()
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<CloudEventImpl> eventProcessor) socket responder handler as SocketAcceptor bean.
RSocketResponderHandlerFactory	rsocketResponderHandlerFactoryWithZipkin(LocalReactiveServiceCaller serviceCaller, reactor.extra.processor.TopicProcessor<CloudEventImpl> eventProcessor)
RSocketServiceAnnotationProcessor	rSocketServiceAnnotationProcessor(RSocketProperties rsocketProperties)
RSocketServiceHealth	rsocketServiceHealth()
RSocketServicesPublishHook	rsocketServicesPublishHook()
UpstreamManager	rsocketUpstreamManager(RSocketRequesterSupport rsocketRequesterSupport)
ServiceInstancesChangedEventConsumer	serviceInstancesChangedEventConsumer(UpstreamManager upstreamManager)
UpstreamClusterChangedEventConsumer	upstreamClusterChangedEventConsumer(UpstreamManager upstreamManager)
org.springframework.context.ApplicationListener<org.springframework.boot.web.context.WebServerInitializedEvent>	webServerInitializedEventApplicationListener()

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<CloudEventImpl> reactiveCloudEventProcessor()

cloudEventsProcessor

@Bean(initMethod="init")
public CloudEventsProcessor cloudEventsProcessor(@Autowired @Qualifier(value="reactiveCloudEventProcessor")
                                                                          reactor.extra.processor.TopicProcessor<CloudEventImpl> eventProcessor,
                                                                          org.springframework.beans.factory.ObjectProvider<CloudEventsConsumer> consumers)

upstreamClusterChangedEventConsumer

@Bean
public UpstreamClusterChangedEventConsumer upstreamClusterChangedEventConsumer(@Autowired
                                                                                     UpstreamManager upstreamManager)

serviceInstancesChangedEventConsumer

@Bean
public ServiceInstancesChangedEventConsumer serviceInstancesChangedEventConsumer(@Autowired
                                                                                       UpstreamManager upstreamManager)

cloudEventToListenerConsumer

@Bean
public CloudEventToListenerConsumer cloudEventToListenerConsumer()

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<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<CloudEventImpl> eventProcessor)

rsocketRequesterSupport

@Bean
 @ConditionalOnMissingBean(value=com.alibaba.rsocket.RSocketRequesterSupport.class)
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
 @ConditionalOnMissingBean(value=com.alibaba.rsocket.rpc.LocalReactiveServiceCaller.class)
public RSocketServiceAnnotationProcessor rSocketServiceAnnotationProcessor(RSocketProperties rsocketProperties)

rsocketUpstreamManager

@Bean(initMethod="init")
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()

webServerInitializedEventApplicationListener

@Bean
public org.springframework.context.ApplicationListener<org.springframework.boot.web.context.WebServerInitializedEvent> webServerInitializedEventApplicationListener()