如何在多个PHP脚本间复用Oracle单一连接或使用持久连接？

针对你遇到的多PHP页面重复创建Oracle连接导致日志臃肿的问题，有两种直接可行的解决思路：

方案一：使用OCI持久连接替代普通连接 #

PHP的OCI扩展提供了oci_pconnect()函数，它会创建持久连接——同一PHP-FPM/Apache进程下的所有请求会复用已有的Oracle连接，不会每次请求都新建连接，能大幅减少Oracle的连接日志量。

只需修改你的页面代码，把oci_connect()替换为oci_pconnect()，并且不要手动调用oci_close()（持久连接会被进程自动保留，手动关闭反而会破坏复用机制）：

修改后的page1.php示例 #

//...
// 用oci_pconnect创建持久连接
$conn = oci_pconnect('user', 'password', $server);
if (!$conn) {
    $e = oci_error();
    // 错误处理逻辑
}
$stid = oci_parse($conn, 'SELECT * FROM table1');
oci_execute($stid);
// 数据处理逻辑
// 无需调用oci_close($conn)，让连接被进程复用
//... 

修改后的page2.php示例 #

//...
$conn = oci_pconnect('user', 'password', $server);
if (!$conn) {
    $e = oci_error();
    // 错误处理逻辑
}
$stid = oci_parse($conn, 'SELECT * FROM table2');
oci_execute($stid);
// 数据处理逻辑
// 无需关闭连接
//... 

额外注意

• PHP默认开启OCI持久连接支持，可通过php.ini的oci8.persistent_timeout设置连接闲置超时时间，避免无用连接长期占用资源。
• 不同进程的连接是独立的，但同一进程内的所有请求会复用同一个连接，能有效降低连接数和日志输出。

方案二：复用现有长连接脚本的单一连接 #

你已经有一个通过Cron运行的conn.php保持着Oracle长连接，可以把这个脚本改成本地服务，让所有前端PHP页面通过这个服务执行Oracle查询，全程复用同一个连接。

步骤1：修改conn.php为Socket服务 #

//...
$conn = oci_connect('user', 'password', $server);
if (!$conn) {
    $e = oci_error();
    // 错误处理，比如退出脚本让Cron重启
    exit(1);
}

// 创建本地Unix Socket监听请求
$socket = socket_create(AF_UNIX, SOCK_STREAM, 0);
// 绑定Socket文件，注意权限要让PHP进程能读写
socket_bind($socket, '/tmp/oracle_query.sock');
socket_listen($socket);

$stop = true;
while ($stop) {
    // 接受前端请求
    $client = socket_accept($socket);
    if (!$client) {
        continue;
    }
    // 读取请求的SQL语句
    $sql = socket_read($client, 1024);
    if (empty($sql)) {
        socket_close($client);
        continue;
    }
    // 执行SQL并返回结果
    $stid = oci_parse($conn, trim($sql));
    oci_execute($stid);
    $data = [];
    while ($row = oci_fetch_assoc($stid)) {
        $data[] = $row;
    }
    // 用JSON序列化结果返回给前端
    socket_write($client, json_encode($data));
    socket_close($client);
    
    sleep(1); // 避免循环过于频繁
}

oci_close($conn);
socket_close($socket);

步骤2：前端PHP页面调用Socket服务 #

// page1.php中的Oracle查询逻辑替换为：
$socket = socket_create(AF_UNIX, SOCK_STREAM, 0);
socket_connect($socket, '/tmp/oracle_query.sock');
// 发送查询SQL
socket_write($socket, 'SELECT * FROM table1');
// 读取并解析结果
$response = socket_read($socket, 4096);
$data = json_decode($response, true);
// 数据处理逻辑
socket_close($socket);

额外注意

• 确保Socket文件的权限正确，避免PHP进程无法读写。
• 给Socket服务添加异常处理，比如Oracle连接断开时自动重连，保证服务稳定性。
• 如果使用TCP Socket（AF_INET），请绑定本地IP（127.0.0.1）避免外部非法访问。

内容的提问来源于stack exchange，提问作者husky