使用Feign作为服务消费者

电玩女神 2022-11-05 11:56 17阅读 0赞

Ribbon是一个基于Http和TCP的负载均衡工具，而Feign（音：菲恩）是一个声明式的伪Http客户端，它比Ribbon更加的优雅。Feign使用的是接口的方式。Feign默认集成了Ribbon，并和Eureka结合，默认实现了负载均衡的效果。

# 1.1 导入feign依赖 #

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

# 1.2 编写application.yml配置文件 #

#指明注册中心的位置
    eureka:
      client:
        serviceUrl:
          defaultZone: http://localhost:8761/eureka/
    #当前项目部署的端口
    server:
      port: 8765
    #当前项目的名称
    spring:
      application:
        name: service-feign

# 1.3 编写启动类 #

@EnableFeignClients注解是开启feign负载均衡工具。

package com.safesoft.feign;
     
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    import org.springframework.cloud.openfeign.EnableFeignClients;
     
    @SpringBootApplication
    @EnableEurekaClient
    @EnableDiscoveryClient
    @EnableFeignClients
    public class ApplicationFeign { 
        public static void main(String[] args) { 
            SpringApplication.run(ApplicationFeign.class, args);
        }
    }

# 1.4 编写服务接口 #

package com.safesoft.feign.service;
     
    import org.springframework.cloud.openfeign.FeignClient;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestParam;
     
    @FeignClient(value = "SERVICE-CLIENT")
    public interface HelloService { 
     
        /** * 从SERVICE-CLIENT服务器的/hi接口获取JSON数据 * @param name * @return */
        @RequestMapping("/hi")
        String obtainOtherServerJsonData(@RequestParam(value = "name") String name);
    }

# 1.5 编写Controller #

package com.safesoft.feign.web;
     
    import com.safesoft.feign.service.HelloService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
     
    @RestController
    public class HelloController { 
     
        /** * 因为HelloService仅仅使用了@FeiginClient注解 * 没有使用@Bean类型的注解，比如@Service @Component等 * 所以编译器会警告，其实可以忽视它 */
        @Autowired
        private HelloService helloService;
     
        @RequestMapping("/sayHello")
        public String sayHello(String name) { 
            return helloService.obtainOtherServerJsonData(name);
        }
    }

# 1.6 启动Feign服务器 #

在浏览器上输入http://localhost:8765/hello?name=pc，尝试从8765端口获取JSON数据。此请求会被Feign服务器负载均衡到部署在8762端口与8763端口的服务器上。  
第一次刷新结果如下：  
![在这里插入图片描述][20210306161318663.png]  
第二次刷新结果如下：  
![在这里插入图片描述][20210306161328267.png]

[20210306161318663.png]: /images/20221023/f95d5838a0d44f978c61881655adacc9.png
[20210306161328267.png]: /images/20221023/631173fcdd2f4166a6fdef7864f9388c.png