小編給大家分享一下Spring Cloud中Zuul如何實(shí)現(xiàn)API網(wǎng)關(guān)與請(qǐng)求過(guò)濾,希望大家閱讀完這篇文章之后都有所收獲,下面讓我們一起去探討吧!
創(chuàng)新互聯(lián)建站專注為客戶提供全方位的互聯(lián)網(wǎng)綜合服務(wù),包含不限于成都網(wǎng)站建設(shè)、成都網(wǎng)站設(shè)計(jì)、定海網(wǎng)絡(luò)推廣、重慶小程序開(kāi)發(fā)、定海網(wǎng)絡(luò)營(yíng)銷、定海企業(yè)策劃、定海品牌公關(guān)、搜索引擎seo、人物專訪、企業(yè)宣傳片、企業(yè)代運(yùn)營(yíng)等,從售前售中售后,我們都將竭誠(chéng)為您服務(wù),您的肯定,是我們大的嘉獎(jiǎng);創(chuàng)新互聯(lián)建站為所有大學(xué)生創(chuàng)業(yè)者提供定海建站搭建服務(wù),24小時(shí)服務(wù)熱線:028-86922220,官方網(wǎng)址:www.cdcxhl.com簡(jiǎn)介
Zuul是Netflix基于JVM的路由器和服務(wù)器端負(fù)載均衡器。最常用的場(chǎng)景是替換Nginx反向代理后臺(tái)微服務(wù)供前端UI訪問(wèn)。
Zuul使用Ribbon來(lái)定位一個(gè)通過(guò)發(fā)現(xiàn)轉(zhuǎn)發(fā)的實(shí)例,所有請(qǐng)求都以hystrix命令執(zhí)行,所以故障將顯示在Hystrix指標(biāo)中。
注:Zuul不包括發(fā)現(xiàn)客戶端,因此對(duì)于基于服務(wù)ID的路由,需要在類路徑中提供其中一個(gè)路由
Zuul是Spring Cloud提供的api網(wǎng)關(guān)和過(guò)濾組件,它提供如下功能:
認(rèn)證
過(guò)濾
壓力測(cè)試
Canary測(cè)試
動(dòng)態(tài)路由
服務(wù)遷移
負(fù)載均衡
安全
靜態(tài)請(qǐng)求處理
動(dòng)態(tài)流量管理
在本教程中,我們將用zuul,把web端的請(qǐng)求/product轉(zhuǎn)發(fā)到對(duì)應(yīng)的產(chǎn)品服務(wù)上,并且定義一個(gè)pre過(guò)濾器來(lái)驗(yàn)證是否經(jīng)過(guò)了zuul的轉(zhuǎn)發(fā)。
基礎(chǔ)環(huán)境
JDK 1.8
Maven 3.3.9
IntelliJ 2018.1
Git
項(xiàng)目源碼
點(diǎn)擊這里
創(chuàng)建Zuul服務(wù)
在IntelliJ中創(chuàng)建一個(gè)maven項(xiàng)目:
cn.zxuqian
apiGateway
然后在pom.xml中添加如下代碼:
4.0.0 cn.zxuqian apiGateway 1.0-SNAPSHOT org.springframework.boot spring-boot-starter-parent 2.0.1.RELEASE org.springframework.cloud spring-cloud-starter-netflix-zuul org.springframework.cloud spring-cloud-starter-netflix-eureka-client org.springframework.cloud spring-cloud-starter-config org.springframework.boot spring-boot-starter-actuator org.springframework.boot spring-boot-starter-web org.springframework.cloud spring-cloud-dependencies Finchley.M9 pom import 1.8 org.springframework.boot spring-boot-maven-plugin spring-milestones Spring Milestones https://repo.spring.io/libs-milestone false
需要注意的是,Spring官網(wǎng)的教程給的zuul的artifactId為spring-cloud-starter-zuul,這個(gè)是舊版zuul的名字,在我們的Finchley.M9版本中已經(jīng)更名為spring-cloud-starter-netflix-zuul。
添加src/main/resources/bootstrap.yml文件,指定spring.application.name:
spring: application: name: zuul-server
創(chuàng)建cn.zxuqian.Application類:
package cn.zxuqian; import cn.zxuqian.filters.PreFilter; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; import org.springframework.cloud.netflix.zuul.EnableZuulProxy; import org.springframework.context.annotation.Bean; @EnableZuulProxy @EnableDiscoveryClient @SpringBootApplication public class Application { public static void main(String[] args) { SpringApplication.run(Application.class, args); } @Bean public PreFilter preFilter() { return new PreFilter(); } }
這里使用了@EnableZuulProxy來(lái)指定使用zuul的反向代理,把我們的請(qǐng)求轉(zhuǎn)發(fā)到對(duì)應(yīng)的服務(wù)器上。然后啟用了eureka的服務(wù)發(fā)現(xiàn)。Zuul默認(rèn)也會(huì)使用Ribbon做負(fù)載均衡,所以可以通過(guò)eureka發(fā)現(xiàn)已注冊(cè)的服務(wù)。PreFilter是一個(gè)預(yù)過(guò)濾器,用來(lái)在request請(qǐng)求被處理之前進(jìn)行一些操作,它的代碼如下:
package cn.zxuqian.filters; import com.netflix.zuul.ZuulFilter; import com.netflix.zuul.context.RequestContext; import com.netflix.zuul.exception.ZuulException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import javax.servlet.http.HttpServletRequest; public class PreFilter extends ZuulFilter { private static Logger log = LoggerFactory.getLogger(PreFilter.class); @Override public String filterType() { return "pre"; } @Override public int filterOrder() { return 1; } @Override public boolean shouldFilter() { return true; } @Override public Object run() throws ZuulException { RequestContext ctx = RequestContext.getCurrentContext(); HttpServletRequest request = ctx.getRequest(); log.info(String.format("%s 方式請(qǐng)求 %s", request.getMethod(), request.getRequestURL().toString())); return null; } }
filterType - Zuul內(nèi)置的filter類型有四種,pre, route,post,error,分別代表請(qǐng)求處理前,處理時(shí),處理后和出錯(cuò)后。
filterOrder - 指定了該過(guò)濾器執(zhí)行的順序。
shouldFilter - 是否開(kāi)啟此過(guò)濾器。
run - 過(guò)濾器的業(yè)務(wù)邏輯。這里只是簡(jiǎn)單的log了一下reqeust的請(qǐng)求方式和請(qǐng)求的路徑。
接下來(lái),在我們的配置中心的git倉(cāng)庫(kù)中創(chuàng)建zuul-server.yml文件,并添加如下配置:
server: port: 8083 zuul: routes: products: path: /product/** serviceId: product-service
這里配置了zuul的端口為8083,然后映射所有/product/的請(qǐng)求到我們的product-service服務(wù)上。如果不配置serviceId,那么products這個(gè)Key就會(huì)默認(rèn)作為ServiceId,而我們的例子中,ServiceId包括了-,所以在下邊顯示指定了ServiceId。配置完成后提交到git。
更新productService
productService的uri做了一點(diǎn)改動(dòng),使其更符合rest風(fēng)格:
@RequestMapping("/list") public String productList() { log.info("Access to /products endpoint"); return "外套,夾克,毛衣,T恤"; }
這里@RequestMapping匹配的路徑改為了/list,之前是/products。
更新web客戶端
在我們的web客戶端的ProductService中添加一個(gè)新的方法:
public String productListZuul() { return this.restTemplate.getForObject("http://zuul-server/product/list", String.class); }
這次我們直接請(qǐng)求zuul-server服務(wù),然后由它把我們的請(qǐng)求反射代理到product-service服務(wù)。最后在ProductController中添加一個(gè)請(qǐng)求處理方法:
@RequestMapping("/product/list") public String productListZuul() { return productService.productListZuul(); }
用來(lái)處理/product/list請(qǐng)求,然后調(diào)用ProductService類中的方法。
測(cè)試
使用mvn spring-boot:run啟動(dòng)configServer,registry, zuulServer, productService,web這幾個(gè)工程,然后啟動(dòng)第二個(gè)productService,使用SERVER_PORT=8082 spring-boot:run。
訪問(wèn)幾次http://localhost:8080/product/list,然后除了會(huì)在瀏覽器看到返回的結(jié)果,我們還會(huì)在zuulServer的命令行窗口中看到如下字樣:
GET 方式請(qǐng)求 http://xuqians-imac:8083/product/list
然后在兩個(gè)productService的命令行窗口中,我們還會(huì)看到隨機(jī)出現(xiàn)的
Access to /products endpoint
說(shuō)明zuulServer也會(huì)自動(dòng)進(jìn)行負(fù)載均衡。
看完了這篇文章,相信你對(duì)“Spring Cloud中Zuul如何實(shí)現(xiàn)API網(wǎng)關(guān)與請(qǐng)求過(guò)濾”有了一定的了解,如果想了解更多相關(guān)知識(shí),歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道,感謝各位的閱讀!