中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

redis如何實現異步隊列

小新
199
2021-01-21 12:10:32
欄目: 云計算

redis如何實現異步隊列

redis實現異步隊列的方法:

1.一般使用list結構作為隊列,rpush生產消息,lpop消費消息,當lpop沒有消息時,需適當sleep一會再重試。

示例:

public class RedisClient {

@Resource

private JedisPool jedisPool;

/**

* 向List頭部追加記錄

* @param key

* @param value

* @return 記錄總數

*/

public void rpush(String key, String value) {

Jedis jedis = null;

try {

jedis = jedisPool.getResource();

jedis.rpush(key,value);

} catch (Exception e) {

throw e;

} finally {

if(jedis != null){

jedis.close();

}

}

}

}

//controller寫一個寫入隊列的方法

@PostMapping("insert")

public void setList(@RequestBody QueueTest queueTest){

System.out.println("塞入一條數據");

redisClient.rpush("queueTest", JSON.toJSONString(queueTest));

}


0
寿宁县| 陈巴尔虎旗| 房山区| 宿迁市| 台南市| 长武县| 屯昌县| 万宁市| 中山市| 女性| 微山县| 花垣县| 栾川县| 宁陕县| 博野县| 阿图什市| 措勤县| 读书| 桂阳县| 自贡市| 吴川市| 嘉峪关市| 巴彦淖尔市| 喀什市| 常宁市| 湘潭市| 安阳县| 华池县| 南皮县| 嘉鱼县| 郧西县| 无棣县| 保山市| 汾阳市| 安图县| 伊春市| 浑源县| 洮南市| 兴义市| 从化市| 新巴尔虎右旗|