spring-cloud ribbin的使用

1.1简介

ribbin是Netflix发布的负载均衡器,它有助于控制HTTP和TCP客户端的行为。为Ribbin配置服务提供者地址列表后,Ribbin就可基于某种负载均衡算法,自动地帮助服务消费者去请求。Ribbin默认为我们提供了很多的负载均衡算法,例如轮询,随机等。当然,我们也可以为Ribbin实现自定义的负载均衡算法。

1.2结构图

spring-cloud   ribbin的使用
spring-cloud   ribbin的使用

1.3使用方法

1.导入ribbin依赖

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
</dependency>

:如果已经导入过spring-cloud-starter-netflix-eureka-client的依赖,此步骤可以省略。

2.为RestTemplate设置@LoadBalanced注解

package com.cc.order;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.hystrix.EnableHystrix;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

@SpringBootApplication
@EnableEurekaClient
@EnableHystrix
@EnableFeignClients
public class ServiceOrderApplication {

    public static void main(String[] args) {

        SpringApplication.run(ServiceOrderApplication.class, args);
    }

    @Bean
    @LoadBalanced  //负载均衡  ribbon
    public RestTemplate restTemplate(){
        return new RestTemplate();//httpClient
    }

}

3.改造service方法,实现Ribbin

package com.cc.order.service;

import com.cc.order.entity.Order;
import com.cc.order.entity.Product;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

import java.math.BigDecimal;
import java.util.Arrays;


@Service
public class OrderService {
    // Spring框架对RESTful方式的http请求做了封装,来简化操作  (底层 httpClient)
    @Autowired
    private RestTemplate restTemplate;
    public  Order createOrder(){
        //1.创建订单对象
        Order order= new Order();
        order.setOid(100010);
        order.setUid(3309);
        //2.调用商品服务--查询所有商品的信息----
        //Product[] productArray = restTemplate.getForObject("http://127.0.0.1:8081/product", Product[].class);

        Product[] productArray = restTemplate.getForObject("http://service-product/product", Product[].class);
        order.setProductList(Arrays.asList(productArray));
        //2.返回
        return order;
    }

使用后的运行结果:

启动2个service-product服务实例
spring-cloud   ribbin的使用

spring-cloud   ribbin的使用
spring-cloud   ribbin的使用
他会根据自己的均衡算法去选择服务实例。

1.4自定义均衡算法

package com.cc.order.load;

import com.netflix.loadbalancer.ClientConfigEnabledRoundRobinRule;
import com.netflix.loadbalancer.ILoadBalancer;
import com.netflix.loadbalancer.Server;

public class myLoadRule extends ClientConfigEnabledRoundRobinRule {
    @Override
    public Server choose(Object key) {
        ILoadBalancer lb = getLoadBalancer();
        Server server = getLoadBalancer().getAllServers().get(0);
        return server;
    }
}

在配置文件application.yml中配置调用我们自己写好的均衡算法。

app-item:
  ribbon:
    NFLoadBalancerRuleClassName: com.cc.order.load.myLoadRule
匿名

发表评论

匿名网友