SpringCloud手写Ribbon实现负载均衡

##服务端口号
server:
 port: 8503
spring:
 application:
 ##服务别名--服务注册到consul名称
 name: consul-member
 ##注册中心consul地址
 cloud:
 consul:
  host: localhost
  port: 8500
 discovery:
  ## consul ip地址
 hostname: 192.168.3.91

java -jar E:\ideaworkspaceback\springcloud-zookeeper\springcloud-zookeeper-member\target\springcloud-zookeeper-member-1.0-SNAPSHOT.jar --spring.profiles.active=consul2

package com.baba.wlb.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;
/**
 * @Author wulongbo
 * @Date 2021/1/9 15:32
 * @Version 1.0
 */@RestController
public class OrderApiController {
 @Autowired
 private RestTemplate restTemplate;
 @Autowired
 private DiscoveryClient discoveryClient;
 //使用原子类AtomicInteger
 private AtomicInteger atomicInteger = new AtomicInteger(1);
 public int add() {
  return atomicInteger.getAndIncrement(); //先获取再自增,对应a++
 //若使用++a 则对应方法是a.incrementAndGet(); 先自增再获取 , //多说一句 a-- 就是 a.getAndDecrement(); //若a = a + 10;————对应API a.getAndAdd(10);
 }
 /**
 * springCloud中，两种方式调用（rest/feign）
 *
 * @return
 */
 // 订单服务调用会员服务
 @RequestMapping("/getOrder")
 public String getOrder() {
  // 有两种调用方式，一种是采用服务别名方式调用，另一种是使用别名去注册中心上获取对应服务调用地址
 // 第一种方式
 String url = "http://dy-202006281547:8000/getMember";
 // 第二种方式
 url = "http://zk-member/getMember";
 String result = restTemplate.getForObject(url, String.class);
 return "订单服务调用会员服务：" + result;
 }
 /**
 * springCloud中，两种方式调用（rest/feign）
 *
 * @return
 */
 // 订单服务调用会员服务
 @RequestMapping("/getRibbonOrder")
 public String getRibbonOrder() {
  // 第一种方式
 String url = getUri() + "/getMember";
 String result = restTemplate.getForObject(url, String.class);
 return "纯手写Ribbon本地负载均衡：" + result;
 }
 public String getUri() {
  List<ServiceInstance> serviceInstances = discoveryClient.getInstances("consul-member");
 if (serviceInstances == null || serviceInstances.isEmpty()) {
   return null;
 }
  int serverSize = serviceInstances.size();
 int count = add();
 int indexServer = count % serverSize;
 return serviceInstances.get(indexServer).getUri().toString();
 }
}

<!--springcloud 整合consul-->
<dependency>
 <groupId>org.springframework.cloud</groupId>
 <artifactId>spring-cloud-starter-consul-discovery</artifactId>
</dependency>

## consul ip地址
##hostname: 192.168.3.91