您的位置: 首页  >  文章  >  spring cloud -- 3.服务消费者（Feign）

spring cloud -- 3.服务消费者（Feign）

分类: 文章 • 2024-12-02 22:53:22

此文章是看了方志朋老师的教材自己写的框架demo：

学习spring cloud推荐大家看下方志朋老师的史上最简单的 SpringCloud 教程 | 终章，地址如下：

   https://blog.****.net/forezp/article/details/70148833 


1.作用

Feign是一个声明式的伪Http客户端，它使得写Http客户端变得更简单。使用Feign，只需要创建一个接口并注解。它具有可插拔的注解特性，可使用Feign 注解和JAX-RS注解。Feign支持可插拔的编码器和解码器。Feign默认集成了Ribbon，并和Eureka结合，默认实现了负载均衡的效果。


2.代码实现

2.1 创建maven项目

spring cloud -- 3.服务消费者（Feign）

spring cloud -- 3.服务消费者（Feign）

spring cloud -- 3.服务消费者（Feign）

2.2 项目创建成功后，pom.xml添加

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

  <modelVersion>4.0.0</modelVersion>

  <groupId>com.immo</groupId>

  <artifactId>immo-feign</artifactId>

  <version>0.0.1-SNAPSHOT</version>

  

   <!-- spring boot 依赖包 -->

  <parent>

        <groupId>org.springframework.boot</groupId>

        <artifactId>spring-boot-starter-parent</artifactId>

        <version>1.5.2.RELEASE</version>

        <relativePath/> 

   </parent>

   

   <!-- 编码和java版本 -->

   <properties>

        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>

        <java.version>1.7</java.version>

    </properties>

   

   <dependencies>

   <!-- spring cloud -->

        <dependency>

            <groupId>org.springframework.cloud</groupId>

            <artifactId>spring-cloud-starter-eureka</artifactId>

            <version>1.3.4.RELEASE</version>

        </dependency>

        

        <!-- feign -->

        <dependency>

            <groupId>org.springframework.cloud</groupId>

            <artifactId>spring-cloud-starter-feign</artifactId>

            <version>1.3.4.RELEASE</version>

        </dependency>

        

        <!-- spring mvc -->

        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-web</artifactId>

        </dependency>

    </dependencies>

</project>

 

 

 

2.3 编写启动类和测试rest类

在src/main/java下创建com.immo包，创建FeignApplication.java:

在src/main/java下创建com.immo.controller包，创建FeignController.java:

在src/main/java下创建com.immo.service包,创建 InvokingImmoClient 接口

在src/main/java下创建com.immo.service.impl 创建

InvokingImmoClientImpl.java

在src/main/resources 下创建 application.properties

spring cloud -- 3.服务消费者（Feign）

编写application.properties

 

 

#发布到的eureka地址

eureka.client.serviceUrl.defaultZone=http://localhost:9000/eureka/

#端口

server.port=9200

#此项目的服务名称

spring.application.name=immo-feign

#打开断路器--默认是关闭的

feign.hystrix.enabled=true

 

 

 

 

编写FeignController.java

 

@RestController = @Controller + @ResponseBody

被@RestController注释的类，默认返回json

 

package com.immo.controller;

 

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.springframework.web.bind.annotation.RequestParam;

import org.springframework.web.bind.annotation.RestController;

 

import com.immo.service.InvokingImmoClient;

 

@RestController

public class FeignController {

@Autowired

private InvokingImmoClient invokingImmoClient;

@Value("${spring.application.name}")

private String serverName;

@RequestMapping(value="getServerName",method=RequestMethod.GET)

public String getServerName(){//用于zuul演示

return serverName;

}

@RequestMapping(value="invoking",method=RequestMethod.GET)

public String invoking(@RequestParam(value="name",required=false)String name){

return invokingImmoClient.invoking(name);

}

}

 

 

 

 

编写InvokingImmoClient

@ FeignClient（“服务名”），来指定调用哪个服务。比如在代码中调用了IMMO-CLIENT服务的“/getMseeage”接口

fallback 属性指定断路器的类

（在微服务架构中，根据业务来拆分成一个个的服务，服务与服务之间可以 相互调用（RPC），在spring Cloud可以用RestTemplate+Ribbon和Feign 来调用。为了保证其高可用，单个服务通常会集群部署。由于网络原因或者 自身的原因，服务并不能保证100%可用，如果单个服务出现问题，调用这个 服务就会出现线程阻塞，此时若有大量的请求涌入，Servlet容器的线程资 源会被消耗完毕，导致服务瘫痪。服务与服务之间的依赖性，故障会传播， 会对整个微服务系统造成灾难性的严重后果，这就是服务故障的“雪崩”效 应）

Feign是自带断路器的

package com.immo.service;

 

import org.springframework.cloud.netflix.feign.FeignClient;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.springframework.web.bind.annotation.RequestParam;

 

import com.immo.service.impl.InvokingImmoClientImpl;

 

@FeignClient(value = "IMMO-CLIENT",fallback = InvokingImmoClientImpl.class)

public interface InvokingImmoClient {

@RequestMapping(value = "/getMessage",method = RequestMethod.GET)

    String invoking(@RequestParam(value = "name") String name);

}

 

 

 

 

 

编写InvokingImmoClient，必须注入容器：

 

package com.immo.service.impl;

 

import org.springframework.stereotype.Component;

import com.immo.service.InvokingImmoClient;

 

@Component

public class InvokingImmoClientImpl implements InvokingImmoClient{

 

@Override

public String invoking(String name) {

return name+" sorry  找不着服务";

}

 

}

 

 

 

 

 

 

编写启动类FeignApplication.java

@EnableFeignClients:开启Feign的功能

 

 

package com.immo;

 

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

import org.springframework.cloud.netflix.feign.EnableFeignClients;

 

@SpringBootApplication

@EnableEurekaClient

@EnableFeignClients

public class FeignApplication {

 public static void main(String[] args) {

        SpringApplication.run(FeignApplication.class,args);

    }

}

 

 

 

2.4 启动和测试

先后启动immo-eureka，immo-client，immo-feign三个项目，然后访问localhost:9000

spring cloud -- 3.服务消费者（Feign）

测试immo-feign写的接口（证明我们成功在immo-feign项目调用到了immo-client方法）：

spring cloud -- 3.服务消费者（Feign）

测试断路器，关闭immo-client服务，我们再次访问此url（说明断路器生效了）：

spring cloud -- 3.服务消费者（Feign）

相关推荐