问在java中实现异步消息队列

EN

我不推荐这种方法。

JMS是为这类事情而生的。它将比你从头开始编写的任何实现都要好。我推荐使用内置了JMS的Java应用服务器，或者可以添加到像Tomcat这样的servlet引擎中的ActiveMQ或RabbitMQ。

我强烈建议您在编写自己的代码之前先研究一下这些内容。

您正在描述的内容听起来像是ExecutorCompletionService。这本质上是一个异步任务代理，它接受来自一个线程的请求(Runnable或Callable)，以Future的形式返回即将到来的结果的“句柄”。然后在thread pool (可以是single thread thread pool)中执行请求，然后通过Future将请求的结果传递回调用线程。

在提交请求和提供响应之间，您的客户端线程将简单地等待Future (带有可选的超时)。

但是，我建议，如果您希望客户端(以及客户端线程)的数量大幅增加，则应该评估一些Java NIO Server框架。这将允许您避免为每个客户端分配一个线程，特别是因为您希望所有这些线程都要花费一些时间等待DB请求。如果是这样的话，我会建议使用MINA或Netty。

干杯。

//Nicholas

听起来你想要做的是限制你想要允许的数据库的并发请求的数量。(为了停止它的过载)

我建议你有一个有限大小的连接池。当太多的线程想要使用数据库时，它们将不得不等待，直到连接空闲。要做到这一点，一种简单的方法是使用预先创建了所有连接的BlockingQueue。

private final BlockingQueue<Connection> connections = new ArrayBlockingQueue<Connection>(40); {
   // create connections
}

// to perform a query.
Connection conn = connections.get();
try {
    // do something
} finally {
    connections.add(conn);
}

通过这种方式，您可以使线程设计保持不变，并限制对数据库的并发查询数量。通过一些调整，您可以根据需要创建连接，并在无法快速获得数据库连接时提供超时。