Невозможно внедрить Java-объект при написании метода-перехватчика на основе аннотаций с использованием инфраструктуры Guice - PullRequest
Новая
       24

Невозможно внедрить Java-объект при написании метода-перехватчика на основе аннотаций с использованием инфраструктуры Guice

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

Моя структура приложения похожа на

Я создал аннотацию, как показано ниже: - 

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface SampleAnnotation {
}

Затем создал образец перехватчика: 

public class SampleInterceptor implements MethodInterceptor {

    private static final Logger logger = LoggerFactory.getLogger(SampleInterceptor.class);

    @Inject
    SampleService sampleService; // this is not working

    public Object invoke(MethodInvocation invocation) throws Throwable {
        logger.info("SampleInterceptor : Interceptor Invoked");
        Object result = invocation.proceed();
        Observable<List<Sample>> observable = (Observable<List<Sample>>) result;
        SampleSender sender = null;
        List<Sample> sampleList = observable.toBlocking().first();

        for(Sample sample : sampleList ) {
            sender = new SampleSender();
            sender.setBoolean(sample.isBoolean());
            logger.info("Pushing Data into Sender");
            sampleService.insert(String.join("_", "key", "value"), sender); // here getting NullPointerException because sampleService is null
        }
        return result;
    }
}

Затем я создал GuiceModule, как показано ниже: - 

public class SampleModule extends AbstractModule {
    @Override
    protected void configure() {
        bindInterceptor(Matchers.any(), Matchers.annotatedWith(SampleAnnotation.class), new SampleInterceptor());
}

}

Класс, в котором я использую вышеупомянутую аннотацию 

// This class also have so many method and this was already declared and using in another services, I created a sample class here
class SampleClassForInterceptor {

      // this sampleMethod() is not a new method, its already created, 
      // now I am adding annotation to it, because after finishing this functionality, 
      // I want something should be done, so created annotation and added here
      @SampleAnnotation
      public Observable<List<Sample>> sampleMethod() {
            Sample sample = new Device();
            sample.setName("*** 7777");
            sample.setBoolean(true);
            List<Sample> list = new ArrayList<>();
            list.add(sample);
            Observable<List<Device>> observable = Observable.just(list);
            return observable;
      }
}

У меня есть RestModule, с помощью которого я связываю SampleClassForInterceptor следующим образом 

public final class RestModule extends JerseyServletModule {
    // other classes binding
    bind(SampleClassForInterceptor.class).in(Scopes.SINGLETON);
    // other classes binding
    install(new SampleModule());
}

Теперь у меня есть класс начальной загрузки, к которому я привязываюсь RestModule

public class Bootstrap extends ServerBootstrap {
   binder.install(new RestModule());
}

Использование: - 

@Path("service/sample")
public class SampleRS {
    @Inject
    SampleClassForInterceptor sampleClassForInterceptor;

    public void someMethod() {
        sampleClassForInterceptor.sampleMethod();
    }
}

Моя функциональность перехватчика начинает выполняться до выполнения sampleMethod() класса SampleClassForInterceptor, затем после выполнения sampleMethod(), снова возвращающегося к Interceptor, теперь здесь у меня есть фрагмент кода, который вставит результат (который мы получили из sampleMethod()). Вот где я получаю NullPointerException, я проверил код и обнаружил, что объект SampleService не вводится, и его значение равно null

Примечание: я использую микросервисы с концепцией RESTFUL-сервисов

1 Ответ

0 голосов
/ 13 ноября 2018

когда я использовал requestInjection в SampleModule, тогда SampleService был введен внутрь перехватчика, т.е. я изменил код SampleModule следующим образом 

public class SampleModule extends AbstractModule {
     @Override
     protected void configure() {
         SampleInterceptor interceptor = new SampleInterceptor();
         requestInjection(interceptor);
         bindInterceptor(Matchers.any(), Matchers.annotatedWith(SampleAnnotation.class), interceptor);
     }
}
...