JAX-RS 2: пользовательское внедрение @Context ограниченного, небезопасного ресурса

• Каждый  AppSession экземпляр привязан к определенному драгоценному идентификатору пользователя String.
• AppSession реализует  java.lang.AutoCloseable интерфейс. Это позволяет использовать его внутри блоков try-with-resources, а также информировать пользователей API о том, что этот ресурс должен быть закрыт.

Фильтр сервлетов

Я хотел управлять BlockingQueue AppSessionInjectionFactory исключительно внутри  , но столкнулся с проблемами с ограничениями.

А именно, поведение Джерси по умолчанию заключалось в создании нового экземпляра фабрики для каждой инъекции. Я попытался изменить области привязок и изменить общую стратегию привязки на bindFactory(new AppSessionInjectionFactory()).to(AppSession.class) (обратите внимание, как я создаю отдельный экземпляр, а не предоставляю метод bindFactory с литералом класса). В обоих случаях я не мог заставить Spring ввести  AppConfig боб  AppSessionInjectionFactory. Таким образом, я остановился на использовании фильтра сервлетов, который, как я знал, будет создан только один раз. Вот код фильтра, самая интересная часть приложения, на мой взгляд.

import static com.google.common.base.Preconditions.checkNotNull;
import com.example.bdkosher.restapi.AppConfig;
import com.example.bdkosher.AppSession;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import javax.inject.Singleton;
import javax.servlet.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@WebFilter(description = "Enforces that each HTTP Servlet Request is associated with one and only one session.")
@Component
@Singleton
public class AppSessionFilter implements Filter {
    private BlockingQueue<String> sessionUserPool;

    @Autowired
    private AppConfig config;

    @Override
    public void init(FilterConfig ignored) throws ServletException {
        Set<String> userIds = checkNotNull(checkNotNull(config).getUserIds());
        sessionUserPool = new ArrayBlockingQueue<>(userIds.size(), true, userIds);
    }

    @Override
    public void doFilter(ServletRequest req, ServletResponse res, FilterChain chain) throws IOException, ServletException {
        String userId = null;
        try {
            /* This method call will block until a userId is avaialable from the pool. */
            userId = sessionUserPool.take();
            /* The try-with-resources block ensures the session is closed, even if the filter chain leaves it open. */
            try (AppSession session = AppSession.open(userId)) {
                req.setAttribute(AppSession.class.getName(), session); // stash the session in the ServletRequest
                chain.doFilter(req, res);
            }
        } catch (InterruptedException ex) {
            throw new ServletException("Issue obtaining session user from pool.", ex);
        } finally {
            /* Return the userId into the pool so future requests can use it. */
            if (userId != null) {
                sessionUserPool.add(userId);
            }
        }
    }

    @Override
    public void destroy() {
        sessionUserPool.clear();
    }
}

import com.example.bdkosher.AppSession;
import javax.inject.Inject;
import javax.servlet.http.HttpServletRequest;
import org.glassfish.hk2.api.Factory;
import org.springframework.context.annotation.Scope;
import org.springframework.stereotype.Component;

@Component
@Scope("request")
public class AppSessionInjectionFactory implements Factory<AppSession> {
    private final AppSession session;

    @Inject
    public AppSessionInjectionFactory(HttpServletRequest request) {
        Object sessionObj = request.getAttribute(AppSession.class.getName());
        if (sessionObj == null) {
            throw new IllegalStateException("No Session found to inject. Did you configure the AppSessionFilter correctly?");
        }
        this.session = (AppSession) sessionObj;
    }

    @Override
    public AppSession provide() {
       return session;
    }

    @Override
    public void dispose(AppSession session) {
       // intentionally empty
    }
}

import com.example.bdkosher.AppSession;
import javax.ws.rs.*;
import javax.ws.rs.core.Context;
import org.springframework.stereotype.Component;

@Path("/greeting")
@Component
public class HelloWorldResource {

    @GET
    @Produces("text/plain")
    public String greet(@Context AppSession session) {
        return "Hello, " + session.getUserId() + "!";
    }
}