发送消息
JmsTemplate 包含许多用于发送消息的便捷方法。发送方法使用 jakarta.jms.Destination 对象指定目标，而其他方法使用 JNDI 查找中的 String 指定目标。不带目标参数的 send 方法使用默认目标。
以下示例使用 MessageCreator 回调从提供的 Session 对象创建文本消息
import jakarta.jms.ConnectionFactory;
import jakarta.jms.JMSException;
import jakarta.jms.Message;
import jakarta.jms.Queue;
import jakarta.jms.Session;
import org.springframework.jms.core.MessageCreator;
import org.springframework.jms.core.JmsTemplate;
public class JmsQueueSender {
private JmsTemplate jmsTemplate;
private Queue queue;
public void setConnectionFactory(ConnectionFactory cf) {
this.jmsTemplate = new JmsTemplate(cf);
}
public void setQueue(Queue queue) {
this.queue = queue;
}
public void simpleSend() {
this.jmsTemplate.send(this.queue, new MessageCreator() {
public Message createMessage(Session session) throws JMSException {
return session.createTextMessage("hello queue world");
}
});
}
}在前面的示例中，JmsTemplate 是通过传递对 ConnectionFactory 的引用来构造的。作为替代方案，提供了零参数构造函数和 connectionFactory，可用于以 JavaBean 样式（使用 BeanFactory 或普通 Java 代码）构造实例。或者，考虑从 Spring 的 JmsGatewaySupport 方便的基类派生，该类为 JMS 配置提供了预构建的 bean 属性。
send(String destinationName, MessageCreator creator) 方法允许您使用目标的字符串名称发送消息。如果这些名称在 JNDI 中注册，则应将模板的 destinationResolver 属性设置为 JndiDestinationResolver 的实例。
如果您创建了 JmsTemplate 并指定了默认目标，则 send(MessageCreator c) 会向该目标发送消息。
使用消息转换器
为了方便发送域模型对象，JmsTemplate 提供了多种发送方法，这些方法接受 Java 对象作为消息数据内容的参数。JmsTemplate 中的重载方法 convertAndSend() 和 receiveAndConvert() 将转换过程委托给 MessageConverter 接口的实例。该接口定义了一个简单的契约，用于在 Java 对象和 JMS 消息之间进行转换。默认实现（SimpleMessageConverter）支持在 String 和 TextMessage、byte[] 和 BytesMessage 以及 java.util.Map 和 MapMessage 之间进行转换。通过使用转换器，您和您的应用程序代码可以专注于通过 JMS 发送或接收的业务对象，而不必关心它如何表示为 JMS 消息。
沙箱目前包含一个 MapMessageConverter，它使用反射在 JavaBean 和 MapMessage 之间进行转换。您可以自己实现的其他流行的实现选择是使用现有 XML 序列化包（例如 JAXB 或 XStream）创建表示对象的 TextMessage 的转换器。
为了适应设置消息属性、头和主体（这些属性不能在转换器类中泛型封装），MessagePostProcessor 接口允许您在消息转换后但发送之前访问消息。以下示例展示了如何在将 java.util.Map 转换为消息后修改消息头和属性。
public void sendWithConversion() {
Map map = new HashMap();
map.put("Name", "Mark");
map.put("Age", new Integer(47));
jmsTemplate.convertAndSend("testQueue", map, new MessagePostProcessor() {
public Message postProcessMessage(Message message) throws JMSException {
message.setIntProperty("AccountID", 1234);
message.setJMSCorrelationID("123-00001");
return message;
}
});
}这将生成以下形式的消息
MapMessage={
Header={
... standard headers ...
CorrelationID={123-00001}
}
Properties={
AccountID={Integer:1234}
}
Fields={
Name={String:Mark}
Age={Integer:47}
}
}
