把瞬间服务器的请求处理换成异步处理，缓解服务器的压力，实现数据顺序排列获取。本文主要和大家分享redis如何实现消息队列，希望能帮助到大家。
消息队列，通俗点说就是消息传输过程中暂时保存消息的容器，可以在不同平台、不同语言的应用之间传输数据，并且可以异步地实现数据写入，在处理大并发问题时能起到很好的效果。
说一下我现在使用消息队列的场景：我的系统需要实时接收来自客户端的请求（周期性请求），并且将请求的数据保存在数据库，每次请求的数据量很小，但是由于需要频繁操作数据库，所以系统遭遇到性能瓶颈。原先的想法是直接将这些数据保存在redis中，但仔细想想，虽然每次的数据量不大，但是由于数据是周期性的并且会不断增长，虽然redis也有持久化功能，但如果依靠持久化到硬盘来保存，就失去了redis作为内存数据库的优势，所以最终决定使用消息队列。
方式如下：
每次请求的数据直接写入消息队列，然后给予客户端响应，后台开启一个线程监听消息队列，一旦有数据写入，取得消息队列中的数据写入mysql数据库，这样就可以实现异步地将实时数据写入数据库，避免系统因直接操作数据库造成的瓶颈。
那么问题来了，使用哪种消息队列，现在比较主流的消息队列如:RabbitMQ，ActiveMQ等，其技术比较成熟效率也很高。但是考虑到项目本身已经使用了redis（做缓存），并且每次的数据量比较小，而redis不仅仅是一个key-value数据库，它支持丰富的数据类型，如HashMap、Set、List等，其中的List完全可以作为消息队列使用，并且redis的List支持blpop，brpop等阻塞式的命令，完全可以满足我的需求。简单的测试代码如下：
bee餐饮点餐外卖小程序是针对餐饮行业推出的一套完整的餐饮解决方案，实现了用户在线点餐下单、外卖、叫号排队、支付、配送等功能，完美的使餐饮行业更高效便捷！功能演示：1、桌号管理登录后台，左侧菜单 “桌号管理”，添加并管理你的桌号信息，添加以后在列表你将可以看到 ID 和 密钥，这两个数据用来生成桌子的二维码2、生成桌子二维码例如上面的ID为 308，密钥为 d3PiIY，那么现在去左侧菜单微信设置
//产生数据
import redis.clients.jedis.Jedis;
public class RedisProducer {
/**
* jedis操作List
*/
public static void main(String[] args){
Jedis jedis = new Jedis("192.168.10.209", 6379);
for(int i = 0;i<10;i++) {
jedis.lpush("informList","value_" + i);
}
jedis.close();
}
}
//消费数据
import java.util.List;
import redis.clients.jedis.Jedis;
public class RedisConsumer {
/**
* jedis操作List
*/
public static void main(String[] args){
ScheduleMQ mq = new ScheduleMQ();
mq.start();
}
}
class ScheduleMQ extends Thread {
@Override
public void run() {
while(true) {
Jedis jedis = new Jedis("192.168.10.209", 6379);
//阻塞式brpop，List中无数据时阻塞
//参数0表示一直阻塞下去，直到List出现数据
List list = jedis.brpop(0, "informList");
for(String s : list) {
System.out.println(s);
}
jedis.close();
}
}
} 相关推荐：
