您的位置:首页 > 数据库 > Redis

使用redis list作为消息队列

2017-11-16 16:52 846 查看
public String popAnswer() {
return stringRedisTemplate.opsForList().rightPop("zd:answercard");
}

public String bpopAnswer() {
return stringRedisTemplate.opsForList().rightPop("zd:answercard", 0, TimeUnit.SECONDS);
}

// public void listen() {

// while (true) {

// String answercard = answerCardDDao.popAnswer();

// if (answercard == null) {

// try {

// TimeUnit.SECONDS.sleep(2);

// } catch (InterruptedException e) {

// e.printStackTrace();

// }

// } else {

// computeScore(answercard);

// }

// }

// }

public void listen() {
while (true) {
String answercard = answerCardDDao.bpopAnswer();
computeScore(answercard);
}
}

使用bpop命令比使用while轮序的方式更好
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: