SC feign重构 20200607 HystrixCommand FeignClient(value = "",fallback ConfigServer:9004 ConfigClient:9005 Zuul:9006 Swagger

feign重构源码






1、-----sccase: 父项目,里面是共同的依赖，maven project 的打包类型选择pom
##########################################################
##########################################################
##########################################################
##############1、eurake:com.sc.ek2.Ek2Application#########
##############2、providercom.sc.api.AppMember#############
##############3、consume:com.sc.api.AppOrder##############
##########################################################
##########################################################
################<groupId>com.sc</groupId>#################
################<artifactId>sccase</artifactId>###########
##########################################################
1.1、pom.xml

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.0.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.sc</groupId>
    <artifactId>sccase</artifactId>
    <packaging>pom</packaging>
    <version>1.0-SNAPSHOT</version>
    <modules>
        <module>ek2</module>
        <module>springcloud-api-service</module>
        <module>springcloud-api-member-service</module>
        <module>springcloud-api-order-service</module>
        <module>springcloud-api-member-impl-service</module>
        <module>springcloud-api-order-impl-service</module>
    </modules>
    <properties>
        <java.version>1.8</java.version>
        <!-- <spring-cloud.version>Hoxton.SR3</spring-cloud.version>-->
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <version>2.3.0.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
            <version>2.2.3.RELEASE</version>
        </dependency>

　　<dependency>
    　　<groupId>org.springframework.cloud</groupId>
    　　<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
    　　<version>2.2.3.RELEASE</version>
　　</dependency>
　　<dependency>
     <groupId>org.springframework.cloud</groupId>
     <artifactId>spring-cloud-config-server</artifactId>
　　</dependency>
　　<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-config</artifactId>
    <version>2.2.2.RELEASE</version>
　　</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-zuul</artifactId>
　　</dependency>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
            <version>2.2.3.RELEASE</version>
        </dependency>

　　<dependency>
    　　<groupId>org.springframework.cloud</groupId>
    　　<artifactId>spring-cloud-starter-hystrix</artifactId>
    　　<version>1.4.7.RELEASE</version>
　　</dependency>

　　　<dependency>
     　　<groupId>com.spring4all</groupId>
     　　<artifactId>swagger-spring-boot-starter</artifactId>
     　　<version>1.9.1.RELEASE</version>
 　　</dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.12</version>
            <scope>provided</scope>
        </dependency>
         <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
            <version>2.11.0</version>
         </dependency>
    </dependencies>
    <dependencyManagement>
        　<dependencies>
        　   <dependency>
        　　　　　<groupId>org.springframework.cloud</groupId>
        　　　　　<artifactId>spring-cloud-dependencies</artifactId>
        　　　　　<version>${spring-cloud.version}</version>
        　　　　　<type>pom</type>
        　　　　　<scope>import</scope>
        　　</dependency>
        　</dependencies>
    </dependencyManagement>



 2、-----sccase: 父项目
  springcloud-api-member-service: 子项目
 2.1、pom.xml
     <parent>
         <groupId>com.sc</groupId>
         <artifactId>sccase</artifactId>
         <version>1.0-SNAPSHOT</version>
     </parent>
     <groupId>com.sc</groupId>
     <artifactId>springcloud-api-member-service</artifactId>
     <version>0.0.1-SNAPSHOT</version>
     <name>springcloud-api-member-service</name>
     <description>Demo project for Spring Boot</description>

 2.2、IMemberService
     package com.sc.api.service;
     import com.sc.api.entity.UserEntity;
     import org.springframework.web.bind.annotation.RequestMapping;


     public interface IMemberService {
         //实体类与定义接口放在接口项目
         @RequestMapping("/getMember")
         public UserEntity getMember(@RequestParam("name") String name);
     }

 2.3、entity

    package com.sc.api.entity;
    import lombok.Data;

    @Data
    public class UserEntity {
        private  String  name;
        private String age;

　　public UserEntity(String name, String age) {
        this.name = name;
        this.age = age;
    }

    }








 3、-----sccase: 父项目
  springcloud-api-member-impl-service: 子项目
  ##########################################################
  9002######################################################
  http://localhost:9002/getMember?name=sdfsdfsafa###########

 #########zuul 9006#################################################
 http://localhost:9006/member/getMember?name=sdfsdfsafa&token=12311
  ##################################################################


 3.1、pom.xml
     <parent>
         <groupId>com.sc</groupId>
         <artifactId>sccase</artifactId>
         <version>1.0-SNAPSHOT</version>
     </parent>
      <groupId>com.sc</groupId>
      <artifactId>springcloud-api-member-impl-service</artifactId>
      <version>0.0.1-SNAPSHOT</version>
      <name>springcloud-api-member-impl-service</name>
      <description>Demo project for Spring Boot</description>

      <dependencies>
         <dependency>
           <groupId>com.sc</groupId>
           <artifactId>springcloud-api-member-service</artifactId>
            <version>0.0.1-SNAPSHOT</version>
         </dependency>
      </dependencies>

 3.2、MemberServiceImpl
    package com.sc.api.service.impl;
    import IMemberService;
    import com.sc.api.entity.UserEntity;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;


    @Api("会员服务接口")
    @RestController
    public class MemberServiceImpl  implements IMemberService {

　　@ApiOperation("获取会员相关信息")
　　@ApiImplicitParam(name="name",value = "用户信息参数",required = true, dataType = "String")

        @RequestMapping("/getMember")
        public UserEntity getMember(@RequestParam("name") String name) {
            UserEntity userEntity=new UserEntity();
            userEntity.setName(name);
            userEntity.setAge("12");
            return userEntity;
        }
    }

3.3、SpringBootApplication
    package com.sc.api;
    AppMember.java
    @SpringBootApplication
    @EnableEurekaClient
    @EnableFeignClients
    @EnableSwagger2Doc



   注:SpringBootApplication 放在最外包层
3.4、application.properties
    server.port=9002
    #server.address=localhost
    spring.application.name=member
    #服务注册地址
    eureka.instance.ip-address=localhost
    eureka.instance.prefer-ip-address=true
    eureka.client.serviceUrl.defaultZone=http://localhost:9001/eureka
    eureka.client.register-with-eureka=true
    eureka.client.fetch-registry=true



 4、-----sccase: 父项目
   springcloud-api-order-service: 子项目
 4.1、pom.xml
     <parent>
         <groupId>com.sc</groupId>
         <artifactId>sccase</artifactId>
         <version>1.0-SNAPSHOT</version>
     </parent>
     <groupId>com.sc</groupId>
     <artifactId>springcloud-api-order-service</artifactId>
     <version>0.0.1-SNAPSHOT</version>
     <name>springcloud-api-order-service</name>
     <description>Demo project for Spring Boot</description>

 4.2、IOrderService
     package com.sc.api.service;
     import org.springframework.web.bind.annotation.RequestMapping;
     public interface IOrderService {
         //订单服务调用会员服务接口信息feign
         @RequestMapping("/orderToMember")
         public  String orderToMember(String name);
     }

 5、-----sccase: 父项目
  springcloud-api-order-impl-service: 子项目
  ##########################################################
  #####9003#############################################################

                         1）、HystrixCommand
  ###########http://localhost:9003/orderToMember?name=hhhh##
  zuul#######http://localhost:9006/order/orderToMember?name=hhhh&token=12311####
            2）、FeignClient(value = "member",fallbac

###########http://localhost:9003/orderToMember2?name=hhhh##

  zuul#######http://localhost:9006/order/orderToMember2?name=hhhh&token=12311####
  ##########################################################
 5.1、pom.xml
     <parent>
         <groupId>com.sc</groupId>
         <artifactId>sccase</artifactId>
         <version>1.0-SNAPSHOT</version>
     </parent>
      <groupId>com.sc</groupId>
      <artifactId>springcloud-api-order-impl-service</artifactId>
      <version>0.0.1-SNAPSHOT</version>
      <name>springcloud-api-order-impl-service</name>
      <description>Demo project for Spring Boot</description>

      <dependencies>
         <dependency>
           <groupId>com.sc</groupId>
           <artifactId>springcloud-api-order-service</artifactId>
            <version>0.0.1-SNAPSHOT</version>
         </dependency>
         <dependency>
                     <groupId>com.sc</groupId>
                     <artifactId>springcloud-api-member-service</artifactId>
                     <version>0.0.1-SNAPSHOT</version>
        </dependency>
      </dependencies>

  5、2、feign
    package com.sc.api.feign;
    import com.sc.api.service.IMemberService;
    import org.springframework.cloud.openfeign.FeignClient;
    import org.springframework.web.bind.annotation.RequestMapping;

    @FeignClient(value = "member",fallback = MemberServiceFallback.class)
    public interface MemberServiceFeign extends IMemberService {

    }

    5、3、OrderServiceImpl

　　@Api("订单服务")

    @RestController
    public class OrderServiceImpl  implements IOrderService {

      @Autowired
      private MemberServiceFeign memberServiceFeign;
      

　　 @HystrixCommand(fallbackMethod = "hiError")
 　　@RequestMapping("/orderToMember")
 　　public String orderToMember(String name) {
     UserEntity userEntity=memberServiceFeign.getMember(name);
     return userEntity==null?"没找到用户信息":userEntity.toString();
　　 }

　　 public String hiError(String name) {
       　　return "hi, "+name+",sorry,error!";
　　 }

　　 /*
     　　　　Hystrix第二种写法
　　 */
        @ApiOperation("订单服务接口")
　　 @RequestMapping("/orderToMember2")
　　public String orderToMember2(String name) {
  　　 　　UserEntity userEntity=memberServiceFeign.getMember(name);
  　　　　return userEntity==null?"没找到用户信息":userEntity.toString();
　　}

    }



    5、4、SpringBootApplication
       package com.sc.api;
       AppMember.java
       @SpringBootApplication
       @EnableEurekaClient
       @EnableFeignClients
       @EnableCircuitBreaker
      @EnableSwagger2Doc




    5.5、application.properties
        server.port=9003
        #server.address=localhost
        spring.application.name=order
        #服务注册地址
        eureka.instance.ip-address=localhost
        eureka.instance.prefer-ip-address=true
        eureka.client.serviceUrl.defaultZone=http://localhost:9001/eureka
        eureka.client.register-with-eureka=true
        eureka.client.fetch-registry=true
        feign.hystrix.enabled=true

5.6、MemberServiceFallback
　　@Component
　　public class MemberServiceFallback implements MemberServiceFeign {

   　　 @Override
    　　public UserEntity getMember(String name) {
        　　return new UserEntity("error","11");
   　　 }
　　}

6、ConfigServer
#############9004################################
#############config server#######################
http://localhost:9004/config-client-dev.properties
http://localhost:9004/config-client/dev
 http://localhost:9004/config-client/dev
http://localhost:9004zuul/dev
#################################################
git:https://github.com/sf2014/sc-config.git
###############config-client-dev.properties#####
https://github.com/sf2014/sc-config/client1/
config-client-dev.properties ###################
#################################################

6-1、pom.xml
  <parent>
     <groupId>com.sc</groupId>
     <artifactId>sccase</artifactId>
     <version>1.0-SNAPSHOT</version>
  </parent>
  <groupId>com.sc</groupId>
  <artifactId>configserver</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <name>configserver</name>
  <description>Demo project for Spring Boot</description>


6-2、application.properties

server.port=9004
spring.application.name=config-server

#eureka服务注册地址
eureka.instance.ip-address=localhost
eureka.instance.prefer-ip-address=true
#eureka.client.serviceUrl.defaultZone=http://localhost:9001/" target="_blank">http://localhost:9001/eureka/,http://localhost:9008/eureka/
eureka.client.serviceUrl.defaultZone=http://localhost:9001/eureka/,http://localhost:9008/eureka/

#连接GitHub
#https://github.com/sf2014/sc-config.git
spring.cloud.config.server.git.uri=https://github.com/sf2014/sc-config.git
spring.cloud.config.server.git.search-paths=client1
spring.cloud.config.label=master
spring.cloud.config.server.git.username=sf2014@qq.com
spring.cloud.config.server.git.password=sf2014git

6-3、CsApplication.java

@EnableConfigServer
@EnableEurekaClient
@SpringBootApplication

 

7、ConfigClient
#############9005##################################
#############config client#########################
http://localhost:9005/foo

###################################################
###################################################
ConfigServer:http://localhost:9004配置变化,需要
actuator/refresh手动刷新同步

i)、 Controller=>@RefreshScope //actuator
ii)、 Post=>http://localhost:9005/actuator/refresh
postman
###################################################
###################################################

7-1、pom.xml
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.1.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.sc</groupId>
    <artifactId>configclient</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>configclient</name>
    <description>Demo project for Spring Boot</description>

    <properties>
    <java.version>1.8</java.version>
    <spring-cloud.version>Hoxton.SR3</spring-cloud.version>
    </properties>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
        <version>2.3.0.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-config</artifactId>
        <version>2.2.2.RELEASE</version>
    </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-eureka-client</artifactId>

        <version>2.2.3.RELEASE</version>
    </dependency>
</dependencies>
<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>${spring-cloud.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>


7-2、bootstrap.properties
server.port=9005
spring.application.name=config-client

####config###########################
spring.cloud.config.profile=dev
spring.cloud.config.label=master
spring.cloud.config.uri=http://localhost:9004

#eureka服务注册地址
eureka.instance.ip-address=localhost
eureka.instance.prefer-ip-address=true
#eureka.client.serviceUrl.defaultZone=http://localhost:9001/" target="_blank">http://localhost:9001/eureka/,http://localhost:9008/eureka/
eureka.client.serviceUrl.defaultZone=http://localhost:9001/" target="_blank">http://localhost:9001/eureka/

#访问端点根路径，默认为/actuator
management.endpoints.web.base-path=/actuator
#需要开启的端点,这里主要用到是refresh这个端点
management.endpoints.web.exposure.include=*
#不需要开启的端点
#management.endpoints.web.exposure.exclude=

7-3、ConfigconsumerApplication
@SpringBootApplication
@RefreshScope //actuator
@RestController
@EnableEurekaClient
public class ConfigconsumerApplication {

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

    @Value("${foo}")
    String foo;

    @RequestMapping(value = "/foo")
    public String hi(){
        return foo;
    }
}

8、ZL Zuul
    ###9006############################################
    #####http://localhost:9006/member/getMember?name=sdfsdfsafa
    #######http://localhost:9006/order/orderToMember2?name=hhhh##
   #######http://127.0.0.1:9006/swagger-ui.html##########swagger
    ###############################################

    8-1、pom.xml
　　<parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.3.1.RELEASE</version>
            <relativePath/> <!-- lookup parent from repository -->
        </parent>
        <groupId>com.sc</groupId>
        <artifactId>zuul</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>zuul</name>
        <description>Demo project for Spring Boot</description>

        <properties>
            <spring-cloud.version>Hoxton.SR3</spring-cloud.version>
            <java.version>1.8</java.version>
        </properties>

        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
                <version>2.3.0.RELEASE</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-config</artifactId>
                <version>2.2.2.RELEASE</version>
            </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-eureka-client</artifactId>
                <version>2.2.3.RELEASE</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-zuul</artifactId>
            </dependency>

　　　<dependency>
     　　<groupId>com.spring4all</groupId>
     　　<artifactId>swagger-spring-boot-starter</artifactId>
     　　<version>1.9.1.RELEASE</version>
 　　</dependency>

        </dependencies>
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>${spring-cloud.version}</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>

        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>


    8-2、application.properties

    server.port=9006
    server.address=localhost
    spring.application.name=zuul

    #服务注册地址
    eureka.instance.ip-address=localhost
    eureka.instance.prefer-ip-address=true
    eureka.client.serviceUrl.defaultZone=http://localhost:9001/eureka/

    #路由配置    #- 临时注解
    #url形式
   #- zuul.routes.baidu.path=/baidu/**
   #-  zuul.routes.baidu.url=http://www.baidu.com

    #注册服务provider####
    #- zuul.routes.member.path=/member/**
   #-  zuul.routes.member.service-id=member

    #注册服务consumer####
    #- zuul.routes.order.service-id=order
    #- zuul.routes.order.path=/order/*


　####config-server###########################
    spring.cloud.config.profile=dev
    spring.cloud.config.label=master
    spring.cloud.config.uri=http://localhost:9004
    #访问端点根路径，默认为/actuator
    management.endpoints.web.base-path=/actuator
    #需要开启的端点,这里主要用到是refresh这个端点
    management.endpoints.web.exposure.include=*
    #不需要开启的端点
    #management.endpoints.web.exposure.exclude=

8-3、AccessFilter
import com.netflix.zuul.ZuulFilter;
import com.netflix.zuul.context.RequestContext;
import com.netflix.zuul.exception.ZuulException;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import javax.servlet.http.HttpServletRequest;

@Component
public class AccessFilter extends ZuulFilter {

    //获取Zuul服务端口号
    @Value("${server.port}")
    private String serverPort;

    @Override
    public String filterType() {
        return "pre";
    }

    /**
     * 判断过滤器是否执行,直接返回true,代表对所有请求过滤
     * 此方法指定过滤范围
     * @return
     */
    @Override
    public int filterOrder() {
        return 0;
    }

    /**
     * 过滤的具体逻辑
     * @return
     */
    @Override
    public boolean shouldFilter() {
        return true;
    }

    @Override
    public Object run() throws ZuulException {
        RequestContext currentContext = RequestContext.getCurrentContext();
        HttpServletRequest request = currentContext.getRequest();
        String token = request.getParameter("token");
        request.setAttribute("serverPort", serverPort);
        if (StringUtils.isEmpty(token)) {
            currentContext.setSendZuulResponse(false);
            currentContext.setResponseBody("token is null");
            currentContext.setResponseStatusCode(401);
            return null;
        }
        System.out.println("网关执行端口号:" + serverPort);
        return null;
    }
}

    8-4、ZuulApplication.java

    @EnableZuulProxy
   @EnableEurekaClient
    @SpringBootApplication
    @EnableSwagger2Doc


 　#######spring.cloud.config.uri=http://localhost:9004
    #######zuul-dev.properties
    @RefreshScope
    @ConfigurationProperties("zuul")
    public ZuulProperties zuulProperties() {
        return new ZuulProperties();
    }

8-5、 DocumentationConfig

// 添加文档来源
@Component
@Primary
class DocumentationConfig implements SwaggerResourcesProvider {
    public List<SwaggerResource> get() {
        List resources = new ArrayList<Object>();
        //app-itmayiedu-order
        resources.add(swaggerResource("member", "/member/v2/api-docs", "2.0")); // 第一个参数可以随便写 第二个参考yml对应
        resources.add(swaggerResource("order", "/order/v2/api-docs", "2.0"));
        return resources;
     }

    private SwaggerResource swaggerResource(String name, String location, String version) {
        SwaggerResource swaggerResource = new SwaggerResource();
        swaggerResource.setName(name);
        swaggerResource.setLocation(location);
        swaggerResource.setSwaggerVersion(version);
        return swaggerResource;
    }
}

9、nginx-zuul
 ###zuul:9006   zuul:9007##############################################
 ###http://localhost/member/getMember?name=sdfsdfsafa&token=12311######
 ###http://localhost/order/orderToMember2?name=hhhh&token=12311########
 ######################################################################
     9-1、nginx.conf
     ##########http://nginx.org/#######################################
     nginx-1.19.1conf
ginx.conf######################################

     upstream backServer{
             server 127.0.0.1:9006 weight=1;

　　　server 127.0.0.1:9007 weight=1;

     }
     server {
         listen       80;
         server_name  localhost;

         #charset koi8-r;

         #access_log  logs/host.access.log  main;

　　location / {
    #root   html;
 　　proxy_pass http://backServer/;
    index  index.html index.htm;
}

  10、其他问题
     10.1、提示如下问题
      1.1、pom.xml以下节点没有添加会提示如下问题
      <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.3.0.RELEASE</version>
            <relativePath/> <!-- lookup parent from repository -->
      </parent>

     问题.......................................
     Caused by: org.springframework.beans.factory.NoSuchBeanDefinitionException: No qualifying bean of type
     No qualifying bean of type 'org.springframework.core.env.Environment

##