vvo*_*dra 5 java hibernate jersey guice jersey-2.0
我有一个用Java编写的运行Jersey应用程序,使用Hibernate作为JPA实现,并使用Guice将所有服务绑定在一起.
我的用例在于有一个应用程序实例提供多个本地化,可在不同的主机下使用.简单的例子是英文版和法文版application.com和application.fr.根据触发的主机,我需要切换应用程序以使用其他数据库.
目前,我只有一个单独SessionFactory配置,由所有数据访问对象使用,只提供对一个数据库的访问.
我正在尝试提出最简单的方法来传递有关国家/地区上下文的信息,从资源(我可以从请求上下文中获取)到DAO,DAO需要选择多个中SessionFactory的一个.
我可以在每个服务方法中传递一个参数,但这看起来非常繁琐.我想过使用一个注册表,它有一个ThreadLocal泽西过滤器设置的当前国家参数的实例,但线程本地使用Executors等会中断.
有没有优雅的方法来实现这一目标？
我不是 Guice 用户，所以这个答案使用 Jersey 的 DI 框架HK2。在基本配置层面，HK2与Guice配置没有太大区别。例如，对于 Guice，您有AbstractModule，而 HK2 则有AbstractBinder。对于这两个组件，您将使用类似的bind(..).to(..).in(Scope)语法。一个区别是 Guice 是bind(Contract).to(Impl)，而 HK2 是bind(Impl).to(Contract)。
HK2 还具有Factorys，允许更复杂地创建可注射对象。对于您的工厂，您将使用语法bindFactory(YourFactory.class).to(YourContract.class).
话虽如此，您可以使用如下所示的内容来实现您的用例。
Factory为英语创建一个SessionFactory
public class EnglishSessionFactoryFactory implements Factory<SessionFactory> {
@Override
public SessionFactory provide() {
...
}
@Override
public void dispose(SessionFactory t) {}
}
Factory为法国人创造一个SessionFactory
public class FrenchSessionFactoryFactory implements Factory<SessionFactory> {
@Override
public SessionFactory provide() {
...
}
@Override
public void dispose(SessionFactory t) {}
}
请注意，上面的两个SessionFactory将在单例范围内并按名称绑定。
创建另一个Factory位于请求范围内的内容，该内容将使用请求上下文信息。该工厂将按名称（使用名称绑定）注入上述两个SessionFactory，并从任何请求上下文信息中返回适当的SessionFactory. 下面的示例仅使用查询参数
public class SessionFactoryFactory
extends AbstractContainerRequestValueFactory<SessionFactory> {
@Inject
@Named("EnglishSessionFactory")
private SessionFactory englishSessionFactory;
@Inject
@Named("FrenchSessionFactory")
private SessionFactory frenchSessionFactory;
@Override
public SessionFactory provide() {
ContainerRequest request = getContainerRequest();
String lang = request.getUriInfo().getQueryParameters().getFirst("lang");
if (lang != null && "fr".equals(lang)) {
return frenchSessionFactory;
}
return englishSessionFactory;
}
}
然后你可以将SessionFactory（我们将给它一个不同的名称）注入到你的 dao 中。
public class IDaoImpl implements IDao {
private final SessionFactory sessionFactory;
@Inject
public IDaoImpl(@Named("SessionFactory") SessionFactory sessionFactory) {
this.sessionFactory = sessionFactory;
}
}
要将所有内容绑定在一起，您将使用AbstractBinder类似于以下的实现
public class PersistenceBinder extends AbstractBinder {
@Override
protected void configure() {
bindFactory(EnglishSessionFactoryFactory.class).to(SessionFactory.class)
.named("EnglishSessionFactory").in(Singleton.class);
bindFactory(FrenchSessionFactoryFactory.class).to(SessionFactory.class)
.named("FrenchSessionFactory").in(Singleton.class);
bindFactory(SessionFactoryFactory.class)
.proxy(true)
.proxyForSameScope(false)
.to(SessionFactory.class)
.named("SessionFactory")
.in(RequestScoped.class);
bind(IDaoImpl.class).to(IDao.class).in(Singleton.class);
}
}
以下是关于活页夹的一些注意事项
SessionFactory是通过名称绑定的。它用于@Named注入，如步骤 3 中所示。您会注意到proxy(true).proxyForSameScope(false). 这是必需的，因为我们假设IDao将是一个单例，并且由于我们在请求范围内“选择” SessionFactory，所以我们无法注入实际的SessionFactory，因为它会随着请求的不同而改变，所以我们需要注入一个代理人。如果IDao请求范围是请求范围，而不是单例，那么我们可以省略这两行。将 dao 请求设置为作用域可能会更好，但我只是想展示它应该如何作为单例来完成。
另请参阅使用 HK2 和 Jersey 将请求范围对象注入单例范围对象，以获取有关此主题的更多检查。
然后你只需要在AbstractBinderJersey 注册即可。为此，您可以register(...)使用ResourceConfig. 如果您需要 web.xml 配置，另请参阅。
就是这样。下面是使用Jersey Test Framework 的完整测试。您可以像任何其他 JUnit 测试一样运行它。使用SessionFactory的只是一个虚拟类，而不是实际的 Hibernate SessionFactory。这只是为了使示例尽可能简短，只是将其替换为常规的 Hibernate 初始化代码。
import java.util.logging.Logger;
import javax.inject.Inject;
import javax.inject.Named;
import javax.inject.Singleton;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.core.Response;
import javax.ws.rs.ext.ExceptionMapper;
import org.glassfish.hk2.api.Factory;
import org.glassfish.hk2.utilities.binding.AbstractBinder;
import org.glassfish.jersey.filter.LoggingFilter;
import org.glassfish.jersey.process.internal.RequestScoped;
import org.glassfish.jersey.server.ContainerRequest;
import org.glassfish.jersey.server.ResourceConfig;
import org.glassfish.jersey.server.internal.inject.AbstractContainerRequestValueFactory;
import org.glassfish.jersey.test.JerseyTest;
import org.junit.Test;
import static junit.framework.Assert.assertEquals;
/**
* Stack Overflow /sf/ask/2463249491/
*
* Run this like any other JUnit test. There is only one required dependency
*
* <dependency>
* <groupId>org.glassfish.jersey.test-framework.providers</groupId>
* <artifactId>jersey-test-framework-provider-inmemory</artifactId>
* <version>${jersey2.version}</version>
* <scope>test</scope>
* </dependency>
*
* @author Paul Samsotha
*/
public class SessionFactoryContextTest extends JerseyTest {
public static interface SessionFactory {
Session openSession();
}
public static class Session {
private final String language;
public Session(String language) {
this.language = language;
}
public String get() {
return this.language;
}
}
public static class EnglishSessionFactoryFactory implements Factory<SessionFactory> {
@Override
public SessionFactory provide() {
return new SessionFactory() {
@Override
public Session openSession() {
return new Session("English");
}
};
}
@Override
public void dispose(SessionFactory t) {}
}
public static class FrenchSessionFactoryFactory implements Factory<SessionFactory> {
@Override
public SessionFactory provide() {
return new SessionFactory() {
@Override
public Session openSession() {
return new Session("French");
}
};
}
@Override
public void dispose(SessionFactory t) {}
}
public static class SessionFactoryFactory
extends AbstractContainerRequestValueFactory<SessionFactory> {
@Inject
@Named("EnglishSessionFactory")
private SessionFactory englishSessionFactory;
@Inject
@Named("FrenchSessionFactory")
private SessionFactory frenchSessionFactory;
@Override
public SessionFactory provide() {
ContainerRequest request = getContainerRequest();
String lang = request.getUriInfo().getQueryParameters().getFirst("lang");
if (lang != null && "fr".equals(lang)) {
return frenchSessionFactory;
}
return englishSessionFactory;
}
}
public static interface IDao {
public String get();
}
public static class IDaoImpl implements IDao {
private final SessionFactory sessionFactory;
@Inject
public IDaoImpl(@Named("SessionFactory") SessionFactory sessionFactory) {
this.sessionFactory = sessionFactory;
}
@Override
public String get() {
return sessionFactory.openSession().get();
}
}
public static class PersistenceBinder extends AbstractBinder {
@Override
protected void configure() {
bindFactory(EnglishSessionFactoryFactory.class).to(SessionFactory.class)
.named("EnglishSessionFactory").in(Singleton.class);
bindFactory(FrenchSessionFactoryFactory.class).to(SessionFactory.class)
.named("FrenchSessionFactory").in(Singleton.class);
bindFactory(SessionFactoryFactory.class)
.proxy(true)
.proxyForSameScope(false)
.to(SessionFactory.class)
.named("SessionFactory")
.in(RequestScoped.class);
bind(IDaoImpl.class).to(IDao.class).in(Singleton.class);
}
}
@Path("test")
public static class TestResource {
private final IDao dao;
@Inject
public TestResource(IDao dao) {
this.dao = dao;
}
@GET
public String get() {
return dao.get();
}
}
private static class Mapper implements ExceptionMapper<Throwable> {
@Override
public Response toResponse(Throwable ex) {
ex.printStackTrace(System.err);
return Response.serverError().build();
}
}
@Override
public ResourceConfig configure() {
return new ResourceConfig(TestResource.class)
.register(new PersistenceBinder())
.register(new Mapper())
.register(new LoggingFilter(Logger.getAnonymousLogger(), true));
}
@Test
public void shouldReturnEnglish() {
final Response response = target("test").queryParam("lang", "en").request().get();
assertEquals(200, response.getStatus());
assertEquals("English", response.readEntity(String.class));
}
@Test
public void shouldReturnFrench() {
final Response response = target("test").queryParam("lang", "fr").request().get();
assertEquals(200, response.getStatus());
assertEquals("French", response.readEntity(String.class));
}
}
您可能还需要考虑的另一件事是 s 的结束SessionFactory。尽管Factory有一个dispose()方法，但 Jersey 不能可靠地调用它。您可能想研究一下ApplicationEventListener. 您可以将SessionFactorys 注入其中，并在 close 事件中关闭它们。