使用Redis队列推送消息，消息分发更快捷（redis队列消息推送）

越来越多的企业采用消息队列（Message Queue）的方式将消息发布到客户端的应用上，从而能够更有效地实现信息推送。而传统的消息队列解决方案中，Redis队列作为最实用的核心来实现消息推送功能，Redis具有多线程、高性能、开源免费等优势，因而在消息队列领域得到了广泛应用。

Redis队列使用起来非常灵活，它可以以字符串的形式存储消息数据，以列表的形式维护消息数据，也可以以散列表的形式储存消息数据，分别以LPUSH、LPOP、HSET、HGET等Redis命令操作。

以基于Spring Boot的Restful API示例演示Redis队列推送消息的方式，可以先在项目里添加Redis相关的依赖：

　　　org.springframework.boot

　　　spring-boot-starter-data-redis

之后可以在应用程序中配置Redis连接：

@Configuration

public class RedisConfiguration {

@Bean

public JedisConnectionFactory jedisConnectionFactory() {

return new JedisConnectionFactory();

}

@Bean

public RedisTemplateredisTemplate() {

RedisTemplatetemplate = new RedisTemplate();

template.setConnectionFactory(jedisConnectionFactory());

return template;

}

}

在这里，传入参数对象由Jackson构造出Json字符串，然后使用Redis命令LPUSH将该字符串放入Redis队列中：

@Autowired

private RedisTemplateredisTemplate;

public void push(String queueKey, Object obj) {

try {

// Jackson序列化对象为Json字符串

ObjectMapper mapper = new ObjectMapper();

String jsonStr = mapper.writeValueAsString(obj);

// 使用Redis命令LPUSH放入队列

redisTemplate.opsForList().leftPush(queueKey, jsonStr);

} catch (Exception e) {

e.printStackTrace();

}

}

其他应用程序可以使用Redis命令RPOP取出该字符串，再使用Jackson反序列化成对象，即实现消息的消费与推送传递：

public Object pull(String queueKey) {

try {

Object obj;

// 使用Redis命令RPOP取出队列中的消息

String jsonStr = (String) redisTemplate.opsForList().rightPop(queueKey);

// 使用Jackson反序列化出对象

ObjectMapper mapper = new ObjectMapper();

obj = mapper.readValue(jsonStr, Object.class);

return obj;

} catch (Exception e) {

e.printStackTrace();

return null;

}

}

从几十毫秒级到几百毫秒级等，Redis队列由于其灵活性和性能极高的特性，使得它的消息推送和消息分发变得更加迅速、高效，能够实现实时消息传输。正是由于这些优势，Redis队列在消息队列领域得到了广泛应用。

香港服务器首选树叶云，2H2G首月10元开通。
树叶云（shuyeidc.com）提供简单好用，价格厚道的香港/美国云服务器和独立服务器。IDC+ISP+ICP资质。ARIN和APNIC会员。成熟技术团队15年行业经验。