SpringBoot + Dubbo + zookeeper实现

server/2024/9/22 19:08:13/

目录

一,框架搭建

1. 启动zookeeper !

2. IDEA创建一个空项目;

3.创建一个模块,实现服务提供者:provider-server , 选择web依赖即可

4.项目创建完毕,我们写一个服务,比如卖票的服务

编写接口

编写实现类

编写service

二,服务提供者

1,第一步 

zookeeper的包我们去maven仓库下载,zkclient;

【新版的坑】zookeeper及其依赖包,解决日志冲突,还需要剔除日志依赖;

dubbo%E7%9B%B8%E5%85%B3%E5%B1%9E%E6%80%A7%EF%BC%81-toc" style="margin-left:80px;"> 在springboot配置文件中配置dubbo相关属性!

dubbo%E4%B8%AD%E7%9A%84%E6%B3%A8%E8%A7%A3%EF%BC%8C%E8%80%8C%E4%B8%8D%E6%98%AFspring%E7%9A%84%E6%B3%A8%E8%A7%A3%2C%E6%89%80%E4%BB%A5%E8%A6%81%E6%8A%8A%E5%85%B6%E6%B3%A8%E5%85%A5%E5%B0%B1%E8%A6%81%E7%94%A8Componet%EF%BC%8C%E4%B8%8D%E8%BF%87%E6%9C%80%E6%96%B0%E7%89%88%E6%9C%AC%E7%9A%84%E5%A5%BD%E5%83%8F%E5%B7%B2%E7%BB%8F%E8%A7%A3%E5%86%B3%E8%BF%99%E4%B8%AA%E9%97%AE%E9%A2%98%EF%BC%9A%E4%B8%80%E4%B8%AA%E6%96%B0%E7%9A%84%E6%B3%A8%E8%A7%A3%40DubboService-toc" style="margin-left:80px;"> 在service的实现类中配置服务注解,发布服务!注意导包问题,因为这里的Service注解需要导入的是dubbo中的注解,而不是spring的注解,所以要把其注入就要用Componet,不过最新版本的好像已经解决这个问题:一个新的注解@DubboService

三,服务消费者

1.导入依赖,和之前的依赖一样;

2.配置参数

3.本来正常步骤是需要将服务提供者的接口打包,然后用pom文件导入,我们这里使用简单的方式,直接将服务的接口拿过来,路径必须保证正确,即和服务提供者相同;

4,完善消费者的服务类

5.测试类编写

四,微服务架构问题:

分布式架构会遇到的四个核心问题:

解决方案:


一,框架搭建

1. 启动zookeeper !

2. IDEA创建一个空项目;

3.创建一个模块,实现服务提供者:provider-server , 选择web依赖即可

4.项目创建完毕,我们写一个服务,比如卖票的服务

编写接口
package com.guo.provider.service;public interface TicketService {public String getTicket();
}
编写实现类
package com.guo.provider.service;public class TicketServiceImpl implements TicketService {@Overridepublic String getTicket() {return "《狂神说Java》";}
}

5.创建一个模块,实现服务消费者:consumer-server , 选择web依赖即可

6.项目创建完毕,我们写一个服务,比如用户的服务;

编写service
package com.guo.consumer.service;public class UserService {//我们需要去拿去注册中心的服务
}
二,服务提供者

1,第一步 

将服务提供者注册到注册中心,我们需要整合Dubbo和zookeeper,所以需要导包

我们从dubbo官网进入github,看下方的帮助文档,找到dubbo-springboot,找到依赖包

<!-- Dubbo Spring Boot Starter -->
<dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.3</version>
</dependency>

zookeeper的包我们去maven仓库下载,zkclient;

<!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient -->
<dependency><groupId>com.github.sgroschupf</groupId><artifactId>zkclient</artifactId><version>0.1</version>
</dependency>

【新版的坑】zookeeper及其依赖包,解决日志冲突,还需要剔除日志依赖;

<!-- 引入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><!--排除这个slf4j-log4j12--><exclusions><exclusion><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId></exclusion></exclusions>
</dependency>

dubbo%E7%9B%B8%E5%85%B3%E5%B1%9E%E6%80%A7%EF%BC%81"> 在springboot配置文件中配置dubbo相关属性!

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

dubbo%E4%B8%AD%E7%9A%84%E6%B3%A8%E8%A7%A3%EF%BC%8C%E8%80%8C%E4%B8%8D%E6%98%AFspring%E7%9A%84%E6%B3%A8%E8%A7%A3%2C%E6%89%80%E4%BB%A5%E8%A6%81%E6%8A%8A%E5%85%B6%E6%B3%A8%E5%85%A5%E5%B0%B1%E8%A6%81%E7%94%A8Componet%EF%BC%8C%E4%B8%8D%E8%BF%87%E6%9C%80%E6%96%B0%E7%89%88%E6%9C%AC%E7%9A%84%E5%A5%BD%E5%83%8F%E5%B7%B2%E7%BB%8F%E8%A7%A3%E5%86%B3%E8%BF%99%E4%B8%AA%E9%97%AE%E9%A2%98%EF%BC%9A%E4%B8%80%E4%B8%AA%E6%96%B0%E7%9A%84%E6%B3%A8%E8%A7%A3%40DubboService"> 在service的实现类中配置服务注解,发布服务!注意导包问题,因为这里的Service注解需要导入的是dubbo中的注解,而不是spring的注解,所以要把其注入就要用Componet,不过最新版本的好像已经解决这个问题:一个新的注解@DubboService

import org.apache.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;@Service //将服务发布出去
@Component //放在容器中
public class TicketServiceImpl implements TicketService {@Overridepublic String getTicket() {return "《狂神说Java》";}
}

逻辑理解 :应用启动起来,dubbo就会扫描指定的包下带有@component注解的服务,将它发布在指定的注册中心中!

三,服务消费者

1.导入依赖,和之前的依赖一样;

<!--dubbo-->
<!-- Dubbo Spring Boot Starter -->
<dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.3</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>
<!-- 引入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><!--排除这个slf4j-log4j12--><exclusions><exclusion><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId></exclusion></exclusions>
</dependency>

2.配置参数

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

3.本来正常步骤是需要将服务提供者的接口打包,然后用pom文件导入,我们这里使用简单的方式,直接将服务的接口拿过来,路径必须保证正确,即和服务提供者相同;

4,完善消费者的服务类
 

package com.guo.consumer.service;import com.guo.provider.service.TicketService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Service;@Service //注入到容器中
public class UserService {@Reference //远程引用指定的服务,他会按照全类名进行匹配,看谁给注册中心注册了这个全类名TicketService ticketService;public void buyTicket(){String ticket = ticketService.getTicket();System.out.println("在注册中心买到"+ticket);}}

5.测试类编写

@RunWith(SpringRunner.class)
@SpringBootTest
public class ConsumerServerApplicationTests {@AutowiredUserService userService;@Testpublic void contextLoads() {userService.bugTicket();}}

四,微服务架构问题:

分布式架构会遇到的四个核心问题:

1.这么多的服务,客户端该如何去访问?
2.这么多的服务,服务器之间如何进行通信?
3.这么多的服务,该如何管理和治理?
4.服务挂了,怎么办?

解决方案:

SpringCloud,是一套生态,就是来解决以上分布式架构的四个问题

想使用SpringCloud,必须要掌握Springboot,因为它是基于SpirngBoot的

1.SpringCloud NetFlix,出了一套解决方案

2.Apcahe Dubbo zookeeper 第二套解决方案

API:没有,要么找第三方,要么自己实现

Dubbo是一个高性能的基于java实现的RPC通信框架

服务注册与发现,zookeeper,没有熔断机制,接住了Hystrix


http://www.ppmy.cn/server/14575.html

相关文章

用Python自动获取PDF图纸的图纸大小,并依此分类整理

在建筑行业&#xff0c;设计师用CAD设计完建筑图纸后&#xff0c;常常需要上传到市、省二级图审平台上&#xff0c;故需要将每张图纸转成PDF文档&#xff0c;并盖电子章&#xff08;出图章、建造师章和结构章&#xff09;&#xff0c;然后上传图审系统。如果设计师在CAD转PDF时…

flutter笔记-万物皆是widget

文章目录 helloFlluter自定义Widget优化 这篇文章后就不见写了&#xff0c;学flutter主要是为了更好的使用 flutter-webrtc&#xff0c;所以到这里基本就了解了大部分的知识&#xff0c;后续边用边查&#xff1b; 在flutter中所有的view都叫widget&#xff0c;类似文本组件Tex…

数据库之数据库恢复技术思维导图+大纲笔记

大纲笔记&#xff1a; 事务的基本概念 事务 定义 用户定义的一个数据库操作系列&#xff0c;这些操作要么全做&#xff0c;要么全不做&#xff0c;是一个不可分割的基本单位 语句 BEGIN TRANSACTION 开始 COMMIT 提交&#xff0c;提交事务的所有操作 ROLLBACK 回滚&#xff0c…

Llama 3大模型发布!快速体验推理及微调

Meta&#xff0c;一家全球知名的科技和社交媒体巨头&#xff0c;在其官方网站上正式宣布了一款开源的大型预训练语言模型——Llama-3。 据了解&#xff0c;Llama-3模型提供了两种不同参数规模的版本&#xff0c;分别是80亿参数和700亿参数。这两种版本分别针对基础的预训练任务…

RabbitMQ3.13.x之十二_WindowsServer服务器安装RabbitMQ后无法连接问题及处理方法

RabbitMQ3.13.x之十二_WindowsServer服务器安装RabbitMQ后无法连接问题及处理方法 文章目录 RabbitMQ3.13.x之十二_WindowsServer服务器安装RabbitMQ后无法连接问题及处理方法1. 基础环境2. 问题描述1. 问题描述2. 原因分析 3. 处理方法1. 修改两个.erlang.cookie 文件一致2. 卸…

1. Tailwind CSS 简介

1.1 什么是 Tailwind CSS Tailwind CSS 是一个高度可定制的、实用的 CSS 框架&#xff0c;它提供了一套丰富的工具类&#xff0c;使得开发者可以快速地构建现代化的用户界面。它的设计理念是“工具优先”&#xff0c;这意味着它提供的是一系列可以直接应用到 HTML 元素上的 CS…

力扣经典150题第四十一题:有效的字母异位词

目录 力扣经典150题第四十二题&#xff1a;有效的字母异位词引言题目详解解题思路代码实现示例演示复杂度分析 力扣经典150题第四十二题&#xff1a;有效的字母异位词 引言 本篇博客介绍了力扣经典150题中的第四十二题&#xff1a;有效的字母异位词。题目要求判断给定的字符串…

2024护眼台灯哪个牌子好?盘点目前比较好用的护眼台灯

在日常生活中&#xff0c;照明环境的好坏直接关系到我们的视力健康。为此&#xff0c;护眼台灯作为一种专为缓解眼部疲劳和保护视力而设计的照明设备&#xff0c;受到了广大用户的青睐。然而&#xff0c;面对市场上众多的护眼台灯品牌&#xff0c;消费者往往难以抉择。2024护眼…