如何开发基于Dubbo RPC的分布式服务？

什么是Dubbo？

Dubbo[]是一个分布式服务框架，致力于提供高性能和透明化的RPC远程服务调用方案，以及SOA服务治理方案。

其核心部分包含:

• 远程通讯: 提供对多种基于长连接的NIO框架抽象封装，包括多种线程模型，序列化，以及“请求-响应”模式的信息交换方式。
• 集群容错: 提供基于接口方法的透明远程过程调用，包括多协议支持，以及软负载均衡，失败容错，地址路由，动态配置等集群支持。
• 自动发现: 基于注册中心目录服务，使服务消费方能动态的查找服务提供方，使地址透明，使服务提供方可以平滑增加或减少机器。

Dubbo能做什么？

• 透明化的远程方法调用，就像调用本地方法一样调用远程方法，只需简单配置，没有任何API侵入。
• 软负载均衡及容错机制，可在内网替代F5等硬件负载均衡器，降低成本，减少单点。
• 服务自动注册与发现，不再需要写死服务提供方地址，注册中心基于接口名查询服务提供者的IP地址，并且能够平滑添加或删除服务提供者。

想了解跟多关于Dubbo的信息，请查看：http://alibaba.github.io/dubbo-doc-static/Home-zh.htm

在Crystal框架下，如何开发基于Dubbo RPC的服务？

第一步：定义接口

1. 创建接口Jar项目，如：test-dubbo-service-api；

2. 创建接口类和接口方法，和通常的接口定义没有什么区别，如：

   public interface TestService {
       /**
        *
        * @param a
        * @return
        */
       public String test(String a);
   }

第二步：实现并发布服务

1. 创建服务实现项目，如：test-dubbo-service-impl；

2. 引入接口项目（test-dubbo-service-api）、Crystal框架dubbo服务支持包（crystal-remote-server-dubbo），如：

   <dependency>
       <groupId>com.gsoft.test</groupId>
       <artifactId>test-dubbo-service-api</artifactId>
   </dependency>
   <dependency>
       <groupId>com.gsoft.crystal</groupId>
       <artifactId>crystal-remote-server-dubbo</artifactId>
   </dependency>

3. 实现服务接口，如：

   @Service
   public class TestServiceImpl implements TestService {
       @Value("${crystal.application.name}")
       private String name;
       /*
        * (non-Javadoc)
        *
        * @see com.gsoft.test.dubbo.TestService#test(java.lang.String)
        */
       @Override
       public String test(String a) {
           return "Hello, " + a + "! " + " I‘m " + name + " " + System.getenv("LOGONSERVER") + ".";
       }
   }

4. 在实现类上添加注解@Service，此处Service为dubbo服务的声明注解com.alibaba.dubbo.config.annotation.Service，到此，基于Dubbo发布的服务已经开发并发布完成。

   Icon

   Crystal框架封装并提供了Dubbo的默认配置，因此开发Dubbo服务非常简单。 当需要调整配置时，可根据Crystal框架参数加载顺序，采用项目中profile/config.properties文件中参数，调整配置，如下：
   
   crystal.application.name = crystal_framework
   
   crystal.application.owner = Crystal
   
   dubbo.registry.address = zookeeper://127.0.0.1:2181
   
   dubbo.protocol.port = 20880

在Crystal框架下，如何调用Dubbo RPC服务？

第一步：项目中引用Dubbo服务接口包和Crystal框架dubbo客户端支持包（crystal-remote-client-dubbo），如

<dependency>
    <groupId>com.gsoft.test</groupId>
    <artifactId>test-dubbo-service-api</artifactId>
</dependency>
<dependency>
    <groupId>com.gsoft.crystal</groupId>
    <artifactId>crystal-remote-client-dubbo</artifactId>
</dependency>

第二步：在需要使用Dubbo RPC服务的类中，添加服务的引用，并添加@Reference注解：（此处Reference为dubbo服务的声明注解com.alibaba.dubbo.config.annotation.Reference

public class TestCostumer {
    @Reference
    private TestService s;
    private int i = 0;
    @Value("${crystal.application.name}")
    private String name;
    public void hello() {
        System.out.println(s.test(name + " " + System.getenv("LOGONSERVER") + "-" + ++i));
    }
}

Crystal框架封装并提供了Dubbo的默认配置，因此开发Dubbo服务非常简单。 当需要调整配置时，可根据Crystal框架参数加载顺序，采用项目中profile/config.properties文件中参数，调整配置，如下：

crystal.application.name = crystal_framework

crystal.application.owner = Crystal

dubbo.registry.address = zookeeper://127.0.0.1:2181