SpringBoot+Dubbo+Zookeeper实现简单的分布式架构

2022-02-24 23:05:21 阅读：182 来源： 互联网

标签：Dubbo zookeeper SpringBoot Service dubbo Zookeeper 注册 import org

前言

什么是分布式系统？
分布式系统的出现是为了用更省钱的方式、更多的普通机器完成单个计算机无法完成的计算。
架构演变经历的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相当于注册中心，用于接收第一个模块的注册，并使得可以被调用。最终输出在这里插入图片描述

标签：Dubbo,zookeeper,SpringBoot,Service,dubbo,Zookeeper,注册,import,org
来源： https://blog.csdn.net/qq_45773419/article/details/123121627

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

SpringBoot+Dubbo+Zookeeper实现简单的分布式架构

目录

前言

搭建框架

启动测试