B003-springcloud alibaba 服务治理 nacos discovery ribbon feign

目录

      • 服务治理
        • 服务治理介绍
        • 什么是服务治理
        • 相关方案
      • nacos实战入门
        • 搭建nacos环境
          • 安装nacos
          • 启动nacos
          • 访问nacos
        • 将商品微服务注册进nacos
        • 将订单微服务注册进nacos
        • 订单服务通过nacos调用商品服务
      • 实现服务调用的负载均衡
        • 什么是负载均衡
        • 代码实现负载均衡
          • 增加一个服务提供者
          • 自定义实现负载均衡
          • 用ribbon实现负载均衡
      • 基于feign实现服务调用
        • 什么是feign
        • feign的使用

服务治理

服务治理介绍

通过上一章的操作，我们已经可以实现微服务之间的调用。但是我们把服务提供者的网络地址(ip，端口）等硬编码到了代码中，这种做法存在许多问题：

一旦服务提供者地址变化，就需要手工修改代码
一旦是多个服务提供者，无法实现负载均衡功能
一旦服务变得越来越多，人工维护调用关系困难

那么应该怎么解决呢，这时候就需要通过注册中心动态的实现服务治理。

什么是服务治理

服务治理是微服务架构中最核心最基本的模块。用于实现各个微服务的自动化注册与发现。

服务注册和心跳机制/续约：在服务治理框架中，都会构建一个注册中心，每个服务单元向注册中心登记自己提供服务的详细信息，并在注册中心形成一张服务的清单，服务注册中心需要以心跳的方式去监测清单中的服务是否可用，如果不可用，需要在服务清单中剔除不可用的服务。

服务发现：服务调用方向服务注册中心咨询服务，并获取所有服务的实例清单，实现对具体服务实例的访问。
在这里插入图片描述

相关方案

zookeeper
zookeeper是一个分布式服务框架，是Apache Hadoop的一个子项目，它主要是用来解决分布式应用中经常遇到的一些数据管理问题，如：统一命名服务、状态同步服务、集群管理、分布式应用配置项的管理等。
consul
Consul是基于GO语言开发的开源工具，主要面向分布式，服务化的系统提供服务注册、服务发现和配置管理的功能。Consul的功能都很实用，其中包括：服务注册/发现、健康检查、Key/Value存储、多数据中心和分布式一致性保证等特性。Consul本身只是一个二进制的可执行文件，所以安装和部署都非常简单，只需要从官网下载后，在执行对应的启动脚本即可。
eureka
Eureka是Springcloud Netflix中的重要组件,主要作用就是做服务注册和发现。但是现在已经闭源
nacos
Nacos是一个更易于构建云原生应用的动态服务发现、配置管理和服务管理平台。它是Spring Cloud Alibaba组件之一，负责服务注册发现和服务配置，可以这样认为nacos=eureka+config。

nacos实战入门

在这里插入图片描述

搭建nacos环境
安装nacos

下载地址：https://github.com/alibaba/nacos/releases
下载zip版本，解压缩

启动nacos

双击或命令行

cd nacos/bin
startup.cmd -m standalone
访问nacos

打开浏览器输入http://localhost:8848/nacos，即可访问服务，默认密码是nacos/nacos
如果有服务注册进来会显示在服务列表

将商品微服务注册进nacos

导包

        <dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency>

application.yml中添加nacos服务地址

  cloud:nacos:discovery:server-addr: localhost:8848

启动类注解

@SpringBootApplication
@EnableDiscoveryClient
public class ProductApp {public static void main(String[] args) {SpringApplication.run(ProductApp.class,args);}
}

启动服务，观察nacos的控制面板中是否有注册上来的商品微服务

将订单微服务注册进nacos

导包，配置，启动类注解，都同上

订单服务通过nacos调用商品服务

OrderController

    /*** 用nacos调用服务*/@RequestMapping("/order/product2/{pid}")public Order createOrder2(@PathVariable("pid") Integer pid) {log.info("接收到{}号商品的下单请求，接下来调用商品微服务查询此商品信息", pid);// 调用商品微服务，查询商品信息List<ServiceInstance> instances = discoveryClient.getInstances("service-product");ServiceInstance instance = instances.get(0);Product product = restTemplate.getForObject("http://" + instance.getHost() + ":" + instance.getPort() + "/product/" + pid, Product.class);log.info("查询到{}号商品的信息，内容是{}", pid, JSON.toJSONString(product));// 下单/创建订单Order order = new Order();order.setUid(1);order.setUsername("测试用户");order.setPid(product.getPid());order.setPname(product.getPname());order.setPprice(product.getPprice());order.setNumber(1);orderService.createOrder(order);log.info("创建订单成功，订单信息为{}", JSON.toJSONString(order));return order;}

浏览器访问测试：http://localhost:8091/order/product2/2

实现服务调用的负载均衡

什么是负载均衡

通俗的讲，负载均衡就是将负载(工作任务，访问请求)进行分摊到多个操作单元(服务器,组件)上进行执行。根据负载均衡发生位置的不同，一般分为服务端负载均衡和客户端负载均衡。
服务端负载均衡指的是发生在服务提供者一方，比如常见的nginx负载均衡，
而客户端负载均衡指的是发生在服务请求的一方，也就是在发送请求之前已经选好了由哪个实例处理请求。
在这里插入图片描述
我们在微服务调用关系中一般会选择客户端负载均衡，也就是在服务调用的一方来决定服务由哪个提供者执行。

代码实现负载均衡
增加一个服务提供者

一个项目并行运行的第二种方式：
编辑配置 - 添加新配置 - springboot
设置新名称，如ProductApp2
设置启动类，如ProductApp
修改端口号，如虚拟机选项：-Dserver.port=8082
启动后可在nacos中看到增加了一个服务实例
在这里插入图片描述

自定义实现负载均衡

修改消费者中OrderController的代码

    /*** 用nacos调用服务，并自定义实现负载均衡*/@RequestMapping("/order/product3/{pid}")public Order createOrder3(@PathVariable("pid") Integer pid) {log.info("接收到{}号商品的下单请求，接下来调用商品微服务查询此商品信息", pid);// 调用商品微服务，查询商品信息List<ServiceInstance> instances = discoveryClient.getInstances("service-product");int i = new Random().nextInt(instances.size());ServiceInstance instance = instances.get(i);log.info("第{}台机器，端口号是{}",i+1,instances.get(i).getPort());Product product = restTemplate.getForObject("http://" + instance.getHost() + ":" + instance.getPort() + "/product/" + pid, Product.class);log.info("查询到{}号商品的信息，内容是{}", pid, JSON.toJSONString(product));// 下单/创建订单Order order = new Order();order.setUid(1);order.setUsername("测试用户");order.setPid(product.getPid());order.setPname(product.getPname());order.setPprice(product.getPprice());order.setNumber(1);orderService.createOrder(order);log.info("创建订单成功，订单信息为{}", JSON.toJSONString(order));return order;}

浏览器访问测试：http://localhost:8091/order/product3/3

用ribbon实现负载均衡

添加LoadBalanced注解

@SpringBootApplication
@EnableDiscoveryClient
public class OrderApp {public static void main(String[] args) {SpringApplication.run(OrderApp.class,args);}@Bean@LoadBalancedpublic RestTemplate restTemplate(){return new RestTemplate();}
}

修改消费者的OrderController的代码

    /*** 用nacos调用服务，并用ribbon实现负载均衡*/@RequestMapping("/order/product4/{pid}")public Order createOrder4(@PathVariable("pid") Integer pid) {log.info("接收到{}号商品的下单请求，接下来调用商品微服务查询此商品信息", pid);// 调用商品微服务，查询商品信息Product product = restTemplate.getForObject("http://service-product/product/" + pid, Product.class);log.info("查询到{}号商品的信息，内容是{}", pid, JSON.toJSONString(product));// 下单/创建订单Order order = new Order();order.setUid(1);order.setUsername("测试用户");order.setPid(product.getPid());order.setPname(product.getPname());order.setPprice(product.getPprice());order.setNumber(1);orderService.createOrder(order);log.info("创建订单成功，订单信息为{}", JSON.toJSONString(order));return order;}

浏览器访问测试：http://localhost:8091/order/product4/1

如果想用默认的轮询以外的其他策略可在消费者的yml中加入以下配置

service-product: # 调用的提供者的名称ribbon:NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

基于feign实现服务调用

什么是feign

Feign是Spring Cloud提供的一个声明式的伪Http客户端，它使得调用远程服务就像调用本地服务一样简单，只需要创建一个接口并添加一个注解即可。

Nacos很好的兼容了Feign，Feign默认集成了Ribbon，所以在Nacos下使用Fegin默认就实现了负载均衡的效果。

feign的使用

导包

    <dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency>

启动类加注解

@EnableFeignClients(basePackages = "cn.ming.client") //如果是主内所在子包，可以不用加basePackages，但是最好加上

调用接口

@FeignClient(value = "service-product") //value用于指定调用nacos下哪个微服务
public interface ProductClient {// 商品信息查询@RequestMapping("/product/{pid}")   //@FeignClient的value + @RequestMapping的value值 其实就是完整的请求地址Product getProductByPid(@PathVariable("pid") Integer pid);
}

应用

    /*** 用nacos调用服务，并用feign实现带有负载均衡的调用*/@RequestMapping("/order/product5/{pid}")public Order createOrder5(@PathVariable("pid") Integer pid) {log.info("接收到{}号商品的下单请求，接下来调用商品微服务查询此商品信息", pid);// 调用商品微服务，查询商品信息Product product = productClient.getProductByPid(pid);log.info("查询到{}号商品的信息，内容是{}", pid, JSON.toJSONString(product));// 下单/创建订单Order order = new Order();order.setUid(1);order.setUsername("测试用户");order.setPid(product.getPid());order.setPname(product.getPname());order.setPprice(product.getPprice());order.setNumber(1);orderService.createOrder(order);log.info("创建订单成功，订单信息为{}", JSON.toJSONString(order));return order;}

浏览器访问测试：http://localhost:8091/order/product5/4

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

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

相关文章

离线数仓、实时数仓与数据湖

离线数仓、实时数仓与数据湖

1 什么是数据仓库 数据仓库是一个为数据分析而设计的企业级数据管理系统。数据仓库可集中、整合多个信息源的大量数据&#xff0c;借助数据仓库的分析能力&#xff0c;企业可从数据中获得宝贵的信息进而改进决策。同时&#xff0c;随着时间的推移&#xff0c;数据仓库中积累的大…
阅读更多...
spring boot 实现 PDF转换图片

spring boot 实现 PDF转换图片

引入依赖 <parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.0.4.RELEASE</version><relativePath/> </parent><dependencies> <depend…
阅读更多...
Spring MVC中redirect重定向几种方式(重构)

Spring MVC中redirect重定向几种方式(重构)

简介 在Web应用开发中&#xff0c;用户在提交表单后刷新页面或点击后退按钮&#xff0c;可能导致表单被重复提交&#xff0c;这会引发多种问题&#xff0c;如重复下订单等。为了避免这种情况&#xff0c;我们可以利用HTTP重定向&#xff08;redirect&#xff09;机制&#xff…
阅读更多...
《深入理解Maven：构建工具、常用命令与项目包技巧解析》

《深入理解Maven：构建工具、常用命令与项目包技巧解析》

文章目录 何为构建工具 | ToolsMaven插件的常用命令 | Commondclean总结 | Summary compile总结 | Summary package总结 | Summary install总结 | Summary build和compile的区别 | Knowledge项目包技巧 | Method 在后端领域开发中&#xff0c;我们构建项目常用到了Maven和Gradl…
阅读更多...
Science Robotics 封面论文：美国宇航局喷气推进实验室开发了自主蛇形机器人，用于冰雪世界探索

Science Robotics 封面论文：美国宇航局喷气推进实验室开发了自主蛇形机器人，用于冰雪世界探索

人们对探索冰冷的卫星&#xff08;如土卫二&#xff09;的兴趣越来越大&#xff0c;这可能具有天体生物学意义。然而&#xff0c;由于地表或冰口内的环境极端&#xff0c;获取样本具有挑战性。美国宇航局的喷气推进实验室正在开发一种名为Exobiology Extant Life Surveyor&…
阅读更多...
ChatGPT：激发学术创新，引领论文写作进程！

ChatGPT：激发学术创新，引领论文写作进程！

ChatGPT无限次数:点击跳转 摘要&#xff1a; 随着人工智能技术的不断发展&#xff0c;ChatGPT成为了学术界的一股清新风潮。本文将探讨ChatGPT在学术论文写作方面的独特性和潜力&#xff0c;并通过多个实例展示其独特的优势。通过ChatGPT&#xff0c;我们可以打破论文写作的瓶…
阅读更多...
【论文阅读笔记】Split frequency attention network for single image deraining

【论文阅读笔记】Split frequency attention network for single image deraining

1.论文介绍 Split frequency attention network for single image deraining 用于单幅图像去噪的分频注意力网络 Paper Code 2023年 SIVP 2.摘要 雨纹对图像质量的影响极大&#xff0c;基于数据驱动的单图像去噪方法不断发展并取得了巨大的成功。然而&#xff0c;传统的卷积…
阅读更多...
C/C++动态链接库的封装和调用

C/C++动态链接库的封装和调用

1 引言 静态链接库是在编译时被链接到程序中的库文件&#xff0c;在编译时&#xff0c;链接器将静态链接库的代码和数据复制到最终的可执行文件中。动态链接库是在程序运行时加载的库文件&#xff0c;在编译时&#xff0c;可执行文件只包含对动态链接库的引用&#xff0c;而不…
阅读更多...
外贸网站文章批量生成器

外贸网站文章批量生成器

随着全球贸易的不断发展&#xff0c;越来越多的企业开始关注外贸市场&#xff0c;而拥有高质量的内容是吸引潜在客户的关键之一。然而&#xff0c;为外贸网站生产大量优质的文章内容可能是一项耗时且繁琐的任务。因此&#xff0c;外贸网站文章批量生成软件成为了解决这一难题的…
阅读更多...
remote: GitLab: LFS objects are missing（pre-receive hook declined）

remote: GitLab: LFS objects are missing（pre-receive hook declined）

Git push 遇到错误&#xff1a; remote: GitLab: LFS objects are missing. Ensure LFS is properly set up or try a manual "git lfs push --all". To http://192.168.x.x/xxxxxx.git! [remote rejected] dev -> dev (pre-receive hook declined) error: faile…
阅读更多...
语音识别：whisper部署服务器（远程访问，语音实时识别文字）

语音识别：whisper部署服务器（远程访问，语音实时识别文字）

Whisper是OpenAI于2022年发布的一个开源深度学习模型&#xff0c;专门用于语音识别任务。它能够将音频转换成文字&#xff0c;支持多种语言的识别&#xff0c;包括但不限于英语、中文、西班牙语等。Whisper模型的特点是它在多种不同的音频条件下&#xff08;如不同的背景噪声水…
阅读更多...
做跨境用哪种代理IP比较好？怎么选到干净的IP？

做跨境用哪种代理IP比较好？怎么选到干净的IP？

代理IP对于做跨境的小伙伴来说&#xff0c;都是必不可少的工具&#xff0c;目前出海的玩法已经是多种多样&#xff0c;开店、账号注册、短视频运营、直播带货、网站SEO等等都是跨境人需要涉及到的业务。而国外代理IP的获取渠道非常多&#xff0c;那么做跨境到底应该用哪种代理I…
阅读更多...
linux开机启动设置方法

linux开机启动设置方法

开机启动最简单的方法是在/etc/rc.local启动脚本中写入需要执行的命令。另一种方式是在/etc/init.d中编写一个启动脚本。但是这两种方式都不是正规的启动模式。init.d是Linux最早的服务管理方案&#xff0c;命令service start xxx就是去调用init.d中的启动脚本。之后init机制被…
阅读更多...
蓝桥杯（3.18 刷真题）

蓝桥杯（3.18 刷真题）

P8697 [蓝桥杯 2019 国 C] 最长子序列 AC import java.util.Scanner; public class Main {public static void main(String[] args) {Scanner sc new Scanner(System.in);String s1 sc.nextLine();String s2 sc.nextLine();char[] c1 s1.toCharArray();char[] c2 s2.toCh…
阅读更多...
使用 Redisson 实现分布式 CountDownLatch，如何使用RCountDownLatch实现内外网数据互通的超时控制？

使用 Redisson 实现分布式 CountDownLatch，如何使用RCountDownLatch实现内外网数据互通的超时控制？

闭锁&#xff08;CountDownLatch&#xff09;是一种用于同步多个线程的机制&#xff0c;它可以让一个或多个线程等待其他线程完成某个任务后再继续执行。 在Java中&#xff0c;RCountDownLatch 是 Redisson 提供的分布式闭锁实现&#xff0c;它基于 Redis 的分布式系统&#x…
阅读更多...
基于Spring Boot的研究生志愿填报辅助系统

基于Spring Boot的研究生志愿填报辅助系统

摘 要 二十一世纪我们的社会进入了信息时代&#xff0c;信息管理系统的建立&#xff0c;大大提高了人们信息化水平。传统的管理方式对时间、地点的限制太多&#xff0c;而在线管理系统刚好能满足这些需求&#xff0c;在线管理系统突破了传统管理方式的局限性。于是本文针对这一…
阅读更多...
掌握请求控制权：Axios 如何取消请求的两种方法

掌握请求控制权：Axios 如何取消请求的两种方法

在前端开发中&#xff0c;网络请求是非常常见的操作。而有时候&#xff0c;我们可能需要在发送请求后取消它&#xff0c;比如用户在请求还未完成时离开了当前页面或者执行了其他操作&#xff0c;本文将介绍如何在使用 Axios 发送请求时取消这些请求。 基本概念 在 Axios 中&am…
阅读更多...
【NLP03-新闻主题分类任务】

【NLP03-新闻主题分类任务】

新闻主题分类任务 背景 以一段新闻报道中的文本描述内容为输入&#xff0c;使用模型帮助我们判断它最优可能属于哪一种类型的新闻&#xff0c;这是典型的文本分类问题&#xff0c;这里假定每种类型是互斥的&#xff0c;即文本描述有且只有一种类型 新闻主题分类数据 #通过t…
阅读更多...
swagger使用手册

swagger使用手册

1.导入依赖 <!--引入swagger--><dependency><groupId>io.springfox</groupId><artifactId>springfox-swagger2</artifactId><version>2.7.0</version></dependency><dependency><groupId>io.springfox</…
阅读更多...
什么是集成学习

什么是集成学习

集成学习是一种机器学习方法&#xff0c;目的是将多个基本学习算法组合起来&#xff0c;以达到更好的预测性能。通过将多个模型的预测结果进行加权平均或投票&#xff0c;集成学习能够减少单个模型的偏差和方差&#xff0c;从而提高整体的泛化能力。常见的集成学习方法包括Bagg…
阅读更多...
最新文章

Copyright @ 2022~2023