1、Ribbon客戶端負載均衡 1.1 依賴 1.2 配置信息 # feign預設載入了ribbon負載均衡,預設負載均衡機制是:輪詢 # 負載均衡機制是添加在消費端(客戶端)的,如果改為隨機,指定服務名,指定規則 edocmall-server: ribbon: NFLoadBalancerRul ...
1、Ribbon客戶端負載均衡
1.1 依賴
1.2 配置信息
# feign預設載入了ribbon負載均衡,預設負載均衡機制是:輪詢
# 負載均衡機制是添加在消費端(客戶端)的,如果改為隨機,指定服務名,指定規則
edocmall-server:
ribbon:
NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule
1.3 測試
1.3.0 測試準備
1.3.0.1 複製一個服務端
1.3.0.2 eureka查看服務
1.3.0.3 查詢數據
1.3.1 預設是輪詢
1.3.1.1 第一個服務端
1.3.1.2 第二個服務端
1.3.2 指定為隨機 後
1.3.2.1 第一個服務端
1.3.2.2 第二個服務端
1.3.3 可以自定義 負載均衡規則(省略)
2、Zuul網關
2.1 模塊說明
2.2 主要依賴
<!-- eureka 客戶端依賴 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
<!-- zuul 依賴 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-zuul</artifactId>
</dependency>
2.3 配置信息
# 埠
server:
port: 8100
# 服務名
spring:
application:
name: edocmall-zuul
# eureka 註冊中心的配置
eureka:
client:
service-url:
defaultZone: http://127.0.0.1:8096/eureka
# 關閉自我保護機制,保證不可用的服務及時剔除
server:
enable-self-preservation: false
# zuul 網關配置
zuul:
ignored-services: '*' # 預設情況下,zuul網關服務會自動將eureka上的所有註冊服務名(serviceId)設置為預設路由地址(path),如果只能按照path配置路徑進行路由,必須手動屏蔽預設路由; *:表示所有的服務名不能作為路由地址,也可以指定具體服務名不能作為路由地址
routes:
edocmall-web-kgc: #預設路由的服務名,可以寫真實的服務名也可以自定義
#方式一
# path: /edocmall-web/** # 指定自定義網關的映射路勁首碼,代理的請求,必須是指定的訪問路徑,才可以進入網關,否者無法進行網關映射處理
# url: http://127.0.0.1:8098 # 指定請求服務的真實地址(一定要確保可以進行訪問即地址有效),註意,無法進行集群處理,不利於維護和擴展
#方式二
path: /edocmall-zuul/** #指定自定義網關路徑,配合service使用,實現通過指定服務名進行介面調用
serviceId: edocmall-web # 指定的是eureka註冊中心上,真實服務名,好處:(不需要維護請求地址)只需要指定服務名,自動根據服務名路由到對應的所有集群服務上
edocmall-server-kgc:
path: /edocmall-zuul2/**
serviceId: edocmall-server
2.4 主啟動類上的註解
@EnableEurekaClient
@EnableZuulProxy //開啟網關代理功能
2.5 測試
2.5.1 不屏蔽預設路由
serviceId: edocmall-web
和
path: /edocmall-zuul/**
都可以訪問
2.5.2 屏蔽預設路由 ignored-services: '*'
只有
path: /edocmall-zuul/**
都可以訪問
2.6 自定義網關過濾器
2.6.1 自定義網關過濾器
//Description: 自定義網關過濾器
@Component
public class AuthZuulFilter extends ZuulFilter {
@Override
public String filterType() {
//指定網關過濾器的類型,允許返回值只能是:pre,post,route,error
//pre : 在請求被路由轉發前調用,通常用於許可權校驗,日誌處理等
//post : 在請求被路由轉發後調用,一般都是收集服務調用信息
//route : 在請求被路由轉發是調用(服務被調用前),通常用戶在特定服務調用前增加參數處理
//error: 在請求被路由轉發過程中,出現異常是調用
return "pre";
}
@Override
public int filterOrder() {
//指定網關過濾器的優先順序,允許值是int類型整數,值越小優先順序越高
return 0;
}
@Override
public boolean shouldFilter() {
//指定網關過濾器是否需要執行自定義的業務邏輯處理,如果是false不執行,true執行,執行自定義業務邏輯處理,就是下麵的run方法內的業務邏輯
return true;
}
@Override
public Object run() {
//自定義網關過濾器需要執行的業務邏輯處理
//模擬場景:當請求到達網關,網關接收請求進行請求映射處理,把必須要先校驗許可權,
// 如果許可權校驗失敗,不進行路由轉發,只有許可權校驗成功,才可以路由轉發到真實服務上
//引入知識點:用戶在登錄狀態保持,一般是通過token令牌實現的,當用戶登錄成功,會返回一個token令牌給客戶端保存,
// 如果再次請求,自動攜帶改=該令牌,如果令牌有效,許可權通過,否者登錄校驗失敗,不允許訪問
//為了方便演示,token變為請求參數,方便獲取(正常流程是後端登錄成功後返回給客戶端,且必須要保存在請求頭,方便攜帶),如果請求地址中沒有token參數,就不給訪問,如果有,可以訪問
RequestContext requestContext = RequestContext.getCurrentContext();
HttpServletRequest request = requestContext.getRequest();
//根據請求對象獲取請求參數
String token = request.getParameter("token");
// TOO 必須要校驗token的有效性
//許可權校驗,如果token令牌是有效的,可以進行路由轉發,否者需要重新登陸
if(StringUtils.isBlank(token)){
//token失敗,許可權校驗失敗,必須過濾調當前請求,不能進行路由轉發
requestContext.setSendZuulResponse(false);
//修改返回提示信息
requestContext.setResponseStatusCode(HttpStatus.FORBIDDEN.value());
// requestContext.setResponseBody(HttpStatus.FORBIDDEN.getReasonPhrase());
requestContext.setResponseBody("token令牌校驗失敗,請求非法,被攔截");
//設置響應的內容格式,防止中文亂碼
HttpServletResponse response = requestContext.getResponse();
response.setContentType("text/html;charset=utf-8");
}
//返回RequestContext 對象
return requestContext;
}
}
2.6.2 測試
3、Config配置中心
3.1 模塊介紹
3.2 conf-sever 配置服務端
3.2.1 依賴
<!-- eureka 客戶端依賴 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
<!-- config 配置中心服務端依賴 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-config-server</artifactId>
</dependency>
3.2.2 配置信息 application.yml
# 埠
server:
port: 8101
# 服務名
spring:
application:
name: edocmall-conf-server
# 指定環境,適用於本地環境配置,即:將公共配置中心內部文件作為公共配置文件,提供給客戶端使用
# profiles:
# active: native
# git 倉配置信息
cloud:
config:
server:
git:
uri: https://gitee.com/wangsong_huayu/kh96-conf-server.git
username: username
password: password
# eureka 註冊中心的配置
eureka:
client:
service-url:
defaultZone: http://127.0.0.1:8096/eureka
3.2.3 主啟動類上的註解
@EnableEurekaClient //config服務端註冊到eureka註冊中心
@EnableConfigServer //開啟 congfig 配置中心服務端
3.2.4 本地公共配置 config-native.properties
# 自定義公共配置
kh96.conf.server=kh96-conf-server-native
3.2.5 git 倉 管理的配置信息
3.2.5.1 本地倉
2.3.5.2 遠程倉
3.3 conf-client 配置客戶端
3.3.1 依賴
<!-- eureka 客戶端依賴 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
<!-- config 配置中心 客戶端依賴 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-config</artifactId>
</dependency>
3.3.2 配置信息application.yml
# 埠
server:
port: 8102
# 服務名
spring:
application:
name: edocmall-conf-client
3.3.3 配置信息 bootstrap.properties
# 什麼時候使用此配置文件
# 1、當使用SpringCloud的config配置中心時,在客戶端需要註冊到eureka註冊中心時,eureka配置信息必須增加在此文件中,才會生效
# 2、當配置信息不能被其它的配置文件覆蓋時,可以將內容配置到此文件中,優先順序高於application(雲可以遮住太陽)
# config客戶端,配置eureka註冊中心
eureka.client.service-url.defaultZone=http://127.0.0.1:8096/eureka
# config客戶端,開啟主動發現eureka註冊中心上 註冊的config配置中心服務端,預設是關閉的,必須手動開
spring.cloud.config.discovery.enabled=true
# config客戶端,指定eureka註冊中心上註冊的config配置中心服務端的服務名
spring.cloud.config.discovery.service-id=edocmall-conf-server
# 讀取本地 配置配置文件
# config客戶端,指定從config配置中心服務端讀取 本地 的公共配置文件名,註意:不需要加尾碼,只要文件名
#spring.cloud.config.name=config-native
# 讀取遠程配置文件
# config客戶端,指定從 config配置中服務端讀取的文件名,對應遠程創庫文件名 符號 - ,前面的名稱
spring.cloud.config.name=config
# config客戶端,指定從 config配置中服務端讀取的文件名,對應遠程創庫文件名 符號 - ,後面的名稱
spring.cloud.config.profile=dev
# config客戶端,指定從 config配置中服務端讀取 對應git遠程倉庫中配置所在的分支名,預設是master主線分支,也可以指定其他分支
spring.cloud.config.label=master
3.3.4 請求方法
//測試讀取config配置中心服務端提供的公共配置信息
@RestController
public class ConfigClientController {
@Value("${kh96.conf.server:kh96-conf-client-native}")
private String kh96ConfigServer;
// 客戶端,測試讀取服務端的公共配置信息
@GetMapping("/testConfigServer")
public String testGetPropertiesFromConfServer(){
return kh96ConfigServer;
}
}
3.3.5 主啟動類上的註解
@EnableEurekaClient