包含数据库信息的自定义筛选器删除向导

Question

我正在使用dropwizard 0.7.0，我想创建一个自定义过滤器。

自定义筛选器应检查数据库中是否存在令牌。创建筛选器并在应用程序类中注册此筛选器的正确方法是什么？

我用这个问题来实现过滤器，这是有效的，但当我将代码更改为：

final AuthenticationDAO authenticationDAO = new AuthenticationDAO(hibernateBundle.getSessionFactory());
environment.servlets().addFilter("authenticationFilter", new AuthenticationFilter(authenticationDAO)).addMappingForUrlPatterns(EnumSet.allOf(DispatcherType.class), false, "/transaction/*");

这是我的过滤器：

public class AuthenticationFilter implements Filter {

    private final AuthenticationDAO authenticationDAO;

    public AuthenticationFilter(AuthenticationDAO authenticationDAO) {
        this.authenticationDAO = authenticationDAO;
    }

    @Override
    public void init(FilterConfig filterConfig) throws ServletException {
    }

    @Override
    public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
        String authenticationToken = ((Request) servletRequest).getHeader(Constants.HEADER_TOKEN_PARAM_NAME);

        HttpServletResponse response = (HttpServletResponse)servletResponse;

        if(Strings.isNullOrEmpty(authenticationToken)){
            response.setStatus(HttpServletResponse.SC_UNAUTHORIZED);
        } else if(!authenticationDAO.findByAuthenticationToken(authenticationToken).isPresent()){
            response.setStatus(HttpServletResponse.SC_FORBIDDEN);
        } else {
            filterChain.doFilter(servletRequest, servletResponse);
        }
    }

    @Override
    public void destroy() {
    }
}

当访问过滤器时，我得到以下错误，因为没有活动会话：

警告 [2014-04-22 14：37：42，733] 组织日食.码头.servlet.伺服员处理程序： /测试/显示 ！Hibernate异常：当前没有会话绑定到执行上下文！在 org.Hibernate.上下文.内部.托管会话.当前会话（托管会话上下文.java：75） ~[Hibernate-核心-4.3.1.最终.jar：4.3.1.最终] ！在组织.Hibernate.内部.会话工厂简化.getCurrentSession（会话工厂简化.java：1013） ~[Hibernate核心-4.3.1.最终.jar：4.3.1.最终]

Answer 1

也许你可以试试:

import com.google.common.base.Strings;
import com.sun.jersey.spi.container.ContainerRequest;
import com.sun.jersey.spi.container.ContainerRequestFilter;

import javax.ws.rs.WebApplicationException;
import javax.ws.rs.core.Response;

public class AuthenticationFilter implements ContainerRequestFilter {
    private final AuthenticationDAO authenticationDAO;

    public AuthenticationFilter(AuthenticationDAO authenticationDAO) {
        this.authenticationDAO = authenticationDAO;
    }

    @Override
    public ContainerRequest filter(final ContainerRequest containerRequest) {
        String authenticationToken = containerRequest.getHeaderValue(Constants.HEADER_TOKEN_PARAM_NAME);

        if (Strings.isNullOrEmpty(authenticationToken)) {
            throw new WebApplicationException(Response.status(Response.Status.UNAUTHORIZED).build());
        } else if (!authenticationDAO.findByAuthenticationToken(authenticationToken).isPresent()) {
            throw new WebApplicationException(Response.status(Response.Status.FORBIDDEN).build());
        }
        return containerRequest;
    }
}

在run-method中，您可以添加：

environment.jersey().getResourceConfig().getContainerRequestFilters().add(new AuthenticationFilter(...));

此拉取请求 https://github.com/dropwizard/dropwizard/pull/541，可能会满足您的需求。

Answer 2

我自己也遇到了这个问题，我想我的问题是在Dropwizard线程中讨论的：https://groups.google.com/forum/#！msg/dropwizard-user/LE6FYIpSDQ0/X5smCEZWltcJ

简而言之，您可能需要打开并绑定自己的会话——我的由Dropwizard管理的类可以很好地使用会话，但是不由dropwizard管理的类会遇到这个错误。

我正在尝试在打开和绑定我自己的会话之间做出决定，并将类移动到由Dropwizard管理的类，以便我可以使用@UnitOfWork注释。

此外，如果您不在@UnitOfWork中（这似乎只对rest调用有效），那么您可以使用会话，但不能使用DAO层。如果使用DAO，则会出现错误。可能还有更多，但出于我的目的，我只使用了一个SQLQuery：

        SQLQuery deleteQuery = session.createSQLQuery("DELETE FROM MYTABLE WHERE REPORTTIME < ?");
        deleteQuery.setTimestamp(0, cutoffDate.toDate());
        deleteQuery.executeUpdate();

这是否是最好的解决方案是有争议的，但对我来说，这已经足够了。

Answer 3

要在代码的非托管部分启用 DropWizard“魔术”（Hibernate），您必须注入会话工厂。您可以看到如何在“拖放向导”配置中创建一个：

https://dropwizard.github.io/dropwizard/manual/hibernate.html

然后，您可以将该sessionFacotry注入到构造函数中的AuthenticationFilter中。

在过滤器中，您必须手动绑定hibernate会话，如下所示:

@Override
public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
    String authenticationToken = ((Request) servletRequest).getHeader(Constants.HEADER_TOKEN_PARAM_NAME);

        Session session = sessionFactory.openSession();
        session.setDefaultReadOnly(true);
        session.setCacheMode(CacheMode.NORMAL);
        session.setFlushMode(FlushMode.MANUAL);
        ManagedSessionContext.bind(session);
        // DropWizard magic enabled from this point.

    HttpServletResponse response = (HttpServletResponse)servletResponse;

    if(Strings.isNullOrEmpty(authenticationToken)){
        response.setStatus(HttpServletResponse.SC_UNAUTHORIZED);
    } else if(!authenticationDAO.findByAuthenticationToken(authenticationToken).isPresent()){
        response.setStatus(HttpServletResponse.SC_FORBIDDEN);
    } else {
        filterChain.doFilter(servletRequest, servletResponse);
    }

        session.close();
        // DropWizard magic disabled from this point.


}

这是本质。bind()和close()之间发生的任何事情都会启用DropWizard魔法——在托管Dao中也是如此。您可以通过错误处理等使其更加健壮来改进它。

即使您遇到了示例中的托管资源，这也会起作用。发生的情况是DropWizards RequestDispatcher激活并执行与您相同的操作：它打开一个会话并将其绑定到线程。其结果是，托管资源使用的会话与手动打开的会话不同，并且原始绑定的会话将在不进行清理的情况下删除。在您的示例中，这样做的效果是，在调用doFilter（…）之后，魔术结束了。如果希望以后访问数据库，则必须重新绑定之前创建的会话。只需致电：

        ManagedSessionContext.bind(session);

我没有遇到过任何关于这项技术的问题，但我可以想象的一个问题是，如果你需要访问在另一个会话中进行的一个会话中的数据。这可能需要对隔离级别进行一些调整。