首先,您需要将 IOException 打包成未经检查的异常,真正的异常将是您在通知中捕获的异常的原因。
最简单的就是取RuntimeException。
public void doTimerJob() {
final Timer timer = new Timer();
timer.scheduleAtFixedRate(new TimerTask() {
@Override
public void run() {
try {
throw new IOException("file not found");
} catch (IOException e) {
timer.cancel();
throw new RuntimeException(e);
}
}
}, new Date(), 2000);
}
然后你可以尝试以下方法:
为 TimerTask#run 创建一个切入点
pointcut timerTaskRun() : execution(public * java.util.TimerTask.run(..) );
以及抛出 RuntimeException 后的建议
after() throwing(RuntimeExceptione) : timerTaskRun() {
System.out.println("log and rethrow " + e.getCause().getMessage());
}
这将在记录后重新抛出异常。
如果你想记录并吞下异常,你可以写一个周围的建议
Object around() : timerTaskRun() {
Object o;
try {
o = proceed();
} catch(RuntimeException e) {
System.out.println("log and swallow " + e.getCause().getMessage());
o = null;
}
return o;
}
请注意,您应该只有一个建议,或者after throwing
两者around
都没有。
但是您可能不想建议所有TimerTask#run
呼叫以及所有RuntimeException
s。在这种情况下,您应该创建自己的类型,您应该在切入点和建议中使用它们。
“未检查” IOException
public class IOExceptionUnchecked extends RuntimeException {
private static final long serialVersionUID = 1L;
public IOExceptionUnchecked(IOException e) {
super(e);
}
}
自定义定时器任务
public class MyTimerTask extends TimerTask {
Timer owner = null;
public MyTimerTask(Timer timer) {this.owner = timer;}
@Override
public void run() {
try {
throw new IOException("file not found");
} catch (IOException e) {
owner.cancel();
throw new IOExceptionUnchecked(e);
}
}
}
切点
pointcut timerTaskRun() : execution(public * com.example.MyTimerTask.run(..) );
投掷建议后:
after() throwing(IOExceptionUnchecked e) : timerTaskRun() {
System.out.println("log and rethrow " + e.getCause().getMessage());
}
或周围的建议
Object around() : timerTaskRun() {
Object o;
try {
o = proceed();
} catch(IOExceptionUnchecked e) {
System.out.println("log and swallow " + e.getCause().getMessage());
o = null;
}
return o;
}