有时我的API引发异常,该服务器无法处理我的请求。我决定创建AOP方面,将重新调用API调用。例如,如果它仍然不起作用,则5次及之后抛出异常。

请参阅我的AOP class 。这不是一个完整的机构,但是我希望您能够理解正在发生的事情:

@Aspect
public class RetryRequestExecutor {

    ....

    @Around("@annotation(com.test.RequestRetriable)")
    public Object retryApiRequest(ProceedingJoinPoint point) throws Throwable {
        int numAttempts = 0;
        ServiceException lastException;
        do {
            numAttempts++;
            try {
                preInvokeLog(point);
                Object retValue = point.proceed();
                postInvokeLog(point);
                return retValue;
            } catch (ServiceException e) {
                lastException = handleServiceException(point, numAttempts, e);
            }
        } while (numAttempts <= maxRetries);
        throw lastException;
    }

    ....
}

这是我的服务 class :
public class UserApiImpl implements UserApi {

    ...

    @Override
    public List<DomainUser> retrieveSuspendedUsers() throws Exception{
        LOG.debug("Retrieving suspended users.");

        ...

        List<DomainUser> users = new ArrayList<DomainUser>(64);
        do {
            //Invoke API. AOP invoke it two times!
            currentPage = getUsers(retrieveUrl);
                    ...
                    URL nextLink = currentPage.getNextLink();
                    if (nextLink == null){
                        break;
                    }
            ...
        } while (nextLink != null);

        return users;
    }

    @Override
    @RequestRetriable
    public UserFeed getUsers(URL feedUrl) throws Exception {
        return userService.getFeed(feedUrl, UserFeed.class);
    }

    ...
}

如您所见,我仅注释了getUsers方法。方法retrieveSuspendedUsers没有注释。

Spring配置如下所示:
<aop:aspectj-autoproxy/>

现在,当我直接调用getUsers方法时,一切正常,AOP仅调用一次。但是,当我调用retrieveSuspendedUsers方法时-AOP为每个页面调用两次(我逐页检索用户,页面大小等于100)。我可以在日志中看到以下几行:
2013-03-11 13:06:40,179 DEBUG [pool-2-thread-1] Invoke API request getUsers with arguments [https://domain.com/user/2.0/]
2013-03-11 13:06:40,180 DEBUG [pool-2-thread-1] Invoke API request getUsers with arguments [https://domain.com/user/2.0/]
2013-03-11 13:06:41,745 DEBUG [pool-2-thread-1] Invoke API request getUsers with arguments [https://domain.com/user/2.0/] finished successfully
2013-03-11 13:06:41,745 DEBUG [pool-2-thread-1] Invoke API request getUsers with arguments [https://domain.com/user/2.0/] finished successfully

API调用非常耗时,我想避免其他不必要的调用。如何解决此问题?

最佳答案

切入点通知的callexecution事件均调用AFAIK切入点拦截。您可以过滤以匹配切入点中的仅方法execution:

@Around("execution(* *(..)) && @annotation(com.test.RequestRetriable)")

10-05 23:18
查看更多