在第十四章我們已經完成了通用業務類的編寫，因此本章我們將講解如何完整的實現我們的許可權架構的消費者的實現，首先開啟我們的rbac-consumer工程，接著開啟我們的主入口檔案RbacConsumerApplication.java加入@EnableDiscoveryClient和@EnableFeignClients註解如下所示：

package com.consumer;

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
@EnableFeignClients
@EnableDiscoveryClient
public class RbacConsumerApplication {

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

      接著在我們的resource底下建立application-prod-7100.properties配置檔案，檔案內容如下：

spring.application.name=rbac-consumer
server.port=7100

# 鏈路資料收集併發送地址
spring.zipkin.base-url=http://127.0.0.1:9100
# 當前應用收集資訊百分比
spring.sleuth.sampler.percentage=0.1

# 實現日誌的輸出
logging.level.com.consumer.routeconsumer.service.RouteService = DEBUG

eureka.client.serviceUrl.defaultZone=http://fjhyll:
 
[email protected]:2100/eureka/

# 開啟GZIP的壓縮功能以減少HTTP通訊的消耗。
feign.compression.request.enabled=true;
feign.compression.response.enabled=true;
# 以下的請求的型別且請求資料的大小超過2048的將為會壓縮傳輸。
feign.compression.request.mime-types=text/xml,application/xml,application/json
feign.compression.request.min-request-size=2048

# 設定全域性的超時時間
ribbon.ReadTimeout = 1000

# 該引數用來開啟重試機制，它預設是關閉的。
spring.cloud.loadbalancer.retry.enabled=true
# 請求連線的超時時間。
RBAC-PRODUCE.ribbon.ConnectTimeout=250
# 請求處理的超時時間，該超時時間的影響層級大於全域性的超時時間,設定了該時間那麼，如果呼叫生產端的時候超過1秒那麼就直接呼叫重試規則，因此若重試次數和切換次數都是為1那麼，響應的時間不超過4秒
RBAC-PRODUCE.ribbon.ReadTimeout=1000
# 對所有操作請求都進行重試。
RBAC-PRODUCE.ribbon.OkToRetryOnAllOperations=true
# 以下重試實現響應EUREKA-PRODUCER的最大次數是 ：（1 + MaxAutoRetries）* （1 + MaxAutoRetriesNextServer）
# 假設 MaxAutoRetries = 2 ，MaxAutoRetriesNextServer = 4 ，那麼最大的重試次數為15次
# 切換例項的重試次數。
RBAC-PRODUCE.ribbon.MaxAutoRetriesNextServer=1
# 對當前例項的重試次數。
RBAC-PRODUCE.ribbon.MaxAutoRetries=1

feign.hystrix.enabled=true

# 這裡需要注意一點， Ribbon的超時與Hystrix的超時是兩個概念。 為了讓上述的重試機制實現有效，我們需要讓Hystrix的超時時間大於Ribbon的超時時間， 否則Hystrix命令超時後，該命令直接熔斷， 重試機制就 沒有任何意義了。
# Hystrix的全域性的超時時間。
hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=5000

 

       接著在com/consumer/sys/service目錄底下建立一個DictService.java實現類內容如下：

package com.consumer.sys.service;

import com.base.entity.Dict;
import com.base.entity.QueryDict;
import com.consumer.common.base.service.GenericService;
import com.consumer.common.config.FullLogConfiguration;
import org.springframework.cloud.netflix.feign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;

import java.util.Map;

/**
 * Created by Administrator on 2018/1/30 0030.
 */
@FeignClient(value="RBAC-PRODUCE",configuration = FullLogConfiguration.class,path = "/dict")
public interface DictService extends GenericService<Dict,QueryDict> {

    /**
     * 功能描述：將字典資料初始化到前端js中
     * @return
     */
    @RequestMapping(value = "/loadDict",method = RequestMethod.POST)
    Map<String,Object> loadDict();



}

      最後在我們的com/produce/sys/controller底下建立我們的DictController.java實現類內容如下：

package com.consumer.sys.controller;

import com.base.entity.Dict;
import com.base.entity.QueryDict;
import com.consumer.common.base.controller.GenericController;
import com.consumer.common.base.service.GenericService;
import com.consumer.sys.service.DictService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

import java.util.Map;

/*
* 類描述：
* @auther linzf
* @create 2018/1/30 0030 
*/
@RestController
@RequestMapping("/dict")
public class DictController  extends GenericController<Dict,QueryDict> {

    @Autowired
    private DictService dictService;

    @Override
    protected GenericService<Dict, QueryDict> getService() {
        return dictService;
    }

    /**
     * 功能描述：將字典資料初始化到前端js中
     * @return
     */
    @RequestMapping(value = "/loadDict",method = RequestMethod.POST)
    public Map<String,Object> loadDict(){
        return dictService.loadDict();
    }
}

      為了方便我們測試，我們需要給我們的許可權架構消費者整合swagger2介面調測工具，因此在我們的config包底下新建一個swagger包同時建立我們的SwaggerConfig.java配置檔案，配置內容如下：

package com.consumer.common.config.swagger;

import com.google.common.base.Predicate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.web.BasicErrorController;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.env.Environment;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import springfox.documentation.RequestHandler;
import springfox.documentation.builders.ApiInfoBuilder;
import springfox.documentation.service.ApiInfo;
import springfox.documentation.spi.DocumentationType;
import springfox.documentation.spring.web.plugins.Docket;
import springfox.documentation.swagger2.annotations.EnableSwagger2;


/*
* 類描述：整合swagger框架
* @auther linzf
* @create 2017/8/9 0009 
*/
@Configuration
@EnableSwagger2
public class SwaggerConfig {

    @Autowired
    private Environment env;


    @Bean
    public Docket createRestApi() {
        Predicate<RequestHandler> predicate = new Predicate<RequestHandler>() {
            @Override
            public boolean apply(RequestHandler input) {
                // 除非是在開發環境中否則不開啟swagger2
                String active = env.getProperty("spring.profiles.active");
                if(!active.equalsIgnoreCase("prod-7100")){
                    return false;
                }
                Class<?> declaringClass = input.declaringClass();
                if (declaringClass == BasicErrorController.class)// 排除
                    return false;
                if(declaringClass.isAnnotationPresent(RestController.class)) // 被註解的類
                    return true;
                if(input.isAnnotatedWith(ResponseBody.class)) // 被註解的方法
                    return true;
                return false;
            }
        };
        return new Docket(DocumentationType.SWAGGER_2)
                .apiInfo(apiInfo())
                .useDefaultResponseMessages(false)
                .select()
                .apis(predicate)
                .build();
    }

    private ApiInfo apiInfo() {
        return new ApiInfoBuilder()
                .title("swagger2 介面測試專用頁面！")//大標題
                .version("1.0")//版本
                .build();
    }

}

      到此我們完成了資料字典的配置工作，其他的使用者管理、組織架構、角色管理和選單管理也完全如上就不在此處累述了，大家直接看本章釋出在GitHub上的原始碼即可。

      接著我們啟動我們的註冊中心、鏈路中心、許可權架構生產者、許可權架構消費者,接著開啟我們的eureka註冊中心大家可以看到如下的頁面則說明我們的所有中心已經全部正常啟動成功了：

      接著直接訪問我們的swagger工程地址：http://127.0.0.1:7100/swagger-ui.html#/，那麼我們會看到如下的頁面則表示我們的許可權架構消費者已經整合成功了。

QQ交流群：578746866