sofa rpc入门

傷城~ 2021-09-22 19:48 309阅读 0赞

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

### 功能特性 ###

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

项目中通过mvn依赖或gradle依赖引入sofa rpc包，使用mvn依赖：

<groupId>com.alipay.sofa</groupId>

<version>最新版本号</version>

</dependency>

gradle依赖方式：

compile group: 'com.alipay.sofa', name: 'sofa-rpc-all', version: '最新版本号'

### 服务发布 ###

服务发布过程涉及到三个类 RegistryConfig ，ServerConfig ，ProviderConfig 。

1、RegistryConfig注册中心配置类

RegistryConfig registryConfig = new RegistryConfig()
                .setProtocol("zookeeper")
                .setAddress("127.0.0.1:2181")

RegistryConfig 表示注册中心。如上声明了服务注册中心的地址和端口是127.0.0.1:2181，协议是 Zookeeper 。

2、ServerConfig服务运行容器配置类

ServerConfig serverConfig = new ServerConfig()
                .setPort(8803)
                .setProtocol("bolt");

ServerConfig 表示服务运行容器。如上声明了一个使用8803端口和 bolt 协议的 server 。

3、ProviderConfig服务发布配置类

ProviderConfig<HelloWorldService> providerConfig = new ProviderConfig<HelloWorldService>()
                .setInterfaceId(HelloWorldService.class.getName())    
                .setRef(new HelloWorldServiceImpl())    
                .setServer(serverConfig)  
                .setRegistry(registryConfig);
    providerConfig.export();

ProviderConfig 表示服务发布，用来设置接口名称、接口实现类引用以及指定服务端配置；如上声明了服务的接口，实现和该服务运行的 server 。 最终通过 export 方法将这个服务发布出去了。

### 服务引用 ###

服务引用涉及到两个类， RegistryConfig 和 ConsumerConfig 。

1、ConsumerConfig服务引用配置类

ConsumerConfig<HelloService> consumerConfig = new ConsumerConfig<HelloService>()
                .setInterfaceId(HelloService.class.getName())       
                .setRegistry(registryConfig);
    HelloService helloService = consumerConfig.refer();

ConsumerConfig 表示服务引用，如上声明了所引用服务的接口和服务注册中心。 最终通过 refer 方法将这个服务引用，获取到该服务的远程调用的代理。

SOFARPC服务引用支持如下特性：

(1)同一服务注册多个注册中心，构建多个RegistryConfig设置给 ConsumerConfig

List<RegistryConfig> registryConfigs = new ArrayList<RegistryConfig>();
    registryConfigs.add(registryA);
    registryConfigs.add(registryB);
    consumerConfig.setRegistry(registryConfigs);

(2)提供MethodConfig进行方法级别参数设置，API方式使用相应的对象set法即可为其设置参数

MethodConfig methodConfigA = new MethodConfig();
    MethodConfig methodConfigB = new MethodConfig();
    List<MethodConfig> methodConfigs = new ArrayList<MethodConfig>();
    methodConfigs.add(methodConfigA);
    methodConfigs.add(methodConfigB);   
    consumerConfig.setMethods(methodConfigs);  //客户端设置

下面我们写一个简单的例子来说明一下

编写服务端实现

第一步：创建接口

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

第二步：创建接口实现

/**
     * 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(); // 发布服务
        }
    }

### 编写客户端实现 ###

第一步：拿到服务端接口

一般服务端会通过jar的形式将接口类提供给客户端。而在本例中，由于服务端和客户端在一个工程所以跳过。

第二步：编程客户端代码

/**
     * 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 ！

参考：

[https://blog.csdn.net/qq924862077/article/details/81915213][https_blog.csdn.net_qq924862077_article_details_81915213]

[https://www.jianshu.com/p/47816d0f1317][https_www.jianshu.com_p_47816d0f1317]

[https_blog.csdn.net_qq924862077_article_details_81915213]: https://blog.csdn.net/qq924862077/article/details/81915213
[https_www.jianshu.com_p_47816d0f1317]: https://www.jianshu.com/p/47816d0f1317