配置文件

     
         
          
      
              
          
                
                 
                 
                     
                          
         
          classpath:redis-context-config.properties
                       
                  
             
                    
            
                
               
                 
                 
             
              
            
                
                 
                 
                 
                 
         
                         
             
                  
                
               
                   
                
               
                   
                
             
          
              
              
              
                
                 
             
                
               
               
                    
                
           
          
      
      
      
          
          
                
           
      
     

 

Demo演示：

消息发布端: 

package com.iwhere.testredis;import org.junit.Before;import org.junit.Test;import org.springframework.context.support.ClassPathXmlApplicationContext;import org.springframework.data.redis.core.StringRedisTemplate;/** * 测试redis做消息 * @author 231 * */public class TestRedis {    private StringRedisTemplate redisTemplate;    @Before    public void before() {        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:redis-context.xml");        redisTemplate = context.getBean(StringRedisTemplate.class);    }        private String channel = "amap";    /**     * 测试连接     */    @Test    public void test1() {        String message = "c26c4ac0-37a3-4277-9020-bfa274c058f5|526548902996869120|Success";        redisTemplate.convertAndSend(channel, message);        System.out.println("发送完成");    }}

消息接收端

package com.iwhere.redis.sub;import java.io.UnsupportedEncodingException;import org.aspectj.bridge.Message;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.data.redis.connection.MessageListener;import org.springframework.data.redis.listener.ChannelTopic;/**  *  */public class MessageDelegateListenerImpl implements MessageListener {        @Autowired    private ChannelTopic channelTopic;        @Override    public void onMessage(org.springframework.data.redis.connection.Message message, byte[] pattern) {        byte[] bytes = message.getBody();// ""里面的参数为需要转化的编码，一般是ISO8859-1        try {            String str = new String(bytes, "utf-8");            System.out.println("I am here" + str + ": " +  channelTopic.getTopic());        } catch (UnsupportedEncodingException e) {            // TODO Auto-generated catch block            e.printStackTrace();        }        System.out.println(message);    }}

 redis的资源文件

#redis.host=dev.iwhere.comredis.host=192.168.1.110redis.port=6379redis.pass=redis密码, 没有密码就注释掉redis.default.db=0redis.timeout=100000redis.maxActive=300redis.maxIdle=100redis.maxWait=1000redis.testOnBorrow=true