2. 程式人生 > >spring boot 使用redis進行釋出訂閱

spring boot 使用redis進行釋出訂閱

阿新 • • 發佈：2018-12-30
@Configuration public class RedisListenerConfig { /** * redis訊息監聽器容器 * 可以新增多個監聽不同話題的redis監聽器，只需要把訊息監聽器和相應的訊息訂閱處理器繫結，該訊息監聽器 * 通過反射技術呼叫訊息訂閱處理器的相關方法進行一些業務處理 * @param connectionFactory * @param listenerAdapter * @return */ @Bean RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter ) { RedisMessageListenerContainer container
= new RedisMessageListenerContainer(); container.setConnectionFactory(connectionFactory); //可以新增多個 messageListener container.addMessageListener(listenerAdapter, new PatternTopic("index")); return container; } /** * 訊息監聽器介面卡，繫結訊息處理器，利用反射技術呼叫訊息處理器的業務方法 *
@param redisReceiver * @return */ @Bean MessageListenerAdapter listenerAdapter(RedisReceiver redisReceiver) { System.out.println("訊息介面卡進來了"); return new MessageListenerAdapter(redisReceiver, "receiveMessage"); } //使用預設的工廠初始化redis操作模板 @Bean StringRedisTemplate template(RedisConnectionFactory connectionFactory) {
return new StringRedisTemplate(connectionFactory); } }

相關推薦

spring boot 使用redis進行釋出訂閱

@Configuration public class RedisListenerConfig { /** * redis訊息監聽器容器 * 可以新增多個監聽不同話題的redis監聽器，只需要把訊息監聽器和相應的訊息訂閱處理器繫結，該訊息監聽器 * 通過反射技術呼叫訊息訂

Spring+Redis 進行釋出訂閱

訊息是許多軟體架構的重要組成部分。訊息傳遞解決方案提供了高效能，可擴充套件性，佇列永續性和耐用性，故障轉移支援等，以及許多更漂亮具備的功能，在Java世界中大多總是使用JMS實現。後來使用Apache ActiveMQ的，有時只是需要簡單的排隊支援，而Apach

Spring boot整合websocket實現分散式websocketsession共享(一)--基於redis的釋出訂閱

本文主要是針對分散式場景下的使用websocket的一個解決方案。我們以下面的圖來說明下業務使用場景。   針對如圖的情況，很多人第一時間想到的是websocket的session共享，這是大多數的第一反應。很遺憾的是，websocketsession是不支援序列化操作

Spring MVC + redis 訊息的訂閱釋出

釋出訂閱(pub/sub)是一種訊息通訊模式，主要的目的是解耦訊息釋出者和訊息訂閱者之間的耦合，這點和設計模式中的觀察者模式比較相似。pub /sub不僅僅解決釋出者和訂閱者直接程式碼級別耦合也解決兩者在物理部署上的耦合。redis作為一個pub/sub server，在

python操作redis進行釋出和訂閱訊息

在遠端伺服器安裝redis，並啟動 訂閱端程式碼 import redis pool=redis.ConnectionPool(host='192.168.100.30',

spring boot redis分布式鎖

supported 分布式架構 tsig utils ali 成了 down eva -- 隨著現在分布式架構越來越盛行，在很多場景下需要使用到分布式鎖。分布式鎖的實現有很多種，比如基於數據庫、 zookeeper 等，本文主要介紹使用 Redis 做分布式鎖的方式，並封

spring boot redis

redis spring bootdependency <dependency> <groupId>org.springframework.boot</groupId> <artifactId>sp

開發者測試-采用精準測試工具對Spring Boot應用進行測試

新建 之間 分享 maven倉庫 第一個 項目 數據傳輸 寫實 blog 簡介：本文主要介紹把現今主流的springboot框架項目和精準測試工具進行結合和應用，通過精準測試的數據穿透、數據采集、測試用例與代碼的雙向追溯、數據分析等一系列精準測試的特有功能，達到對項目質量的

Spring Boot Redis Cluster 實戰幹貨

code ring from 連接超時 row comm reply with 大連 添加配置信息 spring.redis: database: 0 # Redis數據庫索引（默認為0） #host: 192.168.1.8 #port: 6379 pas

Spring Boot Redis session共享

Spring Boot Redis session共享 配置Maven依賴 RedisSessionConfig application.properties application.yml 配置Maven依賴 <dep

spring-boot+Redis實現簡單的分散式叢集session共享

  寫在前面：      首先宣告，筆者是一名Java程式設計屆的小學生。前面一直在幾家公司裡面做開發，其實都是一些傳統的專案，對於像分散式啦，叢集啦一些大型的專案接觸的很少，所以一直沒有自己整合和實現過。由於最近幾天專案不是很忙，自己又有點時間

【星雲測試】開發者測試-採用精準測試工具對Spring Boot應用進行測試

簡介：本文主要介紹把現今主流的springboot框架專案和精準測試工具進行結合和應用，通過精準測試的資料穿透、資料採集、測試用例與程式碼的雙向追溯、資料分析等一系列精準測試的特有功能，達到對專案質量的保證。 　 本次環境搭建分為基礎環境準備、springboot環境搭建、精準測試環境搭建、精準

springboot(二十)：使用spring-boot-admin對spring-boot服務進行監控

上一篇文章《springboot(十九)：使用Spring Boot Actuator監控應用》介紹了Spring Boot Actuator的使用，Spring Boot Actuator提供了對單個Spring Boot的監控，資訊包含：應用狀態、記憶體、執行緒、堆疊

使用spring-boot-admin對spring-boot服務進行監控

一 服務端 1.建立一個web專案 <parent> <groupId>org.springframework.boot</groupId> <

Spring Boot Redis-Sentinel—實現Redis高可用之哨兵模式

廢話簡論     Redis高可用之哨兵模式它就是,當你的reids掛掉了之後,它可以自己切換到其他redis上.不影響使用者的正常使用. 簡述Sentinel:      Sentinel具有四個特點: 監控,通知,自動故障轉移,配置提供者 監控：哨兵不斷的檢查ma

Spring Boot學習-快速搭建 Actuator和spring boot admin 進行監控（八）

1 搭建SpringBoot admin 服務端     建立springBoot 專案並引入springBoot admin 服務端的依賴。 <dependency> <gro

redis 訊息釋出訂閱與訊息佇列

redis可以實現訊息的釋出訂閱,可以用作java中的訂閱釋出模式 純粹redis的釋出訂閱  redis客戶端1中使用命令 SUBSCRIBE talk 可以訂閱通道 talk上的訊息  redis客戶端2中也同樣執行這個命令一起訂閱通道 talk  redis客

spring boot redis pool配置版本問題

spring boot 1.x版本redis配置 redis: database: 0 host: localhost port: 6379 password: pool: max-

spring boot redis做為訊息佇列

SpringBoot基於Redis快速實現訊息佇列     1.常用訊息佇列工具            目前常用的訊息佇列大概有三種類型，RabbitMQ等AMQP系列，kafka，Redis等key value系列，他們的使用場景分別是：            1，r

Spring Boot Redis Cache應用

1.pom檔案 <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchem