Как реализовать очередь с указанием времени выполнения Redis?

Question

[Filipp Shcherbanich]

Необходимо реализовать очередь на Redis да не простую, а с указанием времени выполнения определенных операций. Изучение проблемы показало, что в Redis можно выставлять время жизни ключа ( EXPIRE ), но вот как делать callback на это событие?
Или может быть данную проблему надо решать каким-то другим способом?

Answer 1

[Андрей Буров]

redis.io/topics/notifications

SET notify-keyspace-events Ex
SUBSRCIBE __keyevent@0__:expired

$redisSub = new Redis() or die("Can't create to redis database instance!\n");
$redisSub->connect('localhost', 6379) or  die("Can't connect to redis database!\n");
$redisSub->select(2) or die("Can't select database!\n");
$redisSub->setOption(Redis::OPT_READ_TIMEOUT, -1);
$redisSub->config('SET', 'notify-keyspace-events', 'Ex');
$redisSub->subscribe(['__keyevent@2__:expired'], 'msg'); // db 2
function msg($redisSub, $chan, $msg)  {
}

Comments

[Filipp Shcherbanich]

Спасибо, тут все работает ( только опечатка в SUBSCRIBE ), но вопрос только такой возникает: можно ли как-то получить содержимое или мы можем знать только название ключа?

[Filipp Shcherbanich]

Так как expired срабатывает уже после операции

Answer 2

[He11ion]

Использовать Beanstalk/gearman и не мучаться как вариант

Comments

[Filipp Shcherbanich]

Beanstalk конечно может и нормально, но вот только уже есть Redis, имеет ли смысл использовать тогда другие инструменты, не такие популярные кстати, если редис умеет выполнять нужную задачу...

[He11ion]

Филипп: Редис не умеет, он не очередь задач, а kv хранилище.

[Filipp Shcherbanich]

He11ion: но это kv хранилище можно использовать для организации этой очереди) Вопрос только как лучше это сделать, судя по тому, что написали выше, надо подписываться на событие expired, но как это с PHP связать - вопрос пока открытый