Метод Jetty 9.3.5 ProxyServlet RewriteTarget и! AsyncSupported

Я использую Jetty версии 9.3.5 для создания ProxyServlet.

Для этого я расширяю свой класс с

org.eclipse.jetty.proxy.ProxyServlet;

В отличие от предыдущей версии, у меня нет возможности переопределить метод RewriteURI, защищенный URI (запрос HttpServletRequest). Прочитав grepcode, я увидел что-то вроде следующего и использовал его:

@Override
protected String rewriteTarget(HttpServletRequest request) {
    if (!validateDestination(request.getServerName(), request.getServerPort()))
        return null;

    String roleAlias = (String)request.getSession().getAttribute(ATTR_PROXY_ROLE_ALIAS);        

    String uri =request.getRequestURI();
    String aliasedURI = getAliasedURI(request.getMethod(), uri, roleAlias);

    return aliasedURI ;
}

Я не знаю, правильный ли это метод переопределения.

В web.xml у меня есть несколько фильтров и определен этот сервлет. Для сервлета я определил так:

<servlet>
    <servlet-name>Proxy</servlet-name>
    <servlet-class>com.company.MyProxyServlet</servlet-class>
    <async-supported>true</async-supported>
</servlet>

<servlet-mapping>
    <servlet-name>Proxy</servlet-name>
    <url-pattern>/proxy/*</url-pattern>
</servlet-mapping>

Но получается следующее исключение? Любая идея? Нужно ли мне делать то же самое с фильтрами? тогда как? или чего еще не хватает?

java.lang.IllegalStateException: !asyncSupported
            at org.eclipse.jetty.server.Request.startAsync(Request.java:2224)
            at org.eclipse.jetty.proxy.ProxyServlet.service(ProxyServlet.java:80)
            at javax.servlet.http.HttpServlet.service(HttpServlet.java:790)
            at com.company.MyProxyServlet.service(MyProxyServlet.java:66)
            at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:821)
            at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1685)
            at com.netiq.sentinel.elasticsearch.proxy.AuditFilter.doFilter(AuditFilter.java:104)
            at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1668)
            at com.netiq.sentinel.elasticsearch.proxy.SecurityFilter.doFilter(SecurityFilter.java:160)
            at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1668)
            at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:581)
            at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:143)
            at org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:548)
            at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:226)
            at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1158)
            at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:511)
            at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:185)
            at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1090)
            at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)
            at org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:213)
            at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:109)
            at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:119)
            at org.eclipse.jetty.server.Server.handle(Server.java:517)
            at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:306)
            at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:242)
            at org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:261)
            at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:95)
            at org.eclipse.jetty.io.ssl.SslConnection.onFillable(SslConnection.java:192)
            at org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:261)
            at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:95)
            at org.eclipse.jetty.io.SelectChannelEndPoint$2.run(SelectChannelEndPoint.java:75)
            at org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.produceAndRun(ExecuteProduceConsume.java:213)
            at org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.run(ExecuteProduceConsume.java:147)
            at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:654)
            at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:572)

Любая помощь?

Примечание. - Я нашел несколько других сообщений, связанных с этой ошибкой, но нигде не используется метод rewriteTarget. Везде используется rewriteURI и в Jetty 9.3.5 не нахожу.

Пожалуйста помоги.


jetty embedded-jetty jetty-9
person Tapas Adhikary    schedule 04.12.2015    source источник

Ответы (2)


arrow_upward
1
arrow_downward

Я нашел решение.

Нам также нужно добавить <async-supported>true</async-supported> для всех фильтров.

person Tapas Adhikary    schedule 04.01.2016
comment
Спасибо, что сделал это для меня ‹filter› ... ‹async-supported› правда ‹/async-supported› ‹/filter› - person Klajd Deda; 10.06.2017

arrow_upward
0
arrow_downward

Для встроенного причала в версии 9.3.7 вот как вы можете зарегистрировать AsyncProxyServlet:

    ServletHandler proxyHandler = new ServletHandler();
    AsyncProxyServlet servlet = ...your instance of a proxy...;
    ServletHolder proxyServletHolder = new ServletHolder(servlet);
    proxyServletHolder.setAsyncSupported(true);
    proxyServletHolder.setInitParameter("maxThreads", "100");
    proxyHandler.addServletWithMapping(proxyServletHolder, "/*");

Этот обработчик можно добавить в HandlerList и т. Д.

person Daniel Flower    schedule 13.02.2016