主题解决

生成或使用消息时需要目标主题。 框架在以下有序位置查找以确定主题（在第一个查找处停止）：spring-doc.cadn.net.cn

通过默认机制之一找到主题时，无需在生产或消费 API 上指定主题。spring-doc.cadn.net.cn

当找不到主题时，API 将相应地抛出异常。spring-doc.cadn.net.cn

1. 用户指定

传递到正在使用的 API 中的主题具有最高的优先级（例如PulsarTemplate.send("my-topic", myMessage)或@PulsarListener(topics = "my-topic").spring-doc.cadn.net.cn

2. 消息类型默认

当没有主题传递到 API 时，系统会查找为正在生成或使用的消息类型配置的消息类型到主题的映射。spring-doc.cadn.net.cn

可以使用spring.pulsar.defaults.type-mappings财产。 以下示例使用application.yml配置使用或生产时要使用的默认主题Foo或Bar消息：spring-doc.cadn.net.cn

spring:
  pulsar:
    defaults:
      type-mappings:
        - message-type: com.acme.Foo
          topic-name: foo-topic
        - message-type: com.acme.Bar
          topic-name: bar-topic
这message-type是消息类的完全限定名称。
如果消息（或Publisher输入）是null，则框架将无法从中确定主题。如果您的应用程序可能会发送null消息。

2.1. 通过注释指定

如果没有主题传递到 API 并且未配置自定义主题映射，系统会查找@PulsarMessage正在生成或使用的消息类的注释。 可以通过topic属性。spring-doc.cadn.net.cn

以下示例配置了在生成或使用Foo:spring-doc.cadn.net.cn

@PulsarMessage(topic = "foo-topic")
record Foo(String value) {
}

属性占位符和 SpEL 表达式在@PulsarMessage注解 例如：spring-doc.cadn.net.cn

@PulsarMessage(topic = "${app.topics.foo}")
record Foo(String value) {
}

@PulsarMessage(topic = "#{someBean.getTopic()}")
record Bar(String value) {
}

2.2. 自定义主题解析器

添加映射的首选方法是通过上述属性。 但是，如果需要更多控制，您可以通过证明自己的实现来替换默认解析器，例如：spring-doc.cadn.net.cn

@Bean
public MyTopicResolver topicResolver() {
	return new MyTopicResolver();
}

3. 生产者全局默认

咨询的最终位置（生产时）是系统范围的生产者默认主题。 它是通过spring.pulsar.producer.topic-name使用命令式 API 时的属性和spring.pulsar.reactive.sender.topic-name属性。spring-doc.cadn.net.cn

4. 消费者全局默认

查询的最终位置（使用时）是系统范围的使用者默认主题。 它是通过spring.pulsar.consumer.topics或spring.pulsar.consumer.topics-pattern属性，并且spring.pulsar.reactive.consumer.topics或spring.pulsar.reactive.consumer.topics-pattern属性。spring-doc.cadn.net.cn