进程内 ActiveMQ 生产者/消费者示例？答案

【问题标题】：In-process ActiveMQ producer/consumer example?进程内 ActiveMQ 生产者/消费者示例？
【发布时间】：2010-10-19 03:33:21
【问题描述】：

我正在研究将 ActiveMQ 用作我的嵌入式进程内消息队列应用程序，但我对如何启动这样一个应用程序有点困惑向上。我的设想是这样的（当然是伪代码）：

configureBroker ()
broker.start ()

createProducer (broker)
producer.start ()

for each desired consumer
    createConsumer (broker)
    consumer.start ()

waitForSignal ()
signalProducerShutdown ()

waitForEmptyQueues ()
signalConsumerShutdown ()

broker.stop ()

我试图组装一个简单的版本，但我不知道如何编写生产者和消费者以一种让他们永远工作的方式，或者直到被告知退出。做这个的最好方式是什么？我说的是线程方面。我需要/想要在自己的线程中产生什么，等等......

我对基于消息队列的应用程序完全陌生，所以请详细说明您的示例。

【问题讨论】：

标签： java queue jms activemq

【解决方案1】：

当您指定 ActiveMQConnectionFactory 时，您可以指定“vm://”，其中 name 是代理的内部虚拟机特定名称，它将在 VM 内启动代理。

例如，

String broker = "vm://stackOverflowTest";
ActiveMQConnectionFactory connectionFactory = 
        new ActiveMQConnectionFactory(broker);
Connection amqcon = connectionFactory.createConnection();
amqcon.start();

您可以从那里创建您的生产者或消费者，就像在网络上一样。只要您为代理使用相同的名称，您就可以让多个线程/代码打开/与同一个 VM 实例通信。

此解决方案仅允许与 VM 通信，不打开任何外部端口。我假设这就是您正在寻找的，因为您说您想要嵌入的进程内队列。

【讨论】：