Spring AMQP项目(二)中,有哪些关键特性或使用场景?
- 内容介绍
- 文章标签
- 相关推荐
本文共计18034个文字,预计阅读时间需要73分钟。
4.1.5 发送消息发送消息时,您可以使用以下方法:- 使用 `send(Message message)` 方法发送消息。- 使用 `send(String routingKey, Message message)` 方法发送消息,并指定路由键。- 使用 `send(String exchange, String routingKey, Message message)` 方法发送消息,并指定交换机和路由键。
4.1.5. 发送消息
发送消息时,您可以使用以下任一方法:
void send(Message message) throws AmqpException;void send(String routingKey, Message message) throws AmqpException;void send(String exchange, String routingKey, Message message) throws AmqpException;我们可以从前面清单中的最后一种方法开始讨论,因为它实际上是最明确的。 它允许在运行时提供 AMQP 交换名称(以及路由密钥)。 最后一个参数是负责实际创建消息实例的回调。 使用此方法发送消息的示例可能如下所示: 下面的示例演示如何使用该方法发送消息:send
amqpTemplate.send("marketData.topic", "quotes.nasdaq.THING1", new Message("12.34".getBytes(), someProperties));如果您计划使用该模板实例大部分或所有时间发送到同一交易所,则可以在模板本身上设置属性。 在这种情况下,可以使用前面清单中的第二种方法。
本文共计18034个文字,预计阅读时间需要73分钟。
4.1.5 发送消息发送消息时,您可以使用以下方法:- 使用 `send(Message message)` 方法发送消息。- 使用 `send(String routingKey, Message message)` 方法发送消息,并指定路由键。- 使用 `send(String exchange, String routingKey, Message message)` 方法发送消息,并指定交换机和路由键。
4.1.5. 发送消息
发送消息时,您可以使用以下任一方法:
void send(Message message) throws AmqpException;void send(String routingKey, Message message) throws AmqpException;void send(String exchange, String routingKey, Message message) throws AmqpException;我们可以从前面清单中的最后一种方法开始讨论,因为它实际上是最明确的。 它允许在运行时提供 AMQP 交换名称(以及路由密钥)。 最后一个参数是负责实际创建消息实例的回调。 使用此方法发送消息的示例可能如下所示: 下面的示例演示如何使用该方法发送消息:send
amqpTemplate.send("marketData.topic", "quotes.nasdaq.THING1", new Message("12.34".getBytes(), someProperties));如果您计划使用该模板实例大部分或所有时间发送到同一交易所,则可以在模板本身上设置属性。 在这种情况下,可以使用前面清单中的第二种方法。

