如何通过Java在AMQ Broker中直接向队列（持久化/非持久化）发消息而非地址？

完全可以通过Java实现直接向AMQ Broker的队列写入消息，无需经过地址路由环节。下面是两种常用的实现方式，覆盖外部客户端和Broker内部代码场景：

1. 外部客户端：使用Artemis Core Client直接绑定队列 #

AMQ Broker基于Apache ActiveMQ Artemis，其Core Client支持直接指定队列作为消息发送目标，跳过地址路由逻辑。

代码示例 #

import org.apache.activemq.artemis.api.core.*;
import org.apache.activemq.artemis.api.core.client.*;

public class DirectQueueClient {
    public static void main(String[] args) throws Exception {
        // 初始化连接定位器，指定Broker地址
        ServerLocator locator = ActiveMQClient.createServerLocator("tcp://localhost:61616");
        
        // 创建会话工厂与会话（使用具备对应权限的账号）
        ClientSessionFactory factory = locator.createSessionFactory();
        ClientSession session = factory.createSession("admin", "admin", false, true, true, false, 1);

        // 指定目标队列名称
        String targetQueue = "my-direct-queue";
        
        // 创建直接绑定到队列的生产者
        ClientProducer producer = session.createProducer(targetQueue);

        // 发送持久化消息：createMessage参数true表示持久化
        ClientMessage durableMsg = session.createMessage(true);
        durableMsg.getBodyBuffer().writeString("持久化测试消息");
        producer.send(durableMsg);

        // 发送非持久化消息：createMessage参数false表示非持久化
        ClientMessage nonDurableMsg = session.createMessage(false);
        nonDurableMsg.getBodyBuffer().writeString("非持久化测试消息");
        producer.send(nonDurableMsg);

        // 提交会话并关闭资源
        session.commit();
        producer.close();
        session.close();
        factory.close();
        locator.close();
    }
}

关键说明 #

• createProducer(targetQueue)直接将生产者绑定到目标队列，无需预先创建地址，Broker会自动创建队列（需确保core.xml中auto-create-queues配置为true）。
• 消息的持久化模式通过createMessage(boolean durable)参数直接控制，与队列的持久化属性相互独立：队列持久化仅决定存储介质，消息持久化决定是否写入持久存储。

2. Broker内部代码：直接调用Broker核心API #

如果你的代码运行在Broker进程内部（如自定义插件、拦截器），可以直接使用Broker的核心API操作队列，性能更优。

代码示例 #

import org.apache.activemq.artemis.core.server.ActiveMQServer;
import org.apache.activemq.artemis.core.server.Queue;
import org.apache.activemq.artemis.api.core.Message;
import org.apache.activemq.artemis.api.core.SimpleString;

public class InternalQueueWriter {
    public void writeToQueue(ActiveMQServer server, String queueName, boolean isDurable, String content) throws Exception {
        SimpleString queueStr = new SimpleString(queueName);
        Queue queue = server.locateQueue(queueStr);

        // 若队列不存在，主动创建（需确保Broker允许手动创建队列）
        if (queue == null) {
            server.createQueue(queueStr, queueStr, null, isDurable, false);
            queue = server.locateQueue(queueStr);
        }

        // 创建指定持久化模式的消息
        Message message = server.createMessage(isDurable, false);
        message.getBodyBuffer().writeString(content);

        // 直接将消息添加到队列
        queue.addMessage(message, null, false, false);
    }
}

关键注意事项 #

• 权限控制：无论是外部客户端还是内部代码，操作队列都需要对应的权限（如send、create权限），需在Broker的broker.xml或artemis-roles.properties中配置。
• 队列生命周期：如果依赖自动创建队列，需确保Broker配置允许自动创建；若需固定队列，建议提前在Broker配置文件中声明。

内容的提问来源于stack exchange，提问作者Sharath gowda