蚂蚁金服 Java RPC 开源框架—SOFARPC

「爱情、让人受尽委屈。」 2022-01-29 13:01 337阅读 0赞

#### SOFARPC 简介 ####

SOFARPC 是一个高可扩展性、高性能、生产级的 Java RPC 框架。在蚂蚁金服 SOFARPC 已经经历了十多年及五代版本的发展。SOFARPC 致力于简化应用之间的 RPC 调用，为应用提供方便透明、稳定高效的点对点远程服务调用方案。为了用户和开发者方便的进行功能扩展，SOFARPC 提供了丰富的模型抽象和可扩展接口，包括过滤器、路由、负载均衡等等。同时围绕 SOFARPC 框架及其周边组件提供丰富的微服务治理方案。

#### 功能特性 ####

*  透明化、高性能的远程服务调用
 *  支持多种服务路由及负载均衡策略
 *  支持多种注册中心的集成
 *  支持多种协议，包括 Bolt、Rest、Dubbo 等
 *  支持同步、单向、回调、泛化等多种调用方式
 *  支持集群容错、服务预热、自动故障隔离
 *  强大的扩展功能，可以按需扩展各个功能组件

#### 开发环境支持 ####

1、编译需要 JDK 7 及以上、Maven 3.2.5 及以上  
2、运行需求 JDK 6 及以上

#### 基本原理 ####

![SOFARPC][]  
1、当一个 SOFARPC 的应用启动的时候，如果发现当前应用需要发布 RPC 服务的话，那么 SOFARPC 会将这些服务注册到服务注册中心上。如图中 Service 指向 Registry。  
2、当引用这个服务的 SOFARPC 应用启动时，会从服务注册中心订阅到相应服务的元数据信息。服务注册中心收到订阅请求后，会将发布方的元数据列表实时推送给服务引用方。如图中 Registry 指向 Reference。  
3、当服务引用方拿到地址以后，就可以从中选取地址发起调用了。如图中 Reference 指向 Service。

#### 快速开始 ####

演示如何应用 SOFARPC 进行服务的发布和引用。 本例将在本地模拟服务端启动监听一个端口并发布一个服务，客户端引用该服务进行直连调用。

##### 第一步：新建一个 Maven 工程，并引入 SOFARPC 的依赖 #####

<dependency>
        <groupId>com.alipay.sofa</groupId>
        <artifactId>sofa-rpc-all</artifactId>
        <version>5.5.3</version>
    </dependency>

版本下载地址：[https://mvnrepository.com/artifact/com.alipay.sofa/sofa-rpc-all/][https_mvnrepository.com_artifact_com.alipay.sofa_sofa-rpc-all]

##### 第二步：编写服务端实现 #####

**创建接口HelloService**

/**
     * Quick Start demo interface
     */
    public interface HelloService {
        String sayHello(String string);
    }

**创建接口实现HelloServiceImpl**

/**
     * Quick Start demo implement
     */
    public class HelloServiceImpl implements HelloService {
        @Override
        public String sayHello(String string) {
            System.out.println("Server receive: " + string);
            return "hello " + string + " ！";
        }
    }

**编写服务端代码**

/**
     * Quick Start Server
     */
    public class QuickStartServer {
    
        public static void main(String[] args) {
            ServerConfig serverConfig = new ServerConfig()
                    .setProtocol("bolt") // 设置一个协议，默认bolt
                    .setPort(12200) // 设置一个端口，默认12200
                    .setDaemon(false); // 非守护线程
    
            ProviderConfig<HelloService> providerConfig = new ProviderConfig<HelloService>()
                    .setInterfaceId(HelloService.class.getName()) // 指定接口
                    .setRef(new HelloServiceImpl()) // 指定实现
                    .setServer(serverConfig); // 指定服务端
    
            providerConfig.export(); // 发布服务
        }
    }

**编写客户端实现**

/**
     * Quick Start client
     */
    public class QuickStartClient {
        public static void main(String[] args) {
            ConsumerConfig<HelloService> consumerConfig = new ConsumerConfig<HelloService>()
                .setInterfaceId(HelloService.class.getName()) // 指定接口
                .setProtocol("bolt") // 指定协议
                .setDirectUrl("bolt://127.0.0.1:12200"); // 指定直连地址
            // 生成代理类
            HelloService helloService = consumerConfig.refer();
            while (true) {
                System.out.println(helloService.sayHello("world"));
                try {
                    Thread.sleep(2000);
                } catch (Exception e) {
                }
            }
        }
    }

**运行**  
分别启动服务端和客户端，观察运行效果。  
服务端将打印：

Server receive: world

客户端将打印：

hello world ！

#### 小结 ####

是不是发现，SOFA-RPC 与Dubbo、Motan 并无太大的区别。Dubbo 作为整套服务治理而存在，而 SOFA-RPC 只是一款轻量级的 RPC 框架，基于 HSF 框架改造，提供更加完善、强大的、多样化 RPC 编程 API。

#### 最新版本v5.5.3发布内容 ####

SOFARPC v5.5.3这是一个 Bug Fix 的版本，鼓励目前正在使用 5.5.x 版本的用户升级。  
**1、兼容性**  
没有不兼容问题

**3、BUG 修复**

*  修复特殊场景下路由重复的问题
 *  兼容 Tracer 的采样标识
 *  修复泛化调用再次重试的问题

![关注我们][1240]

## 贡献者 ##

*  [IT实战联盟-Line][IT_-Line]

#### 更多精彩内容可以关注“IT实战联盟”公*众*号哦~~~ ####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poZW5naGhneg_size_16_color_FFFFFF_t_70]

[SOFARPC]: /images/20220129/637560309eff46ac9a2947e21772864d.png
[https_mvnrepository.com_artifact_com.alipay.sofa_sofa-rpc-all]: https://mvnrepository.com/artifact/com.alipay.sofa/sofa-rpc-all/
[1240]: /images/20220129/adc139b1fb8141fabc1a73027153a31f.png
[IT_-Line]: https://www.jianshu.com/u/283f93ada597
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poZW5naGhneg_size_16_color_FFFFFF_t_70]: /images/20220129/c7a63ceaf74d48d5a6ecd625abc3b62a.png