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.mzph.cn/news/728776.shtml

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

相关文章

微服务架构下的接口调用链路梳理方案(AI问答)

接口调用链路梳理 我有很多的接口&#xff0c;不知道有哪些微服务在调用它&#xff0c;我应该怎么把调用链路梳理出来&#xff1f; 在微服务架构中&#xff0c;梳理接口调用链路是一项关键的运维和调试任务。为了找出哪些微服务正在调用特定的接口&#xff0c;可以采用以下几种…

【系统学习】2-Java进阶知识总结-3-集合-1-补充【泛型、树、数据结构】

文章目录 泛型什么是泛型&#xff1f;常见的泛型标识符泛型类泛型方法泛型接口通配符 树树的基本概念什么是二叉树&#xff1f;二叉树--普通二叉树二叉树--二叉查找树定义规则优缺点 二叉树--平衡二叉树定义规则旋转机制 二叉树--红黑树定义规则红黑规则 常见数据结构总体特点结…

【自然语言处理】NLP入门(五):1、正则表达式与Python中的实现(5):字符串常用方法:对齐方式、大小写转换详解

文章目录 一、前言二、正则表达式与Python中的实现1.字符串构造2. 字符串截取3. 字符串格式化输出4.字符转义符5. 字符串常用函数函数与方法之比较 6. 字符串常用方法1. 对齐方式center()ljust()rjust() 2. 大小写转换lower()upper()capitalize()title()swapcase() 一、前言 本…

RabbitMQ实战:docker compose 搭建RabbitMQ

目录 一、yml文件准备二、启动RabbitMQ三、开启图形化管理界面四、验证参考资料 一、yml文件准备 docker-compose-rabbitmq.yml文件如下所示 version: "3.8" services:rabbitmq:image: rabbitmq:3.11-alpine container_name: rabbitmqrestart: alwaysvolumes:- /ho…

软考高级:UML 4+1 视图概念和例题

作者&#xff1a;明明如月学长&#xff0c; CSDN 博客专家&#xff0c;大厂高级 Java 工程师&#xff0c;《性能优化方法论》作者、《解锁大厂思维&#xff1a;剖析《阿里巴巴Java开发手册》》、《再学经典&#xff1a;《Effective Java》独家解析》专栏作者。 热门文章推荐&am…

Java高频面试之总纲篇

Java高频 面试之基础篇 Java高频面试之集合篇 Java高频面试之异常篇 Java高频面试之并发篇Java高频面试之SSM篇 Java高频面试之Mysql篇 Java高频面试之Redis篇 Java高频面试之消息队列与分布式篇 50道SQL面试题 奇奇怪怪的面试题 五花八门的内存溢出

Golang内存管理

# golang内存管理golang是一种编译型的静态类型语言&#xff0c;它提供了一种简洁和高效的方式来管理内存。golang的内存管理主要依赖于两个机制&#xff1a;**栈**和**堆**。## 栈栈是一种后进先出&#xff08;LIFO&#xff09;的数据结构&#xff0c;它用于存储函数的局部变量…

在Jetson Xavier NX 开发板上使用VScode执行ROS程序详细过程

1.创建 ROS 工作空间ws 在home下打开终端输入下面指令 mkdir -p xxx_ws/src(必须得有 src) cd 自己命名_ws catkin_make2.启动 vscode cd 自己命名_ws code .3.vscode 中编译 ros 快捷键 ctrl shift B 调用编译&#xff0c;在上方弹窗位置选择:catkin_make:build 可以点击…

jenkins配置

jenkins前端常用插件&#xff1a; Git Parameter 、Maven Integration 、Proxmox&#xff08;snapshot&#xff09;、Pipeline: Multibranch&#xff08;多分支流水线&#xff09;、Pipeline: Stage Step、pipeline Git plugin、NodeJS Plugin、Publish Over SSH、SSH server…

python界面开发 - Menu (popupmenu) 右键菜单

文章目录 1. python图形界面开发1.1. Python图形界面开发——Tkinter1.2. Python图形界面开发——PyQt1.3. Python图形界面开发——wxPython1.4. Python图形界面开发—— PyGTK&#xff1a;基于GTK1.5. Python图形界面开发—— Kivy1.6. Python图形界面开发——可视化工具1.7. …

【个人学习笔记】概率论与数理统计知识梳理【六】

文章目录 第六章 样本及抽样分布一、随机抽样二、直方图与箱线图2.1 直方图2.2 箱线图 三、抽样分布总结 第六章 样本及抽样分布 好久没更新了&#xff0c;重新捡起来把它更完吧&#xff0c;可能会再开一个机器学习的笔记系列&#xff0c;参考用书是周志华的西瓜书。前五章主要…

Android 14.0 首次开机默认授予app运行时权限(去掉运行时授权弹窗)

1.概述 在14.0的系统rom产品定制化开发中&#xff0c;在6.0以后对于权限的申请&#xff0c;都需要动态申请&#xff0c;所以会在系统首次启动后&#xff0c;在app的首次运行时&#xff0c; 会弹出授权窗口&#xff0c;会让用户手动授予app运行时权限&#xff0c;在由于系统产品…

6、JavaWeb-Mybatis

P116 Mybatis-入门 Mybatis是一款优秀的持久层框架&#xff0c;用于简化JDBC的开发。 持久层就是三层控制中的Dao层&#xff0c;数据访问层/持久层&#xff0c; P117 Mybatis-入门-快速入门程序 步骤&#xff1a; 创建springboot工程&#xff0c;数据表和实体类 引入mybat…

【办公类-39-03】批量下载微信公众号图片(三)-微信公众号链接的爬虫下载

背景需求&#xff1a; 测试两种公众号图片下载&#xff0c; 1、UIBOT下载速度慢&#xff0c;也需要有UIBOT软件 【办公类-39-01】批量下载微信公众号图片&#xff08;一&#xff09;UIBOT图片下载-CSDN博客文章浏览阅读289次。【办公类-39-01】批量下载微信公众号图片&#…

T5模型-基于Transformer架构的通用文本到文本转换模型

T5&#xff08;Text-to-Text Transfer Transformer&#xff09;是由Google于2019年提出的一种基于Transformer架构的通用文本到文本转换模型。T5模型通过在大规模数据集上进行预训练&#xff0c;并使用迁移学习的方式在各种自然语言处理任务上取得了出色的性能。它的设计理念是…

认识JAVA数组

以下是一个Java数组的案例&#xff0c;展示了如何创建、初始化和访问数组中的元素&#xff1a; public class ArrayExample {public static void main(String[] args) {// 创建一个整数数组&#xff0c;长度为5int[] numbers new int[5];// 初始化数组元素numbers[0] 1;numb…

Python笔记(三)—— Python循环语句

循环普遍存在于日常生活中&#xff0c;同样&#xff0c;在程序中&#xff0c;循环功能也是至关重要的基础功能。 循环在程序中同判断一样&#xff0c;也是广泛存在的&#xff0c;是非常多功能实现的基础&#xff1a; bilibili循环轮播图 循环和判断一样&#xff0c;同样是程序…

XXE-XML实体注入漏洞

目录 1.xml基础 1.1什么是xml 1.2xml文档结构 1.3 什么是DTD 1.4 什么是实体 1.5 什么是外部实体 2.xxe漏洞 2.1xxe漏洞基本介绍 2.2xxe漏洞的危害 经典漏洞案例分析 3.xxe漏洞挖掘和利用 3.1. 识别潜在的XML入口 3.2. 检查XML处理逻辑 3.3. 构造试探Payload 常…

Redis核心数据结构之字典(一)

字典 概述 字典又称为符号表(symbol table)、关联数组(associative array)或映射(map)&#xff0c;是一种保存键值对(key-value pair)的抽象数据结构&#xff0c;在字典中&#xff0c;一个键(key)可以和一个值(value)进行关联(或者说将键映射为值)&#xff0c;这些关联的键和…

(delphi11最新学习资料) Object Pascal 学习笔记---第6章第3节(查看内存中的字符串)

6.3.8 查看内存中的字符串 ​ 通过查看字符串的元数据&#xff0c;可以更好地了解字符串内存管理的工作原理&#xff0c;尤其是涉及引用计数时。为此&#xff0c;我在 StringMetaTest 示例中添加了一些代码。 ​ 该程序有两个全局字符串&#xff1a; MyStr1 和 MyStr2。程序将…