面试题：Redis 怎么延时队列

二、SortSet常用命令

zset 中最后一个 value 被移除后，数据结构自动删除，内存被回收。

三、使用场景

排行榜

• 粉丝列表，value 值是粉丝的用户 ID，score 是关注时间
• 视频网站需要对用户上传的视频做排行榜，榜单维护可能是多方面：按照时间、按照播放量、按照获得的赞数等。

权重队列 / 延时队列

比如：订单超时未支付，取消订单，恢复库存.

对消息队列有严格要求(不能丢)的建议还是使用kafka,专业的MQ。这些专业的消息中间件提供了很多功能特性，当然他的部署使用维护都是比较麻烦的。如果你对消息队列没那么高要求，想要轻量级的，使用Redis就没错啦。

PHP - 延时队列实例

下面代码如何增强健壮性：

• function run()需要 lua 来实现器原子性操作
• 可以考虑 在MySQL，MongoDB等持久数据库建立 任务队列 & 已执行队列 进一步容错  
•  
• <?phptrait RedisConnectTrait
• {
      private $servers = array();
      private $instances = array();
   
      /**
       * 设置 Redis 配置
       * @param array $serversConfig
       * @return $this
       * @throws Exception
       */
      private function setServers( array $serversConfig = [ [ '127.0.0.1', 6379, 0.01 ] ] )
      {
          if ( !$serversConfig )
              throw new \Exception( 'Redis链接配置不能为空', false );
   
          $this->servers = $serversConfig;
          return $this;
      }
   
      private function initInstances()
      {
          if (empty($this->instances)) {
              foreach ($this->servers as $server) {
                  list($host, $port, $timeout) = $server;
   
                  $redis = new \Redis();
                  $redis->connect($host, $port, $timeout);
   
                  $this->instances[] = $redis;
              }
          }
      }
  }
   
  class RedisDelayQueueUtil
  {
      use RedisConnectTrait;
   
      const QUEUE_PREFIX = 'delay_queue:';
      protected $redis = null;
      protected $key = '';
   
      public function __construct( string $queueName, array $config = [] )
      {
          $instances = $this->setServers( $config )->initInstances();
   
          $this->key = self::QUEUE_PREFIX . $queueName;
          $this->redis = $instances[ 0 ];
      }
   
      public function delTask($value)
      {
          return $this->redis->zRem($this->key, $value);
      }
   
      public function getTask()
      {
          //获取任务，以0和当前时间为区间，返回一条记录
          return $this->redis->zRangeByScore( $this->key, 0, time(), [ 'limit' => [ 0, 1 ] ] );
      }
   
      public function addTask($name, $time, $data)
      {
          //添加任务，以时间作为score，对任务队列按时间从小到大排序
          return $this->redis->zAdd(
              $this->key,
              $time,
              json_encode([
                  'task_name' => $name,
                  'task_time' => $time,
                  'task_params' => $data,
              ], JSON_UNESCAPED_UNICODE )
          );
      }
   
      public function run()
      {
          //每次只取一条任务
          $task = $this->getTask();
          if (empty($task)) {
              return false;
          }
   
          $task = $task[0];
          if ($this->delTask($task)) {
              $task = json_decode($task, true);
              //处理任务
              echo '任务：' . $task['task_name'] . ' 运行时间：' . date('Y-m-d H:i:s') . PHP_EOL;
   
              return true;
          }
   
          return false;
      }
  }
   
  $dq = new RedisDelayQueueUtil('close_order', [
      'host' => '127.0.0.1',
      'port' => 6379,
      'auth' => '',
      'timeout' => 60,
  ]);
   
  $dq->addTask('close_order_111', time() + 30, ['order_id' => '111']);
  $dq->addTask('close_order_222', time() + 60, ['order_id' => '222']);
  $dq->addTask('close_order_333', time() + 90, ['order_id' => '333']);
   
  set_time_limit(0);
   
  $i2Count = 0;
  while ( $i2Count < 10 ) {
      $dq->run();
      usleep(100000);
      $i2Count++;
  }