dubbo(一)、基本使用方式

Dubbo是阿里巴巴公司开源的一个高性能的服务框架，使得应用可以通过高性能的RPC实现服务的输入和输出功能，可以和spring框架无缝集成。本文会从dubbo的基本使用方式开始，一步一步的去发现问题和解决问题并最终在项目中使用dubbo开发分布式系统，

当垂直应用越来越多，应用之间的交互不可避免，将核心业务抽取出来，作为独立的服务，逐渐形成稳定的服务中心，使前端应用能够快速响应多变的市场需求，此时，用于提高业务复用及整合的分布式服务框架(RPC)是关键.

一、Dubbo架构

架构图

  • Provider: 暴露服务的服务提供商
  • Consumer: 调用远程服务的服务消费房
  • Register: 服务注册于发现的注册中心
  • Monitor: 统计服务的调用次数和调用时间的监控中心
  • Container: 服务运行的容器

调用关系

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

二、安装注册中心（Registry）

此处将zookeeper作为注册中心，这也是dubbo推荐的,下载地址: zookeeper

1、配置

下载完成文件之后解压，在conf目录下复制zoo_sample.cfg并改名为zoo.cfg,打开此文件配置，配置选项如下

1
2
3
4
5
6
7
8
9
tickTime=2000 # zookeeper服务器之间或者客户端和服务器之间维持心跳的时间间隔
dataDir=/opt/zookepper1 # zookeeper保存数据的目录
clientPort=2181 # 连接zookeeper服务器的端口号
# 以下集群模式的基本配置
initLimit=5 # 配置接受客户端能接受多少个信条时间间隔数
syncLimit=2 # 标识Leader和Follower之间发送消息，请求和应答时间长度，最长不能超过多少个tickTime的时间长度，总的时间长度是2*2000=4s
#配置zookeeper集群模式，这儿配置的第一个端口指的是服务器与集群中的Leader服务器交换信息的端口，第二个段端口指的是集群中的Leader宕机了，需要选举一个新的Leader，而这个端口就是用来执行选举时候的服务器相互通信的端口
server.1=192.168.100.1:2888:3000
server.2=192.168.100.2:2888:3000

在dataDir配置的目录下创建myidw文件，设置当前服务器的pid,就是一个数字，对应上面配置的server.1的这个数字，这个数字指定当前zookeeper的id

2、操作命令

所有的操作脚本在zookeeper文件目录的bin文件夹下

1
2
3
4
5
sh zkServer.sh start  # 启动zookeeper
sh zkCli.sh  # zooKeeper的简单客户端
sh zkEnv.sh  # 设置zookeeper的环境变量
sh zkCleanup.sh  # 清理历史数据，包括日志数据和快照数据文件
sh zkServer.sh status  # 查看运行状态

3、一台机器伪集群配置

启动三台zookeeper集群，配置如下

zookeeper1的配置文件

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
# 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.
dataDir=/Users/chengfj/Desktop/dubbo-t/zookeeper/zookeeper1/data
# the port at which the clients will connect
clientPort=2181
server.1=127.0.0.1:4100:4200
server.2=127.0.0.1:4101:4201
server.3=127.0.0.1:4102:4202

zookeeper2的配置文件

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
# 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.
dataDir=/Users/chengfj/Desktop/dubbo-t/zookeeper/zookeeper2/data
# the port at which the clients will connect
clientPort=2182
server.1=127.0.0.1:4100:4200
server.2=127.0.0.1:4101:4201
server.3=127.0.0.1:4102:4202

zookeeper3的配置文件

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
# 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.
dataDir=/Users/chengfj/Desktop/dubbo-t/zookeeper/zookeeper3/data
# the port at which the clients will connect
clientPort=2183
server.1=127.0.0.1:4100:4200
server.2=127.0.0.1:4101:4201
server.3=127.0.0.1:4102:4202

注意: 需要在dataDir配置的文件路径下创建myid文件，并设置id，id用来置顶当前zookeeper服务器的id，如果不创建，将会启动不成功

二、安装监控中心(Monitor)

此处就用dubbo的监控中心，直接下载dubbo的源代码，在项目目录dubbo-simple/dubbo-monitor-simple/target下面，解压文件dubbo-monitor-simple-2.5.4-SNAPSHOT-assembly.tar

1、简单配置

配置文件是conf/dubbo.properties, 打开配置文件，配置如下

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
dubbo.container=log4j,spring,registry,jetty
dubbo.application.name=simple-monitor # 监控中心名称
dubbo.application.owner=
# 配置注册中心地址
#dubbo.registry.address=multicast://224.5.6.7:1234
dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.registry.address=zookeeper://127.0.0.1:2182
dubbo.registry.address=zookeeper://127.0.0.1:2183
#dubbo.registry.address=redis://127.0.0.1:6379
#dubbo.registry.address=dubbo://127.0.0.1:9090
# dubbo协议端口
dubbo.protocol.port=7070
# 网页管理端口
dubbo.jetty.port=8088
dubbo.jetty.directory=/Users/chengfj/Desktop/dubbo-t/dubbo-monitor-simple/monitor
dubbo.charts.directory=/Users/chengfj/Desktop/dubbo-t/dubbo-monitor-simple/monitor/charts
dubbo.statistics.directory=/Users/chengfj/Desktop/dubbo-t/dubbo-monitor-simple/monitor/statistics
dubbo.log4j.file=logs/dubbo-monitor-simple.log
dubbo.log4j.level=WARN

2、基本操作

1
2
sh bin/start.sh  # 启动，启动完成可以通过配置的jetty端口通过网页访问监控中心
sh bin/stop.sh  # 关闭监控中心

三、Dubbo管理控制台

dubbo控制台的war包在源代码的dubbo-admin/target下，复制此war包部署到本地的tomcat服务器上去，然后启动tomcat服务器，可以直接访问了。

1、配置多注册中心

需要下部署tomcat，然后在部署的项目目录下找到WEB-INF/dubbo.properties文件，在此文件里面配置多个注册中心，此处配置上面的三台伪集群zookeeper注册中心配置文件如下

1
2
3
dubbo.registry.address=zookeeper://127.0.0.1:2181|zookeeper://127.0.0.1:2182|zookeeper://127.0.0.1:2183
dubbo.admin.root.password=root
dubbo.admin.guest.password=guest

之后就可以在页面的系统管理/系统状态里面看到注册中心了
注册中心

四、基于spring-boot的集成Dubbo

在spring-boot中这儿用注解来配置dubbo，这样代码看起来相对简洁。

1、maven添加服务依赖

1
2
3
4
5
6
7
8
9
10
11
<dependency>
	<groupId>io.dubbo.springboot</groupId>
	<artifactId>spring-boot-starter-dubbo</artifactId>
	<version>1.0.0</version>
</dependency>

<dependency>
	<groupId>log4j</groupId>
	<artifactId>log4j</artifactId>
	<version>1.2.17</version>
</dependency>

注意: 此处log4j必须要添加，否则抛出异常NoClassDefFoundError: org/apache/log4j/Logger

2、基本配置

在application.properties文件中配置dubbo相关的属性，所有的配置项在io.dubbo.springboot.DubboProperties类下面,这个配置类的源代码如下，可以一目了然的看到需要配置哪些参数:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
@ConfigurationProperties(
	// spring boot配置dubbo的前缀
    prefix = "spring.dubbo"
)
public class DubboProperties {
	//配置需要扫描注解的包
    private String scan;
    //配置应用相关的，例如: 服务名称等等，可以点进去看
    private ApplicationConfig application;
    //配置注册中心相关的，如果配置多个注册中心，是在application属性里面配置
    private RegistryConfig registry;
    // 配置协议相关的
    private ProtocolConfig protocol;
    
    ... 省略若干 ...
}

服务提供方配置如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
//配置扫描的包，dubbo会扫描此包下的dubbo相关的注解
spring.dubbo.scan=huijinhang.business.impl

// 配置协议名称，现在dubbo提供了多种协议供选择,dubbo, rmi, hessian, http, webservice, thrift, memcached, redis等
spring.dubbo.protocol.name=dubbo
spring.dubbo.protocol.host=127.0.0.1
// 协议暴露的本地端口
spring.dubbo.protocol.port=20882

// 配置服务名称
spring.dubbo.application.name=estate-service
// 配置监控中心协议和地址，用于定时上报统计数据
spring.dubbo.application.monitor.protocol=registry
spring.dubbo.application.monitor.address=127.0.0.1:7070
// 此处配置三个zookeeper的注册中心，如果只有一个注册中心，则通过registry配置
spring.dubbo.application.registries[0].address=zookeeper://127.0.0.1:2181
spring.dubbo.application.registries[1].address=zookeeper://127.0.0.1:2182
spring.dubbo.application.registries[2].address=zookeeper://127.0.0.1:2183

3、服务提供方注解配置

在实现类上面加上@Service注解完成服务的暴露

1
2
3
4
5
6
7
8
@Service(version = "1.0.0", executes = 10)
public class EstateAreaImpl implements EstateAreaApi {

    @Override
    public List<EstateAreaModel> queryAllAreaList() {
        return null;
    }
}

注意: 此处的@Service是com.alibaba.dubbo.config.annotation包下面的Service

解释: @Service有很多参数，具体参数和含义可以参考链接: dubbo service配置

4、异常处理

BeanCreationException异常，如果提示实现类找不到,如Error creating bean with name 'estateAreaImpl' defined in file，那在启动类上手动加上需要扫描的包，代码如下:

1
2
3
4
5
6
7
8
@SpringBootApplication
@ComponentScan(basePackages = {"huijinhang.business.impl", "huijinhang.business.service"})
public class EstateServiceApplication {

	public static void main(String[] args) {
		SpringApplication.run(EstateServiceApplication.class, args);
	}
}

5、服务消费方基本配置

(1)、配置properties

配置application.properties文件如下:

1
2
3
4
5
6
7
8
spring.dubbo.application.name=huijinhang-backend
spring.dubbo.application.registries[0].address=zookeeper://127.0.0.1:2181
spring.dubbo.application.registries[1].address=zookeeper://127.0.0.1:2182
spring.dubbo.application.registries[2].address=zookeeper://127.0.0.1:2183
spring.dubbo.scan=huijinhang.backend.controller

spring.dubbo.application.monitor.protocol=registry
spring.dubbo.application.monitor.address=127.0.0.1:7070

(2)、注解使用

1
2
3
4
5
6
7
8
9
10
11
12
13
14
@RestController
@RequestMapping("/estate/area")
public class EstateAreaController {

    @Reference(version = "1.0.0")
    private EstateAreaApi estateAreaApi;

    @GetMapping("/queryAll")
    public ResponseDto getAllEstateArea() {
        List list = estateAreaApi.queryAllAreaList();
        return ResponseDto.data(list);
    }

}

@Reference的参数很多，可参考: dubbo reference

完成配置之后启动项目调用api就可以得到服务提供方的结果了

扫一扫，分享到微信

微信分享二维码

tag:

    缺失模块。
    1、请确保node版本大于6.2
    2、在博客根目录（注意不是yilia根目录）执行以下命令：
    npm i hexo-generator-json-content --save

    3、在根目录_config.yml里添加配置： 

      jsonContent:
    meta: false
    pages: false
    posts:
      title: true
      date: true
      path: true
      text: false
      raw: false
      content: false
      slug: false
      updated: false
      comments: false
      link: false
      permalink: false
      excerpt: false
      categories: false
      tags: true