[Java知识库]SpringBoot+Dubbo+Zookeeper实现简单的分布式架构

前言

什么是分布式系统？
分布式系统的出现是为了用更省钱的方式、更多的普通机器完成单个计算机无法完成的计算。
架构演变经历的4个阶段
单一应用架构
将所有功能都部署在一起，以减少部署节点和成本。但是不利于维护和升级。
垂直应用架构
将应用拆分为多个应用，通信机制一般为RESTful。但是呢？虽然拆分为多个应用，但是应用之间难免存在交互的部分，这就促使下一个架构的诞生。
分布式服务架构
将核心业务抽取出来，作为独立的服务进行部署，供多个垂直应用调用，分布式服务框架(RPC)是关键，RPC【Remote Procedure Call】是指远程过程调用，可以将共同的服务部署在服务器中，用RPC实现服务之间的调用。
流动计算架构
增加一个调度中心基于访问压力实时管理集群容量。

搭建框架

1.创建一个模块SpringBoot-Dubbo-zookeeper，使用springboot的web依赖。
2.编写一个接口：

package com.he.Service;
public interface TicketService {
    public String getTicket();
}

3.编写一个实现类：
这里的@Service表示注册到zookeeper中

package com.he.Service;

import org.apache.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;

//服务注册与发现，新版是@DubboService
@Service
@Component
public class TicketServiceImpl implements TicketService {
    @Override
    public String getTicket() {
        return "票";
    }
}

4.在application.properties中配置注册中心地址，扫描指定包，被调用的方法是需要加入扫描指定包下服务的配置dubbo.scan.base-packages，需要将其注册在zookeeper中和spring中才可使用，调用时注册中心地址与被调用的配置相同方可

server.port=8081
#当前应用名字
dubbo.application.name=provider-server
#注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
#扫描指定包下服务
dubbo.scan.base-packages=com.he.Service

5.在springboot的启动文件中加入注解@EnableDubbo
6.导入依赖包

<!-- Dubbo Spring Boot Starter -->
<dependency>
   <groupId>org.apache.dubbo</groupId>
   <artifactId>dubbo-spring-boot-starter</artifactId>
   <version>2.7.3</version>
</dependency>    
<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>
   <!--解决日志冲突问题-->
   <exclusions>
       <exclusion>
           <groupId>org.slf4j</groupId>
           <artifactId>slf4j-log4j12</artifactId>
       </exclusion>
   </exclusions>
</dependency>

7.创建新的模块用于调用上一个模块，导入一样的包
8.配置dubbo相关属性

server.port=8082
#当前应用名字
dubbo.application.name=consumer-server
#注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181

9.创建调用的类

package com.he.Service;

import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Service;

@Service //注入到容器中
public class Consumerservice {
    @Reference //远程引用指定的服务，他会按照全类名进行匹配，看谁给注册中心注册了这个全类名
    TicketService ticketService;

    public void bugTicket(){
        String ticket = ticketService.getTicket();
        System.out.println("在注册中心买到"+ticket);
    }
}

10.编写测试类

package com.he;

import com.he.Service.Consumerservice;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest
class SpringbootConsumerApplicationTests {

    @Autowired
    Consumerservice consumerservice;
    @Test
    void contextLoads() {
        consumerservice.bugTicket();
    }

}

11.注意，这里需要保持路径相同，且需要加入第一个的服务接口防止报错。

启动测试

开启zookeeper，开启第一个模块SpringBoot-Dubbo-zookeeper，然后启动测试方法。这里的zookeeper相当于注册中心，用于接收第一个模块的注册，并使得可以被调用。最终输出