func.php

<?php
function save_cb($redis, $hash, $content){
    if(!$redis || !$hash)return;
    $content    = htmlspecialchars($content);
    $exceptCb = [
        '8d3c0804d35128b9546b526245bb9b64',
    ];
    if(in_array($hash, $exceptCb)){
        $redis->lPush($hash, $content);
    } else {
        if($redis->lSize($hash)<50){
            $redis->lPush($hash, $content);
        } else {
            $redis->rPop($hash);
            $redis->lPush($hash, $content);
        }
    }
    $redis->bgsave();
}

function publish($redis, $hash, $ws, $content, $raw = false){
    if(!$hash || !$redis || !$ws)return;
    if ($raw == false) {
        $content = htmlspecialchars($content);
    }
    $result = $redis->lRange('publish_'.$hash, 0, -1);
    if ($result) {
        krsort($result);
    } else {
        $result = [];
    }
    foreach ($result as $k => $v) {
        try {
            if (!$ws->isEstablished($v)) {
                var_dump('cannot find client: '.$v);
                // remove client from the push channel.
                $redis->lRem('publish_'.$hash, $v, 0);
                continue;
            }
            if ($raw == true) {
                $ws->push($v, json_encode($content));
            } else {
                $tmp = array('type'=>'single', 'data'=>$content);
                $ws->push($v, json_encode($tmp));
            }
        } catch (\Exception $e) {
            var_dump('lost client: '.$v, $e->getMessage());
        }
        
    }
}

function hash_clear($redis){
    if(!$redis)return;
    $allkeys    = $redis->hKeys('fd.to.hash');
    $all        = $redis->hGetAll('fd.to.hash');

    // remove all login client from push channel
    foreach ($all as $fd => $hash) {
        $redis->lRem('publish_'.$hash, $fd, 0);
    }

    // remove all login info
    foreach ($allkeys as $k => $v) {
        $redis->hDel('fd.to.hash', $v);
    }
    return;
}