如何利用redis做消息队列 redis怎么做消息队列

文章摘要：如何利用redis做消息队列 redis怎么做消息队列

利用redis做消息队列的示例： 1.生产者模拟程序，代码： package scheduleTest; im […]

利用redis做消息队列的示例：

1.生产者模拟程序，代码：

package scheduleTest;

import java.util.Random;

import java.util.UUID;

import redis.clients.jedis.Jedis;

/**

* 模拟一个生产者

*

Title: TaskProducer

*

Description:

*

Company:

* @author 夏 杰

* @date 2020年12月8日 下午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();

}

}

}

}

2.消费者模拟程序，代码：

package scheduleTest;

import java.util.Random;

import redis.clients.jedis.Jedis;

/**

* 模拟消费者

*

Title: TaskConsumer

*

Description:

*

Company:

* @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+"处理成功，被清除");

}

}

}

}

3.调度主程序，代码：

package scheduleTest;

/**

*

Title: TaskShedulerSystem

*

Description:

*

Company:

* @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);

}

}