spring mvc redis消息队列

旧城等待， 2022-03-15 05:56 254阅读 0赞

通常情况下，为了提高系统开发的灵活性和可维护度，我们会采用消息队列队系统进行解耦。下面是一个采用spring redis实现的消息队列实例，但此实例会由于网络延迟和阻塞等情况导致消息处理的延时，因而不能确保消息处理的顺序，所以使用时需要注意。

*  pom.xml中添加如下配置

添加版本配置

<properties>
      <jedis.version>2.8.1</jedis.version>
      <spring-data-redis.version>1.7.2.RELEASE</spring-data-redis.version>
      <commons-pool2.version>2.2</commons-pool2.version>
    </properties>

<dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>${jedis.version}</version>
        </dependency>
    
        <dependency>
          <groupId>org.apache.commons</groupId>
          <artifactId>commons-pool2</artifactId>
          <version>${commons-pool2.version}</version>
        </dependency>
    
        
        <dependency>
          <groupId>org.springframework.data</groupId>
          <artifactId>spring-data-redis</artifactId>
          <version>${spring-data-redis.version}</version>
        </dependency>

*  properties文件中添加如下配置

#redis配置
    redis.host=192.168.1.150
    redis.port=6379
    redis.password=redis
    redis.timeout=2000
    redis.max_total=100
    redis.max_idle=20
    redis.min_idle=5
    redis.test_on_borrow=true
    redis.test_on_return=true

*  applicationContext.xml中添加如下配置：

<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
        <property name="maxIdle" value="${redis.max_idle}" />
        <property name="maxTotal" value="${redis.max_total}"/>
        <property name="minIdle" value="${redis.min_idle}"/>
        <property name="testOnBorrow" value="${redis.test_on_borrow}" />
        <property name="testOnReturn" value="${redis.test_on_return}"/>
    </bean>
    
    
    <bean id="redisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
        <property name="hostName" value="${redis.host}" />
        <property name="port" value="${redis.port}" />
        <property name="password" value="${redis.password}" />
        <property name="poolConfig" ref="jedisPoolConfig" />
    </bean>

*  定义消息发送者（生产者）：

@Component
    public class SendMessage {
    
        @Autowired
        private RedisTemplate<String, Object> redisTemplate;
    
        public void sendMessage(String channel, Serializable message) {
            redisTemplate.convertAndSend(channel, message);
        }
    }

*  定义消息处理者（消费者）：

public class ListenMessage {
        public void handleMessage(Serializable message){
            System.out.println(message);
        }
    }

*  调用：/queue/redis

@Controller
    @RequestMapping(value = "/queue")
    public class QueueController {
    
        @Autowired
        SendMessage sendMessage;
    
        @RequestMapping(value="/redis")
        public void redis(){
            for (int i = 0; i <1000; i++) {
                sendMessage.sendMessage("java",i);
            }
        }
    }

*  新建applicationContext-redis.xml，内容如下：

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xmlns:redis="http://www.springframework.org/schema/redis"
           xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/redis http://www.springframework.org/schema/redis/spring-redis.xsd">
    
        
        <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
            <property name="connectionFactory" ref="redisConnectionFactory"/>
        </bean>
    
        
        <bean id="jdkSerializer" class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer" />
    
        
        <bean id="messageDelegateListener" class="com.quartz.task.core.queue.ListenMessage"/>
    
        <bean id="messageListener" class="org.springframework.data.redis.listener.adapter.MessageListenerAdapter">
            <property name="delegate" ref="messageDelegateListener"/>
            <property name="serializer" ref="jdkSerializer" />
        </bean>
    
        
        <redis:listener-container>
            
            <redis:listener ref="messageListener" method="handleMessage" serializer="jdkSerializer" topic="java"/>
        </redis:listener-container>
    </beans>

特别申明，此文章转载自：[https://www.cnblogs.com/rwxwsblog/p/5889867.html][https_www.cnblogs.com_rwxwsblog_p_5889867.html]

[https_www.cnblogs.com_rwxwsblog_p_5889867.html]: https://www.cnblogs.com/rwxwsblog/p/5889867.html