search

alibaba / alibaba-rsocket-broker

Alibaba RSocket Broker: Mesh, Streaming & IoT
https://alibroker.info
Apache License 2.0
761 stars 165 forks source link
alibaba broker grpc iot rpc rsocket service-mesh

readme

logo

Gitter Maven GitHub repo size Open Issues Build Status Apache License 2

项目存档通知

随着阿里业务发展和技术更新迭代，alibaba-rsocket-broker项目将会进行archive操作（即存档仓库）。 预计存档时间：2024年7月5日，项目存档后，issue、拉取请求、代码、标签、重要事件、wiki、版本、提交、标记、分支等变成只读状态，项目仍然可以fork以及标星。

目前社区替代的开源项目为 https://github.com/reactive-rsocket-broker ，欢迎大家继续使用、贡献。

Alibaba RSocket Broker是一款基于RSocket协议的反应式对等通讯系统，为通讯多方构建分布式的RPC, Pub/Sub, Streaming等通讯支持。

更多RSocket Broker资源和介绍，请访问以下资源：

RSocket Broker工作原理

RSocket Broker桥接应用间通讯的双方，相当于一个中间人的角色。 应用在启动后，和Broker创建一个长连接，在连接创建的时候需要标明自己的身份，如果是服务提供者，会注册自己能提供的服务信息。 Broker会针对所有的连接和服务列表建立对应的映射关系。 当一个应用需要调用其他服务时，应用会将请求以消息的方式发给Broker，然后Broker会解析消息的元信息，然后根据路由表将请求转发给服务提供者，然后将处理结果后的消息再转发给调用方。 Broker完全是异步化的，你不需要关心线程池这些概念，而且消息转发都是基于Zero Copy，所以性能非常高，这也是为何不用担心中心化Broker成为性能瓶颈的主要原因。

RSocket Broker Structure

通过上述的架构图，RSocket Broker彻底解决了传统设计中众多的问题：

项目模块

开发环境要求

如何运行Example?

注意: 样例代码中的AccountService接口采用了Protobuf进行序列化，使用了protobuf-maven-plugin生成对应的Protobuf, 建议使用IDE导入项目之前，首先在项目的根目录下执行一下"mvn -DskipTests package" 完成Protobuf对应的代码生成，不然直接在IDE中编译可能出现编译不通过的情况。

项目提供了完成的样例，你可以在example模块下找到，包括服务接口定义、服务实现和服务调用三个部分。

启动RSocket Broker
运行 RSocket Responder & Requester
$ curl http://localhost:8181/user/2

样例的详细介绍请访问 Example

RSocket服务编写流程

包括如何创建一个Reactive服务接口，在Responder端实现该接口，在Requester完成Reactive服务调用，以及通讯双方是如何和Broker交互的。

public interface UserService {
    Mono<User> findById(Integer id);
}

@RSocketService(serviceInterface = UserService.class)
@Service
public class UserServiceImpl implements UserService {
    @Override
    public Mono<User> findById(Integer id) {
        return Mono.just(new User(1, "nick:" + id));
    }
}

不少开发者会问道，如果是MySQL数据库，如何和Reactive集成。目前R2DBC有对MySQL的支持，你可以参考一个Spring Cloud RSocket + R2DBC + MySQL的Demo实现: https://github.com/linux-china/spring-cloud-function-demo/

    @Bean
    public UserService userService(@Autowired UpstreamManager upstreamManager) {
        return RSocketRemoteServiceBuilder
                .client(UserService.class)
                .upstreamManager(upstreamManager)
                .build();
    }

@RestController
public class PortalController {
    @Autowired
    UserService userService;

    @GetMapping("/user/{id}")
    public Mono<User> user(@PathVariable Integer id) {
        return userService.findById(id);
    }
}

样例项目请参考： https://github.com/alibaba-rsocket-broker/rsocket-broker-simple-example

References