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

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

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

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

<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>

server:
? port: 8888

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

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;
? ? }

? ? /**
? ? ?* 處理內(nèi)容
? ? ?* @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);
? ? }
}

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調(diào)訂單支付完成的消息
? ? ?* @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());
? ? ? ? }
? ? }
}