1. 依赖

org.springframework.cloudspring-cloud-starter-netflix-ribbon

2. 配置

my-service:ribbon:listOfServers: example.com:8080, example.net:8080

常用配置项：
ribbon.eureka.enabled：指定是否启用Ribbon与Eureka服务器集成。默认为true。

ribbon.client.name：指定Ribbon客户端的名称。当使用Spring Cloud Netflix时，该值通常是服务名。

ribbon.NFLoadBalancerRuleClassName：指定负载均衡算法的类名。如果未指定，则使用默认的RoundRobinRule算法。

ribbon.ReadTimeout：指定读取超时时间，以毫秒为单位。如果在此时间内没有收到响应，则请求将被中断。

ribbon.ConnectTimeout：指定连接超时时间，以毫秒为单位。如果在此时间内无法建立连接，则请求将被中断。

ribbon.OkToRetryOnAllOperations：指定在发生故障时是否应重试所有操作。默认为false。

ribbon.MaxAutoRetries：指定自动重试操作的最大次数。默认为0，表示不进行自动重试。

ribbon.MaxAutoRetriesNextServer：指定在下一个服务器上进行自动重试的最大次数。默认为1。

ribbon.ServerListRefreshInterval：指定更新服务器列表的间隔时间，以毫秒为单位。

ribbon.ServerListRefreshInitialDelay：指定在第一次更新服务器列表之前的延迟时间，以毫秒为单位。

ribbon.ServerListClassName：指定服务器列表的实现类。如果未指定，则使用默认的ConfigurationBasedServerList实现。

ribbon.ServerListFilterClassName：指定用于筛选服务器列表的类的名称。如果未指定，则不应用任何过滤器。

ribbon.EnablePrimeConnections：指定是否启用Prime Connections。默认为false。

3. 实现

@Configuration
public class MyLoadBalancerConfiguration {@Beanpublic IRule myLoadBalancingRule() {return new MyLoadBalancingRule();}private static class MyLoadBalancingRule extends AbstractLoadBalancerRule {private AtomicInteger nextServerCyclicCounter;public MyLoadBalancingRule() {nextServerCyclicCounter = new AtomicInteger(0);}@Overridepublic Server choose(Object key) {List allServers = getLoadBalancer().getAllServers();if (allServers.isEmpty()) {return null;}int nextServerIndex = incrementAndGetModulo(allServers.size());return allServers.get(nextServerIndex);}private int incrementAndGetModulo(int modulo) {int current;int next;do {current = nextServerCyclicCounter.get();next = (current + 1) % modulo;} while (!nextServerCyclicCounter.compareAndSet(current, next));return next;}}
}

4. 发送请求

@Service
public class MyService {@Autowiredprivate RestTemplate restTemplate;public String callMyService() {String response = restTemplate.getForObject("http://my-service/path/to/resource", String.class);return response;}
}

Ps

其中的循环遍历可用代码的服务器列表的代码是

List allServers = getLoadBalancer().getAllServers();if (allServers.isEmpty()) {return null;
}int nextServerIndex = incrementAndGetModulo(allServers.size());
return allServers.get(nextServerIndex);

or

private AtomicInteger nextServerCyclicCounter;public MyLoadBalancingRule() {nextServerCyclicCounter = new AtomicInteger(0);
}private int incrementAndGetModulo(int modulo) {int current;int next;do {current = nextServerCyclicCounter.get();next = (current + 1) % modulo;} while (!nextServerCyclicCounter.compareAndSet(current, next));return next;
}