在第三方类上进行Spring-AOP加载时编织

tha*_*yne 1 aspectj spring-aop

我写了一个方面,我试图用junit测试.该方面对第三方方法有一个@Around建议setQuery.在编译时,它抱怨:Can't find referenced pointcut setQuery

这是我的方面:

@Component
@Aspect
public class ElasticsearchQuerySecurityAspect {
    @Around("org.elasticsearch.action.search.SearchRequestBuilder.setQuery() && args(queryBuilder)")
    public void addFilter(final ProceedingJoinPoint pjp, QueryBuilder queryBuilder) throws Throwable {
      Object[] args = pjp.getArgs();

      // Set the filter to use our plugin
      FilterBuilder securityFilter = FilterBuilders.scriptFilter("visibility-filter")
            .lang("native")
            .addParam("visibility-field", "visibility")
            .addParam("parameter", "default");

      // Re-create original query with the filter applied
      QueryBuilder newQuery = QueryBuilders.filteredQuery(queryBuilder,securityFilter);
      log.info("Adding filter to search request");
        // Tell the method to run with the modified parameter
        args[0] = newQuery;
        pjp.proceed(args);
    }
}
Run Code Online (Sandbox Code Playgroud)

这是我的junit测试:

@RunWith(SpringJUnit4ClassRunner.class)// NOTE #1
@ContextConfiguration(loader = AnnotationConfigContextLoader.class)
@EnableLoadTimeWeaving
@ComponentScan
public class ElasticsearchQuerySecurityTest {

  Client client = mock(Client.class);

  @Before
  public void setUp() throws Exception {
  }

  @Test
  public void test() {    
    SearchRequestBuilder s = new SearchRequestBuilder(client);
    QueryBuilder qb = QueryBuilders.queryString("name:foo");
        XContentBuilder builder;
    try {
      builder = XContentFactory.jsonBuilder();
      qb.toXContent(builder, null);
      assertEquals("{\"query_string\":{\"query\":\"name:foo\"}}",builder.string());

      // Call setQuery() which will invoke the security advice and add a filter to the query
      s.setQuery(qb);
      builder = XContentFactory.jsonBuilder().startObject();
      qb.toXContent(builder, null);
      builder.endObject();
      assertEquals("{\"query\": "+
        "{ \"filtered\": "+
        "{ \"query\": "+
        "{ \"query_string\": "+
        "{ \"name:foo\", } }, "+
        "\"filter\": "+
        "{ \"script\": "+
        "{ \"script\": \"visibility-filter\","+
        "\"lang\":\"native\", "+
        "\"params\": "+
        "{ \"visibility-field\":\"visibility\", "+
        "\"parameter\":\"default\" } } } } } }",
        builder.string());
    } catch (IOException e) {
      fail("We threw an I/O exception!");
    }   
  }
}
Run Code Online (Sandbox Code Playgroud)

我在类路径上也有这个aop.xml:

<!DOCTYPE aspectj PUBLIC "-//AspectJ//DTD//EN" "http://www.eclipse.org/aspectj/dtd/aspectj.dtd">
<aspectj>

    <weaver>
        <include within="org.elasticsearch.action.search.*"/>
    </weaver>

    <aspects>
        <aspect name="org.omaas.security.ElasticsearchQuerySecurityAspect"/>
    </aspects>

</aspectj>
Run Code Online (Sandbox Code Playgroud)

我尝试了一个方面,@Around("execution(public * set*())")发现它只建议当前包中的东西.如何将其应用于第三方包中的内容?

kri*_*aex 5

Spring AOP只能编织成Spring Beans.由于您的第三方目标类不是Spring bean,因此无法对其应用方面.为此,您需要使用更强大的AspectJ,而不依赖于基于动态代理的Spring的"AOP lite"实现.

使用AspectJ,您有两种选择:

  • 编译时编织(CTW):您可以将方面编译到第三方类中,并为依赖项创建一个新的,方面增强的JAR.
  • 加载时编织(LTW):您可以在运行时加载第三方类时将其编织到第三方类中.这需要几个CPU周期,同时引导您的应用程序,但不必重新打包第三方JAR.

编辑:哦,顺便说一下,你的切入点语法无效.你不能写

@Around("org.elasticsearch.action.search.SearchRequestBuilder.setQuery() && args(queryBuilder)")
Run Code Online (Sandbox Code Playgroud)

相反,你宁愿需要类似的东西

@Around("execution(* org.elasticsearch.action.search.SearchRequestBuilder.setQuery(*)) && args(queryBuilder)")
Run Code Online (Sandbox Code Playgroud)

方法名称是不够的,您必须告诉AOP框架您要捕获它execution()(在AspectJ中,也可以通过它捕获所有调用者call()).其次,您不会QueryBuilder通过指定setQuery()没有任何参数的方法签名来捕获具有一个参数的方法,因此我建议您使用setQuery(*)或,如果您想要更精确,setQuery(org.elasticsearch.index.query.QueryBuilder).你还需要一个类似于public方法名称前面的返回类型和/或修饰符,或者像一个小丑一样*.