PHP はリアルタイム Weibo および動的メッセージ プッシュ テクノロジーを実装します

function saveWeibo($content) {
 $sql = "INSERT INTO weibo (content,create_time) VALUES ('" . $content . "','" . time() . "')";
 // 执行插入操作
 $result = mysqli_query(self::$link, $sql);
 return $result;
}

function getWeiboList($last_time) {
 $sql = "SELECT * FROM weibo WHERE create_time>$last_time ORDER BY create_time DESC";
 $result = mysqli_query(self::$link, $sql);
 $list = [];
 while ($row=mysqli_fetch_assoc($result)) {
  $list[] = $row;
 }
 return $list;
}

function outputWeibo($weibo) {
 $content = $weibo['content'];
 $time = date("Y-m-d H:i:s",$weibo['create_time']);
 echo "<div class='weibo-item'>";
 echo "<p class='weibo-content'>" . $content . "</p>";
 echo "<p class='weibo-time'>" . $time . "</p>";
 echo "</div>";
}

setInterval(function(){
  $.ajax({
   url:'get_weibo.php',
   type:'post',
   dataType:'json',
   data:{'last_time':last_time},
   success:function(data){
    if(data.length>0){
     last_time = data[0].create_time;
     $.each(data,function(i,weibo){
      output_weibo(weibo);
     });
    }
   }
  });
},interval_time);

$server = new SwooleWebSocketServer('0.0.0.0', 9502);

$server->on('open', function ($server, $req) {
 echo "connection open: {$req->fd}
";
});

$server->on('message', function ($server, $frame) {
 echo "received message: {$frame->data}
";
 $server->push($frame->fd, "hello, {$frame->data}!");
});

$server->on('close', function ($server, $fd) {
 echo "connection close: {$fd}
";
});

$server->start();

var ws = new WebSocket("ws://localhost:9502");

ws.onopen = function() {
 console.log("websocket open");
 ws.send("hello websocket");
};

ws.onmessage = function(evt) {
 console.log("receive message from server: " + evt.data);
};

ws.onclose = function() {
 console.log("websocket close");
};