SpringBoot+Redis实现消息的发布与订阅的示例代码

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 {

    /**

      * 监听订单支付完成主题

      */

    private static final String ORDER_PAY_SUCCESS = "ORDER-PAY-SUCCESS" ;

    /**

      * 注入消息监听适配器

      * @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" );

    }

    /**

      * 注入消息监听容器

      * @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);

    }

}

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;

    /**

      * 模拟发送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());

        }

    }

}