分布式应用简单入门及SpringBoot整合Dubbo+Zookeeper

本文涉及的产品
云原生网关 MSE Higress,422元/月
注册配置 MSE Nacos/ZooKeeper,118元/月
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
简介: 分布式应用简单入门及SpringBoot整合Dubbo+Zookeeper

分布式系统中,国内常用zookeeper+dubbo组合,而Spring Boot推荐使用全栈的Spring,Spring Boot+Spring Cloud。


Dubbo官网架构演变示例图:




单一应用架构

当网站流量很小时,只需一个应用,将所有功能都部署在一起,以减少部署节点和成本。此时,用于简化增删改查工作量的数据访问框架(ORM)是关键。


垂直应用架构

当访问量逐渐增大,单一应用增加机器带来的加速度越来越小,将应用拆成互不相干的几个应用,以提升效率。此时,用于加速前端页面开发的Web框架(MVC)是关键。


分布式服务架构

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


流动计算架构

当服务越来越多,容量的评估,小服务资源的浪费等问题逐渐显现,此时需增加一个调度中心基于访问压力实时管理集群容量,提高集群利用率。此时,用于提高机器利用率的资源调度和治理中心(SOA)是关键。



【1】Zookeeper和Dubbo

① ZooKeeper

ZooKeeper 是一个分布式的,开放源码的分布式应用程序协调服务。它是一个为分布式应用提供一致性服务的软件,提供的功能包括:配置维护、域名服务、分布式同步、组服务等。

简单来说,它是服务注册中心。

② Dubbo

Dubbo是Alibaba开源的分布式服务框架,它最大的特点是按照分层的方式来架构,使用这种方式可以使各个层之间解耦合(或者最大限度地松耦合)。从服务模型的角度来看,Dubbo采用的是一种非常简单的模型,要么是提供方提供服务,要么是消费方消费服务,所以基于这一点可以抽象出服务提供方(Provider)和服务消费方(Consumer)两个角色。


示意图如下,Dubbo容器启动时加载和运行服务提供者(Provider),服务提供者会将自己所能够提供的服务注册到Zookeeper–Registry,服务消费者从Registry中订阅(subscribe)服务,册中心会将服务消费者所需要的服务的地址列表返回给服务消费者。如果服务有变更,Registry将会notify消费者。服务消费者会根据拿到的地址列表,调用服务提供者提供的服务。另外,Dubbo还提供了监控机制(Monitor)。



【2】Docker简单安装Zookeeper

下载镜像命令如下:

docker pull  registry.docker-cn.com/library/zookeeper


启动容器:

官网说明示例如下

docker run --name some-zookeeper --restart always -d zookeeper


This image includes EXPOSE 2181 2888 3888 (the zookeeper client port, follower port, election port respectively), so standard container linking will make it automatically available to the linked containers. Since the Zookeeper “fails fast” it’s better to always restart it.

这里只暴露客户端交互端口2181。

docker run --name zk01 -p 2181:2181 --restart always -d a8a59477268d(镜像id)

【3】编写并配置服务提供者和消费者

① 创建空工程

这里用的是idea。

② 在空工程中分别创建两个Module:consumer-user和provider-ticket

一个是服务消费者,一个是服务提供者。其中user调用ticker的方法。

结构示意图如下:



③ 首先将服务提供者注册到注册中心

三个步骤:

  • 引入dubbo和zkclient相关依赖;
  • 配置dubbo的扫描包和注册中心地址;
  • 使用@Service发布服务

引入依赖pom如下:

    <dependency>
      <groupId>com.alibaba.boot</groupId>
      <artifactId>dubbo-spring-boot-starter</artifactId>
      <version>0.1.0</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>

配置文件如下:

dubbo.application.name=provider-ticket
dubbo.registry.address=zookeeper://192.168.2.110:2181
dubbo.scan.base-packages=com.dubbo.provider.service

provider-ticker如下图所示:


注意这里的@Service非Spring注解而是Dubbo的注解!


启动服务提供者,如下所示,表示正常启动:



④ 服务消费者引用服务

三个步骤:

  • 引入dubbo和zkclient相关依赖;
  • 配置dubbo的注册中心地址;
  • 引用服务

引入依赖同③,application.properties配置如下:

dubbo.application.name=consumer-user
dubbo.registry.address=zookeeper://192.168.2.110:2181

接下来在UserService中引用服务提供者提供的服务!

将TickerService拷贝到位于module consumer-user的同路径下,如下所示:


注意,Dubbo是面向接口的,impl包及实现类不需要!



UserService类如下:

package com.dubbo.consumer.service;
import com.alibaba.dubbo.config.annotation.Reference;
import com.dubbo.provider.service.TicketService;
import org.springframework.stereotype.Service;
/**
 * Created by Janus on 2018/7/11.
 */
@Service//这里是Spring的注解
public class UserService {
    // 远程引用,按照全类名从注册中心寻找
    @Reference
    TicketService ticketService;
    public void hello(){
        String ticket = ticketService.getTicket();
        System.out.println("买到票了:"+ticket);
    }
}

测试类如下:

@RunWith(SpringRunner.class)
@SpringBootTest
public class ConsumerApplicationTests {
  @Autowired
  UserService userService;
  @Test
  public void contextLoads() {
    userService.hello();
  }
}


保持服务提供者正常启动状态,然后服务消费者测试结果如下:


即,通过Zookeeper,服务消费者获取了另一个工程-服务提供者提供的服务!

一个工程引用另一个工程的服务,其实就是远程调用–RPC,常见的如WebService。Dubbo就是基于RPC远程调用实现服务之间的通信!!!


但是本篇博文只是简单实践,实际应用中不可能在消费者下面建立服务提供者同级目录并拷贝接口的。通常是将服务接口抽离到公共接口项目中,消费者和服务提供者依赖该接口项目。


相关实践学习
基于MSE实现微服务的全链路灰度
通过本场景的实验操作,您将了解并实现在线业务的微服务全链路灰度能力。
目录
相关文章
|
18天前
|
前端开发 JavaScript Java
Spring Boot应用中的资源分离与高效打包实践
通过实施资源分离和高效打包策略,不仅可以提升Spring Boot应用的开发和部署效率,还能显著提高用户体验。在实际项目中,根据项目的实际情况和团队的技术栈选择合适的工具和方案是关键。希望本文能为读者在Spring Boot项目中实现资源分离和高效打包提供一些有价值的参考。
|
12天前
|
缓存 NoSQL Java
SpringBoot整合Redis、以及缓存穿透、缓存雪崩、缓存击穿的理解分布式情况下如何添加分布式锁 【续篇】
这篇文章是关于如何在SpringBoot应用中整合Redis并处理分布式场景下的缓存问题,包括缓存穿透、缓存雪崩和缓存击穿。文章详细讨论了在分布式情况下如何添加分布式锁来解决缓存击穿问题,提供了加锁和解锁的实现过程,并展示了使用JMeter进行压力测试来验证锁机制有效性的方法。
SpringBoot整合Redis、以及缓存穿透、缓存雪崩、缓存击穿的理解分布式情况下如何添加分布式锁 【续篇】
|
12天前
|
缓存 NoSQL Java
SpringBoot整合Redis、以及缓存穿透、缓存雪崩、缓存击穿的理解、如何添加锁解决缓存击穿问题?分布式情况下如何添加分布式锁
这篇文章介绍了如何在SpringBoot项目中整合Redis,并探讨了缓存穿透、缓存雪崩和缓存击穿的问题以及解决方法。文章还提供了解决缓存击穿问题的加锁示例代码,包括存在问题和问题解决后的版本,并指出了本地锁在分布式情况下的局限性,引出了分布式锁的概念。
SpringBoot整合Redis、以及缓存穿透、缓存雪崩、缓存击穿的理解、如何添加锁解决缓存击穿问题?分布式情况下如何添加分布式锁
|
2天前
|
机器学习/深度学习 分布式计算 PyTorch
大规模数据集管理:DataLoader在分布式环境中的应用
【8月更文第29天】随着大数据时代的到来,如何高效地处理和利用大规模数据集成为了许多领域面临的关键挑战之一。本文将探讨如何在分布式环境中使用`DataLoader`来优化大规模数据集的管理与加载过程,并通过具体的代码示例展示其实现方法。
12 1
|
7天前
|
运维 安全 Cloud Native
核心系统转型问题之保障云原生分布式转型中的基础设施和应用层面如何解决
核心系统转型问题之保障云原生分布式转型中的基础设施和应用层面如何解决
|
12天前
|
Java 微服务 Spring
SpringBoot+Vue+Spring Cloud Alibaba 实现大型电商系统【分布式微服务实现】
文章介绍了如何利用Spring Cloud Alibaba快速构建大型电商系统的分布式微服务,包括服务限流降级等主要功能的实现,并通过注解和配置简化了Spring Cloud应用的接入和搭建过程。
SpringBoot+Vue+Spring Cloud Alibaba 实现大型电商系统【分布式微服务实现】
|
20天前
|
Java 开发者 Spring
"揭秘SpringBoot魔法SPI机制:一键解锁服务扩展新姿势,让你的应用灵活飞天!"
【8月更文挑战第11天】SPI(Service Provider Interface)是Java的服务提供发现机制,用于运行时动态查找和加载服务实现。SpringBoot在其基础上进行了封装和优化,通过`spring.factories`文件提供更集中的配置方式,便于框架扩展和组件替换。本文通过定义接口`HelloService`及其实现类`HelloServiceImpl`,并在`spring.factories`中配置,结合`SpringFactoriesLoader`加载服务,展示了SpringBoot SPI机制的工作流程和优势。
29 5
|
23天前
|
Kubernetes 安全 云计算
分布式应用的终极革命:Distributionless,告别分布式烦恼!
【8月更文挑战第8天】探讨分布式应用的进化形态——Distributionless,一种使开发者聚焦业务逻辑而非系统细节的理念。借助容器化、云计算与自动化工具的进步,分布式应用的开发与管理变得简易。透过示例展现了使用Bazel构建及Kubernetes部署的流程,预示着Distributionless模式下的应用将更加高效、可靠与安全,引领未来分布式应用的发展趋势。
44 7
|
2天前
|
缓存 Java 数据库连接
Spring Boot 资源文件属性配置,紧跟技术热点,为你的应用注入灵动活力!
【8月更文挑战第29天】在Spring Boot开发中,资源文件属性配置至关重要,它让开发者能灵活定制应用行为而不改动代码,极大提升了可维护性和扩展性。Spring Boot支持多种配置文件类型,如`application.properties`和`application.yml`,分别位于项目的resources目录下。`.properties`文件采用键值对形式,而`yml`文件则具有更清晰的层次结构,适合复杂配置。此外,Spring Boot还支持占位符引用和其他外部来源的属性值,便于不同环境下覆盖默认配置。通过合理配置,应用能快速适应各种环境与需求变化。
|
5天前
|
监控 Java Serverless
美团 Flink 大作业部署问题之想在Serverless平台上实时查看Spring Boot应用的日志要怎么操作
美团 Flink 大作业部署问题之想在Serverless平台上实时查看Spring Boot应用的日志要怎么操作
下一篇
云函数