1. 功能描述

  1. 系统需要每天对7天内UV（访问过系统的用户）进行推送

    2. 开发

    2.1 项目背景

  2. 记录uv是用户端，使用easyswoole框架，原先已经有pv统计埋点接口。

  3. 定实脚本运行服务端，使用yii2框架。

    2.2 开发思路

    1. 方案1

  4. 需要记录7天内UV

  5. 定时脚本，每天运行一次，查询发送

    2. 方案2

  6. 使用reids的bitmap记录用户id

    3. 方案3

  7. 固化用户最后一次访问系统的时间到数据表，同时做30秒最近操作redis记录（防止大并发记录最后一次访问时间）

    4. 方案4

  8. redis记录一天访问用户id（bitmap或hash）

  9. 定时脚本每天凌晨固化前一天用户访问到数据库
  10. 定时脚本取最近7天访问用户推送

    2.3 开发落地

    1. 方案1

  • 用户端

    1. 在Csp类中添加一个记录用户UV的任务，可以并发（见：）的进行原有工作与当前7天uv统计。（采用redis存储，key是 sevenDaysUv:{$userId} ） ```php <? function main() { $csp = new Csp(); /$csp->add(‘t1’, function () use ($spm, $browseTime, $unionId) { storeSPM($spm, $browseTime, $unionId); });/

      // 记录7天内访问过的用户 if ($unionId) { $csp->add(‘sevenDaysUv’, function () use ($unionId) {

      1.   saveUserSevenDaysUv($unionId);

      }); }

      $csp->exec(); }

function saveUserSevenDaysUv($userId) { $key = ‘sevenDaysUv:’ . $userId;

  1. $redis = RedisPool::defer();
  2. $redis->set($key, 1, 7 * 24 * 3600);

}

  2. - 服务端
  3.    1. 通过redis的scan函数轮训扫描所有前缀是 `sevenDaysUv:` 的key，并过滤出userid。
  4.    1. （需要特别注意的是redis的scan查询）（见：）
  5.    1. 批量1000条一次推送到用户端
  6. ```php
  7. <?php
  9. namespace console\controllers;
  11. use common\Manager\PushMessage\AliFacade\Live;
  12. use Yii;
  14. class PushMsgToSevenDaysVisitUserController extends ConsoleBaseController
  15. {
  16.     private static $perSendLimit = 1000;
  18.     private static $prefix = 'sevenDaysUv:';
  20.     public function actionSendLiveMsg()
  21.     {
  22.         $week = date('w');
  23.         $serverName = Live::$serverRemindWeekMap[$week]['serverName'];
  24.         $progress = Live::$serverRemindWeekMap[$week]['progress'];
  25.         $page = Live::$serverRemindWeekMap[$week]['page'];
  27.         $aliUserIds = [];
  28.         $liveMsgObj = new Live();
  29.         $perArrCount = 0;
  30.         $matchPattern = self::$prefix . '*';
  32.         /** @var yii\redis\Connection $redis */
  33.         $redis = Yii::$app->redis;
  35.         // 迭代扫描游标
  36.         $cursor = 0;
  37.         while ($ret = $redis->scan($cursor, 'MATCH', $matchPattern, 'COUNT', self::$perSendLimit)) {
  38.             $scanData = $ret[1] ?? [];
  39.             if ($scanData) {
  40.                 foreach ($scanData as $datum) {
  41.                     $aliUserIds[] = substr($datum, strlen(self::$prefix));
  42.                     $perArrCount++;
  43.                     if ($perArrCount == self::$perSendLimit) {
  44.                         $liveMsgObj->serverRemind($aliUserIds, $serverName, $progress, '', $page);
  46.                         $aliUserIds = [];
  47.                     }
  48.                 }
  49.             }
  51.             $cursor = $ret[0] ?? 0;
  52.             if ($cursor == 0) {
  53.                 break;
  54.             }
  55.         }
  57.         if ($aliUserIds) {
  58.             $liveMsgObj->serverRemind($aliUserIds, $serverName, $progress, '', $page);
  59.         }
  60.     }
  61. }