java在服务器上并行运行服务
我有一个处理用户请求的服务。
此服务调用另一个外部后端系统（Web服务）。 但我需要并行执行这些后端Web服务。 你会怎么做？ 什么是最好的方法？
提前致谢
- - -编辑
后端系统可以并行运行请求，我们使用容器（如tomcat for development）和websphere最终用于生产。 所以我已经在一个线程（servlet）中，需要产生两个任务，并且可能尽可能并行地并行运行它们。
我可以想象使用石英或线程与执行器或让它在Servlet引擎上。 采取这种方案的正确途径是什么？
您可以使用Threads并行运行请求。
根据你想要做什么，建立一些现有的技术如Servlets可能对你有帮助
答案是在不同的线程中运行任务。
对于这样的事情，我认为你应该使用具有有限池大小的ThreadPoolExecutor ，而不是自己创建线程。
代码看起来像这样。 （请注意，这只是一个草图，查看javadocs的详细信息，数字的含义等信息）
// Create the executor ... this needs to be shared by the servlet threads.
Executor exec = new ThreadPoolExecutor(1, 10, 120, TimeUnit.SECONDS,
new ArrayBlockingQueue(100), ThreadPoolExecutor.CallerRunsPolicy);
// Prepare first task
final ArgType someArg = ...
FutureTask<ResultType> task = new FutureTask<ResultType>(
new Callable<ResultType>() {
public ResultType call() {
// Call remote service using information in 'someArg'
return someResult;
}
});
exec.execute(task);
// Repeat above for second task
...
exec.execute(task2);
// Wait for results
ResultType res = task.get(30, TimeUnit.SECONDS);
ResultType res2 = task2.get(30, TimeUnit.SECONDS);
上述内容不会试图处理异常，您需要在超时时间内做更复杂的事情; 例如跟踪整个请求时间并取消随时间推移的任务。
这不是Quartz设计要解决的问题。 Quartz是一个作业调度系统。 你只需要尽快执行一些任务......可以让设施取消它们。
Heiko是正确的，你可以使用线程。 线程是复杂的野兽，需要小心处理。 最好的解决方案是使用标准库，比如java.util.concurrent。 这将是管理并行操作的更健壮的方式。 这种方法带来了性能优势，例如线程池。 如果你可以使用这样的解决方案，这将是推荐的方式。
如果你想自己做，这是一个并行执行多个线程的非常简单的方法，但可能不是很强大。 你需要更好地处理超时和线程的破坏等。
public class Threads {
public class Task implements Runnable {
private Object result;
private String id;
public Task(String id) {
this.id = id;
}
public Object getResult() {
return result;
}
public void run() {
System.out.println("run id=" + id);
try {
// call web service
Thread.sleep(10000);
result = id + " more";
} catch (InterruptedException e) {
// TODO do something with the error
throw new RuntimeException("caught InterruptedException", e);
}
}
}
public void runInParallel(Runnable runnable1, Runnable runnable2) {
try {
Thread t1 = new Thread(runnable1);
Thread t2 = new Thread(runnable2);
t1.start();
t2.start();
t1.join(30000);
t2.join(30000);
} catch (InterruptedException e) {
// TODO do something nice with exception
throw new RuntimeException("caught InterruptedException", e);
}
}
public void foo() {
Task task1 = new Task("1");
Task task2 = new Task("2");
runInParallel(task1, task2);
System.out.println("task1 = " + task1.getResult());
System.out.println("task2 = " + task2.getResult());
}
}
上一篇: java run services in parallel on the server
下一篇: Random Error in typescript while compiling angular 5 project