dubbo?filter中有關(guān)bean注入和配置文件讀取方式

更新時(shí)間：2024年05月16日 08:43:54 作者：weixin_45614626

這篇文章主要介紹了dubbo?filter中有關(guān)bean注入和配置文件讀取方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

dubbo filter中有關(guān)bean注入和配置文件讀取

在寫(xiě)dubbo的filter時(shí)候，需要注入bean和讀取配置文件，然后理所當(dāng)然的就像springboot其他地方的寫(xiě)法一樣，直接用了@Resource和@Value注解。

但是本地調(diào)試的時(shí)候，發(fā)現(xiàn)報(bào)錯(cuò)，注入的bean和讀取的配置變量全部為null，很是不解，于是就上網(wǎng)查了以下資料。

首先，dubbo的攔截器這些組件是由dubbo自己管理的，并不是直接由spring管理的，因此spring的那些注入注解在dubbo里統(tǒng)統(tǒng)不能用。

如果想用可以采取以下代碼：

	private Environment environment;

    public void setEnvironment(Environment environment){
        this.environment=environment;
    }
    @Override
    public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
        String headerTopic = environment.getProperty("spring.kafka.header-topic");
        Result result = invoker.invoke(invocation);
        return result;
    }

這樣就可以讀取到配置文件了。

如果想要注入bean，則使用以下代碼：

private KafkaTemplate<String, String> headKafkaTemplate;
public void setHeadKafkaTemplate(KafkaTemplate<String, String> headKafkaTemplate){
        this.headKafkaTemplate = headKafkaTemplate;
    }

dubbo組件實(shí)例化后，setter方法會(huì)被dubbo調(diào)起，然后在ApplicationContext中去查找對(duì)應(yīng)的bean。

而且在查找的過(guò)程中是優(yōu)先按照名字去匹配，然后才是type，所以盡量把setter方法名字寫(xiě)成要注入的bean的名字。

能夠注入Bean的Filter

DelegatingFilterProxy就是一個(gè)對(duì)于servlet filter的代理，用這個(gè)類的好處主要是通過(guò)Spring容器來(lái)管理servlet filter的生命周期，還有就是如果filter中需要一些Spring容器的實(shí)例，可以通過(guò)spring直接注入，另外讀取一些配置文件這些便利的操作都可以通過(guò)Spring來(lái)配置實(shí)現(xiàn)。

DelegatingFilterProxy運(yùn)用

需求：

在springboot中使用了filter, 并且注入了業(yè)務(wù)工具類(APIUtil )，但注入是null

所以問(wèn)題就來(lái)了：springboot中使用filter時(shí)注入bean為null的解決辦法

其實(shí)Spring中，web應(yīng)用啟動(dòng)的順序是：listener->filter->servlet，先初始化listener，然后再來(lái)就filter的初始化，再接著才到我們的dispathServlet的初始化

解決辦法1

public class TokenAuthFilter implements Filter {
 
    private final static Logger log = LoggerFactory.getLogger(TokenAuthFilter.class);
 
    @Autowired
    private APIUtil apiUtil;
}

新增一個(gè)config類,用來(lái)手工創(chuàng)建filter的bean, 例如:

@Configuration
public class WebConfig {
 
  @Bean
    public Filter tokenAuthFilter() {
 
        return new TokenAuthFilter(); //第一步：先將filter放入容器
    }
    /**
     * 注冊(cè)filter，統(tǒng)一處理api開(kāi)頭的請(qǐng)求
     * @return FilterRegistrationBean
     */
    @Bean
    public FilterRegistrationBean tokenAuthFilterRegistration() {
        FilterRegistrationBean registration = new FilterRegistrationBean();
        // 第二步：DelegatingFilterProxy把servlet 容器中的filter同spring容器中的bean關(guān)聯(lián)起來(lái)
        registration.setFilter(new DelegatingFilterProxy("tokenAuthFilter"));
        registration.addUrlPatterns("/api/*");
        registration.setName("tokenAuthFilter");
        registration.setOrder(1);
        return registration;
    }
}

解決辦法2

過(guò)濾器是servlet規(guī)范中定義的，并不歸spring容器管理，也無(wú)法直接注入spring中的bean（會(huì)報(bào)錯(cuò)）

初始化時(shí)通過(guò)spring上下文獲取，進(jìn)行bean的初始化：

@Override
public void init(FilterConfig filterConfig) throws ServletException {
    ApplicationContext context = WebApplicationContextUtils.getWebApplicationContext(filterConfig.getServletContext());
    RedisTemplate demoBean = (RedisTemplate)context.getBean("redisTemplate");
    System.out.println(demoBean);
 }