创建工程

具体实现

pom.xml


4.0.0com.itmuch.cloudmicroservice-consumer-movie-ribbon-customizing-properties0.0.1-SNAPSHOTjarorg.springframework.bootspring-boot-starter-parent1.4.3.RELEASEUTF-81.8org.springframework.bootspring-boot-starter-weborg.springframework.bootspring-boot-starter-actuatororg.springframework.cloudspring-cloud-starter-eurekaorg.springframework.cloudspring-cloud-dependenciesCamden.SR4pomimportorg.springframework.bootspring-boot-maven-plugin



application.yml

server:port: 8010
spring:application:name: microservice-consumer-movie
eureka:client:serviceUrl:defaultZone: http://localhost:8761/eureka/instance:prefer-ip-address: true#这里选用的是负载均衡的[随机策略]
microservice-provider-user:ribbon:NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

关键处&＃xff1a;

#这里选用的是负载均衡的[随机策略]
microservice-provider-user:
  ribbon:
    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

说明&＃xff1a;还可以更换不同的策略&＃xff1b;

User

package com.itmuch.cloud.study.user.entity;import java.math.BigDecimal;public class User {private Long id;private String username;private String name;private Integer age;private BigDecimal balance;public Long getId() {return this.id;}public void setId(Long id) {this.id &＃61; id;}public String getUsername() {return this.username;}public void setUsername(String username) {this.username &＃61; username;}public String getName() {return this.name;}public void setName(String name) {this.name &＃61; name;}public Integer getAge() {return this.age;}public void setAge(Integer age) {this.age &＃61; age;}public BigDecimal getBalance() {return this.balance;}public void setBalance(BigDecimal balance) {this.balance &＃61; balance;}
}

ConsumerMovieApplication

package com.itmuch.cloud.study;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;/*** 用配置文件来完成自定义*/
&＃64;EnableDiscoveryClient
&＃64;SpringBootApplication
public class ConsumerMovieApplication {&＃64;Bean&＃64;LoadBalancedpublic RestTemplate restTemplate() {return new RestTemplate();}public static void main(String[] args) {SpringApplication.run(ConsumerMovieApplication.class, args);}
}


MovieController

package com.itmuch.cloud.study.user.controller;import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;import com.itmuch.cloud.study.user.entity.User;&＃64;RestController
public class MovieController {private static final Logger LOGGER &＃61; LoggerFactory.getLogger(MovieController.class);&＃64;Autowiredprivate RestTemplate restTemplate;&＃64;Autowiredprivate LoadBalancerClient loadBalancerClient;&＃64;GetMapping("/test")public String test() {ServiceInstance serviceInstance &＃61; this.loadBalancerClient.choose("microservice-provider-user");System.out.println("--------随机&＃xff1a;"&＃43;serviceInstance.getHost()&＃43;":"&＃43;serviceInstance.getPort()&＃43;":"&＃43;serviceInstance.getServiceId());ServiceInstance serviceInstance2 &＃61; this.loadBalancerClient.choose("microservice-provider-user2");System.out.println("--------轮询&＃xff1a;"&＃43;serviceInstance2.getHost()&＃43;":"&＃43;serviceInstance2.getPort()&＃43;":"&＃43;serviceInstance2.getServiceId());return "1";}&＃64;GetMapping("/user/{id}")public User findById(&＃64;PathVariable Long id) {return this.restTemplate.getForObject("http://microservice-provider-user/" &＃43; id, User.class);}&＃64;GetMapping("/log-user-instance")public void logUserInstance() {ServiceInstance serviceInstance &＃61; this.loadBalancerClient.choose("microservice-provider-user");// 打印当前选择的是哪个节点MovieController.LOGGER.info("{}:{}:{}", serviceInstance.getServiceId(), serviceInstance.getHost(), serviceInstance.getPort());}
}


启动测试

启动

microservice-provider-user:8000

microservice-provider-user:8001(改端口)

microservice-provider-user2:8002&＃xff08;改服务名和端口&＃xff09;

microservice-provider-user2:8003&＃xff08;改服务名和端口&＃xff09;

查看eureka

访问测试

控制台输出&＃xff1a;

--------轮询&＃xff1a;192.168.1.102:8002:microservice-provider-user2
--------随机&＃xff1a;192.168.1.102:8000:microservice-provider-user
--------轮询&＃xff1a;192.168.1.102:8003:microservice-provider-user2
--------随机&＃xff1a;192.168.1.102:8000:microservice-provider-user
--------轮询&＃xff1a;192.168.1.102:8002:microservice-provider-user2
--------随机&＃xff1a;192.168.1.102:8000:microservice-provider-user
--------轮询&＃xff1a;192.168.1.102:8003:microservice-provider-user2
--------随机&＃xff1a;192.168.1.102:8000:microservice-provider-user
--------轮询&＃xff1a;192.168.1.102:8002:microservice-provider-user2
--------随机&＃xff1a;192.168.1.102:8001:microservice-provider-user
--------轮询&＃xff1a;192.168.1.102:8003:microservice-provider-user2
--------随机&＃xff1a;192.168.1.102:8001:microservice-provider-user
--------轮询&＃xff1a;192.168.1.102:8002:microservice-provider-user2
--------随机&＃xff1a;192.168.1.102:8001:microservice-provider-user
--------轮询&＃xff1a;192.168.1.102:8003:microservice-provider-user2
--------随机&＃xff1a;192.168.1.102:8001:microservice-provider-user
--------轮询&＃xff1a;192.168.1.102:8002:microservice-provider-user2

......

&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;

QQ群&＃xff1a;143522604

欢迎和大家一起学习、交流、提升&＃xff01;

&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;