Quarkus中filter過濾器跨域cors問題解決方案

更新時間：2022年02月23日 14:59:47 作者：kl

這篇文章主要為大家介紹了Quarkus中filter過濾器跨域cors問題的解決方案，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪

前言

Quarkus中的web模塊是基于java標準web規(guī)范jax-rs構建的，實現則選用了jboss的resteasy。這部分只是請求路由轉發(fā)部分實現。真正的請求接收則使用了eclipse開源的vert.x框架，底層也是基于netty的一個響應式開發(fā)框架。Quarkus將vert.x和resteasy集成在了一起，所以支持響應式和非響應式應用混合開發(fā)，這也是Quarkus的一大賣點。基于以上的認知，我們來看看在Quarkus中，怎么寫過濾器和解決跨域的問題

resteasy4.4.5開發(fā)文檔：https://docs.jboss.org/resteasy/docs/4.5.5.Final

vert'x開發(fā)文檔：https://vertx.io/docs/vertx-web/java/

web依賴

<dependency>
            <groupId>io.quarkus</groupId>
            <artifactId>quarkus-resteasy-jsonb</artifactId>
</dependency>

過濾器filter開發(fā)

resteasy的filter

/**
 * @author kl : http://kailing.pub
 * @version 1.0
 * @date 2020/7/9 15:34
 */
@Priority(Priorities.USER + 1)
@Provider
public class MyFilter implements ContainerRequestFilter, ContainerResponseFilter {
    private volatile CurrentVertxRequest currentVertxRequest;
    CurrentVertxRequest currentVertxRequest() {
        if (currentVertxRequest == null) {
            currentVertxRequest = CDI.current().select(CurrentVertxRequest.class).get();
        }
        return currentVertxRequest;
    }
    @Override
    public void filter(ContainerRequestContext requestContext) throws IOException {
        RoutingContext httpServerRequest = this.currentVertxRequest().getCurrent();
        String str = httpServerRequest.getBodyAsString();
        JsonObject jsonObject = httpServerRequest.getBodyAsJson();
        RequestImpl request = (RequestImpl) requestContext.getRequest();
        System.out.println("攔截到請求了");
    }
    @Override
    public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext) throws IOException {
        System.out.println("攔截到響應了");
    }
}

實現ContainerRequestFilter、ContainerResponseFilter接口，可以分別攔截請求和響應。最后使用@Provider注解標記，@Priority注解用于表明優(yōu)先級，值越大，優(yōu)先級越高。前面已經說過，Quarkus雖然使用了resteasy，但是請求是使用vert'x來接收的，所以在攔截器實現里，可以通過上下文信息拿到vert'x的路由信息RoutingContext

vertx的filter

/**
 * @author kl : http://kailing.pub
 * @version 1.0
 * @date 2020/7/9 18:15
 */
@ApplicationScoped
public class MyFilter {
    public void initfilter(@Observes Filters filters) {
        filters.register(routingContext -> {
            HttpServerRequest httpServerRequest = routingContext.request();
            ForkJoinPool.commonPool().submit(()->{
                System.out.println("進入vertx攔截器,下面是header參數：");
            });
            httpServerRequest.headers().forEach(stringStringEntry -> {
                System.out.println("key:"+stringStringEntry.getKey() +",value:"+stringStringEntry.getValue());
            });
            routingContext.next();//這一句不能漏掉，讓攔截器繼續(xù)往下走的邏輯
        }, 100);
    }
}

Quarkus中的跨域

1、Quarkus中解決跨域問題，可以從兩個層面來分析，一個是resteasy的角度。resteasy中內置了CorsFilter過濾器，我們只需要激活它即可解決跨域問題。如：

/**
 * @author kl : http://kailing.pub
 * @version 1.0
 * @date 2020/7/9 16:46
 */
@Provider
public class CorsFilter extends org.jboss.resteasy.plugins.interceptors.CorsFilter {
    public CorsFilter() {
        super.setAllowedMethods("OPTIONS, GET, POST, DELETE, PUT, PATCH");
        super.setAllowedHeaders("*");
        super.getAllowedOrigins().add("*");
    }
}

2、Quarkus本身也做了跨域的解決方案，是基于vert't的角度來實現的，代碼見io.quarkus.vertx.http.runtime.cors.CORSFilter。從vertx的handler就攔截到了請求并做了跨域處理，但是跨域功能默認不是開啟的，我們可以基于以下的配置來激活它，并進行相關的設置：

quarkus.http.cors=true
quarkus.http.cors.origins=*
quarkus.http.cors.headers=accept, authorization, content-type, x-requested-with
quarkus.http.cors.methods=GET, OPTIONS

以上就是Quarkus中filter過濾器跨域cors問題解決方案的詳細內容，更多關于Quarkus中filter過濾器跨域cors的資料請關注腳本之家其它相關文章！

您可能感興趣的文章: