gpt4 book ai didi

java - 无法使用 java 创建 ActiveMQ 队列或发送消息

转载 作者:行者123 更新时间:2023-12-01 21:37:10 25 4
gpt4 key购买 nike

我是 ActiveMQ 新手。我使用本地计算机上的默认设置在 Windows 上运行 ActiveMQ 服务器。我尝试创建一个简单的队列来测试发送消息。

public class Foo {

public static void main(String[] args) {
new Foo().send();
}

public void send(){
try {
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("vm://localhost:61616");
Connection connection = connectionFactory.createConnection();
connection.start();

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue("TESTQUEUE");
MessageProducer producer = session.createProducer(destination);
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

TextMessage message = session.createTextMessage("MESSAGE123");
producer.send(message);

session.close();
connection.close();

} catch (JMSException ex) {
Logger.getLogger(Foo.class.getName()).log(Level.SEVERE, null, ex);
}
}
}

当我尝试通过登录 ActiveMQ 管理页面并检查队列来检查该代码时,该代码似乎没有执行任何操作。 (本地主机:8161/admin/queues.jsp)队列未创建。然后尝试从管理页面手动创建队列,即使创建了队列,消息也不会发送到队列。

当我使用命令activemq Produceractivemq Consumer测试服务器时,队列被创建,消息被传递到队列并从队列中读取。所以我确信服务器没有任何问题。

当我运行代码时,这是终端输出

WARN | Memory Usage for the Broker (1024mb) is more than the maximum available for the JVM: 887 mb - resetting to 70% of maximum available: 621 mb
INFO | Using Persistence Adapter: KahaDBPersistenceAdapter[C:\Users\Prashan\Desktop\Test\activemq-data\localhost\KahaDB]
INFO | JMX consoles can connect to service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
INFO | KahaDB is version 6
INFO | Recovering from the journal @1:3712
INFO | Recovery replayed 1 operations from the journal in 0.01 seconds.
INFO | PListStore:[C:\Users\Prashan\Desktop\Test\activemq-data\localhost\tmp_storage] started
INFO | Apache ActiveMQ 5.13.2 (localhost, ID:CAPSULE-5179-1461559222267-0:1) is starting
INFO | Apache ActiveMQ 5.13.2 (localhost, ID:CAPSULE-5179-1461559222267-0:1) started
INFO | For help or more information please see: http://activemq.apache.org
WARN | Store limit is 102400 mb (current store usage is 0 mb). The data directory: C:\Users\Prashan\Desktop\Test\activemq-data\localhost\KahaDB only has 6947 mb of usable space. - resetting to maximum available disk space: 6947 mb
WARN | Temporary Store limit is 51200 mb (current store usage is 0 mb). The data directory: C:\Users\Prashan\Desktop\Test\activemq-data\localhost\tmp_storage only has 6947 mb of usable space. - resetting to maximum available disk space: 6947 mb
INFO | Connector vm://localhost started
INFO | Connector vm://localhost stopped
INFO | Apache ActiveMQ 5.13.2 (localhost, ID:CAPSULE-5179-1461559222267-0:1) is shutting down
INFO | PListStore:[C:\Users\Prashan\Desktop\Test\activemq-data\localhost\tmp_storage] stopped
INFO | Stopping async queue tasks
INFO | Stopping async topic tasks
INFO | Stopped KahaDB
INFO | Apache ActiveMQ 5.13.2 (localhost, ID:CAPSULE-5179-1461559222267-0:1) uptime 1.918 seconds
INFO | Apache ActiveMQ 5.13.2 (localhost, ID:CAPSULE-5179-1461559222267-0:1) is shutdown

最佳答案

您实际上正在创建一个嵌入式代理,并且消息会发送到那里。您应该通过以下方式连接到本地计算机代理:tcp://localhost:61616" 而不是 vm://...

关于java - 无法使用 java 创建 ActiveMQ 队列或发送消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/36831990/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com