我有 Perl 背景，正在使用 Spring 编写我的第一个 Java MVC 网络应用程序。

我的网络应用程序允许用户提交订单，该应用程序通过调用第三方 SOAP 服务同步处理这些订单。该项目的下一阶段是允许用户提交批量订单(例如包含 500 行的 CSV)并异步处理它们。这是我现有 Controller 的片段:

@Controller
@Service
@RequestMapping(value = "/orders")
public class OrderController {

    @Autowired
    OrderService orderService;

    @RequestMapping(value="/new", method = RequestMethod.POST)
    public String processNewOrder(@ModelAttribute("order") Order order, Map<String, Object> map) {

        OrderStatus orderStatus = orderService.processNewOrder(order);

        map.put("orderStatus", orderStatus);

        return "new";
    }
}

我计划创建一个新的 @RequestMapping 来处理传入的 CSV 并修改 OrderService 以便能够分解 CSV 并将各个订单保存到数据库。

我的问题是:在 MVC Spring 应用程序中创建后台 worker 的最佳方法是什么？理想情况下，我会有 5 个线程处理这些订单，而且很可能来自一个队列。我已经阅读了有关 @Async 或将 Runnable 提交给 SimpleAsyncTaskExecutor bean 的信息，但我不确定要走哪条路。一些例子真的对我有帮助。

最佳答案

我认为 Spring Batch 有点矫枉过正，并不是您真正想要的。它更适合批处理，例如将所有订单写入一个文件然后一次处理所有订单，而这似乎更像是异步处理，您只想拥有一个工作“队列”并以这种方式处理它。

如果情况确实如此，我会考虑使用使用 JMS 的发布/订阅模型。有几个 JMS 提供程序，例如 Apache ActiveMQ 或 Pivotal RabitMQ。本质上，您的 OrderService 会将 CSV 分解为工作单元，将它们推送到 JMS 队列中，并且您将设置多个消费者以从队列中读取数据并执行工作任务。有很多方法可以配置它，但我只是创建一个类来保存您的工作线程并使线程数可配置。这里的其他额外好处是:

1. 您可以将消费者代码外部化，如果您愿意，甚至可以让它在完全不同的硬件上运行。
2. MQ 是一个非常有名的过程，并且有很多商业产品。这意味着您可以轻松地使用 MQ 在 C# 中编写订单处理系统来移动消息，如果您愿意，甚至可以使用 Spring Batch。哎呀，甚至还有用于主机的 MQ 系列，因此如果适合您的喜好，您可以在 COBOL 的大型机上进行订单处理。
3. 简单地添加更多消费者或生产者是愚蠢的。只需订阅队列，他们就可以离开!
4. 根据所使用的产品，队列会保持状态，因此消息不会“丢失”。如果所有消费者都下线，队列将简单地备份和存储消息，直到消费者回来。
5. 队列通常也更健壮。生产者可以倒下，消费者你甚至都不会退缩。消费者可以下线，生产者甚至不需要知道。

不过也有一些缺点。您现在有一个额外的故障点。您可能希望监视队列深度，并且在缓存消息时需要提供足够的空间来存储消息。此外，如果处理时间可能是个问题，您可能需要监控队列中处理事物的速度，以确保它不会备份太多或破坏任何可能存在的 SLA。

编辑:添加示例... 如果我有一个线程类，例如这个:

public class MyWorkerThread implements Runnable {
  private boolean run = true;

  public void run() {
    while (run) {
      // Do work here...
    }

    // Do any thread cooldown procedures here, like stop listening to the Queue.
  }

  public void setRunning(boolean runState) {
    run = runState;
  }
}

然后我会使用这样的类启动线程:

@Service("MyThreadManagerService")
public class MyThreadManagerServiceImpl implements MyThreadManagerService {
  private Thread[] workers;
  private int workerPoolSize = 5;

  /**
   * This gets ran after any constructors and setters, but before anything else
   */
  @PostConstruct
  private void init() {
    workers = new Thread[workerPoolSize];
    for (int i=0; i < workerPoolSize; i++) {
      workers[i] = new Thread(new MyWorkerThread());  // however you build your worker threads
      workers[i].start();
    }
  }

  /**
   * This gets ran just before the class is destroyed.  You could use this to
   * shut down the threads
   */
  @PreDestroy
  public void dismantle() {
    // Tell each worker to stop
    for (Thread worker : workers) {
      worker.setRunning(false);
    }

    // Now join with each thread to make sure we give them time to stop gracefully
    for (Thread worker : workers) {
      worker.join();  // May want to use the one that allows a millis for a timeout
    }

  }

  /**
   * Sets the size of the worker pool.
   */
  public void setWorkerPoolSize(int newSize) {
    workerPoolSize = newSize;
  }
}

现在您有了一个不错的服务类，您可以向其中添加方法来监视、重新启动、停止等所有工作线程。我将它设为 @Service，因为它感觉比简单的 @Component 更合适，但从技术上讲，它可以是任何东西，只要 Spring 知道在您 Autowiring 时选择它.服务类上的 init() 方法用于启动线程，dismantle() 用于优雅地停止它们并等待它们完成。它们使用 @PostConstruct 和 @PreDestroy 注释，因此您可以随意命名它们。您可能在 MyWorkerThread 上有一个构造函数来设置队列等。另外，作为免责声明，这一切都是根据内存编写的，因此可能存在一些轻微的编译问题或方法名称可能略有偏差。

可能已经有类可以用来做这类事情，但我自己从未见过。有人知道使用现成部件的更好方法吗？我很乐意接受更好的教育。

关于java - Spring MVC后台进程，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/24862140/