Swoole 进程学习

<?php
//  获取当前进程 ID
echo "我是 一个 主进程，我的ID是：" . posix_getpid().PHP_EOL;
// 为进程设置名称
cli_get_process_title("Master");

while (true) {
	sleep(1);
}

<?php
//  获取当前进程 ID
echo "我是 一个 主进程，我的ID是：" . posix_getpid().PHP_EOL;
// 为进程设置名称
cli_get_process_title("Master");

// 创建一个子进程
$child = new \Swoole\Process(function (){
	cli_get_process_title("Child");
	// 这是一个匿名函数，也就是定义子进程需要做的事情。
	echo "我是一个子进程，我的ID 是：" . posix_getpid() . PHP_EOL;
	// 如果就这样放着不管，那么这个子进程不会被回收，它是一个僵尸进程，虽然在那里但是并没有做事情，它的生命周期已经结束了。
});
// 创建
$child->start();

// 回收子进程
\Swoole\Process::wait();

while (true) {
	sleep(1);
}

<?php

//  获取当前进程 ID
echo "我是 一个 主进程，我的ID是：" . posix_getpid().PHP_EOL;
// 为进程设置名称
cli_get_process_title("Master");

// 创建一个子进程
$child = new \Swoole\Process(function (){
	cli_get_process_title("Child");

	while (true) {
		// 这是一个匿名函数，也就是定义子进程需要做的事情。
		echo "我是一个子进程，我的ID 是：" . posix_getpid() . PHP_EOL;
		// 如果就这样放着不管，那么这个子进程不会被回收，它是一个僵尸进程，虽然在那里但是并没有做事情，它的生命周期已经结束了。
		sleep(1);
	}
}, true);
// 创建
$child->start();

// 回收子进程，是否阻塞等待，默认为true，阻塞。
\Swoole\Process::wait(false);

while (true) {
	echo "通过主进程从管道中读取信息：". $child->read(). PHP_EOL;
	sleep(1);
}

$http->set([
  "worker_num" => 1
]);

<?php
use \Swoole\Process;
//  引入协程
use \Swoole\Coroutine\Mysql as Mysql;

//  获取当前进程 ID
echo "我是 一个 主进程，我的ID是：" . posix_getpid().PHP_EOL;

$child = new Process(function (Process $proces){
	// $mysql = new \think\db\builder\Mysql();
	$mysql = new Mysql();
	$db = $mysql->connect(["host" => "127.0.0.1", "user" => "root", "password" => "122410", "database" => "2v"]);
	while (true) {
		$sql = "select * from 2v.2v_user where is_delete = 0 limit 0, 1";
		$rows = $mysql->query($sql);
		if ($rows) {
			$proces->write("我是一号子进程，正在查询数据：".$rows[0]["user_name"]);
		}
		sleep(1);
	}
}, false, 1, true);
// 创建子进程
$child->start();

$child2 = new Process(function (Process $process) {
	while (true) {
		sleep(1);
		$res = $process->read();
		if ($res) {
			echo "我是二号子进程，正在获取数据：".$res.PHP_EOL;
		}
	}
});
// 创建第二个子进程
$child2->start();

while (true) {
	// 一号子进程从管道中读取数据
	$data = $child->read();
	if ($data) {
		// 如果数据存在，二号子进程则向管道中写入数据
		$child2->write($data);
	}
	sleep(1);
}

// 通过信号回收子进程
Process::signal(SIGCHLD, function ($sig) {
	// 必须为false，非阻塞模式
	while ($res = Process::wait(false)) {
		echo "PID = {$res['pid']}";
	}
});