张利源 blog

分布式服务架构

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

什么是RPC框架

RPC【Remote Procedure Call】是指远程过程调用，是一种进程间通信方式，他是一种技术的思想，而不是规范。它允许程序调用另一个地址空间（通常是共享网络的另一台机器上）的过程或函数，而不用程序员显式编码这个远程调用的细节。即程序员无论是调用本地的还是远程的函数，本质上编写的调用代码基本相同。

也就是说两台服务器A，B，一个应用部署在A服务器上，想要调用B服务器上应用提供的函数/方法，由于不在一个内存空间，不能直接调用，需要通过网络来表达调用的语义和传达调用的数据。为什么要用RPC呢？就是无法在一个进程内，甚至一个计算机内通过本地调用的方式完成的需求，比如不同的系统间的通讯，甚至不同的组织间的通讯，由于计算能力需要横向扩展，需要在多台机器组成的集群上部署应用。RPC就是要像调用本地的函数一样去调远程函数；

dubbo基本概念

服务提供者(Provider):暴露服务的服务提供发，服务提供者启动时，向注册中心注册自己提供的服务

服务消费者(Consumer):调用远程服务的服务消费方，服务消费者在启动时，向注册中心订阅自己锁需要的服务，服务消费者从提供者列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选用另一台

注册中心(Register):注册中心返回服务提供者地址列表给服务消费者，如果有变更，注册中心将基于长连接推送变更数据给数据消费者

监控中心(Moiter):服务消费者和提供者，在内存累计调用次数和调用时间，定义每分钟发送一次统计数据到监控中心

使用Dubbo-admin

dubbo本身并不是一个服务软件。它其实就是一个jar包，能够帮你的java程序连接到zookeeper，并利用zookeeper消费、提供服务。

但是为了让用户更好的管理监控众多的dubbo服务，官方提供了一个可视化的监控程序dubbo-admin，不过这个监控即使不装也不影响使用。

地址 ：https://github.com/apache/dubbo-admin/tree/master

下载完成后解压,修改dubbo-admin-server下的配置文件，修改成我们自己的配置即可

将这个项目达成jar包

mvn clean package -Dmaven.test.skip=true

用java -jar启动就好了

访问localhost:8080

测试环境搭建

Linux安装zookeeper

  • xftp上传zookeeper到根目录

  • 解压zookeeper到指定目录

tar -zxvf zookeeper-3.4.6.tar.gz -C /usr/local/

  • 进入zookeeper目录

cd zookeeper-3.4.6

  • 创建data目录

mkdir data

  • 进入conf目录

cd conf

  • 重命名/拷贝zoo_sample.cfg,修改为zoo.cfg

mv zoo_sample.cfg zoo.cfg

  • vim进入zoo.cfg文件

vim zoo.cfg

  • 修改zoo.cfg文件

修改datadir=/usr/local/zookeeper-3.4.6/data
注意:使用i进入修改模式,修改后使用esc退出修改,输入:wq退出vim

操作zookeeper

1.启动
进入bin目录下,执行
./zkServer.sh start

2.停止
./zkServer.sh stop

3.查看状态
./zkServer.sh status

SpringBoot+dubbo+zookeeper

编写服务提供者

导入依赖

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
<!--dubbo-->
<!-- Dubbo Spring Boot Starter -->
<dependency>
   <groupId>org.apache.dubbo</groupId>
   <artifactId>dubbo-spring-boot-starter</artifactId>
   <version>2.7.3</version>
</dependency>
<!--zookeeper-->
<!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient -->
<dependency>
   <groupId>com.github.sgroschupf</groupId>
   <artifactId>zkclient</artifactId>
   <version>0.1</version>
</dependency>
<!-- 引入zookeeper -->
<dependency>
   <groupId>org.apache.curator</groupId>
   <artifactId>curator-framework</artifactId>
   <version>2.12.0</version>
</dependency>
<dependency>
   <groupId>org.apache.curator</groupId>
   <artifactId>curator-recipes</artifactId>
   <version>2.12.0</version>
</dependency>
<dependency>
   <groupId>org.apache.zookeeper</groupId>
   <artifactId>zookeeper</artifactId>
   <version>3.4.14</version>
   <!--排除这个slf4j-log4j12-->
   <exclusions>
       <exclusion>
           <groupId>org.slf4j</groupId>
           <artifactId>slf4j-log4j12</artifactId>
       </exclusion>
   </exclusions>
</dependency>

编写service接口

1
2
3
4
5
6
7
8
package com.gem.service;
/**
 * @author zhang
 * @date 2020/10/24 13:43
 */
public interface HelloService {
    String sayHello(String name);
}

编写实现类

这里注意@Service注解使用的是dubbo的而非spring提供的，loadbalance表示负载均衡，interfaceClass指定接口

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
package com.gem.service.impl;

import com.gem.service.HelloService;
import org.apache.dubbo.config.annotation.Service;

/**
 * @author zhang
 * @date 2020/10/24 13:50
 */
@Service(loadbalance = "random",interfaceClass = HelloService.class)
public class HelloServiceImpl implements HelloService {
    @Override
    public String sayHello(String name) {
        return "Hello," + name;
    }
}

配置文件

1
2
3
4
5
6
7
8
#当前应用名称
dubbo.application.name=dubbo-prodiver
#注册中心地址
dubbo.registry.address=zookeeper://192.168.40.130:2181
#扫描指定包下的服务
dubbo.scan.base-packages=com.gem.service
#服务器端口
server.port=9999

编写服务消费者

导入依赖

同上

编写service接口

同上

配置文件

1
2
3
4
5
6
7
8
9
10
11
12
#当前应用名称
dubbo:
  application:
    name: dubbo-consumer
  registry:
    address: zookeeper://192.168.40.130:2181
  scan:
    base-packages: com.gem.controller


server:
  port: 8888

编写Controller

我们要使用服务提供者的服务，使用@Reference注解去注册中心查找服务

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
package com.gem.controller;

import com.gem.service.HelloService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

/**
 * @author zhang
 * @date 2020/10/24 13:58
 */
@Controller
public class HelloController {
    //到注册中心查找服务
    @Reference(check = false,loadbalance = "random")
    HelloService helloService;

    @RequestMapping("/hello")
    @ResponseBody
    public String sayHello(String name){
        return helloService.sayHello(name);
    }
}

测试

启动服务器，访问呢服务消费者的controller

博客内容遵循 署名-非商业性使用-相同方式共享 4.0 国际 (CC BY-NC-SA 4.0) 协议

评论