message

scripts/crontab/push/news_server.php

@@ -107,16 +107,17 @@ $serv->on('Message', function($server, $frame) use($conf){
                     $sendMessage['toType']= $rev_data['toType'];
                     if(!empty($sendFd)){
                         echo '发送fd:'.$sendFd;
+                        if($sendFd!=$frame->fd){
                             $server->push($sendFd, responseJson(1,"fromMsg","success", $sendMessage));
                         }
+
+                    }
                     echo 'afterSendFd:'.$sendFd;
                 }
                 //echo json_encode($sendMessage);
                 //$redis->rPush("message_center",serialize($sendMessage));
                 $redis->hSet(KEY_PRE.$memberId,'sendTime', time());
-                if($sendFd!=$frame->fd){
                 $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']);
                 $sendMessage['message']=serialize($sendMessage['message']);
                 $redis->rPush('push_center',serialize($sendMessage));