当前位置：首页 > news >正文

[SpringCloud][7]负载均衡介绍，以及一些搭建

news 2026/6/15 12:52:46

[SpringCloud][7]负载均衡介绍，以及一些搭建

文章目录

负载均衡介绍
- 简单实现
- - 问题描述
  - 问题解决
- 什么是负载均衡
- 负载均衡的一些实现
- - 服务端负载均衡
  - 客户端负载均衡

负载均衡介绍

简单实现

问题描述

观察上篇文章的远程调用代码

List<
ServiceInstance> instances = discoveryClient.getInstances("product-service");
// 服务可能有多个，获取第一个 
EurekaServiceInstance instance = (EurekaServiceInstance) instances.get(0);

根据应用名称获取了服务实例列表
从列表中选择了一个服务实例

思考：如果一个服务对应多个实例呢？流量是否可以合理的分配到多个实例？
现象观察：

我们再启动 2 个 product-service 实例
选中要启动的服务，右键选择 Copy Configuration...

在弹出的框中，选择 Modify options -> Add VM options image.png|454
添加 VM options：-Dserver.port=9091

9091 为服务启动的端口号，根据自己的情况可修改

现在 IDEA 的 Service 窗口就会多出一个启动配置，右键启动服务就可以了

同样的操作，再启动一个实例，共启动三个服务器 image.png|310

观察 Eureka，可以看到 product-service 下有三个实例： image.png|424

访问结果：
访问： http://127.0.0.1:8080/order/1

通过日志可以发现，请求多次访问，都是同一台机器

问题解决

这肯定不是我们想要的结果，我们启动多个实例，是希望可以分担其他机器的符合，那么如何实现呢？

我们可以针对上述代码简单修改：

package org.example.order.service;
import jakarta.annotation.PostConstruct;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.example.order.mapper.OrderMapper;
import org.example.order.model.OrderInfo;
import org.example.order.model.ProductInfo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.cloud.netflix.eureka.EurekaServiceInstance;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;
@Slf4j
@Service
public class OrderService
{
@Autowired
private OrderMapper orderMapper;
@Resource
private DiscoveryClient discoveryClient;
@Autowired
private RestTemplate restTemplate;
private static AtomicInteger atomicInteger = new AtomicInteger(1);
private static List<
ServiceInstance> instances;
@PostConstruct
public void init() {
// 根据应用名称获取服务器列表 
instances = discoveryClient.getInstances("product-service");
}
public OrderInfo selectOrderById(Integer orderId) {
OrderInfo orderInfo = orderMapper.selectOrderById(orderId);
//String url = "http://127.0.0.1:9090/product/" + orderInfo.getProductId(); 
// 服务可能有多个，轮询获取实例 
int index = atomicInteger.getAndIncrement() % instances.size();
ServiceInstance instance = instances.get(index);
log.info(instance.getInstanceId());
// 拼接 URL 
String url = instance.getUri() + "/product/" + orderInfo.getProductId();
ProductInfo productInfo = restTemplate.getForObject(url, ProductInfo.class)
;
orderInfo.setProductInfo(productInfo);
return orderInfo;
}
}

@PostConstruct ：在 Spring 容器完成 依赖注入（DI） 后，自动调用标注了 @PostConstruct 的方法，用于执行初始化逻辑。
- 就是当这个 Bean 创建完成并注入完需要的依赖后，Spring 会自动调用我标注的方法一次，用来做一些初始化的操作。
discoveryClient.getInstances() 可以返回当前所有可用的 product-service 实例。
- instances 列表包含了所有可用的 product-service 实例，每个实例包含了服务的 URI 和其他元数据
int index = atomicInteger.getAndIncrement() % instances.size()：该逻辑基于递增的计数器来决定访问哪个实例。每次访问时，计数器会递增，并且通过 index % instances.size() 确保能够在实例列表中轮询（即循环访问所有实例）。
- 例如，如果有 3 个实例，当 atomicInteger 的值为 1、2、3、4 时，它会依次访问