Embedded Jetty: как запустить обработчик безопасности, как только поступят http-запросы? - PullRequest
Новая
       51

Embedded Jetty: как запустить обработчик безопасности, как только поступят http-запросы?

0 голосов
/ 04 сентября 2018

Я использую встроенную причал вместе с Джерси Мой вопрос: возможно ли заставить SecurityHandler пристани вступить в силу до того, как HTTP-запрос достигнет класса Джерси?

Вот мой код: (извините, это может быть слишком много.) Класс, в котором инициализирован джет-сервер: 

public class JettyHttpComponent extends AbstractLifeCycleComponent {

    private static final String REST_SOURCE_KEY = "jersey.config.server.provider.classnames";

    //TODO Security config and implementation
    public int start() throws RuntimeException {

        Server jettyServer = new Server(8080);
        ServletContextHandler context = new ServletContextHandler(jettyServer, "/", ServletContextHandler.SESSIONS|ServletContextHandler.SECURITY);
        context.setContextPath("/");
        context.setSecurityHandler(basicAuth());


        ServletHolder jerseyServlet = context.addServlet(
             org.glassfish.jersey.servlet.ServletContainer.class, "/*");
        jerseyServlet.setInitOrder(0);

        //load rest resources
        jerseyServlet.setInitParameter(REST_SOURCE_KEY, IndexService.class.getCanonicalName());


        try {
            jettyServer.start();
            jettyServer.join();
        } catch(Exception e) {
            e.printStackTrace();
        } finally {
            jettyServer.destroy();
        }
        return 0;
    }

    public int stop() throws RuntimeException {
        //close resources
        try {
            close();
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
        System.out.println("Server stopped.");
        return 0;
    }

    private SecurityHandler basicAuth() {
        ConstraintSecurityHandler securityHandler = new ConstraintSecurityHandler();
        LoginService loginService = new LDAPLoginService();
        securityHandler.setLoginService(loginService);  
        return securityHandler;
    }

}

Класс LDAPLoginService в basicAuth() - это мой настроенный класс входа в систему, расширяющий AbstractLoginService.

Класс Джерси, обрабатывающий http-запрос: 

@Path("/index")
public class IndexService extends BaseRestService {

    @PUT
    @Consumes(MediaType.APPLICATION_JSON)
    @Produces(MediaType.APPLICATION_JSON)
    public Response index(@Context SecurityContext securityContext,
            @Context HttpHeaders headers,
            @Context HttpServletRequest httpRequest,
            @QueryParam("algorithm") String algorithm,
            @QueryParam("executionMode") String mode,
            String request) {
        long t1 = System.currentTimeMillis();
        String response = null;
        IndexContext context = null;
        try {
            init();
            //setup context with security, headers, options and request
            ServiceUserContext suc = buildServiceUserContext(securityContext, httpRequest);
            if (suc == null) {
                return Response.status(Status.UNAUTHORIZED).entity(response).build();
            }
            ServiceDataContext sdc = buildServiceDataContext(request);
            context = IndexContext.builder().algorithm(algorithm).serviceDataContext(sdc).
                    serviceUserContext(suc).build();
            //dispatch service to entity matching core services
            dispatch(context);
        } catch(Throwable t) {
            handlerErrors(t, context);
        } finally {
            if (context != null) {
                close(context);
                response = context.getServiceDataContext().getResponse();
                System.out.println("Index takes: " + (System.currentTimeMillis() - t1) + " ms");
            }
        }
        return Response.status(Status.OK).entity(response).build();
    }   
}

В методе buildServiceDataContext() я вызвал securityContext.getUserPrincipal(), и класс LDAPLoginService, расширяющий AbstractLoginService, ничего не делает, пока не будет достигнут securityContext.getUserPrincipal(). Можно ли выполнить проверку безопасности в самом начале, даже до того, как класс Джерси начнет обрабатывать запрос? Благодаря.

1 Ответ

0 голосов
/ 05 сентября 2018

Как предположил @Paul Samsotha, ContainerRequestFilter - хороший выбор.

...