Springboot、Dubbo、Zookeeper 整合|学习笔记

本文涉及的产品
注册配置 MSE Nacos/ZooKeeper,118元/月
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
云原生网关 MSE Higress,422元/月
简介: 快速学习 Springboot、Dubbo、Zookeeper 整合

开发者学堂课程【SpringBoot 快速掌握 - 高级应用:Springboot、Dubbo、Zookeeper 整合】学习笔记,与课程紧密联系,让用户快速学习知识

课程地址https://developer.aliyun.com/learning/course/613/detail/9318


Springboot、Dubbo、Zookeeper 整合

内容介绍

一、服务提供者

二、服务消费者

三、运行结果


一、服务提供者

创建两个工程,一个是服务器提供者一个是服务的消费者,来测试  Dubbo。

为了整合,创建一个空工程,命名为 Springboot-06-Dubbo。

由于是空工程所以创建完成后需要加入一些子工程。点击 File-New,创建一个 module。选中 Spring 初始化向导,点击 Next。

首先创建一个服务提供者,group 是 com.atguigu,Artifact 是 provider-ticket,把 package 改为 com.atguigu.ticket 。为了测试方便,加入 web 模块,改为1.5.12版本,点击 finish,这样就会在工程创建出一个模块。

//在模块中写入 service,把这个 service 做成接口。

//规定一个方法。表示返回一个电影票。

Public String getTicket();

//写上这个接口的实现,新建一个 class,命名为 TicketServicelmpl。

public c1ass TicketServiceImpl implements TicketService {

@override

public String getTicket() {

return"《厉害了,我的国》”;

}

}


二、服务消费者

新建一个服务作为消费者。group 是 com.atguigu,Artifact 是 consumer-user,package 是 com.atguigu.user,表示用户购买电影票。为了测试方便,加入 web 模块,改为1.5.12版本,点击 finish。在 user service 中新建一个类,命名为 sevice.user service。

在 user service 中想要用到票的服务。步骤如下:使用 Dubbo 将服务提供者注册到注册中心里,user 要消费 ticket 服务,就要同时从注册中心中订阅 ticket 服务。得到 ticket 服务的提供者地址列表后,user 就可以直接调用 ticket 服务了。中间的调用也是 Dubbo做的。

//第一步是将服务提供者注册到注册中心。在 pom.xml 中整合 Dubbo。在 Dubbo官方网站的 Github 中可以查看相关源码。把 spring-boot-dubbo-starter 的依赖放入 pom 文件中。

<dependency>

<groupid>com.alibaba.boot</groupId>

<artifactId>dubbo-spring-boot-starter<,/artifactId>

<version>0.1.0</version>

</dependency>

//由于 dubbo 要操作 zookeeper,所以需要引入 zookeeper 的客户端工具。在 maven respository 中搜索 zkclient 引入客户端工具。这样就引入了依赖。

<!-https:mvnrepository.com/artifact/com.github.sgroschupf/zkclient -->

<dependency>

<groupId>com.github.sgroschupf</groupId>

<artifactId>zkclient</artifactId>

<version>0.1</version>

</dependency>

//配置 application.properties 中 dubbo 的相关属性。

dubbo.application.name=provider-ticket

// dubbo 把应用发布到注册中心。虚拟机的地址是118.24.44.169:2181,端口是2181。

dubbo.registry.address=zookeeper://118.24.44.169:2181

//把 sevice 包下的服务发布出去。

dubbo.scan.base-packages=com.atguigu.ticket.service

//把服务发布出去需要在 TicketServiceImpl 中加一个注解@service,这个 sevice 是 dubbo的 service。@service 的作用就是把服务发布出去。通过 @component 把它加在 Spring 容器中。

@component

@service

public c1ass TicketServiceImpl implements TicketService {

@override

public String getTicket() {

return"《厉害了,我的国》”;

}

这样就将服务发布出去了。Application 应用一启动,dubbo 就会按照 base-packages 扫描规则,将标了 @service 的服务按照配置的注册中心的地址发布出去。总结一共有三个步骤:1、引入 dubbo 和 zkcLient 相关依赖2、配置 dubbo 的扫描包和注册中心地址3、使用 @Service 发布服务。

启用项目,在控制台中 dubbo 的服务就注册成功了。

image.png

在消费者 consumeruserapplication 中测试,假设 userservice 要使用 ticketservice 的功能。做法如下:1、引入依赖2、配置 dubbo 的注册中心地址3、引用服务。

//从原来的 pom 文件中,把 spring-boot-dubbo-starter 以及 zkcLient 复制到消费者的 pom 文件中。

<dependency>

<groupid>com.alibaba.boot</groupId>

<artifactId>dubbo-spring-boot-starter<,/artifactId>

<version>0.1.0</version>

</dependency>

<!-https:mvnrepository.com/artifact/com.github.sgroschupf/zkclient -->

<dependency>

<groupId>com.github.sgroschupf</groupId>

<artifactId>zkclient</artifactId>

<version>0.1</version>

</dependency>

//配置 resource

dubbo.application.name=consumer-user

//配置 dubbo 的注册中心地址,地址和 application.properties 用的是同一个注册中心。这里是消费服务。

dubbo.registry.address=zookeeper:/ /118.24.44.169:2181

// userservice 如果要使用 ticketservice ,做法如下:将 prodiver-ticket 下的 ticketservice 复制到 consumer-user 下的 com.atguigui中,并且要全类名相同。删除 ticket 包的实现类。只需要 ticketservice 中的接口。在 usersevice 中书写如下代码:

import org.springframework.stereotype.Service;

@Service

public c1ass UserService{

}

//这是 spring 的一个组件,它来用 ticketservice 。需要加注解@reference 远程引用。远程引用是按照 ticketService 全类名进行匹配,看哪里在注册中心注册了 ticketService 这个全类名的服务。而在之前的 ticketservice 中发布服务时就是按照 ticketService 这个全类名发布的,所以这里就能够获取到。

import com.alibaba.dubbo.config.annotation.Reference;

import com.atguigu.ticket.service.TicketService;

import org.springframework.stereotype.Service;

@Service

public c1ass UserService{

@reference

TicketService ticketService;

//写一个方法,在hello中调用 ticketservice,只是调接口的方法。这个方法就会远程调用提供者的相关功能。

public void hello(){

String ticket=ticketService.getTicket();

System.out.println("买到票了:“+ticket);

//在测试类中测试能否使用,将 userservice 注入进来。

@Autowired

UserService userService;

//调用 userservice 的 hello 方法,hello 方法会远程调用 ticketservice 的 getTicket 方法。

UserService.hello()


三、运行结果

启动服务,注意在运行中 provider 服务器必须一直保持运行。

运行效果如下:表示运行成功。

image.png

买到票了,《厉害了,我的国》这个内容是 provider 提供的。

以上即是利用 dubbo 分布式做一个消费者,做一个提供者。Dubbo 能让应用以非常简约的方式实现远程调用能力。

相关实践学习
基于MSE实现微服务的全链路灰度
通过本场景的实验操作,您将了解并实现在线业务的微服务全链路灰度能力。
相关文章
|
2月前
|
Dubbo Java 应用服务中间件
微服务学习 | Springboot整合Dubbo+Nacos实现RPC调用
微服务学习 | Springboot整合Dubbo+Nacos实现RPC调用
|
2月前
|
监控 Dubbo 前端开发
快速入门分布式系统与Dubbo+zookeeper Demo
快速入门分布式系统与Dubbo+zookeeper Demo
450 0
|
1月前
|
NoSQL Dubbo 应用服务中间件
Dubbo Zookeeper(一)Zookeeper初识
Dubbo Zookeeper(一)Zookeeper初识
|
29天前
|
Dubbo Java 应用服务中间件
Spring Boot 调用 Dubbo 接口与编写 Dubbo 接口实战
Spring Boot 调用 Dubbo 接口与编写 Dubbo 接口实战
66 1
|
26天前
|
消息中间件 Java 数据库连接
理解java的springboot+mybatisplus+dubbo+nacos+kafka这一套技术栈
理解java的springboot+mybatisplus+dubbo+nacos+kafka这一套技术栈
34 0
|
29天前
|
缓存 NoSQL 数据库
分布式系统面试全集通第一篇(dubbo+redis+zookeeper----分布式+CAP+BASE+分布式事务+分布式锁)
分布式系统面试全集通第一篇(dubbo+redis+zookeeper----分布式+CAP+BASE+分布式事务+分布式锁)
37 0
|
2月前
|
SQL 监控 Java
nacos常见问题之dubbo+nacos+springboot3的native打包成功后运行出现异常如何解决
Nacos是阿里云开源的服务发现和配置管理平台,用于构建动态微服务应用架构;本汇总针对Nacos在实际应用中用户常遇到的问题进行了归纳和解答,旨在帮助开发者和运维人员高效解决使用Nacos时的各类疑难杂症。
150 2
|
2月前
|
Dubbo Java 应用服务中间件
Spring Boot整合Dubbo+Zookeeper实现RPC调用
Spring Boot整合Dubbo+Zookeeper实现RPC调用 技术栈说明 Dubbo:Dubbo作为RPC框架,能在多个服务之间实现远程服务的调用。比如有两个独立的微服务A和B,A服务想要调用B服务时,因为两者不在同个内存空间中,不能直接调用,所以可以通过Dubbo实现这点。 功能和Spring Cloud的Feign相同,两者都是应用于微服务架构的远程调用框架 Zookeeper:作为注册中心去管理Dubbo服务,这点和Eureka、Nacos相同。 概述 通过一个示例说明Dubbo+Zookeeper在Spring Boot中的应用。 现有两个服务provider和con
138 4
|
2月前
|
Dubbo Java 应用服务中间件
阿里巴巴资深架构师深度解析微服务架构设计之SpringCloud+Dubbo
软件架构是一个包含各种组织的系统组织,这些组件包括Web服务器,应用服务器,数据库,存储,通讯层),它们彼此或和环境存在关系。系统架构的目标是解决利益相关者的关注点。
|
2月前
|
Dubbo Cloud Native 应用服务中间件
【阿里云云原生专栏】云原生环境下的微服务治理:阿里云 Dubbo 与 Nacos 的深度整合
【5月更文挑战第25天】阿里云Dubbo和Nacos提供微服务治理的强大工具,整合后实现灵活高效的治理。Dubbo是高性能RPC框架,Nacos则负责服务发现和配置管理。整合示例显示,通过Nacos注册中心,服务能便捷注册发现,动态管理配置。简化部署,提升适应性,但也需注意服务稳定性和策略规划。这种整合为云原生环境的微服务架构带来强大支持,未来应用前景广阔。
240 2