亲宝软件园·资讯

展开

SpringCloud Ribbon负载均衡

叮叮裆 人气:0

Ribbon使用

负载均衡

代码示例

注册中心

这里是Eureka作为服务注册中心,为OpenFeign提供服务端信息的获取,比如说服务的IP地址和端口,使用前面搭建好的项目(eureka-server)。

Provider

在idea中新建两个项目运行主类,选择前面创建好的项目(eureka-provider)。

在这里插入图片描述

设置不同运行主类,使用不同端口号,然后启动三个不同端口号的provider。

在这里插入图片描述

接口实现

调用不同的服务端,会返回对应服务端的接口。

@RestController
@RequestMapping("/api")
public class PoroviderController {

    @Value("${server.port}")
    private String serverPort;

    @PostMapping("/sayHello")
    public String sayHello(String name) {
        return "我是服务端" + serverPort + ",你好" + name;
    }
}

Consumer

新建一个spring-boot工程,取名为consumer-ribbon,在pom文件引入ribbon需要的依赖。

添加依赖

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

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

配置端口、注册中心等

server:
  port: 8091
  servlet:
    context-path: /ribbon
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/
  instance:
    status-page-url-path: ${server.servlet.context-path}/info
    health-check-url-path: ${server.servlet.context-path}/health
spring:
  application:
    name: consumer-ribbon
@Configuration
public class RestTemplateConfig {

    /**
     * @return org.springframework.web.client.RestTemplate
     * @description 注入一个可以进行负载均衡的RestTemple用于服务问调用
     * @author fengfan
     * @date 2022/5/18 14:43
     */
    @Bean
    @LoadBalanced
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }

}

yml配置负载均衡策略

# 配置的方式设置Ribbon的负载均衡策略
EUREKA-PROVIDER: # 设置服务提供方的应用名称
  ribbon:
    NFloadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule # 策略类(全路径名)

代码方式配置负载均衡策略

@Configuration
public class RibbonConfig {

    /**
     * @return com.netflix.loadbalancer.IRule
     * @description 配置随机负载策略
     * @author fengfan
     * @date 2022/5/20 16:04
     */
    @Bean
    public IRule iRule(){
        return new RandomRule();
    }
}

@SpringBootApplication
@EnableEurekaClient
@RibbonClient(name = "consumer-ribbon", configuration = RibbonConfig.class)
public class ConsumerRibbonApplication {

    public static void main(String[] args) {
        SpringApplication.run(ConsumerRibbonApplication.class, args);
    }

}

客户端调用实现

@RestController
@RequestMapping("/api")
public class ConsumerRibbonController {
    @Resource
    private RestTemplate restTemplate;

    @PostMapping("/getServerInfo")
    public String getServerInfo(){
        MultiValueMap<String, String> body = new LinkedMultiValueMap<>();
        body.add("name", "consumer8081");
        ResponseEntity<String> responseEntity = restTemplate.postForEntity("http://EUREKA-PROVIDER/provider/api/sayHello", body, String.class);
        return responseEntity.getBody();
    }
}

测试

在这里插入图片描述

多次请求的服务端,端口随机变化,证明配置成功。

在这里插入图片描述

加载全部内容

相关教程
猜你喜欢
用户评论