0
点赞
收藏
分享

微信扫一扫

【springcloud】--Hystrix+ribbon搭建

萍儿的小确幸 2022-01-23 阅读 58
spring cloud

目录

一、说明

这里先介绍Eureka client、Hystrix、ribbon等组件架构关系,后续继续完善他们的功能原理。
在这里插入图片描述

二、代码实现

需要的jar包

<!--springCloud启动依赖-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter</artifactId>
</dependency>
<!--srpingCloud的eureka client端-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<!--srpingCloud的eureka服务注册依赖,既要充当生产者,又要充当消费者-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
    <version>2.1.0.RELEASE</version>
</dependency>

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

加上注解

@EnableDiscoveryClient //注解注册到服务中心
@EnableEurekaClient
@EnableHystrix

Ribbon方式调用

/**
 * 只有消费者才需要配置这个类,并加上@LoadBalanced,实现负载均衡
 */
@Configuration
public class RestTemplateConfiguration {
    @Bean
    @LoadBalanced
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }
}

服务消费者EurekaClient1Ribbon+hystrix的方式

@Service
public class RibbonPersonService {

    @Autowired
    RestTemplate restTemplate;
    @HystrixCommand(fallbackMethod = "personByIdHytrix")
    public String getPersonById(Integer id){
       // http://localhost:7081/otherPerson/getPersonById.do?id=1
        String result = restTemplate.getForObject(
                "http://eurekaClient2/getPersonById.do?id="+id,String.class);
        return result;
    }
    //熔断的功能
    public String personByIdHytrix(Integer id){
        return "personById Hytrix";
    }
}

服务提供者EurekaClient2–controller层的接口【只要子类实现即可】

public interface OtherPersonApi {
    /**
     * 不支持@GetMapping @PostMapping,只能用@RequestMapping,通过method指定请求方式;
     * 参数传递必须用@RequestParam(value = "id") 注解修饰,传递的参数为对象,必须用@RequestBody修饰;
     * 返回值若为对象,对象必须序列化;
     */
    @RequestMapping(value = "/getPersonById.do",method = RequestMethod.GET)
    String getPersonById(@RequestParam(value = "id") Integer id);

    @RequestMapping(value = "/insertPerson.do",method = RequestMethod.GET)
    PersonPo insertPerson(@RequestParam(value = "userId") Integer userId,@RequestBody PersonPo person);
}
举报

相关推荐

0 条评论