利用Redis 实现消息队列
2015-12-11 19:27
691 查看
1.用redis中的List可以实现队列,这样可以用来做消息处理和任务调度的队列
2.代码模拟
代码结构生产者模拟程序
/** * */ package scheduleTest; import java.util.Random; import java.util.UUID; import redis.clients.jedis.Jedis; /** * 模拟一个生产者 * <p>Title: TaskProducer</p> * <p>Description: </p> * <p>Company: </p> * @author 夏 杰 * @date 2015年12月11日 下午4:26:48 * @vesion 1.0 */ public class TaskProducer implements Runnable{ Jedis jedis = new Jedis("120.55.195.177",6379); public void run() { Random random = new Random(); while(true){ try{ Thread.sleep(random.nextInt(600) + 600); // 模拟生成一个任务 UUID taskid = UUID.randomUUID(); //将任务插入任务队列:task-queue jedis.lpush("task-queue", taskid.toString()); System.out.println("插入了一个新的任务: " + taskid); }catch(Exception e){ e.printStackTrace(); } } } }
消费者模拟程序
/** * */ package scheduleTest; import java.util.Random; import redis.clients.jedis.Jedis; /** * 模拟消费者 * <p>Title: TaskConsumer</p> * <p>Description: </p> * <p>Company: </p> * @author 夏 杰 * @date 2015年12月11日 下午4:44:23 * @vesion 1.0 */ public class TaskConsumer implements Runnable { Jedis jedis = new Jedis("120.55.195.177",6379); public void run() { Random random = new Random(); while(true){ //从任务队列"task-queue"中获取一个任务,并将该任务放入暂存队列"tmp-queue" String taskid = jedis.rpoplpush("task-queue", "tmp-queue"); // 处理任务----纯属业务逻辑,模拟一下:睡觉 try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } //模拟成功和失败的偶然现象 if(random.nextInt(13) % 7 == 0){// 模拟失败的情况,概率为2/13 //将本次处理失败的任务从暂存队列"tmp-queue"中,弹回任务队列"task-queue" jedis.rpoplpush("tmp-queue", "task-queue"); System.out.println(taskid + "处理失败,被弹回任务队列"); } else {// 模拟成功的情况 // 将本次任务从暂存队列"tmp-queue"中清除 jedis.rpop("tmp-queue"); System.out.println(taskid+"处理成功,被清除"); } } } }
调度主程序
/** * */ package scheduleTest; /** * <p>Title: TaskShedulerSystem</p> * <p>Description: </p> * <p>Company: </p> * @author 夏 杰 * @date 2015年12月11日 下午4:19:09 * @vesion 1.0 */ public class TaskShedulerSystem { public static void main(String[] args) throws Exception { // 启动一个生产者线程,模拟任务的产生 new Thread(new TaskProducer()).start(); Thread.sleep(15000); //启动一个线程者线程,模拟任务的处理 new Thread(new TaskConsumer()).start(); //主线程休眠 Thread.sleep(Long.MAX_VALUE); } }
运行结果
相关文章推荐
- Redis 作为缓存服务器的配置
- redis持久化,主从及数据备份
- Windows下Redis的安装使用
- 在redis一致性hash(shard)中使用lua脚本的坑
- nginx+tomcat+redis(单点)
- Tomcat7+Redis存储Session
- redis研究之watch
- Redis 学习手册之redis安装和配置
- 在 windows 环境下安装 redislive
- redis连接php
- redis连接java
- redis备份
- redis字符串
- 单线程你别阻塞,Redis时延问题分析及应对
- redis键
- Redis中List数据类型
- redis命令
- [转]Redis分布式锁服务
- redis命令之zadd
- 如何在 CentOS 7 上安装 Redis 服务器