在 Spring MVC 处理程序返回后调用另一个方法

Question

我有一个要求，我需要从休息控制器返回一些状态/长值，然后执行代码以发送推送通知。

@RequestMapping(value="/create")
public String createTicket() throws InterruptedException {
    // code to create ticket
    return "ticket created";
    // need to call sendPushNotifiction() after I return status
}

    public void sendPushNotifiction() throws InterruptedException {
    // code to send push notification
    System.out.println("Sent push notification successfully!!");    
}

有人可以告诉我如何实现这一目标吗？是否可以为此使用 Spring AOP？我不认为线程只会在返回后保证 sendPushNotifiction 方法的执行。那么有什么方法可以有效地实现这一目标呢？ 提前致谢

Answer 1

我认为这可能是异步处理的一个很好的用例。春天有good support。准确地说，你需要

1. 用@Async注释sendPushNotifiction。
2. 用@EnableAsync注解一些配置类。
3. 在返回语句之前调用sendPushNotifiction()。执行流程不会等待sendPushNotifiction 完成。

如果不起作用，请尝试在单独的服务中编码sendPushNotifiction。

Answer 2

创建另一个方法，它首先调用createTicket() 方法，然后调用sendPushNotifiction()。这将完成这项工作。在我看来，这是最简单的方法。

Answer 3

createTicket()是spring调用的。不能直接调用。可以使用org.springframework.web.servlet.HandlerInterceptor。只需从postHandle()或afterCompletion()方法调用你的sendPushNotifiction()方法 你的 HandlerInterceptor

    package com.sample.interceptor;

   import javax.servlet.http.HttpServletRequest;
   import javax.servlet.http.HttpServletResponse;

   import org.springframework.web.servlet.HandlerInterceptor;
   import org.springframework.web.servlet.ModelAndView;

   public class NotifictionHandlerInterceptor implements HandlerInterceptor {

@Override
public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
    return true;
}

@Override
public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler,
        ModelAndView modelAndView) throws Exception {
    //do nothing
}

@Override
public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex)
        throws Exception {

    //call your method here
    //call sendPushNotifiction()

}

}

并在 spring-mvc 上下文中注册你的处理程序

    <mvc:interceptors>
<bean class="com.sample.NotifictionHandlerInterceptor" />
   </mvc:interceptors>

Answer 4

你可以这样调用：

@RequestMapping(value="/create")
public void create(){
createTicket();
sendPushNotifiction();
}

public String createTicket() throws InterruptedException {
    // code to create ticket
    return "ticket created";
    // need to call sendPushNotifiction() after I return status
}

    public void sendPushNotifiction() throws InterruptedException {
    // code to send push notification
    System.out.println("Sent push notification successfully!!");    
}

Answer 5

我同意 youngHobbit 的解决方案，你可以像下面那样做

@RequestMapping(value="/create")
public String entryMethod() throws InterruptedException {
   String response = createTicket();
   sendPushNotifiction();
   return response ;
}

public String createTicket() throws InterruptedException {
    // code to create ticket
    return "ticket created";
    // need to call sendPushNotifiction() after I return status
}

    public void sendPushNotifiction() throws InterruptedException {
    // code to send push notification
    System.out.println("Sent push notification successfully!!");    
}

虽然另一种解决方案可以在您完成第一个方法后将请求转发/重定向到另一种方法。但是，如果它以简单、清晰和易读的方式解决您的目的，请采用第一种方法

AOP 基本上是用于处理您想要跨应用程序处理的横切关注点，不应该用于像这样的非常特定的目的。为什么要引入额外的复杂性

Answer 6

另一种方法是将 sendPushNotification() 的执行推迟到某个线程/线程池。在返回之前，使用队列将处理入队，然后在你的线程中出列并处理。

但是，您应该注意将您的请求链接到真正的调用者并处理失败等问题。

网络上到处都是例子。查找 java.util.concurrent 示例、执行器、...

Answer 7

HandlerInterceptor 是解决方案，但代码比预期的要复杂一些。这是一个代码建议，通过将整个解决方案放在一个类中来使其更简单：

@RequestMapping(value = "/create")
public String createTicket() throws InterruptedException {
    String ticket = "ticket created";
    result.set(ticket); // Save the ticket to be used after response
    return ticket;
}

public void sendPushNotifiction(String ticket) throws InterruptedException {
    System.out.println("Sent push notification successfully!!");
}

private static final ThreadLocal<String> result = new ThreadLocal<String>();

@Bean
public MappedInterceptor interceptor() {
    return new MappedInterceptor(Arrays.array("/create"), new HandlerInterceptor() {
        @Override
        public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
            // Get the saved object and clean for the next request
            String ticket = result.get();
            result.set(null);

            // Execute after response
            sendPushNotifiction(ticket);
        }
    });
}