针对问题：Hyperf 生产环境, 不上Swarm, 不上 k8s, 如何更新?

<?php

/**
 * 双机热备更新：
 * 1、检查当前项目运行端口 9501
 * 2、更改项目运行端口为 9502，启动项目（此时运行的是两个服务9501+9502）
 * 3、更改nginx配置为 9502，并重新 reload
 * 4、停止9501端口服务
 */

#--------------------- 主要修改内容 start ------------------
// 目录
define("WEB_PATH", "/data/web");
// Todo 项目
define("PROJECT_NAME", "cp-game-api");
// Todo nginx配置文件
define("NGINX_CONF", "/usr/local/nginx/conf/vhost/cp-game-api.conf");
// TODO 原先端口
define("PORT", 9501);
// Todo 交换端口
define("NEW_PORT", 9502);
#--------------------- 主要修改内容 end ------------------

// 完整项目地址
define("PROJECT_PATH", WEB_PATH . "/" . PROJECT_NAME);
// RUNTIME 
define("RUNTIME_PATH", PROJECT_PATH . "/runtime");
// 项目构建日志
define("LOG_FILE", RUNTIME_PATH . "/release.log");
// PID
define("PID_FILE", RUNTIME_PATH . "/hyperf.pid");

class Release
{
    public $pid = 0;

    public function __construct()
    {
        // 旧服务pid
        if (file_exists(PID_FILE)) {
            $this->pid = file_get_contents(PID_FILE);
        }
    }

    // 判断端口
    public function getPort()
    {
        $lsofExec   = "lsof -i:" . PORT;
        $lsofResult = exec($lsofExec);

        $newPort = PORT;
        $oldPort = NEW_PORT;
        if ($lsofResult !== '') {
            $newPort = NEW_PORT;
            $oldPort = PORT;
        }

        return [$oldPort, $newPort];
    }

    // 读取nginx配置，判断当前正在使用的是哪个端口
    public function getNginxServerPort()
    {
        $fileContent = file_get_contents(NGINX_CONF);
        $pattern     = '/127\.0\.0\.1:(\d+)/';
        preg_match($pattern, $fileContent, $matches);
        return $matches[1] ?? 0;
    }

    // 执行正文
    public function run()
    {
        $this->log(PHP_EOL . date("Y-m-d H:i:s") . ' 版本发布 ===> START <=== ');

        // 判断当前是哪个端口正在服务
        [$oldPort, $newPort] = $this->getPort();

        // 将另一个闲置的端口，替换到新版本中
        $projectPath = WEB_PATH . "/" . PROJECT_NAME;
        $this->log(' 新服务端口为：' . $newPort);
        $devConfig = file_get_contents($projectPath . '/.env');
        $devConfig = str_replace($oldPort, $newPort, $devConfig);
        file_put_contents($projectPath . '/.env', $devConfig);

        // 启动新服务(这一刻新旧服务是同时存在的)
        $startExec = "cd {$projectPath}; php bin/hyperf.php start";
        $this->log(" 新服务启动:" . $startExec);
        exec($startExec);

        // 替换 Nginx 配置
        $oldNginxPort = $this->getNginxServerPort();
        if ($oldNginxPort && $oldNginxPort != $newPort) {
            $this->log(' 替换nginx配置端口为：' . NGINX_CONF . ' ==> ' . $newPort);
            ### 这里需要换成自己服务器环境 nginx 配置文件所在的目录
            $ngConfig = file_get_contents(NGINX_CONF);
            $ngConfig = str_replace($oldNginxPort, $newPort, $ngConfig);
            file_put_contents(NGINX_CONF, $ngConfig);

            // 重启 Nginx 服务
            $reloadNgExec = "nginx -s reload";
            $this->log(" 重载nginx: " . $reloadNgExec);
            exec($reloadNgExec);
        }

        if ($this->pid) {
            $stopExec = "kill {$this->pid}";
        } else {
            $stopExec = "netstat -tunlp | awk '{if ($4 == " . '"0.0.0.0:' . $oldPort . '"' . ') print $7}\' | awk -F"/" \'{ print $1 }\' | xargs kill -15';
        }
        $this->log(" 停掉旧服务: " . $stopExec);
        exec($stopExec);

        $this->log(date("Y-m-d H:i:s") . ' 版本发布 ===> END <=== ' . PHP_EOL);
    }

    // 日志记录
    public function log($msg, $filename = '')
    {
        $filename = $filename ?: LOG_FILE;

        echo $msg . PHP_EOL;

        return file_put_contents($filename, $msg . PHP_EOL, FILE_APPEND);
    }
}

(new Release())->run();

执行结果

2023-07-05 11:39:27 版本发布 ===> START <=== 
 新服务端口为：9502
 新服务启动:cd /data/web/cp-game-api; php bin/hyperf.php start
 替换nginx配置端口为：/usr/local/nginx/conf/vhost/cp-game-api.conf ==> 9502
 重载nginx: nginx -s reload
 停掉旧服务: netstat -tunlp | awk '{if ($4 == "0.0.0.0:9501") print $7}' | awk -F"/" '{ print $1 }' | xargs kill -15
2023-07-05 11:39:27 版本发布 ===> END <=== 

再次执行结果

2023-07-05 11:41:36 版本发布 ===> START <=== 
 新服务端口为：9501
 新服务启动:cd /data/web/cp-game-api; php bin/hyperf.php start
 替换nginx配置端口为：/usr/local/nginx/conf/vhost/cp-game-api.conf ==> 9501
 重载nginx: nginx -s reload
 停掉旧服务: netstat -tunlp | awk '{if ($4 == "0.0.0.0:9502") print $7}' | awk -F"/" '{ print $1 }' | xargs kill -15
2023-07-05 11:41:37 版本发布 ===> END <===

通过D:\go\src\runtime\internal\sys\zversion.go的文件 设置版本

package sys

const StackGuardMultiplierDefault = 1

const TheVersion = `go1.20.5`（新增）

1、querystring，的是URL中​​?​​​后面携带的参数，例如：​​/user/search?username=小王子&address=沙河​​。 获取请求的querystring参数的方法如下。

username := c.DefaultQuery("username", "小王子")
//username := c.Query("username")
address := c.Query("address")
//输出json结果给调用方
c.JSON(http.StatusOK, gin.H{
  "message":  "ok",
  "username": username,
  "address":  address,
})

2、获取form参数，当前端请求的数据通过form表单提交时，例如向​​/user/search​​发送一个POST请求，获取请求数据的方式如下。c.PostForm

username := c.PostForm("username")
address := c.PostForm("address")
//输出json结果给调用方
c.JSON(http.StatusOK, gin.H{
  "message":  "ok",
  "username": username,
  "address":  address,
})

3、获取json参数，当前端请求的数据通过JSON提交时，例如向​​/json​​发送一个POST请求，则获取请求参数的方式如下。

b, _ := c.GetRawData()  // 从c.Request.Body读取请求数据
// 定义map或结构体
var m map[string]interface{}
// 反序列化
_ = json.Unmarshal(b, &m)

c.JSON(http.StatusOK, m)

阅读剩余部分...

Supervisor 是一个守护进程管理工具，可以用于管理多个进程，并且能够自动重启进程。下面是使用 Supervisor 进行守护进程管理的基本步骤：

1、安装 Supervisor。可以使用系统的包管理工具（如 yum 或 apt-get）进行安装，也可以使用 pip 进行安装。

2、创建一个Supervisor 配置文件。在 /etc/supervisor/conf.d/ 目录下创建一个新的配置文件，例如myapp.conf，并在其中定义需要管理的进程。例如，下面是一个简单的 Supervisor 配置文件示例：

[program:myapp]
command=php /path/to/your/script.php
directory=/path/to/your/app
autostart=true
autorestart=true
user=www-data
redirect_stderr=true
stdout_logfile=/var/log/myapp.log

其中，myapp 是进程的名称，command 是要运行的命令，directory 是命令的运行目录，autostart 表示是否在 Supervisor 启动时自动启动进程，autorestart 表示进程异常退出后是否自动重启进程，user 是进程运行的用户，redirect_stderr 表示是否将错误信息重定向到日志文件，stdout_logfile 是日志文件的路径。

重新加载 Supervisor 配置文件。执行以下命令重新加载配置文件：

sudo supervisorctl reread
sudo supervisorctl update

启动、停止和重启进程。可以通过以下命令来启动、停止和重启进程：

sudo supervisorctl start myapp
sudo supervisorctl stop myapp
sudo supervisorctl restart myapp

其中，myapp 是进程的名称。

需要注意的是，使用 Supervisor 进行守护进程管理时，需要注意进程的稳定性和安全性，避免出现内存泄露、死锁等问题，防止被黑客攻击。

在 RabbitMQ 中，获取队列内的消息有多种方式，下面列举几种：

1、basic_get 方法：可以使用 basic_get 方法从队列中获取一条消息。可以在循环中多次调用该方法来批量获取消息。

while ($message = $channel->basic_get($queueName)) {
    // 处理消息
}

2、basic_consume 方法：可以使用 basic_consume 方法订阅队列，并在回调函数中处理获取到的消息。可以设置 prefetch_count 参数控制每次获取的消息数量。

$channel->basic_qos(null, 10, null); // 每次最多获取 10 条消息
$channel->basic_consume($queueName, '', false, false, false, false, function ($message) {
    // 处理消息
    $message->delivery_info['channel']->basic_ack($message->delivery_info['delivery_tag']);
});
while ($channel->is_consuming()) {
    $channel->wait();
}

3、basic_get 和 basic_consume 结合使用：可以使用 basic_get 方法获取一定数量的消息，然后使用 basic_ack 方法确认已经处理完消息。

$channel->basic_qos(null, 10, null); // 每次最多获取 10 条消息
while ($message = $channel->basic_get($queueName)) {
    // 处理消息
    $channel->basic_ack($message->delivery_info['delivery_tag']);
}

需要注意的是，在批量获取消息时，需要设置适当的 prefetch_count 参数来控制每次获取的消息数量，避免一次性获取过多的消息导致处理能力不足或者消息堵塞的问题。同时，也需要在处理完每一条消息后及时调用 basic_ack 方法确认消息已经被处理完成，以避免消息重复消费的问题。