如何无需创建生产者连接，通过消费者连接向ActiveMQ Artemis队列发送字节消息？

以下几种方案可以满足你的需求，不用创建独立的生产者连接，同时避免对字节消息进行Base64编码：

1. 复用现有消费者连接的Session发送消息 #

如果已经建立了消费者连接，完全可以复用同一个连接下的Session来发送消息——不需要创建新的连接，只是在现有Session上创建一个临时生产者即可，这是最直接的方式。

示例代码：

// 假设你已经有一个消费者的Connection实例consumerConnection
Session session = consumerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue(queueName);
MessageProducer producer = session.createProducer(queue);

// 直接构造BytesMessage发送原始字节数组
BytesMessage bytesMessage = session.createBytesMessage();
bytesMessage.writeBytes(message.getBytes(StandardCharsets.UTF_8)); // 直接写入原始字节
producer.send(bytesMessage);

// 用完关闭生产者，连接依然保留给消费者使用
producer.close();

这种方式完全复用现有消费者连接，无额外连接开销，且直接发送字节数据，不需要任何编码转换。

2. 使用Session的直接发送API（无显式生产者） #

如果不想显式创建MessageProducer，可以用Session的send方法直接发送消息到指定目的地，底层会自动复用内部的生产者实例，同样基于现有连接：

// 复用消费者连接的Session
Session session = consumerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue(queueName);

BytesMessage bytesMessage = session.createBytesMessage();
bytesMessage.writeBytes(message.getBytes(StandardCharsets.UTF_8));
session.send(queue, bytesMessage);

这个写法更简洁，无需手动管理生产者生命周期，同样满足“不创建新连接”的要求。

3. 改进QueueControl的使用，避免Base64编码 #

如果你坚持使用管理API的方式，不要用现有字符串参数的sendMessage方法，而是直接操作队列核心对象，添加原始字节消息：

// 获取队列的核心实例
Object queueControlObj = server.getManagementService().getResource(ResourceNames.QUEUE + queueName);
Queue queue = ((QueueControlImpl) queueControlObj).getQueue();

// 构造CoreMessage，直接写入字节
CoreMessage coreMessage = new CoreMessage(server.getStorageManager());
coreMessage.setBodyBuffer(server.getStorageManager().createBuffer(message.getBytes(StandardCharsets.UTF_8)));
coreMessage.setType(Message.BYTES_TYPE);

// 直接添加到队列
queue.addMessage(coreMessage, false, null, false);

这种方式绕过了需要编码的管理API接口，直接操作队列核心逻辑，发送原始字节数据，无需Base64转换。

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