我使用方法 Object process( JobContext jobContext );
以及名为 JobProcessImpl 的 impl 来定义 JobProcess。
每当执行此 JobProcessImpl.process 方法时,我都想监视多个子类。
我希望所有这些子类都被执行。
spy 类被定义为基类Task
来查找JobProcessImpl.process调用。
在输出中,我总是看到仅从 AnnotationTask 记录,而不从 ReviewTask 记录。
如果可能,请告诉我问题是什么。
我尝试了 2 天通过关注各种帖子来解决这个问题。
package com.spring.aspect.dynamicflow.activity;
import com.spring.aspect.dynamicflow.entity.JobContext;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
@Component
@Aspect
public abstract class Task {
private static final Logger log = LoggerFactory.getLogger( Task.class );
@Around ( "execution(public java.lang.Object com.spring.aspect.dynamicflow.process.JobProcessImpl.process(..)) " + "&& args(context)" )
public Object task( JobContext context ) {
log.info( "This is the base task and needs to overridden by the derived task for the job id: {} ", context.getJobId() );
return context;
}
}
基类: 注释任务
package com.spring.aspect.dynamicflow.activity;
import com.spring.aspect.dynamicflow.entity.JobContext;
import com.spring.aspect.dynamicflow.entity.TaskStatus;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
@Component
public class AnnotationTask extends Task {
private static final Logger log = LoggerFactory.getLogger( AnnotationTask.class );
@Override
public Object task( JobContext context ) {
log.info( "AnnotationTask's task" );
/*
* do some validation if annotation is completed or not
*/
log.info( "Setting that the annotation is done." );
context.setAnnotationTaskStatus( TaskStatus.COMPLETED );
return "AnnotationTask Completed";
}
审核任务
package com.spring.aspect.dynamicflow.activity;
import com.spring.aspect.dynamicflow.entity.JobContext;
import com.spring.aspect.dynamicflow.entity.TaskStatus;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
@Component
public class ReviewTask extends Task {
private static final Logger log = LoggerFactory.getLogger( ReviewTask.class );
@Override
public Object task( JobContext context ) {
log.info( "ReviewTask's task" );
/*
* do some validation if annotation is completed or not
*/
log.info( "not completing the review task due to some reason" );
context.setReviewTaskStatus( TaskStatus.IN_PROGRESS );
return "ReviewTask Not Completed";
}
}
我希望通过使用 TaskAspects 监视这些任务来执行它们。
package com.spring.aspect.dynamicflow.aspect;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
@Component
@Aspect
public class TaskAspects {
private static final Logger log = LoggerFactory.getLogger( TaskAspects.class );
@Around( "within(com.spring.aspect.dynamicflow.activity.Task+) ")
public Object handleTask( ProceedingJoinPoint proceedingJoinPoint) throws Throwable {
log.info( "Handling the task aspects." );
log.info( "" + proceedingJoinPoint.getThis() );
return proceedingJoinPoint.proceed();
}
}
我也有一个枚举类(提供代码完成)
package com.spring.aspect.dynamicflow.entity;
public enum TaskStatus {
IN_PROGRESS, COMPLETED
}
作业流程
package com.spring.aspect.dynamicflow.process;
import com.spring.aspect.dynamicflow.entity.JobContext;
public interface JobProcess {
Object process( JobContext jobContext );
}
JobProcessImpl
package com.spring.aspect.dynamicflow.process;
import com.spring.aspect.dynamicflow.entity.JobContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
@Component
public class JobProcessImpl implements JobProcess {
Logger logger = LoggerFactory.getLogger( JobProcessImpl.class );
@Override
public Object process( JobContext jobContext ) {
logger.info( "Shouldn't get printed Processing the job with jobid {}", jobContext.getJobId() );
return null;
}
}
最佳答案
我一发布这个,我就尝试用
更改 ReviewTask 和 AnnotationTask@Override
public Object task( ProceedingJoinPoint proceedingJoinPoint, JobContext context ) throws Throwable {
log.info( "ReviewTask's task" );
/*
* do some validation if annotation is completed or not
*/
log.info( "not completing the review task due to some reason" );
context.setReviewTaskStatus( TaskStatus.IN_PROGRESS );
return proceedingJoinPoint.proceed();
}
这解决了我的问题。
关于java - Spring aop : Pointcut defined for subclasses but only one subclass is invoked,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/57862162/