DubboNacos

news/2025/3/18 15:01:36/文章来源:https://www.cnblogs.com/kk-koala/p/18341782

Dubbo的前世今生

2011年10月27日,阿里巴巴开源了自己的SOA服务化治理方案的核心框架Dubbo,服务治理和SOA的设计理念开始逐渐在国内软件行业中落地,并被广泛应用。

  • 早期版本的dubbo遵循SOA的思想,是面向服务架构的重要组件。

  • 如今版本的Dubbo作为Spring Cloud的二进制通信方案来发挥Dubbo的性能优势

Dubbo的快速入门

Dubbo的基本架构

image-20210724230935258

节点角色说明:

节点 角色说明
Provider 暴露服务的服务提供方。
Consumer 调用远程服务的服务消费方。
Registry 服务注册与发现的注册中心。
Monitor 统计服务的调用次数和调用时间的监控中心。

调用关系说明:

  1. 服务容器负责启动,加载,运行服务提供者。
  2. 服务提供者在启动时,向注册中心注册自己提供的服务。
  3. 服务消费者在启动时,向注册中心订阅自己所需的服务。
  4. 注册中心返回服务提供者地址列表给消费者,如果有变更,注册中心将基于长连接推送变更数据给消费者。
  5. 服务消费者,从提供者地址列表中,基于软负载均衡算法,选一台提供者进行调用,如果调用失败,再选另一台调用。
  6. 服务消费者和提供者,在内存中累计调用次数和调用时间,定时每分钟发送一次统计数据到监控中心。

Nacos

Nacos是阿里巴巴的产品,是一个集服务发现,配置管理的平台,在国内受欢迎程度较高。

image-20210727122815029

1、找到今日资料中的nacos安装包

image-20210727122829914

2、解压到没有中文和特殊字符的目录

3、进入bin目录,执行启动命令

#进入bin目录
cd bin
#启动
startup.cmd -m standalone

4、浏览器查看:http://127.0.0.1:8848/nacos

管理后台

DubboAdmin是阿里巴巴管理提供的管理控制台,可以实现服务查询,详情展示,服务测试等功能。借由DubboAdmin可以更好的帮助开发人员对服务进行管理和监控

#1、下载代码: 
git clone https://github.com/apache/dubbo-admin.git
#2、在 dubbo-admin-server/src/main/resources/application.properties中指定注册中心地址
#3、构建
mvn clean package -D maven.test.skip=true
#4、启动
mvn --projects dubbo-admin-server spring-boot:run
#或者
cd dubbo-admin-distribution/target; java -jar dubbo-admin-0.1.jar
#5、访问 http://localhost:8080

入门案例

需求:使用Dubbo构建分布式架构,完成根据用户id查询用户

image-20210727123052273

服务提供者

搭建环境

(1)创建user-provider模块导入依赖

<dependencies><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId></dependency><!--mybatis--><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId></dependency><!--dubbo的起步依赖--><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.8</version></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-registry-nacos</artifactId><version>2.7.8</version></dependency>
</dependencies>

(2)编写引导类

package cn.itcast.user;import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@MapperScan("cn.itcast.user.mapper")
@SpringBootApplication
public class UserProviderApplication {public static void main(String[] args) {SpringApplication.run(UserProviderApplication.class, args);}}
代码实现

(1)UserServiceImpl

package cn.itcast.user.service;import cn.itcast.user.api.UserService;
import cn.itcast.user.domain.User;
import cn.itcast.user.mapper.UserMapper;
import org.apache.dubbo.config.annotation.DubboService;
import org.springframework.beans.factory.annotation.Autowired;@DubboService
public class UserServiceImpl implements UserService {@Autowiredprivate UserMapper userMapper;//根据id查询用户名称public String queryUsername(Long id) {return userMapper.findById(id).getUsername();}
}
配置文件
server:port: 18081
spring:datasource:url: jdbc:mysql://localhost:3306/dubbo-demo?useSSL=falseusername: rootpassword: rootdriver-class-name: com.mysql.jdbc.Driverapplication:name: user-provider
logging:level:cn.itcast: debugpattern:dateformat: HH:mm:ss:SSS
dubbo:protocol:name: dubboport: 20881registry:address: nacos://127.0.0.1:8848scan:base-packages: cn.itcast.user.service

服务消费者

搭建环境

(1)创建user-consumer模块导入依赖

<dependencies><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!--dubbo的起步依赖--><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.8</version></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-registry-nacos</artifactId><version>2.7.8</version></dependency>
</dependencies>

(2)配置引导类

package cn.itcast.user;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
public class UserConsumerApplication {public static void main(String[] args) {SpringApplication.run(UserConsumerApplication.class, args);}
}
代码实现
package cn.itcast.user.controller;import cn.itcast.user.api.UserService;
import cn.itcast.user.domain.User;
import lombok.extern.slf4j.Slf4j;
import org.apache.dubbo.config.annotation.DubboReference;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;@Slf4j
@RestController
@RequestMapping("/user")
public class UserController {//引用远程服务@DubboReferenceprivate UserService userService;@GetMapping("/username/1")public String findUserName(@PathVariable("id") Long id) {return userService.queryUsername(id);}
}
配置文件
server:port: 18080
spring:application:name: user-consumer
logging:level:cn.itcast: debugpattern:dateformat: HH:mm:ss:SSS
dubbo:registry:address: nacos://127.0.0.1:8848

代码优化

将接口抽取为独立模块,并且把接口有关的domain都放到这个模块中

(1)创建user-api模块引入依赖

(2)将UserService接口和User对象导入user-api模块下

(3)User对象实现序列化接口

package cn.itcast.user.domain;import lombok.Data;import java.io.Serializable;@Data
public class User implements Serializable {private Long id;private String username;private String address;
}

Dubbo高级特性

超时与重试

服务消费者在调用服务提供者的时候发生了阻塞、等待的情形,这个时候,服务消费者会一直等待下去。

在某个峰值时刻,大量的请求都在同时请求服务消费者,会造成线程的大量堆积,势必会造成雪崩。

  • dubbo 利用超时机制来解决这个问题(使用timeout属性配置超时时间,默认值1000,单位毫秒)
  • 若超时时间较短,当网络波动时请求就会失败,Dubbo通过重试机制避免此类问题的发生

user-consumer模块中添加配置信息

dubbo:registry:address: nacos://127.0.0.1:8848consumer:timeout: 3000retries: 0

启动检查

为了保障服务的正常可用,Dubbo 缺省会在启动时检查依赖的服务是否可用,不可用时会抛出异常

image-20210727124027308

在正式环境这是很有必要的一项配置,可以保证整个调用链路的平稳运行

在开发时,往往会存在没有提供者的情况。由于启动检查的原因,可能导致开发测试出现问题

可以通过check=false关闭

user-consumer模块中添加配置信息

dubbo:registry:address: nacos://127.0.0.1:8848consumer:check: false

多版本

灰度发布:当出现新功能时,会让一部分用户先使用新功能,用户反馈没问题时,再将所有用户迁移到新功能。

Dubbo提供了提供者多版本的支持,平滑处理项目功能升级部署

(1)user-provider定义新的服务实现类UserServiceImpl2,指定版本

@DubboService(version = “2.0.0”)
public class UserServiceImpl2 implements UserService {…………
}

(2)user-consumer消费者调用时,指定版本调用

@RestController
@RequestMapping("/user")
public class UserController {//引用远程服务@DubboReference(version = "2.0.0")private UserService userService;    ………
}

负载均衡

在集群部署时,Dubbo提供了4种负载均衡策略,帮助消费者找到最优提供者并调用

  • Random :按权重随机,默认值。按权重设置随机概率。

  • RoundRobin :按权重轮询

  • LeastActive:最少活跃调用数,相同活跃数的随机。

  • ConsistentHash:一致性 Hash,相同参数的请求总是发到同一提供者。

@RestController
@RequestMapping("/user")
public class UserController {//引用远程服务@DubboReference(loadbalance = "roundrobin")private UserService userService;
}

SpringCloud整合Dubbo

通常来说,RPC协议比REST具有更好的性能。很多开发人员希望享受Spring Cloud的生态,同时有兼顾PRC的效率的效率。SpringCloud Alibaba很好的解决了这个问题。

功能概述

将Dubbo集成至SpringCloud主要是替换Ribbo或者Feign实现远程调用。加入Dubbo后,整体的架构如下:

image-20210724222206792

入门案例

抽取接口

定义接口模块dubbo-api,并将UserService接口抽取到此模块下

package cn.itcast.dubbo.api;import cn.itcast.dubbo.domain.User;public interface UserService {User queryById(Long id);
}

项目依赖

父工程加入SpringCloud Alibaba依赖

<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-alibaba-dependencies</artifactId><version>2.2.5.RELEASE</version><type>pom</type><scope>import</scope>
</dependency>

消费者和提供者引入nacos注册中心和Dubbo依赖

<!--nacos注册中心的依赖-->
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency><!--springcloud alibaba dubbo依赖   -->
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-dubbo</artifactId>
</dependency><dependency><groupId>cn.itcast</groupId><artifactId>dubbo-api</artifactId><version>1.0-SNAPSHOT</version>
</dependency>

服务提供者

修改UserService实现UserApi接口。并使用@DubboService注解替换@Service对外暴露dubbo服务

package cn.itcast.user.service;import cn.itcast.dubbo.api.UserService;
import cn.itcast.dubbo.domain.User;
import cn.itcast.user.mapper.UserMapper;
import org.apache.dubbo.config.annotation.DubboService;
import org.springframework.beans.factory.annotation.Autowired;@DubboService
public class UserServiceImpl implements UserService {@Autowiredprivate UserMapper userMapper;public User queryById(Long id) {return userMapper.findById(id);}
}

在application.yml中添加配置

spring:datasource:url: jdbc:mysql://localhost:3306/dubbo-demo?useSSL=falseusername: rootpassword: rootdriver-class-name: com.mysql.jdbc.Driverapplication:name: user-servicecloud:nacos:discovery:server-addr: localhost:8848
#配置dubbo,注册中心,暴露的端口和协议,dubbo注解的包扫描
dubbo:protocol:name: dubboport: 20881registry:address: spring-cloud://localhost   #使用SpringCloud中的注册中心scan:base-packages: cn.itcast.user.service  #dubbo中包扫描

服务消费者

在OrderController中引入dubbo服务。调用UserService查询用户

package cn.itcast.order.controller;import cn.itcast.dubbo.api.UserService;
import cn.itcast.dubbo.domain.Order;
import cn.itcast.dubbo.domain.User;
import cn.itcast.order.service.OrderService;
import org.apache.dubbo.config.annotation.DubboReference;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
@RequestMapping("order")
public class OrderController {@Autowiredprivate OrderService orderService;@DubboReferenceprivate UserService userService;@GetMapping("{orderId}")public Order queryOrderByUserId(@PathVariable("orderId") Long orderId) {//根据id查询订单Order order = orderService.queryOrderById(orderId);//获取用户idLong userId = order.getUserId();//查询用户User user = userService.queryById(userId);//设置用户对象order.setUser(user);// 根据id查询订单并返回return order;}
}

在Order-service的模块中添加dubbo配置

spring:application:name: order-servicecloud:nacos:discovery:server-addr: localhost:8848
#dubbo配置
dubbo:registry:address: spring-cloud://localhost  #使用cloud的注册中心consumer:check: false   #dubbo默认有启动检查retries: 0     #dubbo内置的重试机制

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hqwc.cn/news/777729.html

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

c语言其三

返回值 8位—al 16位—ax 32位—eax 64位—eax(放低位,edx(高位 64: 32:1、char(两个字节)类型的返回值 2、short(两个字节) 类型的返回值 3、int (八个字节)类型的返回值 参数传递无论是char还是short类型,反汇编中都是以4个字节传递 结论:整数类型的参数…

ArkTS #02# Ability的调用及启动模式

1调用&单实例 import common from @ohos.app.ability.common import Want from @ohos.app.ability.Want @Entry @Component struct Index {@State message: string = Hello Worldbuild() {Row() {Column() {Text(this.message).fontSize(50).fontWeight(FontWeight.Bold)Bu…

VMware虚拟机版OpenCore引导,Vmware安装苹果系统

使用Windows下的VMware虚拟机安装macOS系统,常规安装都需要使用到unlocker解锁工具.而直接使用OpenCore引导安装,就可以不使用unlocker解锁工具也能安装macOS系统,使用OpenCore引导的优点还是有的,比如改三码或五码还是比较方便,这里将最近配置的OpenCore引导分享给大家一起研究…

开发在线客服系统新的宣传推广站【微客客服】

打造一个软件宣传官网,这事儿可不简单。咱们得先搞清楚,这个网站要给谁看,要传达啥信息,需要哪些功能。我们网站是宣传【在线客服系统】的,所以需要把主要功能展示清楚 在线网址:https://weikefu.com.cn然后,咱们得设计一番,把网站的布局、界面和用户体验给搞定。接下来…

Java - 异常与File

异常灵魂四问:如果try中没有遇到问题,怎么执行?try全部执行,catch不执行如果try中可能会遇到多个问题,怎么执行?写多个catch与之对应,父类异常需要写在下面如果try中遇到的问题没有被捕获,怎么执行?异常会默认交给虚拟机处理,try...catch白写如果try中遇到了问题,那…

费马点(到三角形顶点之和最小的点)

2024_8_4 费马点(到三角形顶点之和最小的点) 1.如果有度数大于120的角,则该点为费马点。 2.否则为某条边为底边往外作正三角形,将外面的点与这条边以外的那个点连线就为最短长度。 \[f(X, \, Y, \, Z) = \sqrt{\frac{a^2+b^2+c^2+4\sqrt{3}S}{2}}. \]

ComfyUI插件:ComfyUI layer style 节点(四)

前言: 学习ComfyUI是一场持久战,而ComfyUI layer style 是一组专为图片设计制作且集成了Photoshop功能的强大节点。该节点几乎将PhotoShop的全部功能迁移到ComfyUI,诸如提供仿照Adobe Photoshop的图层样式、提供调整颜色功能(亮度、饱和度、对比度等)、提供Mask辅助工具、…

ABC365

A link题目已经说的很明白了,判断即可。点击查看代码 #include<bits/stdc++.h>using namespace std;int y;signed main(){cin >> y;if(y%4 != 0) cout << 365;else if(y%4 == 0&&y%100 != 0) cout << 366;else if(y%100 == 0&&y%400 …

没闲着系列 21

离上个20记录已经3个月了。 这3个月我算体会到了什么是欠缺项目管理导致的项目失败。 当然,有一部分我认为项目是没有失败的,但有一部分也是个人原因,但不多。 算了,不去想之前的糟心事,讲一讲TaskSaas近期更新了什么吧。首先还是关于迭代需求,现在不创建迭代不允许新增需…