spring-boot-start-dubbo

spring-boot-start-dubbo，让你可以使用spring-boot的方式开发dubbo程序。使dubbo开发变得如此简单。

该项目是由teaey的项目spring-boot-starter-dubbo重构而成。 如果有什么指正的地方，请联系我 272472809@qq.com

如何使用

1. clone 代码

git clone git@github.com:JohnsonLow/spring-boot-starter-dubbo.git

2. 编译安装（暂时未发布。目前未发现bug）

cd spring-boot-starter-dubbo
mvn clean install

3. 修改maven配置文件(可以参考样例spring-boot-starter-dubbo-sample)

在Spring Boot项目的pom.xml修改依赖的版本及编码:

  <properties>
    <java.version>1.7</java.version>
    <spring-boot.version>1.5.1.RELEASE</spring-boot.version>
    <version.compiler-plugin>3.5.1</version.compiler-plugin>
    <version.source-plugin>2.2.1</version.source-plugin>
    <version.javadoc-plugin>2.9.1</version.javadoc-plugin>
    <version.maven-gpg-plugin>1.5</version.maven-gpg-plugin>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
</properties>

该项目分为了两个模块：

• starter-dubbo-common 该模块主要功能为扫描dubbo组件
• starter-dubbo-server 依赖 starter-common 便于注册到zookeeper

maven插件用于打包成可执行的jar文件,添加以下插件(这里一定要加载需要打包成jar的mudule的pom中)

<plugin>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-maven-plugin</artifactId>
</plugin>

4. 服务接口

package com.lyf.samples.api;

public interface HelloService {
    String code(String device);
}

5. 发布服务

在pom.xml中添加以下依赖:

根据实际情况依赖最新版本

 <dependency>
     <groupId>com.oqiji.springboot</groupId>
     <artifactId>starter-dubbo-server</artifactId>
     <version>1.0.0</version>
 </dependency>

在application.yml添加Dubbo的版本信息和客户端超时信息,如下:

spring:
  dubbo:
    application:
      name: provider
    registry:
      address: zookeeper://127.0.0.1:20181
    protocol:
      name: dubbo
      prot: 20880

  datasource:
      url: jdbc:mysql://127.0.0.1:3306/qiji?useUnicode=true&characterEncoding=UTF8
      username: qiji
      password: qiji,123
debug: true

spring.dubbo.scan 为要扫描的包。也可使用@DubboScan进行配置

• 编写你的Dubbo服务,只需要添加要发布的服务实现上添加 @Service ,如下

  package com.lyf.ds;
  import com.alibaba.dubbo.config.annotation.Service;
  import com.lyf.samples.api.HelloService;
  import org.springframework.beans.factory.annotation.Autowired;
  import org.springframework.jdbc.core.JdbcTemplate;
  import org.springframework.util.CollectionUtils;
  import java.util.List;
  
  @Service(version = "1.0")
  public class HelloServiceProvider implements HelloService {
    @Autowired
    private JdbcTemplate jdbcTemplate;
    @Override
    public String code(String device) {
      List<String> res =  jdbcTemplate.queryForList("SELECT code FROM activity WHERE device = ? ", String.class, device);
      if(CollectionUtils.isEmpty(res)){
        return null;
      }
      return res.get(0);
    }
 }

• 启动zookeeper
  1. 下载zookeeper
  2. 配置相应的参数 conf/zoo.cfg

  # The number of milliseconds of each tick
  

tickTime=2000

The number of ticks that the initial

synchronization phase can take

initLimit=10

The number of ticks that can pass between

sending a request and getting an acknowledgement

syncLimit=5

the directory where the snapshot is stored.

do not use /tmp for storage, /tmp here is just

example sakes.

dataDir=/tmp/zookeeper

the port at which the clients will connect

clientPort=2181

the maximum number of client connections.

increase this if you need to handle more clients

maxClientCnxns=60

Be sure to read the maintenance section of the

administrator guide before turning on autopurge.

http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance

The number of snapshots to retain in dataDir

autopurge.snapRetainCount=3

Purge task interval in hours

Set to "0" to disable auto purge feature

autopurge.purgeInterval=1

clientPort=20181

```
3. 启动：
 ```bash
  cd zookeeper-3.4.9
  sh bin/zkServer.sh
```

• spring boot启动

  package com.lyf.ds;
  
  import com.oqiji.boot.dubbo.DubboScan;
  import org.springframework.boot.SpringApplication;
  import org.springframework.boot.autoconfigure.SpringBootApplication;
  
  /**
   * Created by 永锋 on 2017/2/22.
   */
  @SpringBootApplication
  @DubboScan("com.lyf.ds")
  public class Server {
    public static void main(String[] args) {
      SpringApplication.run(Server.class, args);
    }
  }

6. 消费Dubbo服务

• 在application.properties添加Dubbo的版本信息和客户端超时信息,如下:

spring:
  dubbo:
    application:
      name: consumer
    registry:
      address: zookeeper://127.0.0.1:20181 # zookeeper的注册地址
#    scan: com.lyf.dc
debug: true

在pom.xml中添加以下依赖:

根据实际情况依赖最新版本

 <dependency>
    <groupId>com.oqiji.springboot</groupId>
    <artifactId>starter-dubbo-common</artifactId>
    <version>1.0.0</version>
 </dependency>

• 引用Dubbo服务,只需要添加要发布的服务实现上添加 @Reference ,如下:

  package com.lyf.dc;
  
  import com.alibaba.dubbo.config.annotation.Reference;
  import com.lyf.samples.api.HelloService;
  import org.slf4j.Logger;
  import org.slf4j.LoggerFactory;
  import org.springframework.stereotype.Component;
  
  @Component
  public class HelloServiceReq {
    private static Logger logger = LoggerFactory.getLogger(HelloServiceReq.class);
  
    @Reference(version = "1.0")
    public HelloService helloService;
  
    public void hello() {
      long start = System.currentTimeMillis();
      for (int i = 0; i < 10000; i++) {
        String result = helloService.code("bbk_bbk72_t_jb3_jzusjfbi65wwqosk" + i);
        logger.info("{}. result is {}", i, result);
      }
      logger.info("total spent {} ms", System.currentTimeMillis() - start);
    }
  }

• spring boot启动

  package com.lyf.dct;
  
  import com.lyf.dc.HelloServiceReq;
  import com.oqiji.boot.dubbo.DubboScan;
  import org.springframework.boot.SpringApplication;
  import org.springframework.boot.autoconfigure.SpringBootApplication;
  import org.springframework.context.ConfigurableApplicationContext;
  
  @SpringBootApplication
  @DubboScan("com.lyf.dc")
  public class Client {
    public static void main(String[] args) {
      ConfigurableApplicationContext context = SpringApplication.run(Client.class, args);
      HelloServiceReq helloService = context.getBean(HelloServiceReq.class);
      helloService.hello();
    }
  }

7. 打包

可以直接执行Server或者Client启动

可以通过mvn clean package 打包成可执行的jar文件