java - 从 Socket 读取行并将每行放入 BlockingQueue

Question

任何人都可以提供 Java 示例，或者建议实现一个从套接字异步读取行并将每行放入 BlockingQueue 的类。假设socket已连接，并且BlockingQueue和consumer已经存在。

编辑:还有一件事，它需要能够在一段时间不活动后超时，并根据命令立即停止。

这不是家庭作业，我只是无法找到完整的示例来说明如何可靠地做好这件事。

非常感谢。

Answer 1

说实话，你听起来好像已经完成了工作。您需要做的就是创建一个 BlockingQueue 并有一个线程来处理它，我猜这就是您的消费者。假设你有一个 DataInputStream 'in'...

类似这样的事情:

BlockingQueue<String> receivedQueue = new LinkedBlockingQueue<String>();
public void run()
{
    while (true)
    {
        try
        {
            receivedQueue.put(in.readUTF());
        } catch (EOFException e)
        {
            ch.getClient().disconnect();
            break;
        } catch (IOException e)
        {
            break;
        } catch (InterruptedException e)
        {
            break;
        }
    }
    theQueueProcessor.interrupt();
}