Spring RedisTemplate操作-发布订阅操作

Posted 2020-09-13 aoeiuv

@Component("sub")
public class Sub implements MessageListener{
    
    @Autowired
    private StringRedisSerializer stringRedisSerializer;
    

    /* (非 Javadoc)
     * Description:
     * @see org.springframework.data.redis.connection.MessageListener#onMessage(org.springframework.data.redis.connection.Message, byte[])
     */
    @Override
    public void onMessage(Message message, byte[] pattern) {
        byte[] body = message.getBody();//请使用valueSerializer  
        byte[] channel = message.getChannel();  
        String msg = (String)stringRedisSerializer.deserialize(body);  
        String topic = (String)stringRedisSerializer.deserialize(channel);
        System.out.println("我是sub,监听"+topic+",我收到消息："+msg);
    }

}

@Component("sub2")
public class Sub2 implements MessageListener{
    
    @Autowired
    private StringRedisSerializer stringRedisSerializer;
    
    @Autowired
    private JdkSerializationRedisSerializer jdkSerializationRedisSerializer;
    

    /* (非 Javadoc)
     * Description:
     * @see org.springframework.data.redis.connection.MessageListener#onMessage(org.springframework.data.redis.connection.Message, byte[])
     */
    @Override
    public void onMessage(Message message, byte[] pattern) {
        byte[] body = message.getBody();//请使用valueSerializer  
        byte[] channel = message.getChannel();  
        String msg = (String)stringRedisSerializer.deserialize(body);  
        String topic = (String)stringRedisSerializer.deserialize(channel);
        System.out.println("我是sub2,监听"+topic+",我收到消息："+msg);
    }

}

@Component("sub3")
public class Sub3 implements MessageListener{
    
    @Autowired
    private GenericJackson2JsonRedisSerializer jackson2JsonRedisSerializer;
    @Autowired
    private StringRedisSerializer stringRedisSerializer;
    
    @Autowired
    private JdkSerializationRedisSerializer jdkSerializationRedisSerializer;
    

    /* (非 Javadoc)
     * Description:
     * @see org.springframework.data.redis.connection.MessageListener#onMessage(org.springframework.data.redis.connection.Message, byte[])
     */
    @Override
    public void onMessage(Message message, byte[] pattern) {
        
        byte[] body = message.getBody();//请使用valueSerializer  
        byte[] channel = message.getChannel();  
        User u = jackson2JsonRedisSerializer.deserialize(body,User.class);  
       
        String topic = (String)stringRedisSerializer.deserialize(channel);
        System.out.println("我是sub3,监听"+topic+",我收到消息："+u.getId()+"--"+u.getName());
    }

}

@Service
public class Pub {
    
    @Autowired
    @Resource(name="redisTemplate")
    private RedisTemplate<String, String> rt;
    
    @Autowired
    private GenericJackson2JsonRedisSerializer jackson2JsonRedisSerializer;
    
    @Autowired
    private JdkSerializationRedisSerializer jdkSerializationRedisSerializer;
    
    public void sendMessage(String channel, String message) {  
        rt.convertAndSend(channel, message);  
    }
    public void sendMessage(String channel, User user) {
        byte[] msg =jackson2JsonRedisSerializer.serialize(user);
        rt.convertAndSend(channel, new String(msg));  
        
//        rt.convertAndSend(channel, user);  
    }
    
}

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = "classpath:conf/spring/spring*.xml")
public class PubSubTest {
    
    @Autowired
    private Pub pub;
    
    @Test
    public void test() throws InterruptedException{
        User u  = new User();
        u.setId("1");
        u.setName("wzg");
        pub.sendMessage("dddchannel", "我发消息了");
        pub.sendMessage("cccchannel", u);
        Thread.sleep(100);//jackson 反向序列化慢

    }
    

}