@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 反向序列化慢 } }
时间: 2024-11-12 00:46:06