Package com.alibaba.spring.boot.rsocket

Class RSocketAutoConfiguration

java.lang.Object

com.alibaba.spring.boot.rsocket.RSocketAutoConfiguration

@Configuration
@ConditionalOnExpression("${rsocket.disabled:false}==false")
@EnableConfigurationProperties(RSocketProperties.class)
public class RSocketAutoConfiguration
extends Object

RSocket Auto configuration: listen, upstream manager, handler etc

Author:

leijuan

Constructor Summary

Constructors

Constructor	Description
RSocketAutoConfiguration()

Method Summary

Modifier and Type	Method	Description
CloudEventsProcessor	cloudEventsProcessor(reactor.core.publisher.Sinks.Many<CloudEventImpl> eventProcessor, org.springframework.beans.factory.ObjectProvider<CloudEventsConsumer> consumers)
CloudEventToListenerConsumer	cloudEventToListenerConsumer()
MetricsService	metricsService(io.micrometer.prometheus.PrometheusMeterRegistry meterRegistry)
reactor.core.publisher.Sinks.Many<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.core.publisher.Sinks.Many<CloudEventImpl> eventProcessor)	socket responder handler as SocketAcceptor bean.
RSocketResponderHandlerFactory	rsocketResponderHandlerFactoryWithZipkin(LocalReactiveServiceCaller serviceCaller, reactor.core.publisher.Sinks.Many<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 Details

RSocketAutoConfiguration

public RSocketAutoConfiguration()

Method Details

reactiveCloudEventProcessor

@Bean
public reactor.core.publisher.Sinks.Many<CloudEventImpl> reactiveCloudEventProcessor()

cloudEventsProcessor

@Bean(initMethod="init")
public CloudEventsProcessor cloudEventsProcessor(@Autowired @Qualifier("reactiveCloudEventProcessor")
 reactor.core.publisher.Sinks.Many<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("reactiveCloudEventProcessor")
 reactor.core.publisher.Sinks.Many<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("reactiveCloudEventProcessor")
 reactor.core.publisher.Sinks.Many<CloudEventImpl> eventProcessor)

rsocketRequesterSupport

@Bean
@ConditionalOnMissingBean(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(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("rsocket.brokers")
public RSocketBrokerHealthIndicator rsocketBrokerHealth(RSocketEndpoint rsocketEndpoint,
 UpstreamManager upstreamManager,
 @Value("${rsocket.brokers}")
 String brokers)

rsocketEndpoint

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

metricsService

@Bean
@ConditionalOnClass(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()