开源的技术底座技术中台spring cloud Rsocket 微服务

Spring Cloud RSocket 是一个基于 RSocket 协议的项目，它提供了在 Spring Cloud 服务中使用 RSocket 的工具和抽象。RSocket 是一种二进制的网络协议，设计用于提供更高效的数据传输和更低的开销。

以下是一个简单的例子，展示如何使用 Spring Cloud RSocket 创建一个服务提供者和消费者。

服务提供者 (Provider):

1. 添加依赖到 pom.xml:

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-rsocket</artifactId>
    </dependency>
</dependencies>

2. 配置 RSocket 服务:

@Configuration
public class RSocketConfiguration {
    @Bean
    public RSocketServiceRegistration rsocketServiceRegistration(MyService service) {
        return RSocketServiceRegistration.builder()
                .service(MyService.class, service)
                .dataMimeType(MimeTypeUtils.APPLICATION_JSON_VALUE)
                .build();
    }
}

3. 提供服务接口:

public interface MyService {
    Mono<String> hello(String name);
}
 
@Service
public class MyServiceImpl implements MyService {
    @Override
    public Mono<String> hello(String name) {
        return Mono.just("Hello " + name);
    }
}

服务消费者 (Consumer):

1. 添加依赖到 pom.xml:

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-rsocket-core</artifactId>
    </dependency>
</dependencies>

2. 使用 RSocket 客户端调用服务:

@Service
public class MyRSocketService {
 
    private RSocketRequester rSocketRequester;
 
    public MyRSocketService(RSocketRequester.Builder builder) {
        this.rSocketRequester = builder.tcp("localhost", 7000)
                .dataMimeType(MimeTypeUtils.APPLICATION_JSON_VALUE)
                .connectTcp(Duration.ofSeconds(10));
    }
 
    public Mono<String> callHelloService(String name) {
        return rSocketRequester.route("hello")
                .data(name)
                .retrieveMono(String.class);
    }
}

在这个例子中，我们创建了一个简单的服务提供者和消费者，服务提供者使用 RSocket 协议暴露了一个 hello 方法，服务消费者使用 RSocket 客户端连接到服务提供者并调用这个方法。

注意：这只是一个简化的例子，实际使用时需要更多的配置和安全措施。