ToB企服应用市场:ToB评测及商务社交产业平台

标题: quarkus依赖注入之十三：其他重要知识点大串讲(终篇) [打印本页]
作者: 冬雨财经    时间: 2023-8-12 09:31
标题: quarkus依赖注入之十三：其他重要知识点大串讲(终篇)
欢迎访问我的GitHub

这里分类和汇总了欣宸的全部原创(含配套源码)：https://github.com/zq2599/blog_demos
本篇概览


简化之一：bean注入

  1.   @Inject
  2.   @ConfigProperty(name = "greeting.message")
  3.   String greetingMsg;
复制代码
  1. @ConfigProperty(name = "greeting.message")
  2. String greetingMsg;
复制代码
简化之二：bean构造方法

  1. @ApplicationScoped
  2. public class MyCoolService {
  4.   private SimpleProcessor processor;
  6.   MyCoolService() { // dummy constructor needed
  7.   }
  9.   @Inject // constructor injection
  10.   MyCoolService(SimpleProcessor processor) {
  11.     this.processor = processor;
  12.   }
  13. }
复制代码
  1. @ApplicationScoped
  2. public class MyCoolService {
  4.   private SimpleProcessor processor;
  6.   MyCoolService(SimpleProcessor processor) {
  7.     this.processor = processor;
  8.   }
  9. }
复制代码
简化之三：bean生产方法

  1. class Producers {
  2.   
  3.   @Produces
  4.   @ApplicationScoped
  5.   MyService produceServ
  6.     ice() {
  7.     return new MyService(coolProperty);
  8.   }
  9. }
复制代码
  1. class Producers {
  3.   @ApplicationScoped
  4.   MyService produceService() {
  5.     return new MyService(coolProperty);
  6.   }
  7. }
复制代码
WithCaching注解：避免不必要的多次实例化

  1. @QuarkusTest
  2. public class WithCachingTest {
  4.     @Inject
  5.     Instance<HelloDependent> instance;
  7.     @Test
  8.     public void test() {
  9.         // 第一次调用Instance#get方法
  10.         HelloDependent helloDependent = instance.get();
  11.         helloDependent.hello();
  13.         // 第二次调用Instance#get方法
  14.         helloDependent = instance.get();
  15.         helloDependent.hello();
  16.     }
  17. }
复制代码
  1. @Dependent
  2. public class HelloDependent {
  4.     public HelloDependent(InjectionPoint injectionPoint) {
  5.         Log.info("injecting from bean "+ injectionPoint.getMember().getDeclaringClass());
  6.     }
  8.     public String hello() {
  9.         return this.getClass().getSimpleName();
  10.     }
  11. }
复制代码


拦截静态方法



All更加直观的注入

  1. public interface SayHello {
  2.     void hello();
  3. }
复制代码
  1. public class InjectAllTest {
  2.     /**
  3.      * 用Instance接收注入，得到所有SayHello类型的bean
  4.      */
  5.     @Inject
  6.     Instance<SayHello> instance;
  8.     @Test
  9.     public void testInstance() {
  10.         // instance中有迭代器，可以用遍历的方式得到所有bean
  11.         for (SayHello sayHello : instance) {
  12.             sayHello.hello();
  13.         }
  14.     }
  15. }
复制代码
  1. @QuarkusTest
  2. public class InjectAllTest {
  3.     /**
  4.      * 用All注解可以将SayHello类型的bean全部注入到list中，
  5.      * 这样更加直观
  6.      */
  7.     @All
  8.     List<SayHello> list;
  10.     @Test
  11.     public void testAll() {
  12.         for (SayHello sayHello : list) {
  13.             sayHello.hello();
  14.         }
  15.     }
  16. }
复制代码
  1. @QuarkusTest
  2. public class InjectAllTest {
  3.    
  4.     @All
  5.     List<InstanceHandle<SayHello>> list;
  7.     @Test
  8.     public void testQuarkusAllAnnonation() {
  9.         for (InstanceHandle<SayHello> instanceHandle : list) {
  10.             // InstanceHandle#get可以得到注入bean
  11.             SayHello sayHello = instanceHandle.get();
  13.             // InjectableBean封装了注入bean的元数据信息
  14.             InjectableBean<SayHello> injectableBean = instanceHandle.getBean();
  16.             // 例如bean的作用域就能从InjectableBean中取得
  17.             Class clazz = injectableBean.getScope();
  19.             // 打印出来验证
  20.             Log.infov("bean [{0}], scope [{1}]", sayHello.getClass().getSimpleName(), clazz.getSimpleName() );
  21.         }
  22.     }
  23. }
复制代码

统一处理异步事件的异常

  1. public class TestEvent {
  2. }
复制代码
  1. @ApplicationScoped
  2. public class TestEventProducer {
  4.     @Inject
  5.     Event<TestEvent> event;
  7.     /**
  8.      * 发送异步事件
  9.      */
  10.     public void asyncProduce() {
  11.         event.fireAsync(new TestEvent());
  12.     }
  13. }
复制代码
  1. @ApplicationScoped
  2. public class TestEventConsumer {
  4.     /**
  5.      * 消费异步事件，这里故意抛出异常
  6.      */
  7.     public void aSyncConsume(@ObservesAsync TestEvent testEvent) throws Exception {
  8.        throw new Exception("exception from aSyncConsume");
  9.     }
  10. }
复制代码
  1. @QuarkusTest
  2. public class EventExceptionHandlerTest {
  4.     @Inject
  5.     TestEventProducer testEventProducer;
  7.     @Test
  8.     public void testAsync() throws InterruptedException {
  9.        testEventProducer.asyncProduce();
  10.     }
  11. }
复制代码

  1. package com.bolingcavalry.service.impl;
  3. import io.quarkus.arc.AsyncObserverExceptionHandler;
  4. import io.quarkus.logging.Log;
  6. import javax.enterprise.context.ApplicationScoped;
  7. import javax.enterprise.inject.spi.EventContext;
  8. import javax.enterprise.inject.spi.ObserverMethod;
  10. @ApplicationScoped
  11. public class NoopAsyncObserverExceptionHandler implements AsyncObserverExceptionHandler {
  13.     @Override
  14.     public void handle(Throwable throwable, ObserverMethod<?> observerMethod, EventContext<?> eventContext) {
  15.         // 异常信息
  16.         Log.info("exception is - " + throwable);
  17.         // 事件信息
  18.         Log.info("observer type is - " + observerMethod.getObservedType().getTypeName());
  19.     }
  20. }
复制代码

欢迎关注博客园：程序员欣宸

学习路上，你不孤单，欣宸原创一路相伴...

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！



欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/) Powered by Discuz! X3.4