dubbo+zookeeper+springboot构建服务

本文涉及的产品
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
云原生网关 MSE Higress,422元/月
注册配置 MSE Nacos/ZooKeeper,118元/月
简介:   本次和大家分享的是dubbo框架应用的初略配置和zookeeper注册中心的使用;说到注册中心现在我使用过的只有两种:zookeeper和Eureka,zk我结合dubbo来使用,而Eureka结合springcloud使用,因此后面将和大家分享一些关于微服务的一些篇章,希望对你有好的帮助。

  本次和大家分享的是dubbo框架应用的初略配置和zookeeper注册中心的使用;说到注册中心现在我使用过的只有两种:zookeeper和Eureka,zk我结合dubbo来使用,而Eureka结合springcloud使用,因此后面将和大家分享一些关于微服务的一些篇章,希望对你有好的帮助。

  安装注册中心zookeeper

  dubbo框架之provider和consumer

  dubbo-admin部署

安装注册中心zookeeper

  首先,我们需要在网上搜索下zookeeper下载地址,我这里是linux系统,所以下载了zookeeper-3.3.6.tar.gz包,通过 tar -zxvf zookeeper-3.3.6.tar.gz 解压出来,需要注意的是一般的包里面配置文件都是默认的sample版本,zookeeper默认配置文件名只zoo.cfg,为了不每次指定文件名来运行,因此需要我们自己在conf目录下创建一个名称为zoo.cfg的配置文件,文件内容可以从zoo_sample.cfg拷贝或者把这个文件重命名都行,内容如下 vim zoo.cfg :

 1 # The number of milliseconds of each tick
 2 tickTime=2000  #心跳频率
 3 # The number of ticks that the initial 
 4 # synchronization phase can take
 5 initLimit=10   #限制连接
 6 # The number of ticks that can pass between 
 7 # sending a request and getting an acknowledgement
 8 syncLimit=5
 9 # the directory where the snapshot is stored.
10 dataDir=/tmp/zookeeper   #数据存储文件夹
11 # the port at which the clients will connect
12 clientPort=2081  #zookeeper对外的端口

  这里就不修改参数信息了,采用默认;简单介绍下linux下怎么编辑文件内容的常用的几个命令:

  vim zoo.cfg:查看文件内容

  insert:执行插入命令

  esc:取消命令,再接着按:q:退出,:wq:保存并退出

  当有了zoo.cfg后,我们只需要进入她的bin目录里面查找zkServer.sh文件,通过执行: ./zkServer.sh start 命令启动zookeeper注册中心,正常启动提示如:

  

  通常情况是zookeeper作为注册中心在单独的一台服务器上,而程序(这里指我本地)需要调用另外注册中心需要检查zookeeper开放的端口是否能通,我本地是window10因此可以不需要通过zookeeper客户端去验证端口,只需要通过 telnet ip 2081 就能检测出是否端口开放;

dubbo框架之provider和consumer

  首先为了方便,我们需要定义一个统一的接口,该接口就是业务抽出来的公用接口,我们单独对这种接口包装成一个module,我这里是dubbo_api,我们在这个module中定义如下的接口:

1 public interface UserService {
2     
3     List<MoUser> getUsers();
4 }

  然后,创建一个provider模块,这个模块去依赖dubbo_api模块,并且实现UserService接口,代码如:

 1 public class UserServiceImpl implements UserService {
 2 
 3     @Value("${server.port}")
 4     private int port;
 5 
 6     /**
 7      * @return
 8      */
 9     @Override
10     public List<MoUser> getUsers() {
11 
12         List<MoUser> list = new ArrayList<>();
13         for (int i = 0; i < 5; i++) {
14             MoUser user = new MoUser();
15             user.setUserName("shenniu" + i);
16             user.setUserPwd("端口:" + port);
17             list.add(user);
18         }
19         return list;
20     }
21 }

  作为服务提供者,要使用dubbo框架就需要先引入dubbo,然后再做一些配置,首先我们需要在dubbo_provider模块通过maven引入dubbo依赖,注册中心用的zookeeper所以也需要通过maven引入相应的依赖:

 1 <dependency>
 2             <groupId>org.apache.zookeeper</groupId>
 3             <artifactId>zookeeper</artifactId>
 4             <version>3.4.8</version>
 5         </dependency>
 6         <dependency>
 7             <groupId>com.101tec</groupId>
 8             <artifactId>zkclient</artifactId>
 9             <version>0.3</version>
10         </dependency>
11         <dependency>
12             <groupId>com.alibaba</groupId>
13             <artifactId>dubbo</artifactId>
14             <version>2.5.3</version>
15             <exclusions>
16                 <exclusion>
17                     <groupId>org.springframework</groupId>
18                     <artifactId>spring</artifactId>
19                 </exclusion>
20             </exclusions>
21         </dependency>
22         <dependency>
23             <groupId>com.example</groupId>
24             <artifactId>dubbo_api</artifactId>
25             <version>0.0.1-SNAPSHOT</version>
26         </dependency>

  完成依赖后,剩下的就是对dubbo的provider的配置了,创建resources/dubbo-conf/server.xml的配置文件,文件内容:

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <beans xmlns="http://www.springframework.org/schema/beans"
 3        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
 4        xsi:schemaLocation="http://www.springframework.org/schema/beans
 5             http://www.springframework.org/schema/beans/spring-beans.xsd
 6             http://code.alibabatech.com/schema/dubbo
 7             http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
 8 
 9     <!-- 提供者名称 -->
10     <dubbo:application name="demo-provider" />
11 
12     <!-- zookeeper注册中心的服务地址 -->
13     <dubbo:registry protocol="zookeeper" address="192.168.168.168:2081" />
14 
15     <!-- 用dubbo协议在20880端口暴露服务,协议通信端口 -->
16     <dubbo:protocol name="dubbo" port="20880" />
17 
18     <!-- 用户服务接口 -->
19     <dubbo:service interface="service.UserService" ref="userService" />
20 
21     <!-- 用户服务接口实现 -->
22     <bean id="userService" class="com.example.demo.service.UserServiceImpl"/>
23 </beans>

  在DubboProviderApplication入口增加资源导入 @ImportResource("classpath:dubbo-conf/*.xml") ,到这里我们的服务提供端就完成了,查看下启动日志:

  

  服务提供者启动暂无异常,再来看调用方创建一个dubbo_consumer的moduel,同样去引入dubbo_api公共接口的模块依赖,然后创建一个UserController,并暴露一个get的user接口:

 1 @RestController
 2 public class UserController {
 3     @Autowired
 4     private UserService userService;
 5 
 6     @GetMapping("/users")
 7     public List<MoUser> getUsers(){
 8 
 9         return userService.getUsers();
10     }
11 }

  这里的UserService是公共接口的注入;编码完成后剩下的就是consumer端引入dubbo和zookeeper依赖了:

 1 <dependency>
 2             <groupId>org.apache.zookeeper</groupId>
 3             <artifactId>zookeeper</artifactId>
 4             <version>3.4.8</version>
 5         </dependency>
 6         <dependency>
 7             <groupId>com.101tec</groupId>
 8             <artifactId>zkclient</artifactId>
 9             <version>0.3</version>
10         </dependency>
11         <dependency>
12             <groupId>com.alibaba</groupId>
13             <artifactId>dubbo</artifactId>
14             <version>2.5.3</version>
15             <exclusions>
16                 <exclusion>
17                     <groupId>org.springframework</groupId>
18                     <artifactId>spring</artifactId>
19                 </exclusion>
20             </exclusions>
21         </dependency>

  我们同样创建名称resources/dubbo-conf/client.xml的配置文件,并在application入口引入这个资源:

1 @ImportResource("classpath:dubbo-conf/*.xml")
2 @SpringBootApplication
3 public class DubboConsumerApplication {
4     public static void main(String[] args) {
5         SpringApplication.run(DubboConsumerApplication.class, args);
6     }
7 }

  client.xml的配置内容如:

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <beans xmlns="http://www.springframework.org/schema/beans"
 3        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
 4        xsi:schemaLocation="http://www.springframework.org/schema/beans
 5             http://www.springframework.org/schema/beans/spring-beans.xsd
 6             http://code.alibabatech.com/schema/dubbo
 7             http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
 8 
 9     <!-- 服务名 -->
10     <dubbo:application name="demo-consumer" />
11 
12     <!-- zookeeper注册中心暴露服务地址 -->
13     <dubbo:registry protocol="zookeeper" address="192.168.168.168:2081" />
14 
15     <!-- 用户服务接口 -->
16     <dubbo:reference id="userService" interface="service.UserService" />
17 
18 </beans>

  这个时候一个简单的服务提供者,服务调用者配置和编码都完成了,3个module如下:

  

  然后分别启动provider,consumer;再通过consumer暴露的controller接口请求接口,我这里的地址是 http://localhost:8082/users :

  

  效果是Consumer通过注入的UserService接口依赖调用getUsers()拿到了Provider返回的结果,也表示此次dubbo框架的简单使用算成功了。

dubbo-admin部署

  作为一个流行的rpc框架dubbo有这一个开源的监控工具dubbo-admin,不得不说现在网上现成的dubbo-admin.war包要么现在下来不能用要么就是下载需要csdn积分,版本多种多样有点坑啊,果断去git拉源码自己打包,git地址: https://github.com/apache/incubator-dubbo-ops ,拉下来后我们只需要关注dubbo-admin工程,其他的暂可忽略;打开项目后,我们需要改的地方只有如下截图配置(也可以对打包后的配置文件修改):

  

1 #zookeeper配置地址和端口
2 dubbo.registry.address=zookeeper://127.0.0.1:2081
3 #后台登录密码
4 dubbo.admin.root.password=root
5 dubbo.admin.guest.password=guest

  执行打包后,能得到名称:dubbo-admin-2.0.0.war包,然后放在tomcat中,再通过浏览器浏览,账号和密码:都是root;登录后能看到我们之前的启动的provider和consumer在里面,这就是dubbo-admin监控注册中心服务的界面,能够直接对这些服务做点击操作,其他的不多说自行尝试吧。

  

相关实践学习
基于MSE实现微服务的全链路灰度
通过本场景的实验操作,您将了解并实现在线业务的微服务全链路灰度能力。
目录
相关文章
|
2月前
|
Java API 数据库
构建RESTful API已经成为现代Web开发的标准做法之一。Spring Boot框架因其简洁的配置、快速的启动特性及丰富的功能集而备受开发者青睐。
【10月更文挑战第11天】本文介绍如何使用Spring Boot构建在线图书管理系统的RESTful API。通过创建Spring Boot项目,定义`Book`实体类、`BookRepository`接口和`BookService`服务类,最后实现`BookController`控制器来处理HTTP请求,展示了从基础环境搭建到API测试的完整过程。
60 4
|
2月前
|
Java API 数据库
如何使用Spring Boot构建RESTful API,以在线图书管理系统为例
【10月更文挑战第9天】本文介绍了如何使用Spring Boot构建RESTful API,以在线图书管理系统为例,从项目搭建、实体类定义、数据访问层创建、业务逻辑处理到RESTful API的实现,详细展示了每个步骤。通过Spring Boot的简洁配置和强大功能,开发者可以高效地开发出功能完备、易于维护的Web应用。
81 3
|
1月前
|
JavaScript 安全 Java
如何使用 Spring Boot 和 Ant Design Pro Vue 构建一个具有动态路由和菜单功能的前后端分离应用。
本文介绍了如何使用 Spring Boot 和 Ant Design Pro Vue 构建一个具有动态路由和菜单功能的前后端分离应用。首先,创建并配置 Spring Boot 项目,实现后端 API;然后,使用 Ant Design Pro Vue 创建前端项目,配置动态路由和菜单。通过具体案例,展示了如何快速搭建高效、易维护的项目框架。
118 62
|
25天前
|
负载均衡 Java 开发者
深入探索Spring Cloud与Spring Boot:构建微服务架构的实践经验
深入探索Spring Cloud与Spring Boot:构建微服务架构的实践经验
83 5
|
28天前
|
消息中间件 Java Kafka
Spring Boot 与 Apache Kafka 集成详解:构建高效消息驱动应用
Spring Boot 与 Apache Kafka 集成详解:构建高效消息驱动应用
43 1
|
1月前
|
Java
SpringBoot构建Bean(RedisConfig + RestTemplateConfig)
SpringBoot构建Bean(RedisConfig + RestTemplateConfig)
45 2
|
1月前
|
Dubbo Java 应用服务中间件
深入探讨了“dubbo+nacos+springboot3的native打包成功后运行出现异常”的原因及解决方案
本文深入探讨了“dubbo+nacos+springboot3的native打包成功后运行出现异常”的原因及解决方案。通过检查GraalVM版本兼容性、配置反射列表、使用代理类、检查配置文件、禁用不支持的功能、查看日志文件、使用GraalVM诊断工具和调整GraalVM配置等步骤,帮助开发者快速定位并解决问题,确保服务的正常运行。
52 1
|
1月前
|
JavaScript 安全 Java
如何使用 Spring Boot 和 Ant Design Pro Vue 构建一个前后端分离的应用框架,实现动态路由和菜单功能
本文介绍了如何使用 Spring Boot 和 Ant Design Pro Vue 构建一个前后端分离的应用框架,实现动态路由和菜单功能。首先,确保开发环境已安装必要的工具,然后创建并配置 Spring Boot 项目,包括添加依赖和配置 Spring Security。接着,创建后端 API 和前端项目,配置动态路由和菜单。最后,运行项目并分享实践心得,帮助开发者提高开发效率和应用的可维护性。
92 2
|
2月前
|
Dubbo 应用服务中间件 Apache
Dubbo 应用切换 ZooKeeper 注册中心实例,流量无损迁移
如果 Dubbo 应用使用 ZooKeeper 作为注册中心,现在需要切换到新的 ZooKeeper 实例,如何做到流量无损?
30 4
|
2月前
|
自然语言处理 Java API
Spring Boot 接入大模型实战:通义千问赋能智能应用快速构建
【10月更文挑战第23天】在人工智能(AI)技术飞速发展的今天,大模型如通义千问(阿里云推出的生成式对话引擎)等已成为推动智能应用创新的重要力量。然而,对于许多开发者而言,如何高效、便捷地接入这些大模型并构建出功能丰富的智能应用仍是一个挑战。
272 6

热门文章

最新文章