pc

application/models/Redis/Abstract.php

@@ -34,6 +34,12 @@ class AbstractModel {
      */
     static $redis;
 
+
+    public function __destruct(){
+        if(!empty(self::$redis)){
+            self::$redis->close();
+        }
+    }
     /**
      * 获取redis连接
      * 

scripts/crontab/push/news_server.php

@@ -115,12 +115,14 @@ $serv->on('Message', function($server, $frame) use($conf){
                 $redis->hSet(KEY_PRE.$memberId,'sendTime', time());
                 $server->push($frame->fd, responseJson(1,"sendMsg","success", $sendMessage));
                 $messageService->addMessage($sendMessage['fromId'],$sendMessage['fromUserId'],$sendMessage['fromUserName'],$sendMessage['fromType'],$sendMessage['message'],$sendMessage['toId'],$sendMessage['toUserId'],$sendMessage['toUserName'],$sendMessage['toType'],$sendMessage['id']);
-
+                $memberDb0Redis=\Redis\Db0\MemberRedisModel::getInstance();
+                $memberDb0Redis->tableHDel($memberId,'unread_message_count');
                 $sendMessage['message']=serialize($sendMessage['message']);
                 $redis->rPush('push_center',serialize($sendMessage));
             }
             $redis->close();
             unset($redis);
+            unset($memberDb0Redis);
            // $messageService->unsetDb();
             unset($messageService);
             \Mysql\LinkMySQLModel::unsetDbConecet();