考虑到方便Java开发人员更快启动Alibaba RSocket Broker进行本地测试，Alibaba RSocket Broker提供Jbang支持，现在你只需要执行以下命令就可以启动RSocket Broker。
jbang rsocket-broker@alibaba
JBang的安装请参考： https://www.jbang.dev/download/ ，如Mac下执行 brew install jbangdev/tap/jbang 即可。
如果你本机已经安装了Docker Compose，那么使用Docker Compose启动RSocket Broker也是没有问题的，如下：
version: "3"
services:
alibaba-rsocket-broker:
image: linuxchina/alibaba-rsocket-broker:1.1.2
ports:
- "9997:9997"
- "9998:9998"
- "9999:9999"
Java 17正式发布已经有一周多啦，Java 17作为LTS版本，而且从11到17版本增加了大量特性，收到非常多的开发者关注，大家也积极将自己的产品和Java 17进行兼容。
Alibaba RSocket Broker主要基于RSocket Java SDK和Spring Boot进行开发，伴随着Spring Boot 2.5.5的发布，Spring Boot已经全面兼容ava 17， 在此基础上，我们也对Alibaba RSocket Broker进行全面Java 17兼容测试。 结果向大家汇报一下： Alibaba RSocket Broker全面兼容JDK 17，你可以放心使用JDK + RSocket Broker SDK开发你的应用。
最后希望越来越多的Java开发者升级到Java 17，提升开发效率的同时，享受编程带来的喜悦。 :)
在当前的架构设计和开发中，HTTP REST API还是扮演着重要的角色，但是GraphQL和RSocket对比HTTP REST提供更丰富的特性和更高的性能。 如果能在当前的架构设计中能透明增加GraphQL和RSocket支持将是非常好的事情。
现在你只需为HTTP REST Controller添加几个Annotation，就可以同时支持HTTP REST， GraphQL和RSocket三者。 高效通讯的走RSocket，数据聚合的走GraphQL，传统的走HTTP REST。
当然你也可以选择GraphQL over RSocket，你只需要添加以下代码即可：
@Autowired
private GraphQlService graphQlService;
@MessageMapping("graphql")
public Mono<Map<String, Object>> graphql(Map<String, Object> input) {
final RequestInput requestInput = new RequestInput((String) input.get("query"),
(String) input.get("operationName"),
(Map<String, Object>) input.get("variables"));
return graphQlService.execute(requestInput)
.map(ExecutionResult::toSpecification);
}
如果你对该方案有兴趣，可以参考Demo样例： https://github.com/linux-china/rest-graphql-rsocket-demo
从1.1.1版本开始，我们决定对RSocket Broker进行瘦身，一味地叠加特性不是好的设计策略。 将核心功能做的更加可靠，并提供更好的扩展才是好的设计策略，同时让RSocket Broker也能更小。 所以在1.1.1的版本中，我们将以下功能从RSocket Broker的核心代码移除：
如果你使用Kubernetes，那么建议看一下 Alibaba RSocket Broker Helm chart .
GraphQL在数据查询领域扮演者非常重要的角色，个人觉得GraphQL、OpenAPI和AsyncAPI这三者相辅相成，都是服务自描述，不需要单独的文档说明；包括完成的Schema，如数据类型等； 完备的元数据支持等。
GraphQL服务主要是基于HTTP通讯，如query, mutation基于HTTP GET和POST，subscription则基于WebSocket。 这篇文章我们主要是讨论如何基于RSocket来实现GraphQL远程服务。 为何要选择RSocket来实现GraphQL通讯，原因如下：
在RSocket的架构中，通常都会选择基于RSocket Broker设计方案，也就是由RSocket Broker程度着通讯双方流量转发的角色，所以我们会基于RSocket Broker说明。
我们只需要构建一个GraphQL Server，如你可以选择graphql-java-spring-boot-starter-webflux，注意要选择WebFlux :)
<dependency>
<groupId>com.graphql-java</groupId>
<artifactId>graphql-java-spring-boot-starter-webflux</artifactId>
<version>2.0</version>
</dependency>
稍微说明一下：graphql-java-spring-boot-starter-webflux会调用 graphQL.executeAsync(executionInput) 进行GraphQL异步化的操作，所以刚好和WebFlux无缝对接。
接下来就是让GraphQL的DataFetcher和Rsocket Broker通讯，调用各种RSocket Domain Service，获取对应的数据。 由于RSocket Broker管理着众多的服务，所有RSocket Broker管理的服务都可以被DataFetcher调用，可以说非常方便，架构如下：
DataFetcher异步化： 这里我选择的是graphql-java，而DataFetcher的泛型是支持CompletableFuture，而Java Reactive框架都支持和CompletableFuture转换的，看一下样例代码：
public DataFetcher<CompletableFuture<Map<String, Object>>> bookById() {
return dataFetchingEnvironment -> {
String bookId = dataFetchingEnvironment.getArgument("id");
return Flux.fromIterable(BOOKS)
.filter(book -> book.get("id").equals(bookId))
.next()
.toFuture();
};
}
即便不是GraphQL RSocket方案，如果你做GraphQL异步化时，也要利用好CompletableFuture特性，可以方便你和各种Reactive框架对接，包含异步RPC，R2DBC等。
备注： 如果你使用Netflix的DGS GraphQL框架，从4.2.0版本开始，Mono/Flux可以作为Data Fetcher的返回类型，也就是DGS默认就支持Reactive框架。
GraphQL其实并不特别复杂，JS/TS对GraphQL的支持不用说啦，我这里以graphql-java为例，我会实现领域服务的同时，也会对外提供GraphQL服务，主要是GraphQL的DataFetcher对接数据库、NoSQL等就非常很多，也发布我们构建相对复杂的查询。 在Domain服务和GraphQL服务合二为一的架构下，下图结构可能就方便 一些：
在上述的架构设计中，GraphQL Service有不同的系统自行考虑，这个时候就会出现多个不同的GraphQL Service，所以你需要了解你要查询的GraphQL Service是什么。 这里我们介入一个namespace的感念，其实就是GraphQL的服务名称，一来方便RSocket Broker的路由，而来方便定位GraphQL Service。 所以在GraphQL Gateway上，你要访问的GraphQL服务的HTTP URL则如下：
http://localhost:8383/com.alibaba.rsocket.graphql.book.BookGraphqlService/graphql
你不用太担心，RSocket Broker包含所有的信息GraphQL服务的元信息，通过GraphQL Introspection，你是可以发现整个集群的所有GraphQL Schema信息，方便你构建GraphQL服务查询系统。
个人觉得方案2更合适点，主要是GraphQL Service和domain Service是在一起的，都是一拨人开发的，他们对需求的把握的非常好，而且GraphQL Schema设计可能更合理一些。
方案1主要是用在GraphQL对接上，如公司内部并没有GraphQL需求，都是在使用OpenAPI和RPC，但是合作伙伴可能希望使用GraphQL，主要是对应的业务场景更合适，所以这个时候增加一个GraphQL Gateway来对接目前的RSocket服务、OpenAPI或RPC等，可能比较简单一些。
前面说到，GraphQL和RSocket的配合比较好，如果我不选择HTTP通讯方案，而选择RSocket通讯协议，那我们应该如何做？ 其实非常简单，给出一个样例的GraphqlRSocketClient样例代码：
public interface GraphqlRSocketClient {
Mono<ByteBuf> query(String query, Map<String, Object> variables);
Mono<ByteBuf> mutation(String mutation, Map<String, Object> variables);
Flux<ByteBuf> subscription(String subscription, Map<String, Object> variables);
}
当然在构建GraphqlRSocketClient我们会接入GraphQL服务的namespace作为RSocket的路由信息，接下来就是和RSocket Broker通讯，这个实现还是非常简单的。在代码样例中，也会包含对应的代码。
RSocket GraphQL Gateway样例代码： https://github.com/alibaba-rsocket-broker/rsocket-graphql-gateway
最新发布的CloudEvents Java SDK 2.1.0添加了RSocket支持，主要CloudEvents对应的cloudevents-spring模块，Maven依赖如下：
<dependency>
<groupId>io.cloudevents</groupId>
<artifactId>cloudevents-spring</artifactId>
<version>2.1.0</version>
</dependency>
这样特性主要就是CloudEvent接口类型可以作为API函数的参数或者返回值类型，这样就省去了对CloudEvent进行转换的操作，代码如下：
@MessageMapping("event")
public Mono<CloudEvent> event(@RequestBody Mono<CloudEvent> body) {
return body.map(event -> CloudEventBuilder.from(event) //
.withId(UUID.randomUUID().toString()) //
.withSource(URI.create("https://spring.io/foos")) //
.withType("io.spring.event.Foo") //
.withData(event.getData().toBytes()) //
.build());
}
为了达到上述的效果，你只需要添加一个RSocketStrategiesCustomizer bean，添加添加CloudEvent对应的encoder和decoder就可以，如下：
@Bean
@Order(-1)
public RSocketStrategiesCustomizer cloudEventsCustomizer() {
return new RSocketStrategiesCustomizer() {
@Override
public void customize(Builder strategies) {
strategies.encoder(new CloudEventEncoder());
strategies.decoder(new CloudEventDecoder());
}
};
}
在启动Spring Boot RSocket应用后，你就可以使用一下命令进行测试：
rsc --request --dataMimeType=application/cloudevents+json --route=event \
--data='{"data": {"value": "Foo"},
"id": "1",
"source": "cloud-event-example",
"type": "my.application.Foo",
"specversion": "1.0"}' \
--debug tcp://localhost:7000
当然Alibaba RSocket Broker在1.1.0版本也增加了CloudEvent接口支持，你同样可以在API函数中使用CloudEvent作为参数和返回值。
注意: 如果你使用CloudEvent作为参数类型，那么只能传递一个CloudEvent参数值，当然CloudEvent本身就包括数据和扩展，对实际使用没有任何影响。
CloudEvents Spring RSocket样例代码： https://github.com/cloudevents/sdk-java/blob/master/examples/spring-rsocket/pom.xml
启动RSocket Broker非常简单，但是考虑开发的流畅性，我们推出了一个免费的Alibaba RSocket Broker提供给大家测试使用，请注意，是测试，不是产品环境。 :)
使用非常简单，首先我们将rsocket.brokers调整为线上服务列表，如下
rsocket.brokers=tcp://139.196.223.16:9999,tcp://139.196.223.138:9999
接下来我们执行一下 curl https://jwt.alibroker.info 获取对应的JWT token，然后设置为rsocket.jwt-token的属性值，如下：
rsocket.jwt-token=xxx
最后启动你的RSocket应用进行测试就可以。 详细的样例，你可以参考： https://github.com/alibaba-rsocket-broker/rsocket-broker-simple-example
借助于RSocket Cloud Broker，下图架构完全没有问题，你可以马上使用免费的RSocket Broker测试起来。
Alibaba RSocket Broker 1.1.0版本增加了Kubernetes的支持， 部署也不是特别麻烦，就是大家都懂的kubectl apply -f deployment.yaml， 考虑到K8S社区还是基于Helm部署为主，所以我们添加了RSocket Broker Helm Chart，借助Helm更方便地管理RSocket Broker部署。
详细的信息请参考： https://artifacthub.io/packages/helm/alibaba-rsocket-broker/alibaba-rsocket-broker
RSocket Broker的Helm安装步骤如下：
helm repo add alibaba-rsocket-broker https://alibaba-rsocket-broker.github.io/helm/charts/
helm install rsocket-broker alibaba-rsocket-broker/alibaba-rsocket-broker
在使用Helm安装RSocket Broker完毕后，我们建议使用rsocket-box来验证RSocket Broker是否正常工作，命令行如下：
kubectl run -i --rm --tty rsocket-box --image=linuxchina/rsocket-box --restart=Never --image-pull-policy=Always
然后调用alirsc对rsocket broker的集群进行服务测试，如查看Broker集群的拓扑结构：
$ alirsc tcp://rsocket-broker.rsocket.svc.cluster.local:9999 --request --route com.alibaba.user.UserService.findById -d '[1]'
RSocket Broker 1.1基于RSocket Java 1.1.0和Spring Boot 2.4.x开发，紧跟当前最新的技术，但是alibaba-rsocket-spring-boot-starter还是兼容Spring Boot 2.3.x的，Broker Server则调整为基于Spring Boot 2.4.x版本开发，主要是性能等方面的要求。
server.shutdown=graceful即可