【微服务学习二】nacos服务发现与负载均衡

news2025/2/15 12:00:51

nacos服务发现

想要开启服务发现,需要在main函数上添加 @EnableDiscoveryClient 注解

然后我们编写一个controller类来查询nacos中注册的所有微服务以及对应的ip+端口号

@Controller
public class DiscoveryController {

    @Autowired
    DiscoveryClient discoveryClient;

    // 这个方法可以获取nacos中注册的服务信息
    @GetMapping("/getServicesInfo")
    @ResponseBody
    public String getServicesInfo() {
        StringBuilder sb = new StringBuilder();
        // 查询服务名称和服务的ip+端口号
        for (String serviceId : discoveryClient.getServices()) {
            sb.append(serviceId + "<br>");
            for (ServiceInstance instance : discoveryClient.getInstances(serviceId)) {
                sb.append(instance.getHost() + ":" + instance.getPort() + "<br>");
            }
        }
        return sb.toString();
    }

}

接着启动微服务,然后在浏览器中调用该接口就可以查到对应的信息

简单下单场景

了解了服务发现的基本内容,我们就可以进行一个简单的下单场景模拟,场景流程如下

首先我们需要给商品服务编写一个根据商品id查询商品的接口

由于我们需要编写bean类,为了方便起见,我们首先给services的配置文件中添加lombok依赖和fastjson依赖

接着我们编写controller类,这个类提供一个查询商品信息的接口

@RestController
public class ProductController {

    @Autowired
    ProductService productService;

    @GetMapping("/getProduct/{id}")
    @ResponseBody
    public String getProductById(@PathVariable("id") Long productId) {
        Product product = productService.getProductById(productId);
        return JSON.toJSONString(product);
    }

}

接着是商品的bean类

@Data
public class Product {

    private Long id;
    private BigDecimal price;
    private String productName;
    private int num;

}

最后是service类

@Service
public class ProductServiceImpl implements ProductService {

    @Override
    public Product getProductById(Long id) {
        Product product = new Product();
        product.setId(id);
        product.setPrice(new BigDecimal("99"));
        product.setProductName("苹果-" + id);
        product.setNum(2);
        return product;
    }
}

在浏览器中调用方法可以获取查询结果

由于微服务之间可能会有相互依赖的模型层,因此需要将共用的模型层的bean类放到一个公共的模块中

需要在model模块中添加lombok依赖

然后在services模块中引入model模块

 一下是Order实体类的代码

@Data
public class Order {

    private Long id;
    private BigDecimal totalAmount;
    private Long userId;
    private String nickName;
    private String address;
    private List<Object> productList;

}

接着我们编写order服务的controller

@RestController
public class OrderController {

    @Autowired
    OrderService orderService;

    @GetMapping("/createOrder/{userId}/{productId}")
    public String createOrder(@PathVariable Long userId, @PathVariable Long productId) {
        Order order = orderService.createOrder(userId, productId);
        return JSON.toJSONString(order);
    }

}

由于在service中由于需要使用到RestTemplate进行远程调用,因此我们需要编写一个配置类,给容器注入一个RestTemplate实例

@Configuration
public class OrderConfig {

    @Bean
    public RestTemplate getRestTemplate() {
        return new RestTemplate();
    }

}

最后编写service

@Slf4j
@Service
public class OrderServiceImpl implements OrderService {

    @Autowired
    DiscoveryClient discoveryClient;

    @Autowired
    RestTemplate restTemplate;

    @Override
    public Order createOrder(Long userId, Long productId) {
        Order order = new Order();
        order.setId(2L);
        order.setUserId(userId);
        Product product = getProductRemote(productId);
        BigDecimal totalPrice = product.getPrice().multiply(new BigDecimal(product.getNum()));
        order.setTotalAmount(totalPrice);
        order.setAddress("福建省");
        order.setNickName("小明明");
        order.setProductList(Arrays.asList(product));
        return order;
    }

    // 通过远程调用的方式获取商品数据
    private Product getProductRemote(Long productId) {
        discoveryClient.getInstances("service-product");
        List<ServiceInstance> instances = discoveryClient.getInstances("service-product");
        String url = "http://" + instances.get(0).getHost() + ":" + instances.get(0).getPort() + "/getProduct/" + productId;
        log.info("远程调用:{}", url);
        Product product = restTemplate.getForObject(url, Product.class);
        return product;
    }


}

在浏览器中调用接口就可以获取数据

负载均衡

由于我们的订单服务需要进行负载均衡的调用,因此首先需要添加负载均衡的依赖

接着就是在service中使用 LoadBalancerClient 进行负载均衡的调用

用浏览器进行多次调用得到的测试结果如下

可以发现是交替调用两个商品服务的

除了上述方式外,还可以通过注解的方式进行负载均衡的调用

首先需要在配置类中加上 @LoadBalanced 注解

接着在如下图修改远程调用方法中的url即可

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

深入剖析推理模型:从DeepSeek R1看LLM推理能力构建与优化

著名 AI 研究者和博主 Sebastian Raschka 又更新博客了。原文地址&#xff1a;https://sebastianraschka.com/blog/2025/understanding-reasoning-llms.html。这一次&#xff0c;他将立足于 DeepSeek 技术报告&#xff0c;介绍用于构建推理模型的四种主要方法&#xff0c;也就是…

Kafka分区管理大师指南:扩容、均衡、迁移与限流全解析

#作者&#xff1a;孙德新 文章目录 分区分配操作(kafka-reassign-partitions.sh)1.1 分区扩容、数据均衡、迁移(kafka-reassign-partitions.sh)1.2、修改topic分区partition的副本数&#xff08;扩缩容副本&#xff09;1.3、Partition Reassign场景限流1.4、节点内副本移动到不…

AIoT时代来临,物联网技术如何颠覆未来生活?

在这个万物互联的时代&#xff0c;“物联网”&#xff08;IoT&#xff09;正以前所未有的速度改变我们的生活&#xff0c;而“AIoT”则是在物联网基础上融入人工智能技术&#xff0c;赋予设备更高的智能和自主决策能力。随着5G、边缘计算和云技术的不断发展&#xff0c;物联网正…

基于SpringBoot的电影院售票管理系统

作者&#xff1a;计算机学姐 开发技术&#xff1a;SpringBoot、SSM、Vue、MySQL、JSP、ElementUI、Python、小程序等&#xff0c;“文末源码”。 专栏推荐&#xff1a;前后端分离项目源码、SpringBoot项目源码、Vue项目源码、SSM项目源码、微信小程序源码 精品专栏&#xff1a;…

深度学习与人工智能:解锁未来的无限可能

在当今这个科技飞速发展的时代&#xff0c;深度学习和人工智能已不再只是科幻小说中的概念&#xff0c;它们正以惊人的速度渗透到我们生活的方方面面&#xff0c;从智能手机上的语音助手到医疗领域的疾病诊断&#xff0c;从自动驾驶汽车到金融市场的风险预测&#xff0c;其影响…

2025年02月14日Github流行趋势

项目名称&#xff1a;data-formulator 项目地址url&#xff1a;https://github.com/microsoft/data-formulator项目语言&#xff1a;TypeScript历史star数&#xff1a;5921今日star数&#xff1a;820项目维护者&#xff1a;Chenglong-MS, danmarshall, apps/dependabot, micros…

华为云+硅基流动使用Chatbox接入DeepSeek-R1满血版671B

华为云硅基流动使用Chatbox接入DeepSeek-R1满血版671B 硅基流动 1.1 注册登录 1.2 实名认证 1.3 创建API密钥 1.4 客户端工具 OllamaChatboxCherry StudioAnythingLLM 资源包下载&#xff1a; AI聊天本地客户端 接入Chatbox客户端 点击设置 选择SiliconFloW API 粘贴1.3创…

【github】docker realtime

Linux和Docker实时指南&#xff0c;适用于Ubuntu实时内核和PREEMPT_RT ReadMe.md 作者&#xff1a;Tobit Flatscher&#xff08;2021 - 2024&#xff09; 概述 本指南解释了如何在Linux操作系统内开发/部署运行实时代码的Docker容器。因此&#xff0c;它会带你了解&#xf…

MySQL官网驱动下载(jar包驱动和ODBC驱动)【详细教程】

1.打开MySQL的官网&#xff0c;选择下载(Download) MySQL[这里是图片001]https://www.mysql.com/cn/ 2.往下划点击MySQL Community(GPL)Downloads 3.要下载MySQL的jar包的选择Connector/J 4.进入后&#xff0c;根据自己的需求选择相应的版本 5.下载完成后&#xff0c;进行解压…

jenkins服务启动-排错

服务状态为active (exited) 且进程不在 查看/etc/rc.d/init.d/jenkins配置 获取配置参数 [rootfy-jenkins-prod jenkins]# cat /etc/rc.d/init.d/jenkins | grep -v #JENKINS_WAR"/usr/lib/jenkins/jenkins.war" test -r "$JENKINS_WAR" || { echo "…

Redis7.0八种数据结构底层原理

导读 本文介绍redis应用数据结构与物理存储结构,共八种应用数据结构和 一. 内部数据结构 1. sds sds是redis自己设计的字符串结构有以下特点: jemalloc内存管理预分配冗余空间二进制安全(c原生使用\0作为结尾标识,所以无法直接存储\0)动态计数类型(根据字符串长度动态选择…

细说STM32F407单片机RTC的备份寄存器原理及使用方法

目录 一、备份寄存器的功能 二、示例功能 三、项目设置 1、晶振、DEBUG、CodeGenerator、USART6 2、RTC 3、NVIC 4、GPIO 及KEYLED 四、软件设计 1、main.h 2、main.c 3、rtc.c 4、keyled.c、keyled.h 五、运行调试 本实例旨在介绍备份寄存器的作用。本实例继续使…

spring 学习 (注解)

目录 前言 常用的注解 须知 1 Conponent注解 demo&#xff08;案例&#xff09; 2 ControllerServiceRepository demo(案例&#xff09; 3 ScopeLazyPostConstructPreDestroy demo(案例&#xff09; 4 ValueAutowiredQualifierResource demo(案例&#xff09; 5 Co…

【Linux】多线程 -> 从线程概念到线程控制

线程概念 在一个程序里的一个执行路线就叫做线程&#xff08;thread&#xff09;。更准确的定义是&#xff1a;线程是“一个进程内部的控制序列”。一切进程至少都有一个执行线程。线程在进程内部运行&#xff0c;本质是在进程地址空间内运行。在Linux系统中&#xff0c;在CPU眼…

mapbox 从入门到精通 - 目录

&#x1f468;‍⚕️ 主页&#xff1a; gis分享者 &#x1f468;‍⚕️ 感谢各位大佬 点赞&#x1f44d; 收藏⭐ 留言&#x1f4dd; 加关注✅! &#x1f468;‍⚕️ 收录于专栏&#xff1a;mapbox 从入门到精通 文章目录 一、&#x1f340;总目录1.1 ☘️ mapbox基础1.2 ☘️…

深度学习在半导体领域的创新点研究

摘要&#xff1a;本论文聚焦于深度学习在半导体领域的创新应用&#xff0c;全面剖析其为半导体产业带来的变革与机遇。通过深入探究深度学习在半导体设计、制造、测试及质量管控等多方面的创新实践&#xff0c;揭示其对提升半导体性能、降低成本及增强产业竞争力的关键作用。同…

谈谈云计算、DeepSeek和哪吒

我不会硬蹭热点&#xff0c;去分析自己不擅长的跨专业内容&#xff0c;本文谈DeepSeek和哪吒&#xff0c;都是以这两个热点为引子&#xff0c;最终仍然在分析的云计算。 这只是个散文随笔&#xff0c;没有严谨的上下游关联关系&#xff0c;想到哪里就写到哪里。 “人心中的成见…

分享 UniApp 实现列表长按删除功能

在移动应用开发中&#xff0c;列表是常见的展示形式&#xff0c;而长按删除列表项也是一个实用且常见的交互功能。今天就来和大家分享如何在 UniApp 中实现列表的长按删除功能&#xff0c;同时附上详细的代码。 效果预览 通过代码实现后&#xff0c;我们将得到一个带有红色边…

k8s集群搭建参考(by lqw)

文章目录 声明配置yum源安装docker安装 kubeadm&#xff0c;kubelet 和 kubectl部署主节点其他节点加入集群安装网络插件 声明 由于看了几个k8s的教程&#xff0c;都存在各种问题&#xff0c;自己搭建的时候&#xff0c;踩了不少坑&#xff0c;最后还是靠百度csdnchatGPT才搭建…

「前端面试宝典」 - 猿媛之家(21.06)

模拟面试是提高个人沟通技巧的最有效方式 请记住&#xff1a;思维的深度&#xff0c;决定你人生的高度。胸怀的广度&#xff0c;决定你事业的长度。 面试官关注的重点不是题目的答案&#xff0c;而是求职者解题的思路与方法. 以排序算法为例&#xff1a;时间利用是否高效&#…