ADADADADAD

redis如何实现异步队列[ 建站问答 ]

建站问答时间：2024-12-01 19:11:14

作者：文/会员上传

幻兽帕鲁孵化器制作在哪里

简介：

redis实现异步队列的方法：1.一般使用list结构作为队列，rpush生产消息，lpop消费消息，当lpop没有消息时，需适当sleep一会再重试。示例：publicclassRedisClient{@ResourceprivateJedi

以下为本文的正文内容，内容仅供参考！本站为公益性网站，复制本文以及下载DOC文档全部免费。

redis实现异步队列的方法：

1.一般使用list结构作为队列，rpush生产消息，lpop消费消息，当lpop没有消息时，需适当sleep一会再重试。

示例：

publicclassRedisClient{
@Resource
privateJedisPooljedisPool;
/**
*向List头部追加记录
*@paramkey
*@paramvalue
*@return记录总数
*/
publicvoidrpush(Stringkey,Stringvalue){
Jedisjedis=null;
try{
jedis=jedisPool.getResource();
jedis.rpush(key,value);
}catch(Exceptione){
throwe;
}finally{
if(jedis!=null){
jedis.close();
}
}
}
}
//controller写一个写入队列的方法
@PostMapping("insert")
publicvoidsetList(@RequestBodyQueueTestqueueTest){
System.out.println("塞入一条数据");
redisClient.rpush("queueTest",JSON.toJSONString(queueTest));
}