Cloud-Eureka服务治理-Ribbon负载均衡

构建Cloud父工程

父工程只做依赖版本管理  不引入依赖

pom.xml

 <packaging>pom</packaging><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.3.9.RELEASE</version><relativePath/></parent><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding><java.version>1.8</java.version><spring-cloud.version>Hoxton.SR10</spring-cloud.version><mysql.version>5.1.47</mysql.version><mybatis.version>2.1.1</mybatis.version><junit.version>4.12</junit.version><log4j.version>1.2.17</log4j.version><lombok.version>1.16.18</lombok.version></properties><dependencyManagement><dependencies><!-- springCloud --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${spring-cloud.version}</version><type>pom</type><scope>import</scope></dependency><!-- mysql驱动 --><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>${mysql.version}</version></dependency><!--mybatis--><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>${mybatis.version}</version></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>${junit.version}</version></dependency><dependency><groupId>log4j</groupId><artifactId>log4j</artifactId><version>${log4j.version}</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>${lombok.version}</version><optional>true</optional></dependency></dependencies></dependencyManagement><dependencies><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency></dependencies>

构建用户模块

CREATE TABLE `tb_user` (
  `id` bigint NOT NULL AUTO_INCREMENT,
  `username` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT NULL COMMENT '收件人',
  `address` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT NULL COMMENT '地址',
  PRIMARY KEY (`id`) USING BTREE,
  UNIQUE KEY `username` (`username`) USING BTREE
) ENGINE=InnoDB AUTO_INCREMENT=109 DEFAULT CHARSET=utf8mb3 ROW_FORMAT=COMPACT;

INSERT INTO `tb_user`(`id`, `username`, `address`) VALUES (1, '柳岩', '湖南省衡阳市');
INSERT INTO `tb_user`(`id`, `username`, `address`) VALUES (2, '文二狗', '陕西省西安市');
INSERT INTO `tb_user`(`id`, `username`, `address`) VALUES (3, '华沉鱼', '湖北省十堰市');
INSERT INTO `tb_user`(`id`, `username`, `address`) VALUES (4, '张必沉', '天津市');
INSERT INTO `tb_user`(`id`, `username`, `address`) VALUES (5, '郑爽爽', '辽宁省沈阳市大东区');
INSERT INTO `tb_user`(`id`, `username`, `address`) VALUES (6, '范兵兵', '山东省青岛市');

pom.xml

 <dependencies><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></dependencies><build><finalName>app</finalName><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build>

application.yml

server:port: 8081
spring:application:name: user-servicedatasource:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://localhost:3306/cloud-user?useSSL=false&useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=GMT%2B8&useCursorFetch=trueusername: rootpassword: 123456#redis:#port: 6379#database: 0#password: 1111111111111#ssl: false#####################################################redis 集群环境配置#cluster:#  nodes: 127.0.0.1:7001,127.0.0.1:7002,127.0.0.1:7003#  commandTimeout: 5000
mybatis:type-aliases-package: com.example.userservice.pojoconfiguration:map-underscore-to-camel-case: true
logging:level:com.example.userservice.mapper: debug

pojo

@Data
public class User {private Long id;private String username;private String address;
}

mapper

public interface UserMapper {@Select("select * from tb_user where id = #{id}")User findById(@Param("id") Long id);
}

service

public interface UserService {User queryById(Long id);
}

impl

@Service
public class UserServiceImpl implements UserService {@Autowiredprivate UserMapper userMapper;public User queryById(Long id) {return userMapper.findById(id);}
}

controller

@RestController
@RequestMapping("/user")
@Slf4j
public class UserController {@Autowiredprivate UserService userService;@Value("${server.port}")private String serverPort;@GetMapping("/serverport")public String serverport(){return serverPort;}@GetMapping("/{id}")public User queryById(@PathVariable("id") Long id) {return userService.queryById(id);}
}

这样你可以开多个

构建订单模块

CREATE TABLE `tb_order` (
  `id` bigint NOT NULL AUTO_INCREMENT COMMENT '订单id',
  `user_id` bigint NOT NULL COMMENT '用户id',
  `name` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT NULL COMMENT '商品名称',
  `price` bigint NOT NULL COMMENT '商品价格',
  `num` int DEFAULT '0' COMMENT '商品数量',
  PRIMARY KEY (`id`) USING BTREE,
  UNIQUE KEY `username` (`name`) USING BTREE
) ENGINE=InnoDB AUTO_INCREMENT=109 DEFAULT CHARSET=utf8mb3 ROW_FORMAT=COMPACT;

INSERT INTO `tb_order` VALUES (101, 1, 'Apple 苹果 iPhone 12 ', 699900, 1);
INSERT INTO `tb_order` VALUES (102, 2, '雅迪 yadea 新国标电动车', 209900, 1);
INSERT INTO `tb_order` VALUES (103, 3, '骆驼（CAMEL）休闲运动鞋女', 43900, 1);
INSERT INTO `tb_order` VALUES (104, 4, '小米10 双模5G 骁龙865', 359900, 1);
INSERT INTO `tb_order` VALUES (105, 5, 'OPPO Reno3 Pro 双模5G 视频双防抖', 299900, 1);
INSERT INTO `tb_order` VALUES (106, 6, '美的（Midea) 新能效 冷静星II ', 544900, 1);
INSERT INTO `tb_order` VALUES (107, 2, '西昊/SIHOO 人体工学电脑椅子', 79900, 1);
INSERT INTO `tb_order` VALUES (108, 3, '梵班（FAMDBANN）休闲男鞋', 31900, 1);

pom.xml

 <dependencies><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><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency></dependencies><build><finalName>orderserver</finalName><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build>

pojo

@Data
public class Order {private Long id;private Long price;private String name;private Integer num;private Long userId;private User user;
}

@Data
public class User {private Long id;private String username;private String address;
}

mapper

public interface OrderMapper {@Select("select * from tb_order where id = #{id}")Order findById(Long id);
}

service

public interface OrderService {Order queryOrderById(Long orderId);
}

impl

@Service
public class OrderServiceImpl implements OrderService {@Autowiredprivate OrderMapper orderMapper;@Overridepublic Order queryOrderById(Long orderId) {return orderMapper.findById(orderId);}
}

controller

@RestController
@RequestMapping("/order")
public class OrderController {@Autowiredprivate OrderService orderService;@GetMapping("{orderId}")public Order queryOrderByUserId(@PathVariable("orderId") Long orderId) {// 根据id查询订单并返回return orderService.queryOrderById(orderId);}
}

合并公共代码

像pojo可以放在common-api里

构建基础公用模块

使用RestTemplate进行服务间调用

服务调用出现的问题

通过硬编码的方式调用,那么当服务多了又该如何应对

搭建单机Eureka服务

服务既可以是生产者,也可是是消费者  也可以同时扮演生产者和消费者两个角色

Eureka分服务端和客户端

我们要注册进去的OrderServer和UserServer都是客户端

所有注册到Eureka的服务每30秒都会给注册中心发送心跳检测,证明我活着

server:port: 7001
spring:application:name: eureka-server
eureka:instance:hostname: eurekaserver  # eureka服务端的实例名称  集群的时候配置client:# 表示不向注册中心注册自己  集群必须为trueregister-with-eureka: true# 表示自己就是注册中心，职责是维护服务实例，并不需要去检索服务  单fetch-registry: trueservice-url:# 设置与eureka server交互的地址查询服务和注册服务都需要依赖这个地址  ${}是上面定义的defaultZone: http://127.0.0.1:${server.port}/eureka/

服务注册(将order-server和user-server注册到Eureka服务)

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

两个客户端都添加依赖

两个application.yml

通过IDEA设置启动多个生产者

这样也行

通过Ribbon实现负载均衡

为了看清楚调用的是哪个端口服务

修改Ribbon负载均衡方式

有两种方式  一种是添加配置类           另外一种是application.yml配置 

添加配置Bean的方式   注意这种方式针对的是所有  如果非要用这种方式去配置单一服务方法也是有的 自行扩展

如果想用这种方式配置某个服务的负载均衡  自己试试  我没试过

application.yml配置方式

Ribbon 提供了多种负载均衡策略，可以根据不同的场景和需求来选择。下面介绍几种常用的策略及其配置方式：

1. RoundRobinRule（轮询策略）

默认策略，按顺序逐一调用服务器。如果服务器达到列表末尾，调用将从头开始。

配置方式：

在application.yml中配置：

 

yamlCopy code
 

your-service-name: ribbon: NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RoundRobinRule 
 

2. RandomRule（随机策略）
 

随机选择一个服务器进行调用。
 

配置方式：
 

在application.yml中配置：
 

 

yamlCopy code
 

your-service-name: ribbon: NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule 
 

3. RetryRule（重试策略）
 

在一个配置的重试时间内，当选择的服务器不成功时，使用子规则（默认为轮询）重新选择一个可用的服务器。
 

配置方式：
 

在application.yml中配置：
 

 

yamlCopy code
 

your-service-name: ribbon: NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RetryRule 
 

4. WeightedResponseTimeRule（响应时间加权策略）
 

根据服务器的响应时间分配权重。响应时间越快的服务器被选中的可能性越高。随着时间的推移，权重会动态调整。
 

配置方式：
 

在application.yml中配置：
 

 

yamlCopy code
 

your-service-name: ribbon: NFLoadBalancerRuleClassName: com.netflix.loadbalancer.WeightedResponseTimeRule 
 

5. BestAvailableRule（最少并发请求策略）
 

选择并发请求最小的服务器。适用于负载比较重的操作。
 

配置方式：
 

在application.yml中配置：
 

 

yamlCopy code
 

your-service-name: ribbon: NFLoadBalancerRuleClassName: com.netflix.loadbalancer.BestAvailableRule 
 

6. AvailabilityFilteringRule（可用性过滤策略）
 

过滤掉一直连接失败的被标记为 circuit tripped 的服务器，以及并发连接数超过阈值的服务器，然后选择一个并发量最小的服务器。
 

配置方式：
 

在application.yml中配置：
 

 

yamlCopy code
 

your-service-name: ribbon: NFLoadBalancerRuleClassName: com.netflix.loadbalancer.AvailabilityFilteringRule 
 

7. ZoneAvoidanceRule（区域敏感策略）
 

复合判断server所在区域的性能和server的可用性选择服务器。
 

配置方式：
 

在application.yml中配置：
 

 

yamlCopy code
 

your-service-name: ribbon: NFLoadBalancerRuleClassName: com.netflix.loadbalancer.ZoneAvoidanceRule 
 

配置注意事项
 

  • your-service-name应该替换为你的服务名称。
  • 在使用特定策略时，确保已经了解其工作原理及适用场景，以免影响服务的稳定性和性能。
  • 随着Spring Cloud的版本更新，一些配置方式可能会有所变化，建议查看最新的官方文档进行配置。
 


  
 

配置饥饿加载
 

 

单个服务的配置
 

 

 

 












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


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












相关文章










【嵌入式——QT】Model/View








【嵌入式——QT】Model/View




【嵌入式——QT】Model/View 基本原理数据模型视图组件代理Model/View结构的一些概念QFileSystemModelQStringListModelQStandardItemModel自定义代理 基本原理 
GUI应用程序的一个很重要的功能是由用户在界面上编辑和修改数据&#xff0c;典型的如数据库应用程序&#xff0c;数…




阅读更多...

















【ArcGIS Pro二次开发】(84)：WPF_给Combobox加点料








【ArcGIS Pro二次开发】(84)：WPF_给Combobox加点料




一、要实现的功能 
在WPF中&#xff0c;一个正常的Combobox是长这样的&#xff1a; 当点击下拉框的时候&#xff0c;下拉列表就是简单的文本&#xff0c;看起来很单一。 
这里我们给它加点料&#xff0c;让它变成这样&#xff1a; 就是给文本前面加个图标&#xff0c;这个图标可…




阅读更多...

















高精度减法








高精度减法




#include<iostream>
#include<vector>using namespace std;//判断是否有A>B,
bool cmp(vector<int> &A,vector<int> &B)
{if(A.size()!B.size()) return A.size()>B.size();for(int iA.size()-1;i>0;i--)if(A[i]!B[i])return A[i]>…




阅读更多...

















Manz高压清洗机S11-028GCH-High Quality Cleaner 操作使用说明492页








Manz高压清洗机S11-028GCH-High Quality Cleaner 操作使用说明492页




Manz高压清洗机S11-028GCH-High Quality Cleaner 操作使用说明492页




阅读更多...

















YOLOv9(2):YOLOv9网络结构








YOLOv9(2):YOLOv9网络结构




1. 前言 
本文仅以官方提供的yolov9.yaml来进行简要讲解。 
讲解之前&#xff0c;还是要做一些简单的铺垫。 
Slice层不做任何的操作&#xff0c;纯粹是做一个占位层。这样一来&#xff0c;在parse_model时&#xff0c;ch[n]可表示第n层的输出通道。 
Detect和DDetect主要区别还…




阅读更多...

















Django cookie 与 session








Django cookie 与 session




Django cookie 与 session 
Cookie 是存储在客户端计算机上的文本文件&#xff0c;并保留了各种跟踪信息。 
识别返回用户包括三个步骤&#xff1a; 
服务器脚本向浏览器发送一组 Cookie。例如&#xff1a;姓名、年龄或识别号码等。浏览器将这些信息存储在本地计算机上&#xf…




阅读更多...

















JS实现chatgpt数据流式回复效果








JS实现chatgpt数据流式回复效果




最近高了一个简单chatgpt对话功功能&#xff0c;回复时希望流式回复&#xff0c;而不是直接显示结果&#xff0c;其实很简单&#xff0c;前端流式读取即可&#xff0c;后端SSE实现流式传输 
前端用到fetch获取数据&#xff0c;然后利用reader读取 
let requestId   parseInt(Ma…




阅读更多...

















勾股定理的七种经典证明








勾股定理的七种经典证明




据说勾股定理约有500种证明方法&#xff0c;下面介绍几种经典的证明方法。 
一、切割重拼法。 
顾名思义&#xff0c;就是将图形切割成其他形式的图形&#xff0c;然后通过拼图转换为另一种图形&#xff0c;这个过程中图形的面积是不变的。 
“赵爽弦图”是这种方法的经典应用&…




阅读更多...

















西门子Mendix低代码资深技术顾问张戟，将出席“ISIG-低代码/零代码技术与应用发展峰会”








西门子Mendix低代码资深技术顾问张戟，将出席“ISIG-低代码/零代码技术与应用发展峰会”




3月16日&#xff0c;第四届「ISIG中国产业智能大会」将在上海中庚聚龙酒店拉开序幕。本届大会由苏州市金融科技协会指导&#xff0c;企智未来科技&#xff08;LowCode低码时代、RPA中国、AIGC开放社区&#xff09;主办。大会旨在聚合每一位产业成员的力量&#xff0c;深入探索低…




阅读更多...

















腾讯云学生服务器多少钱？怎么申请？








腾讯云学生服务器多少钱？怎么申请？




2024年腾讯云学生服务器优惠活动「云校园」&#xff0c;学生服务器优惠价格&#xff1a;轻量应用服务器2核2G学生价30元3个月、58元6个月、112元一年&#xff0c;轻量应用服务器4核8G配置191.1元3个月、352.8元6个月、646.8元一年&#xff0c;CVM云服务器2核4G配置842.4元一年&…




阅读更多...

















学习clickhouse 集群搭建和分布式存储








学习clickhouse 集群搭建和分布式存储




为什么要用集群 
使用集群的主要原因是为了提高系统的可扩展性、可用性和容错性。 
可扩展性&#xff1a;当单个节点无法处理增加的负载时&#xff0c;可以通过添加更多的节点到集群来增加处理能力。这使得系统可以处理更大的数据量和更高的查询负载。可用性&#xff1a;在集群…




阅读更多...

















驱动调试第013期-G120XA驱动同步电机应用案例








驱动调试第013期-G120XA驱动同步电机应用案例




概述 
SINAMICS G120XA是西门子SINAMICS系列变频器的新成员&#xff0c; 功率范围覆盖0.75 kW~560 kW&#xff0c;内置风机和水泵行业应用功能&#xff0c;汇集了优异的高性能矢量控制算法&#xff0c;可以轻松的驱动风机、水泵及压缩机等负载。胜任各种应用场合&#xff0c;专…




阅读更多...


















推荐文章












最新文章


















Copyright @ 2022~2023