Java微服务（二）：服务消费者与提供者搭建

本文接着上一篇写的《 Java微服务（一）：dubbo-admin控制台的使用 》，上篇文章介绍了docker，zookeeper环境的安装，并参考dubbo官网演示了dubbo-admin控制台的使用。上篇文章已经搭建好zookeeper服务注册中心，本片文章主要搭建服务消费者和服务提供者。按照微服务的原则，本文将demo分为3部分：服务接口、服务消费者、服务消费者。

服务接口：定义了系统所需要的全部接口。

服务提供者：主要是对接口的实现。

服务消费者：对接口的使用

1.Dubbo介绍

Dubbo 架构具有以下几个特点，分别是连通性、健壮性、伸缩性、以及向未来架构的升级性。

调用关系说明

0. 服务容器负责启动，加载，运行服务提供者。
1. 服务提供者在启动时，向注册中心注册自己提供的服务。
2. 服务消费者在启动时，向注册中心订阅自己所需的服务。
3. 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。
4. 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。
5. 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

Dubbo 架构具有以下几个特点，分别是连通性、健壮性、伸缩性、以及向未来架构的升级性。

更详细的介绍，请参考官网： http://dubbo.apache.org/en-us/

2.服务接口

通过idea创建一个jar工程，创建工程的过程可以参考《 Spring boot 入门（一）：快速搭建Spring boot项目 》， 此工程的目的只是简单的定义接口，所以 这里直接创建jar包，不是maven工程 。创建好了后，新建一个接口。以下是我创建的接口：

其中UserService代码如下：

1 package com.edu.hello.dubbo.service.user.api;
2 
3 public interface UserService {
4     String sayHi();
5 }

创建完接口后，需要把接口install到本地仓库，供服务消费者和服务提供者使用

在Terminal直接指向mvn clean install或者直接在lifecycle目录下点击install进行安装，出现如下页面，表示安装成功

3.服务提供者

服务提供者主要是对接口的实现，用相同的方法创建一个maven工程，创建好后的maven工程目录如下：

其中UserServicelmpl是多接口的实现，代码如下：

 1 package com.edu.hello.dubbo.service.user.provider.api.impl;
 2 
 3 import com.alibaba.dubbo.config.annotation.Service;
 4 import com.edu.hello.dubbo.service.user.api.UserService;
 5 import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
 6 import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty;
 7 import org.springframework.beans.factory.annotation.Value;
 8 
 9 /**
10  * @ClassName UserServiceImpl
11  * @Deccription TODO
12  * @Author DZ
13  * @Date 2019/8/31 11:20
14  **/
15 @Service(version = "${user.service.version}")
16 public class UserServiceImpl implements UserService {
17 
18     @Value("${dubbo.protocol.port}")
19     private String port;
20 
21     /*@HystrixCommand(commandProperties = {
22             @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "10"),
23             @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "2000")
24     })*/
25     @Override
26     public String sayHi() {
27         return "Say Hello, i am from " + port;
28     }
29 }

其中@HystrixCommand注解在后面熔断器中会讲到，这里先注释。

yml配置如下：

 1 spring:
 2   application:
 3     name: hello-dubbo-service-user-provider
 4 
 5 user:
 6   service:
 7     version: 1.0.0
 8 
 9 dubbo:
10   scan:
11     basePackages: com.edu.hello.dubbo.service.user.provider.api
12   application:
13     id: hello-dubbo-service-user-provider
14     name: hello-dubbo-service-user-provider
15     qos-port: 22222
16     qos-enable: true
17   protocol:
18     id: dubbo
19     name: dubbo
20     port: 12346
21     status: server
22     serialization: kryo #高速序列化
23     # optimizer:
24 
25   registry:
26     id: zookeeper
27     address: zookeeper://192.168.1.12:2181?back=192.168.1.12:2182,192.168.1.12:2183
28   provider:
29     loadbalance: roundrobin #负载均衡
30 
31 
32 
33 management:
34   endpoint:
35     dubbo:
36       enable: true
37     dubbo-shutdown:
38       enabled: true
39     dubbo-configs:
40       enabled: true
41     dubbo-services:
42       enabled: true
43     dubbo-references:
44       enabled: true
45     dubbo-peoperties:
46       enabled: true
47   health:
48     dubbo:
49       status:
50         defaults: memory
51         extras: load,threadpool

View Code

pom文件如下：

 1 
 2 
 4     4.0.0
 5     
 6         org.springframework.boot
 7         spring-boot-starter-parent
 8         2.1.7.RELEASE
 9          
10     
11     com.edu
12     hello-dubbo-service-user-provider
13     1.0.0-SNAPSHOT
14     hello-dubbo-service-user-provider
15     Demo project for Spring Boot
16 
17     
18         1.8
19     
20 
21     
22         
23             org.springframework.boot
24             spring-boot-starter
25         
26         
27             org.springframework.boot
28             spring-boot-starter-actuator
29         
30         
31             org.springframework.boot
32             spring-boot-starter-test
33             test
34         
35         
36             com.alibaba.boot
37             dubbo-spring-boot-starter
38             0.2.0
39         
40         
41             com.edu
42             hello-dubbo-service-user-api
43             ${project.version}
44         
45         
46             de.javakaffee
47             kryo-serializers
48             0.42
49         
50         
51         
52         
53             org.springframework.cloud
54             spring-cloud-starter-netflix-hystrix
55             2.0.1.RELEASE
56         
57         
58         
59             org.springframework.cloud
60             spring-cloud-starter-netflix-hystrix-dashboard
61             2.0.1.RELEASE
62         
63 
64 
65 
66     
67 
68     
69         
70             
71                 org.springframework.boot
72                 spring-boot-maven-plugin
73             
74         
75     
76 
77 

View Code

本文pom文件和yml文件主要是根据dubbo官网中服务提供者的pom文件中的依赖而来，具体参考： https://github.com/apache/dubbo-spring-boot-project/tree/master/dubbo-spring-boot-samples/dubbo-registry-zookeeper-samples 。

注意basePackages注解

4.服务提供者

按照相同的方式创建服务提供者，配置文件和服务提供者也类似，直接贴代码了

 1 package com.edu.hello.dubbo.service.user.consumer.controller;
 2 
 3 
 4 import com.alibaba.dubbo.config.annotation.Reference;
 5 import com.edu.hello.dubbo.service.user.api.UserService;
 6 import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
 7 import org.springframework.web.bind.annotation.RequestMapping;
 8 import org.springframework.web.bind.annotation.RequestMethod;
 9 import org.springframework.web.bind.annotation.RestController;
10 
11 /**
12  * @ClassName UserController
13  * @Deccription TODO
14  * @Author DZ
15  * @Date 2019/8/31 18:37
16  **/
17 @RestController
18 public class UserController {
19 
20     @Reference(version = "${user.service.version}")
21     private UserService userService;
22 
23     @HystrixCommand(fallbackMethod = "sayHiError")
24     @RequestMapping(value = "hi", method = RequestMethod.GET)
25     public String sayHi() {
26         return userService.sayHi();
27     }
28 
29     public String sayHiError() {
30         return "Hystrix fallback";
31     }
32 }

yml配置文件和pom配置文件和提供者基本类似；

 1 spring:
 2   application:
 3     name: hello-dubbo-service-user-consumer
 4 
 5 user:
 6   service:
 7     version: 1.0.0
 8 
 9 dubbo:
10   scan:
11     basePackages: com.edu.hello.dubbo.service.user.consumer.controller
12   application:
13     id: hello-dubbo-service-user-consumer
14     name: hello-dubbo-service-user-consumer
15     qos-port: 22223
16     qos-enable: true
17   protocol:
18     id: dubbo
19     name: dubbo
20     port: 12345
21     #status: server
22     serialization: kryo
23   registry:
24     id: zookeeper
25     address: zookeeper://192.168.1.12:2181?back=192.168.1.12:2182,192.168.1.12:2183
26 
27 
28 management:
29   endpoint:
30     dubbo:
31       enable: true
32     dubbo-shutdown:
33       enabled: true
34     dubbo-configs:
35       enabled: true
36     dubbo-services:
37       enabled: true
38     dubbo-references:
39       enabled: true
40     dubbo-peoperties:
41       enabled: true
42   health:
43     dubbo:
44       status:
45         defaults: memory
46         extras: load,threadpool
47 server:
48   port: 9090

View Code

 1 
 2 
 4     4.0.0
 5     
 6         org.springframework.boot
 7         spring-boot-starter-parent
 8         2.1.7.RELEASE
 9          
10     
11     com.edu
12     hello-dubbo-service-user-consumer
13     1.0.0-SNAPSHOT
14     hello-dubbo-service-user-consumer
15     Demo project for Spring Boot
16 
17     
18         1.8
19     
20 
21     
22         
23             org.springframework.boot
24             spring-boot-starter-web
25         
26         
27             org.springframework.boot
28             spring-boot-starter-actuator
29         
30         
31             org.springframework.boot
32             spring-boot-starter-test
33             test
34         
35         
36             com.alibaba.boot
37             dubbo-spring-boot-starter
38             0.2.0
39         
40         
41             com.edu
42             hello-dubbo-service-user-api
43             ${project.version}
44         
45         
46             de.javakaffee
47             kryo-serializers
48             0.42
49         
50         
51         
52         
53             org.springframework.cloud
54             spring-cloud-starter-netflix-hystrix
55             2.0.1.RELEASE
56         
57         
58         
59             org.springframework.cloud
60             spring-cloud-starter-netflix-hystrix-dashboard
61             2.0.1.RELEASE
62         
63     
64 
65     
66         
67             
68                 org.springframework.boot
69                 spring-boot-maven-plugin
70                 
71                     com.edu.hello.dubbo.service.user.consumer.HelloDubboServiceUserConsumerApplication
72                 
73             
74         
75     
76 
77 

View Code

这里面关于服务熔断和负载均衡的的代码可以暂时不关注，后面会专门对熔断进行讨论。

5 .结果

分别启动服务消费者和服务提供者，启动成功后，如下：

访问 http://localhost:9090/hi

同时我们可以启动dubbo-admin控制台查看服务， 注意端口的冲突 ：