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

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

创建工程

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

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

  1. <dependency>
  2.     <groupId>com.alipay.sofa</groupId>
  3.     <artifactId>sofa-rpc-all</artifactId>
  4.     <version>最新版本</version>
  5. </dependency>

注：最新版本可以从 https://github.com/sofastack/sofa-rpc/releases 里找到。

编写服务端实现

第一步：创建接口

  1. /**
  2.  * Quick Start demo interface
  3.  */
  4. public interface HelloService {
  5.     String sayHello(String string);
  6. }

第二步：创建接口实现

  1. /**
  2.  * Quick Start demo implement
  3.  */
  4. public class HelloServiceImpl implements HelloService {
  5.     @Override
  6.     public String sayHello(String string) {
  7.         System.out.println("Server receive: " + string);
  8.         return "hello " + string + " ！";
  9.     }
  10. }

第三步：编写服务端代码

  1. /**
  2.  * Quick Start Server
  3.  */
  4. public class QuickStartServer {
  6.     public static void main(String[] args) {
  7.         ServerConfig serverConfig = new ServerConfig()
  8.                 .setProtocol("bolt") // 设置一个协议，默认bolt
  9.                 .setPort(12200) // 设置一个端口，默认12200
  10.                 .setDaemon(false); // 非守护线程
  12.         ProviderConfig<HelloService> providerConfig = new ProviderConfig<HelloService>()
  13.                 .setInterfaceId(HelloService.class.getName()) // 指定接口
  14.                 .setRef(new HelloServiceImpl()) // 指定实现
  15.                 .setServer(serverConfig); // 指定服务端
  17.         providerConfig.export(); // 发布服务
  18.     }
  19. }

编写客户端实现

第一步：拿到服务端接口

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

第二步：编程客户端代码

  1. /**
  2.  * Quick Start client
  3.  */
  4. public class QuickStartClient {
  5.     public static void main(String[] args) {
  6.         ConsumerConfig<HelloService> consumerConfig = new ConsumerConfig<HelloService>()
  7.             .setInterfaceId(HelloService.class.getName()) // 指定接口
  8.             .setProtocol("bolt") // 指定协议
  9.             .setDirectUrl("bolt://127.0.0.1:12200"); // 指定直连地址
  10.         // 生成代理类
  11.         HelloService helloService = consumerConfig.refer();
  12.         while (true) {
  13.             System.out.println(helloService.sayHello("world"));
  14.             try {
  15.                 Thread.sleep(2000);
  16.             } catch (Exception e) {
  17.             }
  18.         }
  19.     }
  20. }

运行

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

服务端将打印：

Server receive: world

客户端将打印：

hello world ！

更多

更多示例请参考：example