redis发布与订阅

以你之姓@ 2024-04-18 16:55 89阅读 0赞

1.  **publish/subscribe的用法**  
    *redis提供了如下6个命令来支持该功能：*
    
    subscribe subscribe channel \[channel …\] 订阅一个或多个频道  
    unsubscribe unsubscribe \[channel \[channel …\]\] 退订频道，如果没有指定频道，则退订所有的频道  
    publish publish channel message 给指定的频道发消息  
    psubscribe psubscribe pattern \[pattern …\] 订阅给定模式相匹配的所有频道  
    punsubscribe punsubscribe \[pattern \[pattern …\]\] 退订给定的模式，如果没有指定模式，则退订所有模式
2.  实现原理  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzIxNzA2NQ_size_16_color_FFFFFF_t_70]
3.  实现过期优惠卷处理  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzIxNzA2NQ_size_16_color_FFFFFF_t_70 1]
4.  代码实现  
    1）首先构造一个自定义的监听器

/**
     * 
     * @author FJW
     * onmessage:处理消息
     *  message:完整的消息
     *  pattern：获取的频道信息
     *
     */
    public class RedisMessageListener implements MessageListener {
    
    	@Override
    	public void onMessage(Message message, byte[] panttern) {
    		System.out.println("从channel为："+new String(message.getChannel())+"获取一条新的消息，消息内容为："+new String(message.getBody()));
    	}
    }

2）配置applicationContext.xml文件

<bean class="org.springframework.data.redis.listener.adapter.MessageListenerAdapter" id="messageListener">
    	<constructor-arg>
    		
    		<bean class="com.test.Listern.RedisMessageListener"></bean>
    	</constructor-arg>
    </bean>
    
    <bean class="org.springframework.data.redis.listener.RedisMessageListenerContainer" id="redisContainer">
    	
    	<property name="connectionFactory" ref="connectionFactory"/>
    	<property name="messageListeners">
    		<map>
    			<entry key-ref="messageListener">
    				
    				 <list>
    				 	<bean class="org.springframework.data.redis.listener.ChannelTopic">
    				 		<constructor-arg value="_keyevent@0__:expired"></constructor-arg>
    				 	</bean>
    				 </list>
    			</entry>
    		</map>
    	</property>
    </bean>

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzIxNzA2NQ_size_16_color_FFFFFF_t_70]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/bfcb552762594e9cbdbe468c11b472f2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzIxNzA2NQ_size_16_color_FFFFFF_t_70 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/0c3bbf3998aa4423ac9225226f0758d9.png