SOFARPC 是一个高可扩展性、高性能、生产级的 Java RPC 框架。SOFARPC 致力于简化应用之间的 RPC 调用，为应用提供方便透明、稳定高效的点对点远程服务调用方案。为了用户和开发者方便的进行功能扩展，SOFARPC 提供了丰富的模型抽象和可扩展接口，包括过滤器、路由、负载均衡等等。同时围绕 SOFARPC 框架及其周边组件提供丰富的微服务治理方案。
功能特性
- 透明化、高性能的远程服务调用
- 支持多种服务路由及负载均衡策略
- 支持多种注册中心的集成
- 支持多种协议，包括 Bolt、Rest、Dubbo 等
- 支持同步、单向、回调、泛化等多种调用方式
- 支持集群容错、服务预热、自动故障隔离
- 强大的扩展功能，可以按需扩展各个功能组件
项目中通过mvn依赖或gradle依赖引入sofa rpc包，使用mvn依赖：
<dependency>
<groupId>com.alipay.sofa</groupId>
<artifactId>sofa-rpc-all</artifactId>
<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 ！
参考：