bitsCN.com
前面讲过一篇《实现一个简单的服务端推送方案-实例篇Polling(服务端阻塞读)》，那篇文章服务端利用Gearman队列来实现阻塞读，这篇服务器端用原生MySQL的Sleep函数来实现阻塞读，这篇文章也是另一篇文章《使用MySQL构建一个队列表》的实例实现。
客户端代码，JS库为prototype.js：
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd"><html xmlns="http://www.w3.org/1999/xhtml"><head><meta http-equiv="Content-Type" content="text/html; charset=gb2312" /><title>无标题文档</title><script language="JavaScript" type="text/javascript" src="./prototype.js"></script></head><body><script language="JavaScript"> var Class = { create: function() { return function() { this.initialize.apply(this, arguments); } } } var Comet = Class.create(); Comet.prototype = { maxvid: 0, url: './backend.php', noerror: true, initialize: function(){ }, connect: function(){ this.ajax = new Ajax.Request(this.url, { method: 'get', parameters: { 'maxvid': this.maxvid }, onSuccess: function(transport){ var response = transport.responseText.evalJSON(); this.comet.maxvid = response['vid']; this.comet.handleResponse(response); this.comet.noerror = true; }, onComplete: function(transport){ if (!this.comet.noerror) setTimeout(function(){ comet.connect() }, 5000); else this.comet.connect(); this.comet.noerror = false; } }); this.ajax.comet = this; }, handleResponse: function(response){ $('content').innerHTML += '<p>' + response['msg'] + '</p>'; } } var comet = new Comet(); comet.connect();</script><p id="content"></p></body></html>服务器端代码，backend.php，在这里当读不到新数据时，就调用"带注释的Sleep函数"来阻塞，阻塞直到超时或线程被KILL
<?phpheader("Cache-Control: no-cache, must-revalidate");header("Expires: Mon, 26 Jul 1997 05:00:00 GMT");flush();//控制浏览器前端不要缓存结果，每次都要重新查询$maxvid = $_GET["maxvid"];//$maxvid = -1;error_log(date("[Y-m-d H:i:s]")." > "."maxvid: ".$maxvid."/n", 3 , "/usr/local/apache2219/logs/php_log");$dblnk = mysql_connect('localhost:3306', 'root', 'cpyf');mysql_select_db('test', $dblnk);if ( $maxvid <= 0 ) { $result = mysql_query("select max(vid) from vdooropen"); $result = mysql_fetch_row($result); $maxvid = $result[0]; error_log(date("[Y-m-d H:i:s]")." > "."maxvid: ".$maxvid."/n", 3 , "/usr/local/apache2219/logs/php_log");}while (1){ $result = mysql_query("select * from vdooropen where vid > $maxvid order by vid limit 1"); $num = mysql_num_rows($result); if ( $num > 0 ) break; mysql_query("/*!999999 wait queue msg */ SELECT SLEEP(300)"); if ( mysql_errno() != 0 ) { mysql_close($dblnk); //必须先关闭 $dblnk = mysql_connect('localhost:3306', 'root', 'cpyf'); mysql_select_db('test', $dblnk); }}$result = mysql_fetch_row($result);// 返回 JSON 数组$response = array();$response['vid'] = $result[0];$response['msg'] = $result[0].",".$result[1].",".$result[2].",".$result[3].",".$result[4];$responseText = json_encode($response);error_log(date("[Y-m-d H:i:s]")." < ".$responseText."/n", 3 , "/usr/local/apache2219/logs/php_log");echo $responseText;flush();?>当新增加数据后，通过show processlist找到带注释的Sleep线程，并KILL掉，阻塞就会退出。增加数据代码如下：
<?php$dblnk = mysql_connect('localhost:3306', 'root', 'cpyf');mysql_select_db('test', $dblnk);mysql_query('insert into vdooropen values(0, 2001, "0863030900020185","20130510-115152","D")');mysql_query('insert into vdooropen values(0, 2001, "0863030900020185","20130510-115152","D")');mysql_query('insert into vdooropen values(0, 2001, "0863030900020185","20130510-115152","D")');mysql_query('insert into vdooropen values(0, 2001, "0863030900020185","20130510-115152","D")');mysql_query('insert into vdooropen values(0, 2001, "0863030900020185","20130510-115152","D")');$result = mysql_query("SHOW PROCESSLIST");$num = mysql_num_rows($result);for ($i = 0; $i < $num; $i++) { $row = mysql_fetch_row($result); if ( strstr($row[7], "wait queue msg") != NULL ) { echo "KILL ".$row[0] . "/n"; mysql_query("KILL ".$row[0]); }}?>
如何在 RHEL 9 上配置 DHCP 服务器Jun 08, 2023 pm 07:02 PMDHCP是“动态主机配置协议DynamicHostConfigurationProtocol”的首字母缩写词，它是一种网络协议，可自动为计算机网络中的客户端系统分配IP地址。它从DHCP池或在其配置中指定的IP地址范围分配客户端。虽然你可以手动为客户端系统分配静态IP，但DHCP服务器简化了这一过程，并为网络上的客户端系统动态分配IP地址。在本文中，我们将演示如何在RHEL9/RockyLinux9上安装和配置DHCP服务器。先决条件预装RHEL9或RockyLinux9具有sudo管理权限的普
在容器中怎么使用nginx搭建上传下载的文件服务器May 15, 2023 pm 11:49 PM一、安装nginx容器为了让nginx支持文件上传，需要下载并运行带有nginx-upload-module模块的容器：sudopodmanpulldocker.io/dimka2014/nginx-upload-with-progress-modules:latestsudopodman-d--namenginx-p83:80docker.io/dimka2014/nginx-upload-with-progress-modules该容器同时带有nginx-upload-module模块和ng
服务器怎么使用Nginx部署Springboot项目May 14, 2023 pm 01:55 PM1,将java项目打成jar包这里我用到的是maven工具这里有两个项目，打包完成后一个为demo.jar,另一个为jst.jar2.准备工具1.服务器2.域名(注：经过备案)3.xshell用于连接服务器4.winscp（注:视图工具，用于传输jar）3.将jar包传入服务器直接拖动即可3.使用xshell运行jar包注：（服务器的java环境以及maven环境，各位请自行配置，这里不做描述。）cd到jar包路径下执行：nohupjava-jardemo.jar>temp.txt&
vue3项目打包发布到服务器后访问页面显示空白怎么解决May 17, 2023 am 08:19 AMvue3项目打包发布到服务器后访问页面显示空白1、处理vue.config.js文件中的publicPath处理如下：const{defineConfig}=require('@vue/cli-service')module.exports=defineConfig({publicPath:process.env.NODE_ENV==='production'?'./':'/&
python中怎么使用TCP实现对话客户端和服务器May 17, 2023 pm 03:40 PMTCP客户端一个使用TCP协议实现可连续对话的客户端示例代码：importsocket#客户端配置HOST='localhost'PORT=12345#创建TCP套接字并连接服务器client_socket=socket.socket(socket.AF_INET,socket.SOCK_STREAM)client_socket.connect((HOST,PORT))whileTrue:#获取用户输入message=input("请输入要发送的消息：&
Linux怎么在两个服务器直接传文件May 14, 2023 am 09:46 AMscp是securecopy的简写，是linux系统下基于ssh登陆进行安全的远程文件拷贝命令。scp是加密的，rcp是不加密的，scp是rcp的加强版。因为scp传输是加密的,可能会稍微影响一下速度。另外，scp还非常不占资源，不会提高多少系统负荷，在这一点上，rsync就远远不及它了。虽然rsync比scp会快一点，但当小文件众多的情况下，rsync会导致硬盘I/O非常高，而scp基本不影响系统正常使用。场景：假设我现在有两台服务器(这里的公网ip和内网ip相互传都可以，当然用内网ip相互传
如何使用psutil模块获取服务器的CPU、内存和磁盘使用率？May 07, 2023 pm 10:28 PMpsutil是一个跨平台的Python库，它允许你获取有关系统进程和系统资源使用情况的信息。它支持Windows、Linux、OSX、FreeBSD、OpenBSD和NetBSD等操作系统，并提供了一些非常有用的功能，如：获取系统CPU使用率、内存使用率、磁盘使用率等信息。获取进程列表、进程状态、进程CPU使用率、进程内存使用率、进程IO信息等。杀死进程、发送信号给进程、挂起进程、恢复进程等操作。使用psutil，可以很方便地监控系统的运行状况，诊断问题和优化性能。以下是一个简单的示例，演示如何
怎么在同一台服务器上安装多个MySQLMay 29, 2023 pm 12:10 PM一、安装前的准备工作在进行MySQL多实例的安装前，需要进行以下准备工作：准备多个MySQL的安装包，可以从MySQL官网下载适合自己环境的版本进行下载：https://dev.mysql.com/downloads/准备多个MySQL数据目录，可以通过创建不同的目录来支持不同的MySQL实例，例如：/data/mysql1、/data/mysql2等。针对每个MySQL实例，配置一个独立的MySQL用户，该用户拥有对应的MySQL安装路径和数据目录的权限。二、基于二进制包安装多个MySQL实例
Hot AI Tools
Undresser.AI Undress
AI-powered app for creating realistic nude photos
AI Clothes Remover
Online AI tool for removing clothes from photos.
Undress AI Tool
Undress images for free
Clothoff.io
AI clothes remover
AI Hentai Generator
Generate AI Hentai for free.
Hot Article
Hot Tools
EditPlus Chinese cracked version
Small size, syntax highlighting, does not support code prompt function
Dreamweaver CS6
Visual web development tools
WebStorm Mac version
Useful JavaScript development tools
SublimeText3 Mac version
God-level code editing software (SublimeText3)
DVWA
Damn Vulnerable Web App (DVWA) is a PHP/MySQL web application that is very vulnerable. Its main goals are to be an aid for security professionals to test their skills and tools in a legal environment, to help web developers better understand the process of securing web applications, and to help teachers/students teach/learn in a classroom environment Web application security. The goal of DVWA is to practice some of the most common web vulnerabilities through a simple and straightforward interface, with varying degrees of difficulty. Please note that this software
