java中异步进程的技术与设计

Question

我目前正在用Java在Restfull架构下开发一个应用程序。在我的web rest服务、另一个web服务soap和android客户端之间的交互过程中，我遇到了一个非常大的问题。

经过几次测试后，我意识到客户端有时会在操作仍在处理时返回操作失败，对于上面提到的两个服务之间的服务消费也是如此，只是因为这种情况下的调用是阻塞的。

为了解决这个问题，我将这样处理:当客户端向服务器发送操作时，服务器立即响应请求。那么客户每次都必须测试他的操作状态，直到它是好的，它就这样通知用户。

现在我担心的是，我只会创建一个线程；但我找不到一个好的设计和技术来实现这一点……提前感谢您的帮助。

Answer 1

您将监听来自客户端的调用，轮询状态(在服务器的一个端点上)，并让使用者线程实现getStatus方法，同时更新run方法内部的状态。关于消费者线程，一个粗略的实现应该是这样的：

public class ConsumerThread implements Runnable{
    private int status = 0;
    private Random rand = new Random();
    private final CountDownLatch startSignal;

    public ConsumerThread(CountDownLatch latch){
        this.startSignal = latch;
    }

    public int getStatus() {
        return status;
    }

    private void setStatus(int status) {
        this.status = status;
    }

    public void run() {
        try {
            this.startSignal.await();
            while (true){
                this.setStatus(rand.nextInt(10));
            }
        } catch (InterruptedException e1) {
            e1.printStackTrace();
        }       
    }
}

然后尝试一个简单的main方法(我实现了一个CountDownLatch，让我的所有线程同时启动，这不是强制性的)：

public class ThreadMain{
    private static List<ConsumerThread> consumers = new ArrayList<ConsumerThread>();

    public static void main(String[] args) {
        int NUM_THREAD = 15;
        ExecutorService executor = Executors.newFixedThreadPool(NUM_THREAD);

        CountDownLatch latch = new CountDownLatch(NUM_THREAD);
        ConsumerThread buffer = new ConsumerThread(latch);
        for (int i = 0; i < NUM_THREAD; i++){
            consumers.add(buffer);
            executor.execute(buffer);
            latch.countDown();
            buffer = new ConsumerThread(latch);
        }

        for (int i = 0; i < 100; i++){
            System.out.println("Status for Thread 0: " + getStatusId(0));
            System.out.println("Status for Thread 14: " + getStatusId(14));
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    public static int getStatusId(int index){
        return consumers.get(index).getStatus();
    }
}

示例输出：

Status for Thread 0: 5
Status for Thread 14: 0
Status for Thread 0: 7
Status for Thread 14: 2
Status for Thread 0: 7
Status for Thread 14: 4
Status for Thread 0: 6
Status for Thread 14: 3