SOFA原理学习

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

SOFARPC 简介

   

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 及以上。

文档

• 快速开始
• 用户手册
• 开发者指南
• 发布历史
• 发展路线

示例：

1、引入sofa-rpc相关的jar

1. <dependency>
2. <groupId>com.alipay.sofa</groupId>
3. <artifactId>sofa-rpc-all</artifactId>
4. <version>5.3.1</version>
5. </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、客户端引用服务

1. public class ClientMain {
3. public static void main(String[] args) {
4. // 指定注册中心
5. RegistryConfig registryConfig = new RegistryConfig()
6. .setProtocol('zookeeper')
7. .setAddress('127.0.0.1:2181');
8. // 引用一个服务
9. ConsumerConfig<HelloService> consumerConfig = new ConsumerConfig<HelloService>()
10. .setInterfaceId(HelloService.class.getName())
11. .setProtocol('bolt')
12. .setRegistry(registryConfig);
13. // 拿到代理类
14. HelloService service = consumerConfig.refer();
16. // 发起调用
17. while (true) {
18. System.out.println(service.sayHello('world'));
19. try {
20. Thread.sleep(1000);
21. } catch (InterruptedException e) {
22. }
23. }
24. }
25. }

4、服务接口及实现类

（1）接口

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

（2）实现类

1. public class HelloServiceImpl implements HelloService {
3. public String sayHello(String name) {
4. return 'hello ' name;
5. }
6. }

5、运行结果

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

（2）运行结果数据

6、sofa-rpc调用流程

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

参见：