phpredis消息队列_redis怎么实现消息队列？

把瞬间服务器的请求处理换成异步处理&＃xff0c;缓解服务器的压力&＃xff0c;实现数据顺序排列获取。本文主要和大家分享redis如何实现消息队列&＃xff0c;希望能帮助到大家。

消息队列&＃xff0c;通俗点说就是消息传输过程中暂时保存消息的容器&＃xff0c;可以在不同平台、不同语言的应用之间传输数据&＃xff0c;并且可以异步地实现数据写入&＃xff0c;在处理大并发问题时能起到很好的效果。

说一下我现在使用消息队列的场景&＃xff1a;我的系统需要实时接收来自客户端的请求(周期性请求)&＃xff0c;并且将请求的数据保存在数据库&＃xff0c;每次请求的数据量很小&＃xff0c;但是由于需要频繁操作数据库&＃xff0c;所以系统遭遇到性能瓶颈。原先的想法是直接将这些数据保存在redis中&＃xff0c;但仔细想想&＃xff0c;虽然每次的数据量不大&＃xff0c;但是由于数据是周期性的并且会不断增长&＃xff0c;虽然redis也有持久化功能&＃xff0c;但如果依靠持久化到硬盘来保存&＃xff0c;就失去了redis作为内存数据库的优势&＃xff0c;所以最终决定使用消息队列。

方式如下&＃xff1a;

每次请求的数据直接写入消息队列&＃xff0c;然后给予客户端响应&＃xff0c;后台开启一个线程监听消息队列&＃xff0c;一旦有数据写入&＃xff0c;取得消息队列中的数据写入mysql数据库&＃xff0c;这样就可以实现异步地将实时数据写入数据库&＃xff0c;避免系统因直接操作数据库造成的瓶颈。

那么问题来了&＃xff0c;使用哪种消息队列&＃xff0c;现在比较主流的消息队列如:RabbitMQ&＃xff0c;ActiveMQ等&＃xff0c;其技术比较成熟效率也很高。但是考虑到项目本身已经使用了redis(做缓存)&＃xff0c;并且每次的数据量比较小&＃xff0c;而redis不仅仅是一个key-value数据库&＃xff0c;它支持丰富的数据类型&＃xff0c;如HashMap、Set、List等&＃xff0c;其中的List完全可以作为消息队列使用&＃xff0c;并且redis的List支持blpop&＃xff0c;brpop等阻塞式的命令&＃xff0c;完全可以满足我的需求。简单的测试代码如下&＃xff1a;//产生数据

import redis.clients.jedis.Jedis;

public class RedisProducer {

/**

* jedis操作List

*/

public static void main(String[] args){

Jedis jedis &＃61; new Jedis("192.168.10.209", 6379);

for(int i &＃61; 0;i<10;i&＃43;&＃43;) {

jedis.lpush("informList","value_" &＃43; 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 &＃61; new ScheduleMQ();

mq.start();

}

}

class ScheduleMQ extends Thread {

&＃64;Override

public void run() {

while(true) {

Jedis jedis &＃61; new Jedis("192.168.10.209", 6379);

//阻塞式brpop&＃xff0c;List中无数据时阻塞

//参数0表示一直阻塞下去&＃xff0c;直到List出现数据

List list &＃61; jedis.brpop(0, "informList");

for(String s : list) {

System.out.println(s);

}

jedis.close();

}

}

}

相关推荐&＃xff1a;