redisTemplate阻塞式处理消息队列

用redis中的List可以实现队列，这样可以用来做消息处理和任务调度的队列

文章目录

Redis 消息队列
redis五种数据结构
队列生产者
队列消费者
测试类
并发情况下使用increment递增
- 线程一：
- 线程二：
借鉴

Redis 消息队列

redis五种数据结构

队列生产者

package cn.stylefeng.guns.knowledge.modular.knowledge.schedule;import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.core.RedisTemplate;import java.util.Random;
import java.util.UUID;/*** <p>* 队列生产者* </p>** @SINCE 2021/11/30 21:03* @AUTHOR dispark* @Date: 2021/11/30 21:03*/
@Slf4j
public class QueueProducer implements Runnable {/*** 生产者队列 key*/public static final String QUEUE_PRODUCTER = "queue-producter";private RedisTemplate<String, Object> redisTemplate;public QueueProducer(RedisTemplate<String, Object> redisTemplate) {this.redisTemplate = redisTemplate;}@Overridepublic void run() {Random random = new Random();while (true) {try {Thread.sleep(random.nextInt(600) + 600);// 1.模拟生成一个任务UUID queueProducerId = UUID.randomUUID();// 2.将任务插入任务队列：queue-producterredisTemplate.opsForList().leftPush(QUEUE_PRODUCTER, queueProducerId.toString());log.info("生产一条数据 >>> {}", queueProducerId.toString());} catch (Exception e) {e.printStackTrace();}}}
}

队列消费者

package cn.stylefeng.guns.knowledge.modular.knowledge.schedule;import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.core.RedisTemplate;import java.util.Random;/*** <p>* 队列消费者* </p>** @SINCE 2021/11/30 21:14* @AUTHOR dispark* @Date: 2021/11/30 21:14*/
@Slf4j
public class QueueConsumer implements Runnable {public static final String QUEUE_PRODUCTER = "queue-producter";public static final String TMP_QUEUE = "tmp-queue";private RedisTemplate<String, Object> redisTemplate;public QueueConsumer(RedisTemplate<String, Object> redisTemplate) {this.redisTemplate = redisTemplate;}/*** 功能描述: 取值 - <brpop：阻塞式> - 推荐使用** @author dispark* @date 2021/11/30 21:17*/@Overridepublic void run() {Random random = new Random();while (true) {// 1.从任务队列"queue-producter"中获取一个任务，并将该任务放入暂存队列"tmp-queue"Long ququeConsumerId = redisTemplate.opsForList().rightPush(QUEUE_PRODUCTER, TMP_QUEUE);// 2.处理任务----纯属业务逻辑，模拟一下：睡觉try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}// 3.模拟成功和失败的偶然现象,模拟失败的情况,概率为2/13if (random.nextInt(13) % 7 == 0) {// 4.将本次处理失败的任务从暂存队列"tmp-queue"中，弹回任务队列"queue-producter"redisTemplate.opsForList().rightPush(TMP_QUEUE, QUEUE_PRODUCTER);log.info(ququeConsumerId + "处理失败，被弹回任务队列");} else {// 5. 模拟成功的情况,将本次任务从暂存队列"tmp-queue"中清除redisTemplate.opsForList().rightPop(TMP_QUEUE);log.info(ququeConsumerId + "处理成功，被清除");}}}
}

测试类

    @Testpublic void QueueThreadTotalEntry() throws Exception {// 1.启动一个生产者线程，模拟任务的产生new Thread(new QueueProducer(redisTemplate)).start();Thread.sleep(15000);// 2.启动一个线程者线程，模拟任务的处理new Thread(new QueueConsumer(redisTemplate)).start();// 3.主线程Thread.sleep(Long.MAX_VALUE);}

并发情况下使用increment递增

线程一：

Long increment = redisTemplate.opsForValue().increment("increment", 1L);log.info("队列消费者 >> increment递增: {}", increment);

线程二：

Long increment = redisTemplate.opsForValue().increment("increment", 1L);log.info("生产者队列 >> increment递增: {}", increment);

借鉴

redis实现消息队列&发布/订阅模式使用
redisTemplate处理/获取redis消息队列

redisTemplate阻塞式处理消息队列相关推荐

阻塞双端消息队列 BlockingDeque（先进先出的原则管理）
昨晚为了赶项目,干到两点钟,不过也有收获,来自华为的大神,在我们公司做后台,教了我一招好用的消息队列管理方法,分享给大家了. 既是一个队列的生产者又是这个队列的消费者的时候可以使用到 Blocking ...
进程间通信的方式（三）：消息队列
消息队列是在两个不相关进程间传递数据的一种简单.高效方式,她独立于发送进程.接受进程而存在.消息队列提供了一种从一个进程向另一个进程发送一个数据块的方法.每个数据块都被认为是一个管道,接收进程可以独 ...
进程间通信IPC（一）（半双工管道和消息队列）
引言: 之前学习的进程之间交换信息的方法只能由fork或exec传送打开文件,或者文件系统.但是这种通讯方式有局限性,接下来将说明进程之间相互通信的其他技术--IPC(InterProcessComm ...
POSIX和SYSTEM的消息队列应该注意的问题
首先看看POSIX的代码: 1.posix_mq_server.c #include <mqueue.h> #include <sys/stat.h> #include < ...
jmstemplate 获取队列id_学习Linux（38）消息队列
消息队列.共享内存和信号量被统称为 system-V IPC,V 是罗马数字 5,是 Unix 的AT&T 分支的其中一个版本,一般习惯称呼他们为 IPC 对象,这些对象的操作接口都比较 ...
linux 消息队列_Linux消息队列
消息队列,Unix的通信机制之一,可以理解为是一个存放消息(数据)容器.将消息写入消息队列,然后再从消息队列中取消息,一般来说是先进先出的顺序.可以解决两个进程的读写速度不同(处理数据速度不同),系统 ...
为什么要使用kafka消息队列
1.为什么要使用 kafka?为什么要使用消息队列? 缓冲和削峰:上游数据时有突发流量,下游可能扛不住,或者下游没有足够多的机器来保证冗余,kafka在中间可以起到一个缓冲的作用,把消息暂存在kafk ...
【Linux Program】信号量、共享内存和消息队列
系列文章: 文件操作数据管理进程和信号 POSIX 线程进程间通信:管道信号量共享内存和消息队列套接字文章目录 1. 信号量 1.1 信号量的定义 1.2 Linux 的信号量机制 1.3 ...
Linux消息队列编程（简单应用）
消息队列,Unix的通信机制之一,可以理解为是一个存放消息(数据)容器.将消息写入消息队列,然后再从消息队列中取消息,一般来说是先进先出的顺序.可以解决两个进程的读写速度不同(处理数据速度不同),系统 ...

redisTemplate阻塞式处理消息队列

文章目录

Redis 消息队列

redis五种数据结构

队列生产者

队列消费者

测试类

并发情况下使用increment递增

线程一：

线程二：

借鉴

redisTemplate阻塞式处理消息队列相关推荐

最新文章

热门文章