```php
<?php
// +----------------------------------------------------------------------
// | 定时检测IP代理有效率 - 每35秒执行一次
// +----------------------------------------------------------------------
// | Copyright (c) 2018 https://xiuxian.junphp.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | Author: 小黄牛 <1731223728@qq.com>
// +----------------------------------------------------------------------

//引入数据库文件
require dirname(dirname(__FILE__)) .'/key/Db.php';

class vif_ip {
	
	/*********************多进程设置*********************/
	// 最大开启进程数量
    private $max_process_num = 50;
    // 超时秒数
    private $timeout = 3;
	// 数据集
	private $list = [];
	// 表名称
	private $table = 'proxy_test';
	
	/**
     * 获取所有IP地址
	 * @todo 无
	 * @author 小黄牛
	 * @version v1.0.0.9 + 2018.12.11
	 * @deprecated 暂不弃用
	 * @global 无
	 * @return bool|array
    */
	public function get_ip_list() {
		$conn = link_db();
		# 目前机器只支持最大500个子进程一起跑，还得用定时器延时支持
		# 没有检测通过的IP优先检测，同时更新时间最快的最优先检测
		$res =$conn->query("select * from {$this->table} ORDER BY update_time ASC  limit 0, ".($this->max_process_num * 10).";");
		$list =$res->fetch_all();
		return $list;
	}
	
	/**
	 * 发送请求，验证IP合理性
	 * @todo 无
	 * @author 小黄牛
	 * @version v1.0.0.9 + 2018.12.11
	 * @deprecated 暂不弃用
	 * @global 无
     * @param string $proxy 代理IP+端口
	 * @return int
	*/
	public function vif_proxy($proxy) {
		$ch = curl_init();
		curl_setopt($ch, CURLOPT_URL, 'https://www.youtube.com/');
		curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
		curl_setopt($ch, CURLOPT_HEADER, 0);
		curl_setopt($ch, CURLOPT_NOBODY, true);
		curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); //不验证证书
		curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false); //不验证证书
		curl_setopt ($ch, CURLOPT_TIMEOUT_MS, ($this->timeout * 1000));//超时时间
		curl_setopt($ch, CURLOPT_PROXY, $proxy);
		curl_exec($ch);
		$info = curl_getinfo($ch);
		curl_close($ch);
		$data = [
			'time' => round($info['total_time'], 2),
			'code' => (string)$info['http_code']
		];
		return json_encode($data);
	}
	
	/**
	 * 多进程，循环验证所有IP
	 * @todo 无
	 * @author 小黄牛
	 * @version v1.0.0.9 + 2018.12.11
	 * @deprecated 暂不弃用
	 * @global 无
	 * @return void
	*/
	public function run() {
		$list  = $this->get_ip_list();
		$count = count($list);
		$num   = $count / $this->max_process_num;
		$k     = 0;
		$data  = [];
		// 进程分组
		foreach ($list as $key => $val) {
			$data[$k][] = $val;
			if ( ($key+1) % $this->max_process_num ==0){
				$k++;
			}
		}

// 定时读取分组内容
		foreach ($data as $v) {
			// 毫秒级等待 比超时时间要多等待0.5秒，给内存释放的时间
			swoole_timer_after( (($this->timeout + 0.5) * 1000), function() use ($v){
				foreach ($v as $val) {
					$process = new swoole_process(function(swoole_process $worker) use ($val){
						$code = $this->vif_proxy($val[1]);
						$worker->write($code);
					}, true);
					$process->start();
			
					swoole_event_add($process->pipe, function($pipe) use($process, $val) {
						$json = $process->read();
						$array = json_decode($json, true);
						$status = $array['code'];
						$head_time = $array['time'];
						$proxy  = $val[1];
						$time   = time();

// 创建连接
						$conn = link_db();

if ($status == '200') {
							$sql = "update {$this->table} set status=1,update_time={$time},head_time='{$head_time}' where proxy='{$proxy}';";
							// 检测连接
							if (!$conn->connect_error) {
								$conn->query($sql);
								mysqli_close($conn);
							}
						} else {
							if ($head_time > 0.05) {
								$sql = "update {$this->table} set status=0,update_time={$time},head_time='{$head_time}' where proxy='{$proxy}';";
								// 检测连接
								if (!$conn->connect_error) {
									$conn->query($sql);
									mysqli_close($conn);
								}
							}else {
								// 检测连接
								if (!$conn->connect_error) {
									# 响应时间为0秒的IP，都是需要踢到黑名单里
									$sql = "DELETE FROM {$this->table} where proxy='{$proxy}';";
									$conn->query($sql);
									$sql = "INSERT INTO {$this->table} (proxy,add_time) VALUES ('{$proxy}', {$time});";
									$conn->query($sql);
									mysqli_close($conn);
								}
							}
						}

swoole_event_del($pipe);
					});
				}
				echo "ok.\n";
				//子进程结束必须要执行wait进行回收，否则子进程会变成僵尸进程
				while($ret = swoole_process::wait()){
					// echo PHP_EOL."Worker Exit, PID=" . $ret['pid'] . PHP_EOL;
				}
			});
		}
	}
}

$obj = new vif_ip();
$obj->run();
```

没有进一步优化，如果有更好意见的朋友，可以留意提出，一起改进学习，(^.^)~~

已有0条评论

添加新评论☺

如果认为本文对您有所帮助请赞助本站

支付宝扫一扫赞助

已有0条评论

添加新评论☺