java - 如何使用消息传递编写生产者-消费者解决方案？

Question

我找到了下一个代码：

public static void main(String args[]) {
        Producer producer = new Producer();
        producer.start();
        new Consumer(producer).start();
    }
}
class Producer extends Thread {
    static final int MAXQUEUE = 5;
    private Vector<String> messages = new Vector<String>();

    public void run() {
        try {
            while (true) {
                putMessage();
                sleep(1000);
            }
        } catch (InterruptedException e) {
        }
    }

    private synchronized void putMessage() throws InterruptedException {

        while (messages.size() == MAXQUEUE)
            wait();
        messages.addElement(new java.util.Date().toString());
        notify();
    }

    public synchronized String getMessage() throws InterruptedException {
        notify();
        while (messages.size() == 0)
            wait();
        String message = (String) messages.firstElement();
        messages.removeElement(message);
        return message;
    }
}

class Consumer extends Thread {
    Producer producer;

    Consumer(Producer p) {
        producer = p;
    }

    public void run() {
        try {
            while (true) {
                String message = producer.getMessage();
                System.out.println("Got message: " + message);
                sleep(2000);
            }
        } catch (InterruptedException e) {
        }
    }

因此，据我了解消息传递 - 只是不使用共享资源，而是像上面的示例引用一样使用从一个对象到另一个对象进行通信。我对吗？

Answer 1

如果您遵循发布/订阅模式，那么您需要某种消息队列。生产者将消息放入队列，消费者读取队列中的消息。

消息传递的重点是您的生产者/消费者不必直接相互引用，而只需通过队列进行通信。

Answer 2

为什么要自己写？您可以使用现有的 Java 消息服务 (JMS) 解决方案，例如ActiveMQ。它可以在进程中运行并在您的对象之间传递消息。