Spring Integration 2.1引入了對Redis?的支持：“一個開源的高級鍵值存儲”。 這種支持以基于 Redis 以及發布-訂閱消息傳遞適配器的形式出現，Redis 通過其PUBLISH、SUBSCRIBE和UNSUBSCRIBE?命令支持這些適配器。??MessageStore??

您需要將此依賴項包含在項目中：

    org.springframework.integration    spring-integration-redis    6.0.0

您還需要包含 Redis 客戶端依賴項，例如 Lettuce。

(相關資料圖)

要下載、安裝和運行 Redis，請參閱Redis 文檔。

連接到 Redis

要開始與 Redis 交互，您首先需要連接到它。 Spring Integration 使用另一個 Spring 項目 SpringData Redis提供的支持，該項目提供了典型的 Spring 構造：和 。 這些抽象簡化了與多個 Redis 客戶端 Java API 的集成。 目前，Spring Data Redis 支持Jedis和Lettuce。??ConnectionFactory????Template??

用??RedisConnectionFactory??

要連接到 Redis，您可以使用接口的實現之一。 以下清單顯示了接口定義：??RedisConnectionFactory??

public interface RedisConnectionFactory extends PersistenceExceptionTranslator {    /**     * Provides a suitable connection for interacting with Redis.     * @return connection for interacting with Redis.     */    RedisConnection getConnection();}

以下示例顯示了如何在 Java 中創建：??LettuceConnectionFactory??

LettuceConnectionFactory cf = new LettuceConnectionFactory();cf.afterPropertiesSet();

下面的示例展示了如何在 Spring 的 XML 配置中創建：??LettuceConnectionFactory??

的實現提供了一組屬性，例如端口和主機，您可以根據需要設置這些屬性。 擁有 的實例后，可以創建 的實例并將其注入 .??RedisConnectionFactory????RedisConnectionFactory????RedisTemplate????RedisConnectionFactory??

用??RedisTemplate??

與 Spring 中的其他模板類（例如 和 ）一樣，它是一個簡化 Redis 數據訪問代碼的輔助類。 有關及其變體的更多信息（例如），請參閱Spring Data Redis 文檔。??JdbcTemplate????JmsTemplate????RedisTemplate????RedisTemplate????StringRedisTemplate??

以下示例演示如何在 Java 中創建 的實例：??RedisTemplate??

RedisTemplate rt = new RedisTemplate();rt.setConnectionFactory(redisConnectionFactory);

下面的示例展示了如何在 Spring 的 XML 配置中創建 的實例：??RedisTemplate??

使用 Redis 發送消息

如簡介中所述，Redis 通過其 、 和命令提供對發布-訂閱消息傳遞的支持。 與JMS和AMQP一樣，Spring Integration提供了消息通道和適配器，用于通過Redis發送和接收消息。??PUBLISH????SUBSCRIBE????UNSUBSCRIBE??

瑞迪斯發布/訂閱頻道

與 JMS 類似，在某些情況下，生產者和使用者都打算成為同一應用程序的一部分，在同一進程中運行。 可以使用一對入站和出站通道適配器來實現此目的。 但是，與Spring Integration的JMS支持一樣，有一種更簡單的方法來解決這個用例。 您可以創建發布-訂閱通道，如以下示例所示：

A 的行為很像 Spring 集成主命名空間中的普通元素。 它可以由任何終結點的 和屬性引用。 不同之處在于，此通道由 Redis 主題名稱支持：屬性指定的值。 但是，與 JMS 不同的是，本主題不必提前創建，甚至不必由 Redis 自動創建。 在 Redis 中，主題是扮演地址角色的簡單值。 生成者和使用者可以使用與其主題名稱相同的值進行通信。 對此通道的簡單訂閱意味著可以在生產和消費終結點之間實現異步發布-訂閱消息傳遞。 但是，與通過在簡單的 Spring 集成元素中添加元素創建的異步消息通道不同，消息不會存儲在內存中隊列中。 相反，這些消息通過 Redis 傳遞，這使您可以依賴它對持久性和集群的支持以及與其他非 Java 平臺的互操作性。??publish-subscribe-channel????????input-channel????output-channel????String????topic-name????String????String??????????

Redis 入站通道適配器

Redis 入站通道適配器 （） 以與其他入站適配器相同的方式將傳入的 Redis 消息調整為 Spring 消息。 它接收特定于平臺的消息（在本例中為 Redis），并使用策略將它們轉換為 Spring 消息。 以下示例演示如何配置 Redis 入站通道適配器：??RedisInboundChannelAdapter????MessageConverter??

前面的示例顯示了 Redis 入站通道適配器的簡單但完整的配置。 請注意，前面的配置依賴于熟悉的 Spring 范式，即自動發現某些 bean。 在這種情況下，將隱式注入適配器。 可以改用屬性顯式指定它。??redisConnectionFactory????connection-factory??

另請注意，上述配置為適配器注入了自定義 . 該方法類似于 JMS，其中實例用于在 Redis 消息和 Spring 集成消息有效負載之間進行轉換。 默認值為 .??MessageConverter????MessageConverter????SimpleMessageConverter??

入站適配器可以訂閱多個主題名稱，因此屬性中的值集以逗號分隔。??topics??

從 V3.0 開始，除了現有屬性之外，入站適配器現在還具有該屬性。 此屬性包含一組以逗號分隔的 Redis 主題模式。 有關 Redis 發布-訂閱的更多信息，請參閱Redis 發布/訂閱。??topics????topic-patterns??

入站適配器可以使用 對 Redis 消息正文進行反序列化。 的屬性可以設置為空字符串，這將生成屬性的值。 在這種情況下，Redis 消息的原始正文作為消息有效負載提供。??RedisSerializer????serializer????????null????RedisSerializer????byte[]??

從 V5.0 開始，您可以使用 的屬性向入站適配器提供實例。 此外，收到的 Spring 集成消息現在具有指示已發布消息來源的標頭：主題或模式。 您可以將此下游用于路由邏輯。??Executor????task-executor????????RedisHeaders.MESSAGE_SOURCE??

Redis 出站通道適配器

Redis 出站通道適配器將傳出的 Spring 集成消息調整為 Redis 消息，方式與其他出站適配器相同。 它接收 Spring 集成消息，并使用策略將它們轉換為特定于平臺的消息（在本例中為 Redis）。 以下示例演示如何配置 Redis 出站通道適配器：??MessageConverter??

該配置與 Redis 入站通道適配器并行。 適配器隱式注入 ，該 定義為其 Bean 名稱。 此示例還包括可選（和自定義）（bean）。??RedisConnectionFactory????redisConnectionFactory????MessageConverter????testConverter??

從 Spring Integration 3.0 開始，提供了該屬性的替代方法：您可以使用該屬性在運行時確定消息的 Redis 主題。 這些屬性是互斥的。??????topic????topic-expression??

Redis 隊列入站通道適配器

Spring Integration 3.0引入了一個隊列入站通道適配器，用于從Redis列表中“彈出”消息。 默認情況下，它使用“右彈出”，但您可以將其配置為使用“左彈出”。 適配器是消息驅動的。 它使用內部偵聽器線程，不使用輪詢器。

以下清單顯示了 的所有可用屬性：??queue-inbound-channel-adapter??

Redis 隊列出站通道適配器

Spring Integration 3.0引入了一個隊列出站通道適配器，用于從Spring Integration消息“推送”到Redis列表。 默認情況下，它使用“左推”，但您可以將其配置為使用“右推”。 以下清單顯示了 Redis 的所有可用屬性：??queue-outbound-channel-adapter??

瑞迪斯應用程序事件

從 Spring Integration 3.0 開始，Redis 模塊提供了 的實現，而 又是一個 . 封裝了 Redis 操作的異常（端點是事件的“源”）。 例如，在捕獲操作中的異常后發出這些事件。 例外可以是任何泛型或 . 使用 處理這些事件對于確定后臺 Redis 任務的問題和采取管理操作非常有用。??IntegrationEvent????org.springframework.context.ApplicationEvent????RedisExceptionEvent????????BoundListOperations.rightPop????org.springframework.data.redis.RedisSystemException????org.springframework.data.redis.RedisConnectionFailureException??????

紅與紅消息存儲

如企業集成模式（EIP） 一書中所述，郵件存儲允許您保留消息。 當考慮可靠性時，這在處理具有緩沖消息功能的組件（聚合器、重新排序器等）時非常有用。 在 Spring 集成中，該策略還為聲明檢查模式提供了基礎，EIP 中也有描述。??MessageStore??

Spring 集成的 Redis 模塊提供了 . 以下示例演示如何將其與聚合器一起使用：??RedisMessageStore??

前面的示例是一個 Bean 配置，它需要 a 作為構造函數參數。??RedisConnectionFactory??

缺省情況下，使用 Java 序列化來序列化消息。 但是，如果要使用其他序列化技術（如 JSON），可以通過設置 .??RedisMessageStore????valueSerializer????RedisMessageStore??

從版本 4.3.10 開始，框架分別為實例和實例提供了 Jackson 序列化程序和解序列化程序實現 — 和 。 必須使用的選項配置它們。 此外，還應設置為每個序列化的復雜對象添加類型信息（如果您信任源）。 然后在反序列化期間使用該類型信息。 該框架提供了一個名為 的實用程序方法，該方法已隨前面提到的所有屬性和序列化程序一起提供。 此實用程序方法附帶一個參數，用于限制 Java 包進行反序列化以避免安全漏洞。 默認的受信任軟件包：、、。 若要在 中管理 JSON 序列化，必須以類似于以下示例的方式對其進行配置：??Message????MessageHeaders????MessageJacksonDeserializer????MessageHeadersJacksonSerializer????SimpleModule????ObjectMapper????enableDefaultTyping????ObjectMapper????JacksonJsonUtils.messagingAwareMapper()????trustedPackages????java.util????java.lang????org.springframework.messaging.support????org.springframework.integration.support????org.springframework.integration.message????org.springframework.integration.store????RedisMessageStore??

RedisMessageStore store = new RedisMessageStore(redisConnectionFactory);ObjectMapper mapper = JacksonJsonUtils.messagingAwareMapper();RedisSerializer