SOFA原理学习--sofa rpc入门示例

女爷i 2022-05-14 22:17 358阅读 0赞

最近在项目开发中有用到sofa-rpc框架，其是蚂蚁金服开源的，简单的看了一下源码其和阿里巴巴另外一个比较出名的RPC框架Dubbo类似，其实sofa-rpc提供的dubbo协议最终就是使用的Dubbo的功能（sofa-rpc直接将dubbo的jar引入），所以如果对Dubbo有所了解的人我感觉在sofa-rpc学习上也是很快的。

# SOFARPC 简介 #

[![Build Status][]][Build Status 1] [![Coverage Status][]][Coverage Status 1] [![License][]][License] [![Maven][]][Maven 1]

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

## 功能特性 ##

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

## 关联项目 ##

*  [sofa-rpc-boot-project][] SOFABoot 扩展项目，包括 starter 工程及使用示例。

## 需要 ##

编译需要 JDK 7 及以上、Maven 3.2.5 及以上。

运行需求 JDK 6 及以上。

## 文档 ##

*  [快速开始][Link 1]
 *  [用户手册][Link 2]
 *  [开发者指南][Link 3]
 *  [发布历史][Link 4]
 *  [发展路线][Link 5]

示例：

1、引入sofa-rpc相关的jar

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

2、服务端发布服务，sofa-rpc支持zookeeper作为注册中心

public class ServerMain {
        public static void main(String[] args) {
            // 指定注册中心
            RegistryConfig registryConfig = new RegistryConfig()
                    .setProtocol("zookeeper")
                    .setAddress("127.0.0.1:2181");
            // 指定服务端协议和地址
            ServerConfig serverConfig = new ServerConfig()
                    .setProtocol("bolt")
                    .setPort(12345)
                    .setDaemon(false);
            //　发布一个服务
            ProviderConfig<HelloService> providerConfig = new ProviderConfig<HelloService>()
                    .setInterfaceId(HelloService.class.getName())
                    .setRef(new HelloServiceImpl())
                    .setRegistry(registryConfig)
                    .setServer(serverConfig);
            providerConfig.export();
        }
    }

3、客户端引用服务

public class ClientMain {
    
        public static void main(String[] args) {
            // 指定注册中心
            RegistryConfig registryConfig = new RegistryConfig()
                    .setProtocol("zookeeper")
                    .setAddress("127.0.0.1:2181");
            // 引用一个服务
            ConsumerConfig<HelloService> consumerConfig = new ConsumerConfig<HelloService>()
                    .setInterfaceId(HelloService.class.getName())
                    .setProtocol("bolt")
                    .setRegistry(registryConfig);
            // 拿到代理类
            HelloService service = consumerConfig.refer();
            
            // 发起调用
            while (true) {
                System.out.println(service.sayHello("world"));
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                }
            }
        }
    }

4、服务接口及实现类

（1）接口

public interface HelloService {
        
        public String sayHello(String name);
    }

（2）实现类

public class HelloServiceImpl implements HelloService {
    
        public String sayHello(String name) {
            return "hello " + name;
        }
    }

5、运行结果

（1）zookeeper中生产者和消费者节点

![70][]

（2）运行结果数据

![70 1][]

6、sofa-rpc调用流程

客户端模块是一个较复杂的模块，这里包含了集群管理、路由、地址管理器、连接管理器、负载均衡器，还与代理、注册中心等模块交互。

参见：

![client组件][client]

[Build Status]: https://camo.githubusercontent.com/561e21d5d5d2b9555823a40c46478d6f61c8500b/68747470733a2f2f7472617669732d63692e6f72672f616c697061792f736f66612d7270632e7376673f6272616e63683d6d6173746572
[Build Status 1]: https://travis-ci.org/alipay/sofa-rpc
[Coverage Status]: https://camo.githubusercontent.com/4db9e534b75ed3fb4db0116b1b1921ebc50622f5/68747470733a2f2f636f6465636f762e696f2f67682f616c697061792f736f66612d7270632f6272616e63682f6d61737465722f67726170682f62616467652e737667
[Coverage Status 1]: https://codecov.io/gh/alipay/sofa-rpc
[License]: https://camo.githubusercontent.com/b476de7a12afe41ab3d873a26f0d891dd083e48e/68747470733a2f2f696d672e736869656c64732e696f2f62616467652f6c6963656e73652d4170616368652d2d322e302d677265656e2e737667
[Maven]: /images/20220515/8340196567d9421c93f1225c20026647.png
[Maven 1]: https://github.com/alipay/sofa-rpc/releases
[sofa-rpc-boot-project]: https://github.com/alipay/sofa-rpc-boot-projects
[Link 1]: http://www.sofastack.tech/sofa-rpc/docs/Getting-Started-With-SOFA-Boot
[Link 2]: http://www.sofastack.tech/sofa-rpc/docs/Programming
[Link 3]: http://www.sofastack.tech/sofa-rpc/docs/How-To-Build
[Link 4]: http://www.sofastack.tech/sofa-rpc/docs/ReleaseNotes
[Link 5]: http://www.sofastack.tech/sofa-rpc/docs/RoadMap
[70]: /images/20220515/9dce9ae00b6f4fc08acd603e1409cb97.png
[70 1]: /images/20220515/8598060763e84c4d9bb4bd0a8d4d6f22.png
[client]: /images/20220515/d5b455162335402a8d72580a13240888.png