Jersey HK2依赖注入

Question

我正在写一个简单的微服务来公开REST API。所以我开始与泽西合作，当然我需要将我的对象注入球衣资源。基本上我有2个类定义了一组资源，其中一些需要使用另一个服务。

所以基本上我有：

public interface MyService { 

String getServiceName(); 

void doService(); 

}这个接口的

2实施方式（MyServiceBean和MyAlternativeServiceBean）

和，据我理解读球衣文档，我所定义的HK2粘结剂：

public class MyBinder implements Binder{ 

@Override 
public void bind(DynamicConfiguration config) { 

    DescriptorImpl descriptor = BuilderHelper.link(MyServiceBean.class).named("MyServiceBean").to(MyService.class).build(); 
    config.bind(descriptor); 


    config.bind(BuilderHelper.link(MyAlternativeServiceBean.class).named("MyAlternativeServiceBean").to(MyService.class).build()); 

} 

我注册了这个活页夹在ApplicationConfig类

public class ApplicationConfig extends ResourceConfig{ 

public ApplicationConfig(){ 
    property("property.value", "MyAlternativeServiceImplementation"); 
    registerInstances(new MyBinder()); 
} 

}

并适当注释到资源

@Path("first") 
    public class First { 

     @Inject @Named(value = "MyServiceBean") 
     private MyService myService; 
    //... 
    } 

    @Path("second") 
    public class Second { 

     @Inject @Named(value = "MyAlternativeServiceBean") 
     private MyService myService; 
    //... 
    } 

所有作品，直至为MyService实现无参数的构造函数。但在1例中，我需要为MyAlternativeServiceBean提供一个依赖项。

这里是构造

@Inject @Named("property.value") 
    public MyAlternativeServiceBean(String property){ 
     this.property = property; 
    } 

但我得到一个异常：

javax.servlet.ServletException: A MultiException has 5 exceptions. They are:|1. org.glassfish.hk2.api.UnsatisfiedDependencyException: There was no object available for injection at Injectee(requiredType=String,parent=MyAlternativeServiceBean,qualifiers={}),position=0,optional=false,self=false,unqualified=null,2080509613)|2. java.lang.IllegalArgumentException: While attempting to resolve the dependencies of com.hpe.services.MyAlternativeServiceBean errors were found|3. java.lang.IllegalStateException: Unable to perform operation: resolve on com.hpe.services.MyAlternativeServiceBean|4. java.lang.IllegalArgumentException: While attempting to resolve the dependencies of com.hpe.tests.SecondEntryPoint errors were found|5. java.lang.IllegalStateException: Unable to perform operation: resolve on com.hpe.tests.SecondEntryPoint| 
    at org.glassfish.jersey.servlet.WebComponent.service(WebComponent.java:392) 
    at org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:381) 
    at org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:344) 
    at org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:219) 
    at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:684) 
    at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:501) 
    at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:229) 
    at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1086) 
    at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:427) 
    at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:193) 
    at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1020) 
    at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:135) 
    at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:116) 
    at org.eclipse.jetty.server.Server.handle(Server.java:370) 
    at org.eclipse.jetty.server.AbstractHttpConnection.handleRequest(AbstractHttpConnection.java:494) 
    at org.eclipse.jetty.server.AbstractHttpConnection.headerComplete(AbstractHttpConnection.java:973) 
    at org.eclipse.jetty.server.AbstractHttpConnection$RequestHandler.headerComplete(AbstractHttpConnection.java:1035) 
    at org.eclipse.jetty.http.HttpParser.parseNext(HttpParser.java:641) 
    at org.eclipse.jetty.http.HttpParser.parseAvailable(HttpParser.java:231) 
    at org.eclipse.jetty.server.AsyncHttpConnection.handle(AsyncHttpConnection.java:82) 
    at org.eclipse.jetty.io.nio.SelectChannelEndPoint.handle(SelectChannelEndPoint.java:696) 
    at org.eclipse.jetty.io.nio.SelectChannelEndPoint$1.run(SelectChannelEndPoint.java:53) 
    at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:608) 
    at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:543) 
    at java.lang.Thread.run(Thread.java:745) 

基本上我却不知道如何注入性能/常数（即我可以从一个配置文件中读取实例）in hk2

谢谢

Regards

Answer 1

你可以做的是创建一个自定义的注释

@Target({ElementType.FIELD, ElementType.PARAMETER}) 
@Retention(RetentionPolicy.RUNTIME) 
public @interface Config { 
    String value(); 
} 

然后为它创建一个InjectionResolver（允许注射使用自定义的注释）

public static class ConfigInjectionResolver implements InjectionResolver<Config> { 

    private static final Map<String, String> properties = new HashMap<>(); 

    public ConfigInjectionResolver() { 
     properties.put("greeting.message", "Hello World"); 
    } 

    @Override 
    public Object resolve(Injectee injectee, ServiceHandle<?> handle) { 
     if (String.class == injectee.getRequiredType()) { 
      AnnotatedElement elem = injectee.getParent(); 
      if (elem instanceof Constructor) { 
       Constructor ctor = (Constructor) elem; 
       Config config = (Config) ctor.getParameterAnnotations()[injectee.getPosition()][0]; 
       return properties.get(config.value()); 
      } else { 
       Config config = elem.getAnnotation(Config.class); 
       return properties.get(config.value()); 
      } 
     } 
     return null; 
    } 

    @Override 
    public boolean isConstructorParameterIndicator() { return true; } 

    @Override 
    public boolean isMethodParameterIndicator() { return false; } 
} 

本例使用的是Map，但我相信你可以弄清楚如何使它使用Properties。一旦你注册InjectionResolver，现在你可以只是做

public SomeService(@Config("some.property") String property) {} 

下面是一个完整的测试用例

import org.glassfish.hk2.api.Injectee; 
import org.glassfish.hk2.api.InjectionResolver; 
import org.glassfish.hk2.api.ServiceHandle; 
import org.glassfish.hk2.api.TypeLiteral; 
import org.glassfish.hk2.utilities.binding.AbstractBinder; 
import org.glassfish.jersey.filter.LoggingFilter; 
import org.glassfish.jersey.server.ResourceConfig; 
import org.glassfish.jersey.test.JerseyTest; 
import org.junit.Test; 

import javax.inject.Inject; 
import javax.inject.Singleton; 
import javax.ws.rs.GET; 
import javax.ws.rs.Path; 
import javax.ws.rs.core.Response; 
import java.lang.annotation.*; 
import java.lang.reflect.AnnotatedElement; 
import java.lang.reflect.Constructor; 
import java.util.HashMap; 
import java.util.Map; 
import java.util.logging.Logger; 

import static org.junit.Assert.*; 

/** 
* Run like any other JUnit Test. Only one required dependency 
* 
* <dependency> 
* <groupId>org.glassfish.jersey.test-framework.providers</groupId> 
* <artifactId>jersey-test-framework-provider-grizzly2</artifactId> 
* <version>${jersey2.version}</version> 
* </dependency> 
* 
* @author Paul Samsotha 
*/ 
public class ConfigExample extends JerseyTest { 

    @Target({ElementType.FIELD, ElementType.PARAMETER}) 
    @Retention(RetentionPolicy.RUNTIME) 
    public static @interface Config { 
     String value(); 
    } 

    public static class ConfigInjectionResolver implements InjectionResolver<Config> { 

     private static final Map<String, String> properties = new HashMap<>(); 

     public ConfigInjectionResolver() { 
      properties.put("greeting.message", "Hello World"); 
     } 

     @Override 
     public Object resolve(Injectee injectee, ServiceHandle<?> handle) { 
      if (String.class == injectee.getRequiredType()) { 
       AnnotatedElement elem = injectee.getParent(); 
       if (elem instanceof Constructor) { 
        Constructor ctor = (Constructor) elem; 
        Config config = (Config) ctor.getParameterAnnotations()[injectee.getPosition()][0]; 
        return properties.get(config.value()); 
       } else { 
        Config config = elem.getAnnotation(Config.class); 
        return properties.get(config.value()); 
       } 
      } 
      return null; 
     } 

     @Override 
     public boolean isConstructorParameterIndicator() { return true; } 

     @Override 
     public boolean isMethodParameterIndicator() { return false; } 
    } 


    private static interface GreetingService { 
     String getGreeting(); 
    } 

    private static class ConfiguredGreetingService implements GreetingService { 
     private String message; 

     public ConfiguredGreetingService(@Config("greeting.message") String message) { 
      this.message = message; 
     } 

     @Override 
     public String getGreeting() { 
      return this.message; 
     } 
    } 

    @Path("greeting") 
    public static class GreetingResource { 

     @Inject 
     private GreetingService greetingService; 

     @GET 
     public String getConfigProp() { 
      return greetingService.getGreeting(); 
     } 
    } 

    @Override 
    public ResourceConfig configure() { 
     ResourceConfig config = new ResourceConfig(GreetingResource.class); 
     config.register(new LoggingFilter(Logger.getAnonymousLogger(), true)); 
     config.register(new AbstractBinder(){ 
      @Override 
      protected void configure() { 
       bind(ConfiguredGreetingService.class).to(GreetingService.class).in(Singleton.class); 
       bind(ConfigInjectionResolver.class) 
         .to(new TypeLiteral<InjectionResolver<Config>>(){}) 
         .in(Singleton.class); 
      } 
     }); 
     return config; 
    } 

    @Test 
    public void should_get_configured_greeting() { 
     final Response response = target("greeting") 
       .request().get(); 
     assertEquals("Hello World", response.readEntity(String.class)); 
    } 
}