SpringBoot+Redis實現消息的發(fā)布與訂閱的示例代碼

更新時間：2022年04月08日 16:10:17 作者：逆著黑夜便是光

本文主要介紹了SpringBoot+Redis實現消息的發(fā)布與訂閱，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧

1.什么是redis的發(fā)布與訂閱

在官網的文檔介紹中有一行介紹：Redis是一個快速穩(wěn)定的發(fā)布/訂閱消息系統。

2.Redis發(fā)布訂閱

機制

Redis提供了發(fā)布與訂閱的功能，可以用于消息的傳輸，Redis的發(fā)布訂閱機制包括三部分，發(fā)布者、訂閱者和Channel（主題或者隊列）。

3.命令行實現功能

訂閱主題

Redis采用SUBSCRIBE channel命令訂閱某個主題，返回的參數subscribe表示已經成功訂閱主題，第二個參數表示訂閱的主題名稱，第三個表示當前訂閱數

127.0.0.1:6379> SUBSCRIBE ORDER-PAY-SUCCESS
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "ORDER-PAY-SUCCESS"
3) (integer) 1

模式匹配訂閱

模式匹配功能是允許客戶端訂閱匹配某種模式的頻道，Redis采用PSUBSCRIBE channel命令訂閱匹配某種模式的所有頻道，用*表示模式，*可以被任意值代替。

127.0.0.1:6379> PSUBSCRIBE ORDER-PAY-*
Reading messages... (press Ctrl-C to quit)
1) "psubscribe"
2) "ORDER-PAY-*"
3) (integer) 1

發(fā)布消息

Redis采用PUBLISH channel message命令在某個主題上發(fā)布消息，返回的參數是接收到消息的訂閱者個數

127.0.0.1:6379> PUBLISH ORDER-PAY-SUCCESS DD202109071525
(integer) 1

取消訂閱

Redis采用UNSUBSCRIBE channel或PUNSUBSCRIBE channel命令取消某個主題的訂閱，由于Redis的訂閱操作是阻塞式的，因此一旦客戶端訂閱了某個頻道或模式，就將會一直處于訂閱狀態(tài)直到退出。在 SUBSCRIBE，PSUBSCRIBE，UNSUBSCRIBE 和 PUNSUBSCRIBE 命令中，其返回值都包含了該客戶端當前訂閱的頻道和模式的數量，當這個數量變?yōu)?時，該客戶端會自動退出訂閱狀態(tài)。

127.0.0.1:6379> UNSUBSCRIBE ORDER-PAY-SUCCESS
1) "unsubscribe"
2) "ORDER-PAY-SUCCESS"
3) (integer) 0
127.0.0.1:6379> PUNSUBSCRIBE ORDER-PAY-SUCCESS
1) "punsubscribe"
2) "ORDER-PAY-SUCCESS"
3) (integer) 0

測試

首先三個訂閱者訂閱ORDER-PAY-SUCCESS主題，當發(fā)送者在這個主題內發(fā)送訂單號時，所有的訂閱者都會收到這個主題的消息。

4.SpringBoot實現功能

Springboot整合Redis

引入依賴包

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
            <version>2.2.10.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <version>2.2.10.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
            <version>2.4.1</version>
        </dependency>
    </dependencies>

配置yaml文件

server:
? port: 8888

spring:
? application:
? ? name: spring-boot-redis
? redis:
? ? host: 127.0.0.1
? ? port: 6379

配置消息監(jiān)聽

import com.demo.redis.listener.MessageListener;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.listener.PatternTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;

/**
?* @author Bai
?* @date 2021/4/29 上午 11:17
?* @description
?*/
@Configuration
public class RedisMessageConfig {

? ? /**
? ? ?* 監(jiān)聽訂單支付完成主題
? ? ?*/
? ? private static final String ORDER_PAY_SUCCESS = "ORDER-PAY-SUCCESS";

? ? /**
? ? ?* 注入消息監(jiān)聽適配器
? ? ?* @param messageListener
? ? ?* @return {@link MessageListenerAdapter}
? ? ?* @throws
? ? ?* @author Bai
? ? ?* @date 2021/9/7 下午 03:54
? ? ?*/
? ? @Bean
? ? public MessageListenerAdapter getMessageListenerAdapter(MessageListener messageListener){
? ? ? ? return new MessageListenerAdapter(messageListener, "onMessage");
? ? }

? ? /**
? ? ?* 注入消息監(jiān)聽容器
? ? ?* @param redisConnectionFactory
? ? ?* @param messageListenerAdapter
? ? ?* @return {@link RedisMessageListenerContainer}
? ? ?* @throws
? ? ?* @author Bai
? ? ?* @date 2021/9/7 下午 03:54
? ? ?*/
? ? @Bean
? ? public RedisMessageListenerContainer getRedisMessageListenerContainer(RedisConnectionFactory redisConnectionFactory, MessageListenerAdapter messageListenerAdapter){
? ? ? ? RedisMessageListenerContainer redisMessageListenerContainer = new RedisMessageListenerContainer();
? ? ? ? redisMessageListenerContainer.setConnectionFactory(redisConnectionFactory);

? ? ? ? //訂閱訂單支付成功主題
? ? ? ? redisMessageListenerContainer.addMessageListener(messageListenerAdapter, new PatternTopic(ORDER_PAY_SUCCESS));
? ? ? ? return redisMessageListenerContainer;
? ? }

? ? /**
? ? ?* 處理內容
? ? ?* @param connectionFactory
? ? ?* @return {@link StringRedisTemplate}
? ? ?* @throws
? ? ?* @author Bai
? ? ?* @date 2021/9/7 下午 04:01
? ? ?*/
? ? @Bean
? ? StringRedisTemplate template(RedisConnectionFactory connectionFactory) {
? ? ? ? return new StringRedisTemplate(connectionFactory);
? ? }
}

接收消息

import org.springframework.stereotype.Component;

/**
?* @author Bai
?* @date 2021/9/7 下午 03:51
?* @description
?*/
@Component
public class MessageListener {

? ? public void onMessage(String message){
? ? ? ? System.out.println("接收消息：" + message);
? ? }
}

測試

發(fā)送訂單支付成功的消息

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.test.context.junit4.SpringRunner;

import javax.annotation.Resource;

/**
?* @author Bai
?* @date 2021/9/7 下午 04:32
?* @description
?*/
@RunWith(value = SpringRunner.class)
@SpringBootTest
public class RedisPubTest {

? ? /**
? ? ?* 訂單支付完成主題
? ? ?*/
? ? private static final String ORDER_PAY_SUCCESS = "ORDER-PAY-SUCCESS";

? ? @Resource
? ? private StringRedisTemplate stringRedisTemplate;

? ? /**
? ? ?* 模擬發(fā)送5調訂單支付完成的消息
? ? ?* @throws
? ? ?* @author Bai
? ? ?* @date 2021/9/7 下午 04:57
? ? ?*/
? ? @Test
? ? public void sendMessage(){
? ? ? ? for (int i = 0; i < 5; i++) {
? ? ? ? ? ? stringRedisTemplate.convertAndSend(ORDER_PAY_SUCCESS,"DD" + System.currentTimeMillis());
? ? ? ? }
? ? }
}

接收到訂單支付成功的消息

. ____ _ __ _ _
/\\ / ___'_ __ _ _(_)_ __ __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
\\/ ___)| |_)| | | | | || (_| | ) ) ) )
' |____| .__|_| |_|_| |_\__, | / / / /
=========|_|==============|___/=/_/_/_/
:: Spring Boot :: (v2.2.10.RELEASE)

2021-09-07 16:56:54.729 INFO 3712 --- [ main] com.demo.redis.RedisSubPubApplication : Starting RedisSubPubApplication on DESKTOP-595LI4G with PID 3712 (D:\Bai\Sources\spring-boot-demo\redis-sub-pub\target\classes started by 1 in D:\Bai\Sources\spring-boot-demo)
2021-09-07 16:56:54.735 INFO 3712 --- [ main] com.demo.redis.RedisSubPubApplication : No active profile set, falling back to default profiles: default
2021-09-07 16:56:55.205 INFO 3712 --- [ main] .s.d.r.c.RepositoryConfigurationDelegate : Multiple Spring Data modules found, entering strict repository configuration mode!
2021-09-07 16:56:55.207 INFO 3712 --- [ main] .s.d.r.c.RepositoryConfigurationDelegate : Bootstrapping Spring Data Redis repositories in DEFAULT mode.
2021-09-07 16:56:55.229 INFO 3712 --- [ main] .s.d.r.c.RepositoryConfigurationDelegate : Finished Spring Data repository scanning in 11 ms. Found 0 Redis repository interfaces.
2021-09-07 16:56:55.557 INFO 3712 --- [ main] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat initialized with port(s): 8888 (http)
2021-09-07 16:56:55.565 INFO 3712 --- [ main] o.apache.catalina.core.StandardService : Starting service [Tomcat]
2021-09-07 16:56:55.565 INFO 3712 --- [ main] org.apache.catalina.core.StandardEngine : Starting Servlet engine: [Apache Tomcat/9.0.38]
2021-09-07 16:56:55.669 INFO 3712 --- [ main] o.a.c.c.C.[Tomcat].[localhost].[/] : Initializing Spring embedded WebApplicationContext
2021-09-07 16:56:55.669 INFO 3712 --- [ main] w.s.c.ServletWebServerApplicationContext : Root WebApplicationContext: initialization completed in 895 ms
2021-09-07 16:56:56.032 INFO 3712 --- [ main] o.s.s.concurrent.ThreadPoolTaskExecutor : Initializing ExecutorService 'applicationTaskExecutor'
2021-09-07 16:56:56.950 INFO 3712 --- [ main] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat started on port(s): 8888 (http) with context path ''
2021-09-07 16:56:56.952 INFO 3712 --- [ main] com.demo.redis.RedisSubPubApplication : Started RedisSubPubApplication in 2.557 seconds (JVM running for 3.436)
接收消息：DD1631005025949
接收消息：DD1631005025964
接收消息：DD1631005025965
接收消息：DD1631005025967
接收消息：DD1631005025968

到此這篇關于SpringBoot+Redis實現消息的發(fā)布與訂閱的示例代碼的文章就介紹到這了,更多相關SpringBoot Redis消息發(fā)布與訂閱內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

Springboot打包部署代碼實例
這篇文章主要介紹了Springboot打包部署代碼實例,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
2020-01-01
spring security CSRF防護的示例代碼
這篇文章主要介紹了spring security CSRF防護的示例代碼,小編覺得挺不錯的，現在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
2019-03-03
Java中JSON字符串進行各種轉換的方法小結
Gson和Hutool的JSONUtil都是常用的用于處理JSON數據的工具庫,它們提供了簡單易用的API來進行JSON字符串的解析、轉換和操作,下面就跟隨小編一起學習一下如果使用他們實現JSON字符串的各種轉換吧
2024-01-01
Spring配置文件如何使用${username}
這篇文章主要介紹了Spring配置文件如何使用${username},文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
2020-02-02
Java刪除二叉搜索樹最大元素和最小元素的方法詳解
這篇文章主要介紹了Java刪除二叉搜索樹最大元素和最小元素的方法,結合實例形式詳細分析了java針對二叉搜索樹的基本遍歷、查找、判斷、刪除等相關操作技巧,需要的朋友可以參考下
2020-03-03
Java中EnumSet代替位域代碼詳解
這篇文章主要介紹了Java中EnumSet代替位域代碼詳解，分享了相關代碼示例，小編覺得還是挺不錯的，具有一定借鑒價值，需要的朋友可以參考下
2018-02-02
SpringBoot3.2.2整合MyBatis Plus3.5.5的詳細過程
這篇文章給大家介紹了SpringBoot3.2.2整合MyBatis Plus3.5.5的詳細過程,文中通過代碼示例給大家介紹的非常詳細,對大家的學習或工作有一定的幫助,需要的朋友可以參考下
2024-01-01
Java實現的文件過濾代碼分享（按后輟過濾）
這篇文章主要介紹了Java實現的文件過濾代碼分享,本文通過后輟名過濾,代碼寫簡潔,容易看懂,需要的朋友可以參考下
2014-07-07
使用javassist動態(tài)生成類的配置代碼
Javassist它是一個用 Java 編輯字節(jié)碼的類庫，它使 Java 程序能夠在運行時定義新類，并在 JVM 加載時修改類文件，本文給大家介紹使用javassist動態(tài)生成類的實例代碼，感興趣的朋友一起看看吧
2022-09-09
Java集合框架迭代器Iterator實現原理解析
這篇文章主要介紹了Java集合框架迭代器Iterator實現原理解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
2020-08-08