SpringBoot+消息队列——Redis

一时失言乱红尘 2023-02-28 11:25 23阅读 0赞

1.新建一个maven项目并添加相应的依赖pom.xml

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
      <modelVersion>4.0.0</modelVersion>
    
      <groupId>com.demo</groupId>
      <artifactId>redis</artifactId>
      <version>0.0.1-SNAPSHOT</version>
      <packaging>jar</packaging>
    
      <name>redis</name>
      <url>http://maven.apache.org</url>
    
      <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <java.version>1.8</java.version>
      </properties>
      
       <parent>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-parent</artifactId>
          <version>2.0.3.RELEASE</version>
          <relativePath/>
       </parent>
    
      <dependencies>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
        		<artifactId>spring-boot-starter-web</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
        		<artifactId>spring-boot-starter-test</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-data-redis</artifactId>
    		</dependency>
      </dependencies>
    </project>

2.新建一个消息接受者，为正常的Bean

package com.demo.redis.sys.bean;
    
    import java.util.concurrent.CountDownLatch;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Autowired;
    
    public class Receiver { 
    
    	private static final Logger LOGGER = LoggerFactory.getLogger(Receiver.class);
    	
    	private CountDownLatch countDownLatch;
    
    	@Autowired
    	public Receiver(CountDownLatch countDownLatch) { 
    		this.countDownLatch = countDownLatch;
    	}
    	//消息接收到处理方式
    	public void receiverMessage(String message) { 
    		LOGGER.info("Received < {} >", message);
    		countDownLatch.countDown();
    	}
    }

3.配置Redis相关参数以及消息队列

package com.demo.redis.sys.bean;
    
    import java.util.Arrays;
    import java.util.Collection;
    import java.util.Collections;
    import java.util.HashMap;
    import java.util.HashSet;
    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.CountDownLatch;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.data.redis.connection.MessageListener;
    import org.springframework.data.redis.connection.RedisConnectionFactory;
    import org.springframework.data.redis.connection.RedisPassword;
    import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
    import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
    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.Topic;
    import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;
    
    @Configuration
    public class ReceiverConfig { 
    	//向容器放入接收对象
    	@Bean
    	public Receiver receiver(@Autowired CountDownLatch latch) { 
    		return new Receiver(latch);
    	}
    	//提供给接收对象实体
    	@Bean
    	public CountDownLatch countDownLatch() { 
    		return new CountDownLatch(1);
    	}
    	//redis
    	@Bean
    	public StringRedisTemplate stringRedisTemplate(@Autowired RedisConnectionFactory connectionFactory) { 
    		return new StringRedisTemplate(connectionFactory);
    	}
    	//redis连接工厂里面参数可以放入到application.properties内通过@value注解引入
    	@Bean
    	public RedisConnectionFactory redisConnectionFactory() { 
    		RedisStandaloneConfiguration configuration = new RedisStandaloneConfiguration("192.168.1.22", 32768);
    		configuration.setDatabase(0);
    		RedisPassword password = RedisPassword.of("123456");
    		configuration.setPassword(password);
    		LettuceConnectionFactory factory = new LettuceConnectionFactory(configuration);
    		return factory;
    	}
    	//redis消息监听容器
    	@Bean
    	public RedisMessageListenerContainer container (@Autowired RedisConnectionFactory connectionFactory,
    			@Autowired MessageListenerAdapter listenerAdapter) { 
    		RedisMessageListenerContainer container = new RedisMessageListenerContainer();
    		container.setConnectionFactory(connectionFactory);
    		container.addMessageListener(listenerAdapter, Arrays.asList(new PatternTopic("chat")));//chat为redis中的key
    		return container;
    	}
    	//消息监听路由
    	@Bean
    	public MessageListenerAdapter listenerAdapter(@Autowired Receiver receiver) { 
    		//receiver 接受者 receiverMessage执行的方法
    		return new MessageListenerAdapter(receiver, "receiverMessage");
    	}
    	
    }

4.创建启动测试

package com.demo.redis;
    
    import java.util.concurrent.CountDownLatch;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.context.ApplicationContext;
    import org.springframework.data.redis.core.StringRedisTemplate;
    
    /** * Hello world! * */
    @SpringBootApplication
    public class RedisApplication 
    { 
    	private static final Logger LOGGER = LoggerFactory.getLogger(RedisApplication.class);
    	
        public static void main( String[] args ) throws InterruptedException
        { 
            ApplicationContext ctx = SpringApplication.run(RedisApplication.class, args);
            StringRedisTemplate redisTemplate = ctx.getBean(StringRedisTemplate.class);
            CountDownLatch countDownLatch = ctx.getBean(CountDownLatch.class);
            LOGGER.info("Sending Message...");
            redisTemplate.convertAndSend("chat", "Hello From Redis!");
            countDownLatch.await();
            System.exit(0);
        }
    }

查看控制台方法是否正确