【微服务】SpringBoot+Dubbo+ZooKeeper 实战

• 项目说明
• common模块
• provider模块
• customer模块
• 小结
• Dubbo配置标签属性说明

本项目采用dubbo来是实现消费者来远程调用生产者的服务。
原本生产者应该连接数据库，service服务来对dao层进行业务逻辑实现，但是为了更好的理解，项目将省略数据库操作，采用模拟实现。

如果你对微服务感兴趣可参考博主以前写的SpringCould系列文章：Spring Could

项目有3个模块：

• common：存放实体类，interface接口，以及其他一些公共部分
• provider：生产者，提供服务：实现common模块的interface接口
• customer：消费者，远程调用product的服务。
  

1. pom.xml【引入springboot、dubbo、zk相关依赖】

    
        
        
            org.springframework.boot
            spring-boot-starter-web
            2.5.1
        

        
            org.springframework.boot
            spring-boot-starter-test
            2.5.2
        

        
        
            com.alibaba.boot
            dubbo-spring-boot-starter
            0.1.0
        
        
        
            com.101tec
            zkclient
            0.6
        
    

2. 实体类User

public class User implements Serializable {
    
    private String username;
    
    private String nick;
    
    private Integer age;
    //构造器，get、set方法 省略
}

3. 服务接口UserService

public interface DemoService {

    
    List getUser();
}

common模块是一个公共模块，把生产者消费者都需要的依赖，都统一导入common模块，然后其他模块引入common模块，还有都需要用到的实体类，需要远程调用的服务接口都统一放在common模块。

1. pom.xml 【引入common模块即可】

    
        
        
            org.example
            common
            1.0-SNAPSHOT
        
    

2. DemoServiceImpl【实现common模块的接口】

@Service("demoService")
public class DemoServiceImpl implements DemoService {
    @Override
    public List getUser() {
        //暂不连接数据库 采用模拟数据
        User user = new User("小明","明明",18);
        User user2 = new User("小菜","菜菜",20);
        List list = new ArrayList<>();
        list.add(user);
        list.add(user2);
        return list;
    }
}

3. service-provide.xml【dubbo配置，把借口暴露给消费者】

关于dubbo标签解释，在文章最后有介绍。

4. application.yml

dubbo:
  #服务器名称唯一
  application:
    name: provider
  #注册中心配置，使用zookeeper做注册中心
  registry:
    address: zookeeper://127.0.0.1:2181
  protocol:
    #    使用dubbo协议，端口默认20880
    port: 20880
    name: dubbo
  monitor:
    address: registry

server:
  port: 8081

关于dubbo的配置，你可以放到service-provide.xml里面，也可以在application.yml里面配置，但是最好不要两个地方都配置，不然到时候会报dubbo服务器名称不唯一的错误，启动不起来。

5. ProductApplication 【启动类，需要@ImportResource扫描到dubbo的配置，不然不会生效】

@SpringBootApplication
@ImportResource({"classpath:/dubbo/service-provider.xml"})
public class ProviderApplication {

    public static void main(String[] args) {
        SpringApplication.run(ProviderApplication.class, args);
        System.out.println("生产者启动成功");
    }
}

1. service-consumer.xml【dubbo，接受生产者暴露的服务】

2. application.yml

server:
  port: 8088

3. DomeController

@RestController
@RequestMapping("/user")
public class DemoController {

    @Autowired
    private DemoService demoService;

    @RequestMapping(value = "/get", method = RequestMethod.POST)
    public List getUsers(){
        return demoService.getUser();
    }
}

4. CustomerApplication

@SpringBootApplication
@ImportResource({"classpath:/dubbo/service-consumer.xml"})
public class CustomerApplication {

    public static void main(String[] args) {
        SpringApplication.run(CustomerApplication.class, args);
        System.out.println("消费者启动成功");
    }
}

先在本地启动zookeeper服务，然后启动生产者（product），再启动消费者（customer）。
访问POST http://localhost:8088/user/get，最好不要用浏览器访问，浏览器默认的是get请求方式，可能会报405错误，可以修改Controller请求的方法，改为get方式。

参考官方网址：https://dubbo.apache.org/zh/docs/references/xml/dubbo-provider/