在兩個java項目中實現Redis的發布訂閱模式

如何在兩個java項目中實現Redis的發布訂閱模式?

    • 1. Redis簡介
    • 2. 發布訂閱模式介紹
    • 3. 實現思路
    • 4. 代碼實現及詳細解釋
      • 4.1. RedisUtil
      • 4.2. Publisher
      • 4.3. Subscriber
      • 4.4. 運行程序

目錄:

  1. Redis簡介
  2. 發布訂閱模式介紹
  3. 實現思路
  4. 代碼實現及詳細解釋

1. Redis簡介

Redis是一種高性能的鍵值存儲系統,常用于緩存、分布式會話和實時分析等場景。它支持多種數據結構(如字符串、哈希、列表、集合和有序集合),同時具備高速讀寫和持久化功能。

2. 發布訂閱模式介紹

Redis的發布訂閱模式是其提供的一種通信模式,在這種模式下,消息發布者將消息發送到一個頻道,所有訂閱該頻道的訂閱者都會收到這個消息。發布者和訂閱者之間通過頻道進行信息傳遞,可以實現解耦和異步處理。

3. 實現思路

要在兩個Java項目中實現Redis的發布訂閱模式,需要使用Redis的Java客戶端,如jedis或lettuce。下面是一種通用的實現思路:

  1. 引入Redis的Java客戶端依賴:
    在兩個項目的pom.xml文件中,引入Redis的Java客戶端依賴,如jedis或lettuce。可以通過Maven或Gradle等構建工具來管理依賴關系。

  2. 初始化Redis連接:
    在每個Java項目中,創建一個RedisUtil類來管理Redis連接。在該類中,可以通過配置文件或硬編碼的方式,初始化Redis連接池,并提供獲取和釋放連接的方法。

  3. 實現發布者:
    在發布者項目中,創建一個Publisher類,通過RedisUtil獲取Redis連接,并使用發布方法將消息發送到指定頻道。在頻道上發布消息時,可以將消息序列化為字符串或其他形式進行傳輸。

  4. 實現訂閱者:
    在訂閱者項目中,創建一個Subscriber類,通過RedisUtil獲取Redis連接,并注冊一個監聽器來監聽指定頻道上的消息。當有消息發布到頻道上時,監聽器會調用相應的處理邏輯。

4. 代碼實現及詳細解釋

4.1. RedisUtil

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;/*** @author linx 2023-10-24 20:50*/
public class RedisUtil {private static JedisPool jedisPool;// 初始化Redis連接public static void initRedisPool() {JedisPoolConfig config = new JedisPoolConfig();config.setMaxTotal(100);config.setMaxIdle(20);config.setMaxWaitMillis(10000);config.setTestOnBorrow(true);jedisPool = new JedisPool(config, "redis-server", 6379);}// 獲取Redis連接public static Jedis getJedis() {if (jedisPool == null) {initRedisPool();}return jedisPool.getResource();}// 釋放Redis連接public static void releaseJedis(Jedis jedis) {if (jedis != null) {jedis.close();}}public static void set(String key, String value, int expireSeconds) {Jedis jedis = null;try {jedis = getJedis();jedis.set(key, value);if (expireSeconds > 0) {jedis.expire(key, expireSeconds);}} finally {releaseJedis(jedis);}}public static String get(String key) {Jedis jedis = null;try {jedis = getJedis();return jedis.get(key);} finally {releaseJedis(jedis);}}public static void delete(String key) {Jedis jedis = null;try {jedis = getJedis();jedis.del(key);} finally {releaseJedis(jedis);}}public static Boolean exists(String key) {Jedis jedis = null;try {jedis = getJedis();return jedis.exists(key);} finally {releaseJedis(jedis);}}public static void publish(String channel, String content) {Jedis jedis = null;try {jedis = getJedis();jedis.publish(channel, content);} finally {releaseJedis(jedis);}}public static void main(String[] args){RedisUtil.publish("TESTCHANNEL:001","你好啊");}
}

上述代碼中,我們使用了jedis作為Redis的Java客戶端。在RedisUtil中,初始化了一個Redis連接池,并提供獲取和釋放連接的方法。

4.2. Publisher

import redis.clients.jedis.Jedis;public class Publisher {public static void main(String[] args) {Jedis jedis = RedisUtil.getJedis();jedis.publish("channel", "Hello, Redis!");RedisUtil.releaseJedis(jedis);}
}

上述代碼中,我們通過RedisUtil獲取一個Redis連接,并使用publish方法將消息發送到名為"channel"的頻道上。

4.3. Subscriber

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPubSub;/*** @author linx 2023-11-24 4:06*/
public class Subscriber extends JedisPubSub {@Overridepublic void onMessage(String channel, String message) {System.out.println("Received message: " + message);}public static void main(String[] args) {Jedis jedis = RedisUtil.getJedis();Subscriber subscriber = new Subscriber();jedis.subscribe(subscriber, "TESTCHANNEL:001");RedisUtil.releaseJedis(jedis);}
}

上述代碼中,我們創建了一個繼承自JedisPubSub的Subscriber類,并重寫了onMessage方法來處理接收到的消息。然后,我們通過RedisUtil獲取一個Redis連接,并使用subscribe方法注冊一個監聽器,來監聽名為"channel"的頻道上的消息。

4.4. 運行程序

在這里插入圖片描述

在Publisher項目中運行Publisher類,它會向名為"channel"的頻道發布一條消息"你好啊"。然后,在Subscriber項目中運行Subscriber類,它會監聽"channel"頻道上的消息,并在接收到消息時打印出來。

至此,我們已經完成了在兩個Java項目中實現Redis的發布訂閱模式。

總結:
Redis的發布訂閱模式是一種解耦和異步處理的通信模式。通過Redis的Java客戶端,我們可以輕松地在多個Java項目中實現該模式。本文通過RedisUtil類對Redis連接進行管理,并通過Publisher和Subscriber類實現了消息的發布和訂閱。希望本文對你有所幫助。

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/news/165102.shtml
繁體地址,請注明出處:http://hk.pswp.cn/news/165102.shtml
英文地址,請注明出處:http://en.pswp.cn/news/165102.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

HTB Napper WriteUp

Napper 2023年11月12日 14:58:35User Nmap ? Napper nmap -sCV -A -p- 10.10.11.240 --min-rate 10000 Starting Nmap 7.80 ( https://nmap.org ) at 2023-11-12 13:58 CST Nmap scan report for app.napper.htb (10.10.11.240) Host is up (0.15s latency). Not shown: …

gitee推薦-SAPI++

一下內容來自gitee。 SaaS-Apps-Engine: 智者|SAPI是多應用、多租戶SaaS應用引擎,支持(小程序/公眾號/輕應用/企微/抖音/支付寶/百度)等多平臺應用。基于ThinkPHP6.1/8.0原生多應用模式開發,簡潔、高效、易擴展。集成強大的權限控…

適用于電腦的5個免費文件恢復軟件分享

適用于電腦的最佳免費文件恢復軟件 任何計算機用戶都可能經歷過丟失重要文件的恐懼。重要數據的丟失可能會令人不安和沮喪,無論是由于不小心刪除、計算機故障還是硬盤格式化造成的。幸運的是,在數字時代,您可以使用值得信賴的解決方案檢索這些…

好工具|datamap,一個好用的地圖可視化Excel插件,在Excel中實現地理編碼、拾取坐標

在做VRP相關研究的時候,需要對地圖數據做很多處理,比如地理編碼,根據“重慶市沙坪壩區沙正街174號”這樣的一個文本地址知道他的經緯度;再比如繪制一些散點圖,根據某個位置的經緯度在地圖上把它標注出來。還有有的時候…

vue + docxtemplater 導出 word 文檔

一、痛點 word 導出 這種功能其實之前都是后端實現的,但最近有個項目沒得后端。所以研究下前端導出。 ps: 前端還可以導出 pdf,但是其分頁問題需要話精力去計算才可能實現,并且都不是很完善。可參考之前的文章:利用 h…

MIT6.824-Raft筆記:腦裂、Majority Vote(過半投票/過半選舉)

本部分主要是問題引入,以及給出一個解決方案 1 腦裂(Split Brain) replication system的共同點:單點 前面幾個容錯特性(fault-tolerant)的系統,有一個共同的特點。 MapReduce復制了計算&…

JavaScript框架 Angular、React、Vue.js 的全棧解決方案比較

在 Web 開發領域,JavaScript 提供大量技術棧可供選擇。其中最典型的三套組合,分別是 MERN、MEAN 和 MEVN。前端框架(React、Angular 和 Vue)進行簡化比較。 MERN 技術棧詳解 MERN 技術棧包含四大具體組件: MongoDB&am…

藍橋杯物聯網競賽_STM32L071_3_Oled顯示

地位: 對于任何一門編程語言的學習,print函數毫無疑問是一種最好的調試手段,調試者不僅能通過它獲取程序變量的運行狀態而且通過對其合理使用獲取程序的運行流程,更能通過關鍵變量的輸出幫你驗證推理的正確與否,樸素的…

常見網絡安全防護

1 阻斷服務攻擊(DOS) 阻斷服務攻擊,想辦法目標網絡資源用盡變種:分布式阻斷服務攻擊 影響: 寬帶消耗性(消耗目標的帶寬)資源消耗型(消耗目標的計算資源) 解決方案&am…

人工智能對網絡安全的影響越來越大

如果問當前IT行業最熱門的話題是什么,很少有人會回答除了人工智能(AI)之外的任何話題。 在不到 12 個月的時間里,人工智能已經從一項只有 IT 專業人員才能理解的技術發展成為從小學生到作家、程序員和藝術家的每個人都使用的工具…

MySQL索引事務基礎

目錄 1. 索引 1.1索引的概念 1.2索引的特點 1.3 索引的使用場景 1.4索引的使用 1.4.1查看索引 1.4.2創建索引 1.4.3刪除索引 1.5索引保存的數據結構 2.事務 2.1經典例子 2.2事務的概念 2.3事務的使用 2.4事務的4個核心特性 2.5事務的并發問題 2.5.1臟讀 2.5.2不可…

Python + Docker 還是 Rust + WebAssembly?

在不斷發展的技術世界中,由大語言模型驅動的應用程序,通常被稱為“LLM 應用”,已成為各種行業技術創新背后的驅動力。隨著這些應用程序的普及,用戶需求的大量涌入對底層基礎設施的性能、安全性和可靠性提出了新的挑戰。 Python 和…

Java項目如何打包成Jar(最簡單)

最簡單的辦法,使用Maven插件(idea自帶) 1.選擇需要打包的mudule,點擊idea右側的maven插件 2.clean操作 3.選擇需要的其他mudule,進行install操作(如果有) 4.再次選擇需要打包的module&#…

Vue.observable 是什么

Observable 翻譯過來我們可以理解成可觀察的 Vue.js2.6 新增 Vue.observable,讓一個對象變成響應式數據。Vue 內部會用它來處理 data 函數返回的對象 。 返回的對象可以直接用于渲染函數和計算屬性內,并且會在發生變更時觸發相應的更新。也可以作為最小化…

Git的指令

Git 各平臺安裝包下載地址為:http://git-scm.com/downloads Ubuntu Git 安裝命令為: $ apt-get install git用戶信息 配置個人的用戶名稱和電子郵件地址: $ git config --global user.name "runoob" $ git config --global user.…

Python----類對象和實例對象

目錄 一.類和類的實例 二.類屬性和實例屬性 三.私有屬性和公有屬性 四.靜態方法和類方法 五.__init__方法,__new__方法和__del__方法: 六.私有方法和公有方法 七.方法的重載 八.方法的繼承 九.方法的重寫 十.對象的特殊方法 十一.對象的引用&a…

軟件開發模式開源和閉源的優劣之爭

開源和閉源,兩種截然不同的開發模式,對于大模型的發展有著重要影響。開源讓技術共享,吸引了眾多人才加入,推動了大模的創新。而閉源則保護了商業利益和技術優勢,為大模型的商業應用提供了更好的保障。 開源與閉源軟件的…

基于命令行模式設計退款請求處理

前言 這篇文章的業務背景是基于我的另一篇文章: 對接蘋果支付退款退單接口-CSDN博客 然后就是說設計模式是很開放的東西,可能我覺得合適,你可能覺得不合適,這里只是做下討論,沒有一定要各位同意的意思.... 相關圖文件 這里我先把相關的圖文件放上來,可能看著會比較清晰點 代碼邏…

sql之left join、right join、inner join的區別

sql之left join、right join、inner join的區別 left join(左聯接) 返回包括左表中的所有記錄和右表中聯結字段相等的記錄 right join(右聯接) 返回包括右表中的所有記錄和左表中聯結字段相等的記錄 inner join(等值連接) 只返回兩個表中聯結字段相等的行 舉例如下&#xff1…

Web服務器(go net/http) 處理Get、Post請求

大家好 我是寸鐵👊 總結了一篇Go Web服務器(go net/http) 處理Get、Post請求的文章? 喜歡的小伙伴可以點點關注 💝 前言 go http請求如何編寫簡單的函數去拿到前端的請求(Get和Post) 服務器(后端)接收到請求后,又是怎么處理請求&#xff0c…