有色建设网站,免费网站平台推荐,什么是网页布局,网站建设服务费应该算什么科目1.新建两个provider#xff1a;springcloud-provider-dept-8002 2. 配置跟8001一样
整合 Ribbon 由上述可知#xff0c;Ribbon 是需要集成在消费端的 所以在消费端 #xff1a; springcloud-03-consumer-dept-8082 进行修改 在 POM 文件中添加 Ribbon、Eureka 依赖 !--…1.新建两个providerspringcloud-provider-dept-8002 2. 配置跟8001一样
整合 Ribbon 由上述可知Ribbon 是需要集成在消费端的 所以在消费端 springcloud-03-consumer-dept-8082 进行修改 在 POM 文件中添加 Ribbon、Eureka 依赖 !--ribbon--!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-ribbon --dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-ribbon/artifactIdversion1.4.7.RELEASE/version/dependency!--Eureka 服务提供者--!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-eureka --dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-eureka/artifactIdversion1.4.7.RELEASE/version/dependency 编写 application.yml
# Eureka
eureka:client:# 不向注册中心注册自己register-with-eureka: false# 配置 可连接的注册中心service-url:defaultZone: http://127.0.0.1:7001/eureka/,http://127.0.0.2:7002/eureka/ 在主启动类上添加 Eureka 启动项 EnableEurekaClient
在之前把 RestTemplate 注册到 Bean 的配置方法上添加一个注解
配置 负载均衡实现 RestTemplate LoadBalanced 修改控制层 /**提供者 URL 的前缀** 不使用 Ribbon 时 这里就是第一中写法** 使用 Ribbon 实现负载均衡 时这里就不能写死为一个地址* 而需要通过注册中心的服务名来访问* 服务名在 提供者 YML 文件中配置的 spring:application:name: 的值* 或者 监控页面的 Application 字段值*/
//private static final String REST_URL_PREFIX http://localhost:8081;private static final String REST_URL_PREFIX http://SpringCloud-02-provider; 启动集群、提供者、消费者进行测试
进入 消费者页面 发出请求得到正确结果
2.2 添加提供者观察负载均衡 添加一个数据库 spring_cloud_02 新建一个 服务提供者 springcloud-02-provider-dept-8083
把另一个 提供者 的文件都复制过来再做修改
修改 application.yml 端口号、数据库、描述信息
【注意】多个提供者的服务名必须一致
server:port: 8083mybatis:type-aliases-package: com.demo.pojomapper-locations: classpath:mybatis/mapper/*.xmlconfig-location: classpath:mybatis/mybatis-config.xmlspring:application:name: SpringCloud-02-providerdatasource:username: rootpassword: 123456driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://localhost:3306/spring_cloud_02?serverTimezoneUTCuseUnicodetruecharacterEncodingutf-8type: com.alibaba.druid.pool.DruidDataSourcelogging:level:com.demo.mapper: DEBUG# Eureka配置服务注册到哪里
eureka:client:service-url:# 配置监控页面的地址这是在 Eureka Server 中配置的defaultZone: http://127.0.0.1:7001/eureka/,http://127.0.0.2:7002/eureka/instance:# 修改 Eureka 监控页面上的默认描述信息instance-id: springcloud-provider-dept-8083 修改主启动类添加注解
//在配置过这个注解后服务启动会自动注册到 Eureka Server
EnableEurekaClient
//开启服务发现
EnableDiscoveryClient
2.3 修改负载均衡策略 负载均衡有一个核心的结构 IRule 进入该接口 实现类
修改为已经实现的策略 因为是在消费者端做负载均衡所以在消费者中修改
把已经实现的策略注册的 Bean 中即可
修改 springcloud-03-consumer-dept-8082 的 BeanConfig 文件
Bean
public IRule myRule(){// 先使用已经实现的策略——随机return new RandomRule();
} 重建消费者刷新请求会发现不再轮询会在已有的提供者之间随机选择
修改配置 Ribbon 的方式 新建一个 MyRule 类并且把上面那个 myRule 方法挪过去 【注意】这个 MyRule 类 不能在主应用程序的上下文也就是 主启动类的同级目录中所以需要单独的创建一个包
Configuration
public class MyRule {/*** 修改默认的负载均衡策略*/Beanpublic IRule customize(){// 先使用已经实现的策略——随机return new RandomRule();}
} 在主启动类上加上 Ribbon 的注解
RibbonClientSpringBootApplication
EnableEurekaClient
// configuration:标注 Rule 的配置类 name标注需要配置的服务名
RibbonClient(configuration MyRule.class,name SpringCloud-02-provider)
public class Springcloud03ConsumerDept8082Application {public static void main(String[] args) {SpringApplication.run(Springcloud03ConsumerDept8082Application.class, args);}
} 自定义策略简单示例 可以点开刚刚看的那个 RandomRule 的源代码复制过来修改一下 修改要求每个提供者访问五次 编写 DiyRule()
public class DiyRule extends AbstractLoadBalancerRule {public Server choose(ILoadBalancer lb, Object key) {if (lb null) {return null;} else {Server server null;while(server null) {if (Thread.interrupted()) {return null;}// 获得可获得活着的的服务ListServer upList lb.getReachableServers();// 获得所有的服务ListServer allList lb.getAllServers();int serverCount allList.size();if (serverCount 0) {return null;}//上面是写死的中间是修改部分System.out.println(自定义的 Rule);System.out.println(upList.size());// 访问某一个提供者的次数int times 0;// 提供者的下标int index 0;// 从活着的服务中随机获取一个server (Server)upList.get(index);if (times 4){times;}else {times 1;index (index 1) % upList.size();}//下面是写死的中间是修改部分if (server null) {Thread.yield();} else {if (server.isAlive()) {return server;}server null;Thread.yield();}}return server;}}Overridepublic void initWithNiwsConfig(IClientConfig iClientConfig) {}Overridepublic Server choose(Object o) {return null;}
} MyRule 类
Configuration
public class CustomizedRule {/*** 修改默认的负载均衡策略*/Beanpublic IRule customize(){// 先使用已经实现的策略——随机return new DiyRule();}
}
在主启动类上添加
// configuration:标注 Rule 的配置类 name标注需要配置的服务名
RibbonClient(name SPRINGCLOUD-PROVIDER, configuration CustomizedRule.class)
