概述

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

功能特性

透明化、高性能的远程服务调用

支持多种服务路由及负载均衡策略

支持多种注册中心的集成

支持多种协议

支持同步、单向、回调、泛化等多种调用方式

支持集群容错、服务预热、自动故障隔离

强大的扩展功能，可以按需扩展各个功能组件

关联项目

SOFABoot 扩展项目，包括 starter 工程及使用示例。

需要

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

运行需求 JDK 6 及以上。

快速入门

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

您可以直接在工程下找到本文档的。

创建工程

需要安装 JDK 6 及以上和 Maven 3 以上.

我们新建一个 Maven 工程，并引入 SOFARPC 的依赖。


        
     
      com.alipay.sofa
         
     
      sofa-rpc-all
         
     
      5.3.1

编写服务端实现

第一步：创建接口

/** * 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(9696) // 设置一个端口，默认12200                .setDaemon(false); // 非守护线程        ProviderConfig
    
      providerConfig = new ProviderConfig
     
      ()                .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
    
      consumerConfig = new ConsumerConfig
     
      ()            .setInterfaceId(HelloService.class.getName()) // 指定接口            .setProtocol("bolt") // 指定协议            .setDirectUrl("bolt://127.0.0.1:9696"); // 指定直连地址        // 生成代理类        HelloService helloService = consumerConfig.refer();        while (true) {            System.out.println(helloService.sayHello("world"));            try {                Thread.sleep(2000);            } catch (Exception e) {            }        }    }}

运行

分别启动服务端和客户端，观察运行效果。

服务端将打印：

Server receive: world

客户端将打印：

hello world ！

更多示例请参考：

SOFABoot 示例请参考：

来自:https://github.com/alipay/sofa-rpc

转载于:https://my.oschina.net/Rayn/blog/1798221

你可能感兴趣的文章