Spring Cloud GCP 發(fā)布到主題

2024-01-09 17:36 更新

PubSubTemplate提供了異步方法來將消息發(fā)布到Google Cloud Pub / Sub主題。publish()方法采用主題名稱以將消息發(fā)布到通用類型的有效負(fù)載以及（可選）帶有消息頭的映射中。

以下是如何將消息發(fā)布到Google Cloud Pub / Sub主題的示例： 

public void publishMessage() {
    this.pubSubTemplate.publish("topic", "your message payload", ImmutableMap.of("key1", "val1"));
}

默認(rèn)情況下，SimplePubSubMessageConverter用于將類型為byte[]，ByteString，ByteBuffer和String的有效載荷轉(zhuǎn)換為Pub / Sub消息。

JSON支持

要使用Jackson JSON對(duì)POJO進(jìn)行序列化和反序列化，請(qǐng)配置JacksonPubSubMessageConverter bean，GCP Pub / Sub的Spring Boot入門程序會(huì)自動(dòng)將其連接到PubSubTemplate。 

// Note: The ObjectMapper is used to convert Java POJOs to and from JSON.
// You will have to configure your own instance if you are unable to depend
// on the ObjectMapper provided by Spring Boot starters.
@Bean
public JacksonPubSubMessageConverter jacksonPubSubMessageConverter(ObjectMapper objectMapper) {
    return new JacksonPubSubMessageConverter(objectMapper);
}

另外，您可以通過調(diào)用PubSubTemplate上的setMessageConverter()方法直接進(jìn)行設(shè)置。PubSubMessageConverter的其他實(shí)現(xiàn)也可以相同的方式配置。

請(qǐng)參考我們的發(fā)布/訂閱JSON有效負(fù)載示例應(yīng)用程序，以作為使用此功能的參考。

以上內(nèi)容是否對(duì)您有幫助：
在線筆記
App下載
App下載

掃描二維碼

下載編程獅App

公眾號(hào)
微信公眾號(hào)

編程獅公眾號(hào)