likun-mci/php-ai

框架无关的 PHP AI 标准库:统一 OpenAI / Claude / Gemini / DeepSeek 调用,内置流式输出、Agent 工具调用循环、AI 代码编辑协议与安全网页抓取。

Maintainers

Package info

github.com/likun-mci/php-ai

pkg:composer/likun-mci/php-ai

Transparency log

Statistics

Installs: 14

Dependents: 0

Suggesters: 0

Stars: 0

Open Issues: 0

v1.1.0 2026-07-29 01:53 UTC

This package is auto-updated.

Last update: 2026-07-29 02:17:47 UTC


README

一个框架无关的 PHP AI 调用标准库,用统一接口屏蔽 OpenAI / Claude(Anthropic) / Gemini / DeepSeek / OpenRouter 等平台在鉴权方式、请求协议、返回格式、流式协议上的差异。

除对话能力外,还内置了 Agent 工具调用循环AI 代码编辑协议带 SSRF 防护的网页抓取工具Agent 长期记忆,可直接用于构建后台 AI 助手、代码编辑助手、内容翻译等实际业务。

本文档中的示例均来自真实业务系统(一套 CodeIgniter 3 的建站系统)中的实际用法,非伪代码。

特性

  • 🔌 多平台:OpenAI、Claude(Anthropic)、Gemini、DeepSeek、OpenRouter,含 DeepSeek 的 Anthropic 兼容端点
  • 🎯 统一接口AI::create()->chat(),切换平台只需换 model
  • 🧩 任意模型 + 任意接口:模型名不受内置清单限制,可手选协议格式(protocol)并指定自定义接口地址(base_url / endpoint),一套代码同时对接官方 API、第三方中转与自建网关
  • 🌊 流式输出:一行 setStream(true),自动按 SSE 协议实时吐出数据块
  • 🧰 Agent 循环:挂载工具(函数)后自动完成「模型决策 → 执行工具 → 回填结果」多轮循环
  • 📝 代码编辑协议:结构化编辑上下文 + 可校验的编辑动作,支持规划/审核/自动执行三种模式
  • 🛡️ 安全抓取HttpFetch 内置 SSRF、DNS rebinding、内网地址、协议逃逸防护
  • 📄 多模态附件:图片等附件按各平台格式自动适配
  • 🪶 零硬依赖:仅需 PHP 与 cURL,可 Composer 安装,也可单文件 autoload 引入

环境要求

项目 要求
PHP >= 7.2
扩展 ext-curlext-jsonext-mbstringext-dom(仅 HTML 转换用到)
网络 可访问对应平台 API;中国环境通常需配置代理,见 网络代理

安装

Composer

composer require likun-mci/php-ai
require __DIR__ . '/vendor/autoload.php';

use Ai\AI;

手动引入(不使用 Composer)

库自带 PSR-4 加载器,把整个目录放进项目后引入一次即可:

require_once __DIR__ . '/autoload.php';

use Ai\AI;

快速开始

use Ai\AI;

$ai = AI::create([
    'model'   => 'gpt-4o',
    'api_key' => 'sk-xxxxxxxxxxxxx',
]);

$response = $ai->chat('用一句话介绍人工智能');

echo $response->getContent();          // 回复文本
echo $response->tokens();              // 总消耗 tokens

chat() 接受字符串(自动包装为一条 user 消息)或完整 payload 数组:

$response = $ai->chat([
    'messages' => [
        ['role' => 'system',    'content' => '你是一个有帮助的助手'],
        ['role' => 'user',      'content' => '介绍一下人工智能'],
        ['role' => 'assistant', 'content' => '人工智能是……'],
        ['role' => 'user',      'content' => '再简短一点'],
    ],
    'temperature' => 0.7,
    'max_tokens'  => 1000,
]);

注意:本库不会自动保存对话历史。多轮对话需要业务层自己维护 messages 数组并每次完整传入,参见 多轮对话上下文

支持的模型

model 传下表中的模型标识即可,库会自动解析出平台、协议与端点:

平台 模型标识 实际协议 端点
OpenAI gpt-4.1 OpenAI api.openai.com
OpenAI gpt-4o OpenAI api.openai.com
Claude claude-3-opus Claude api.anthropic.com
Gemini gemini-2.5-pro Gemini(OpenAI 兼容端点) generativelanguage.googleapis.com
DeepSeek deepseek-chat OpenAI api.deepseek.com
DeepSeek deepseek-reasoner OpenAI api.deepseek.com
DeepSeek deepseek-v4-pro OpenAI api.deepseek.com
DeepSeek deepseek-v4-flash OpenAI api.deepseek.com
DeepSeek deepseek-anthropic Claude api.deepseek.com/anthropic
OpenRouter openai/gpt-4o 等完整标识 OpenRouter(OpenAI 兼容) openrouter.ai/api

deepseek-anthropic 是 DeepSeek 的 Anthropic 兼容端点,用 Claude 协议通信——需要工具调用(Agent)时用它,可以用 DeepSeek 的价格跑 Anthropic 的 tools 协议

表外的模型也能直接用

上表只是「开箱即用的快捷标识」,model 并不限于表内的值

  • 官方新模型(如 claude-sonnet-4-5gpt-5.1gemini-3-prodeepseek-v3):库按模型名识别出协议家族与官方端点,直接可用,不必等库更新;
  • 其它平台/第三方中转/自建网关的模型(如 qwen-maxglm-4.6llama3):加上 base_url(或 endpoint)即可,必要时用 protocol 手选协议格式。
// 官方新模型:识别出 claude 家族,自动使用 api.anthropic.com/v1/messages
$ai = AI::create(['model' => 'claude-sonnet-4-5', 'api_key' => 'sk-ant-xxx']);

// 第三方接口:任意模型名 + 手选协议 + 自定义地址
$ai = AI::create([
    'model'    => 'qwen-max',
    'protocol' => 'openai',                                              // 手选协议格式
    'base_url' => 'https://dashscope.aliyuncs.com/compatible-mode/v1',   // 自定义接口地址
    'api_key'  => 'sk-xxx',
]);

模型名无法归属官方平台、又没给 base_url / endpoint 时,请求前会抛 ConfigException,而不是把 Key 发到不相干的官方域名。

可选的协议格式(protocol):

取值 说明 默认路径
openai(默认) OpenAI Chat Completions,绝大多数国产/中转接口都兼容它 /v1/chat/completions
claude / anthropic Anthropic Messages,工具调用(Agent)必须用它 /v1/messages
gemini Gemini 的 OpenAI 兼容端点 /v1beta/openai/chat/completions
deepseek DeepSeek(OpenAI 兼容),仅默认地址不同 /v1/chat/completions
openrouter / or OpenRouter 聚合中转(OpenAI 兼容),自动拼接默认地址 /v1/chat/completions
自定义协议类名 实现 Ai\Contracts\ProtocolInterface 的类,见「扩展开发」 由该类决定

不传 protocol 时按模型名推断(gpt-*→openai、claude-*→claude、gemini-*→gemini、deepseek-*→deepseek,也识别 厂商/模型 写法),推断不出则按 openai 处理。$ai->listProtocols() 可取到上表用于后台下拉框。

协议差异(重要)

各平台协议对 payload 键的支持并不一致,写业务代码前需要知道:

payload 键 OpenAI 协议 Claude 协议 Gemini 协议
messages ✅(role: system 会被丢弃)
system(顶层) ❌ 忽略 ❌ 忽略
tools / tool_choice ❌ 忽略 ❌ 忽略
temperature / max_tokens
stream ✅(自动附带 usage 统计)

结论:

  • OpenAI / Gemini 的系统提示词要写进 messagesrole: system
  • Claude 的系统提示词要写在顶层 system 键;
  • Agent / 工具调用只能用 Claude 协议的模型claude-3-opusdeepseek-anthropic)。

运行时查询平台与模型

$ai = new AI();

$ai->listPlatforms();   // ['claude'=>'Claude','deepseek'=>'Deepseek','gemini'=>'Gemini','openai'=>'Openai']
$ai->listProtocols();   // ['openai'=>'OpenAI 兼容(Chat Completions)', 'claude'=>..., 'gemini'=>..., 'deepseek'=>...]
$ai->listModels();      // 未设置 model 时:返回本库内置的模型标识列表
$ai->platformOfModel('qwen-max');   // 'custom'(设置模型前即可安全调用,无法归属官方平台时返回 custom)

$ai->setConfig(['model' => 'gpt-4o', 'api_key' => 'sk-xxx']);
$ai->getPlatform();     // 'openai'
$ai->getProtocolKey();  // 'openai',当前实际使用的协议
$ai->resolveEndpoint(); // 'https://api.openai.com/v1/chat/completions',当前实际请求端点
$ai->listModels();      // 已设置 model 时:调用平台接口拉取该平台真实可用模型
                        // 端点跟随 base_url / endpoint 走,接第三方网关时列的就是网关的模型
                        // OpenAI / Gemini / DeepSeek 实时拉取;Claude 拉取失败时回退内置列表;不支持则返回 null
$ai->listModels(true);  // 传入 true 返回完整模型数据(含 id / created / owned_by / pricing 等)
                        // 适用于 OpenRouter、Requesty 等需要展示模型价格/能力标签的场景

真实用例——按平台分组拉取模型列表并本地缓存一周,供后台下拉框渲染:

$platforms = $this->ai->listPlatforms();
$result    = [];

foreach ($platforms as $platform => $platformName) {
    $apiKey = (string)($this->siteConfig["{$platform}__api_key"] ?? '');
    if (empty($apiKey)) continue;               // 未配置 Key 的平台直接跳过

    try {
        $ai = new AI();
        $ai->setConfig([
            'model'   => $this->platformDefaultModels[$platform],  // 该平台任一模型,用于确定协议
            'api_key' => $apiKey,
        ]);
        $models = $ai->listModels();
        if (is_array($models) && $models) $result[$platform] = $models;
    } catch (\Exception $e) {
        // 单平台失败不影响其它平台
    }
}

配置项

$ai->setConfig([
    'model'        => 'gpt-4o',      // 模型标识(必填),内置标识或任意自定义模型名
    'api_key'      => 'sk-xxx',      // API 密钥(自建/内网接口可不填)
    'protocol'     => '',            // 手选协议格式:openai / claude(anthropic) / gemini / deepseek / 自定义协议类名
    'base_url'     => '',            // 接口根地址,与协议官方路径智能拼接,见「自定义接口地址」
    'endpoint'     => '',            // 完整对话端点,原样使用,优先级高于 base_url
    'endpoint_models' => '',         // 完整模型列表端点(仅 listModels 生效)
    'platform'     => '',            // 平台名,仅供业务层标识,默认由模型名/协议决定
    'headers'      => [],            // 追加/覆盖请求头,值为 null 表示删除协议默认头
    'extra_body'   => [],            // 追加到请求体的私有参数
    'max_tokens'             => 1024 * 64,  // 最大输出 tokens
    'max_completion_tokens'  => 16384,      // 仅 OpenAI o1/o3 系列,覆盖 max_tokens
    'temperature'            => 0.7,        // 温度
    'organization' => 'org-xxx',     // 仅 OpenAI 企业账号
    'project_id'   => 'proj_xxx',    // 仅 OpenAI 企业账号
]);

setConfig()增量合并,可以分多次调用;每次传入 model 都会重建模型与协议实例。base_urlprotocol 等既可以和 model 一起传,也可以在设置模型之后再补。

生成参数(max_tokensmax_completion_tokenstemperaturetop_ptop_kstoppresence_penaltyfrequency_penaltyseedresponse_formatsystemtoolstool_choicereasoning_effortthinking)写在 setConfig() 里对所有请求生效,单次 chat() 的 payload 优先级更高;连接信息(api_keybase_url 等)不会进入请求体。

接口有私有参数时用 extra_body(直接并入请求体),需要特殊鉴权头时用 headers

$ai->setConfig([
    'headers'    => [
        'Authorization' => null,      // 删掉协议默认写入的 Bearer 头
        'X-Api-Token'   => 'abc123',  // 换成对方要求的鉴权头
    ],
    'extra_body' => ['enable_thinking' => false, 'safe_mode' => 1],
]);

链式接口:

$ai->setModel('claude-3-opus')   // 单独切换模型
   ->setTimeout(300)             // 超时(秒),长文本生成务必调大
   ->setConnectTimeout(30)       // 连接超时(秒),独立于总超时
   ->setUserAgent('MyApp/1.0')   // 自定义 User-Agent(默认不发送)
   ->setSslVerify(false)         // 禁用 SSL 校验(仅调试/内网自签)
   ->setProxy('socks5h://127.0.0.1:1080')
   ->setStream(true)
   ->setAttachments([$file])
   ->chat($prompt);

调试时可用 $ai->getLastInfo() 获取最近一次请求的 cURL 信息(http_code、总耗时等)。

网络代理

支持 http://https://socks5://socks5h://(DNS 也走代理)、socks4://socks4a://

if (!empty($config['PROXY_SOCKS5'])) {
    $ai->setProxy($config['PROXY_SOCKS5']);
} elseif (!empty($config['PROXY_HTTP'])) {
    $ai->setProxy($config['PROXY_HTTP']);
}

自定义接口地址(第三方转发 / 中转 / 自建网关)

默认端点是各平台的官方地址。要接入第三方转发、中转或自建网关,有两种配置方式,优先级从高到低:

1. base_url —— 接口根地址,与协议官方路径智能拼接(最常用)

只要给出根地址即可,库会补上协议对应的路径;根地址自带的路径前缀会保留,与官方路径重叠的片段自动去重:

$ai = AI::create([
    'model'    => 'deepseek-chat',
    'api_key'  => 'sk-xxx',
    'base_url' => 'https://proxy.example.com',   // 或带端口 http://127.0.0.1:8080
]);
// 实际请求 => https://proxy.example.com/v1/chat/completions
base_url 协议路径 实际端点
https://proxy.com /v1/chat/completions https://proxy.com/v1/chat/completions
https://proxy.com/v1 /v1/chat/completions https://proxy.com/v1/chat/completions(重叠段去重)
https://proxy.com/openai /v1/chat/completions https://proxy.com/openai/v1/chat/completions
https://proxy.com/v1/chat/completions /v1/chat/completions 原样(已是完整端点)
127.0.0.1:8080 /v1/chat/completions https://127.0.0.1:8080/v1/chat/completions(缺 scheme 按 https)

2. endpoint —— 完整端点覆盖,原样使用(最灵活)

当接口路径结构与官方完全不同时使用,直接给出完整 URL:

$ai = AI::create([
    'model'    => 'deepseek-chat',
    'api_key'  => 'sk-xxx',
    'endpoint' => 'https://proxy.example.com/openai/deepseek/chat',  // 原样使用
]);

endpoint 优先级高于 base_url;两者都不设置时使用官方默认端点,完全向后兼容。

OpenRouter 聚合中转

OpenRouter 是一个 AI 模型聚合平台,通过统一的 OpenAI 兼容接口访问 OpenAI、Claude、Gemini、DeepSeek、Llama 等多种模型。库已内置 openrouter 协议,开箱即用

// 方式一(推荐):手选 protocol = openrouter,自动使用 openrouter.ai/api
$ai = AI::create([
    'model'    => 'openai/gpt-4o',              // OpenRouter 上的完整模型标识
    'protocol' => 'openrouter',
    'api_key'  => 'sk-or-v1-xxxxxxxxx',         // OpenRouter API Key
    'referer'  => 'https://myapp.com',          // 可选,来源标识(OpenRouter 后台查看)
    'title'    => 'MyApp',                      // 可选,应用名称
]);

// 方式二:用 base_url 配置(不依赖 protocol=openrouter)
$ai = AI::create([
    'model'    => 'anthropic/claude-sonnet-4-20250514',
    'base_url' => 'https://openrouter.ai/api',
    'api_key'  => 'sk-or-v1-xxxxxxxxx',
]);

OpenRouter 上的模型名使用 厂商/模型 格式,协议推断规则会自动提取厂商前缀:

  • openai/gpt-4o → 协议推断为 openai,自动使用 OpenAI 协议格式
  • anthropic/claude-sonnet-4-20250514 → 协议推断为 claude(但 OpenRouter 接口仍以 OpenAI 兼容格式应答,协议以 protocol 配置为准
  • deepseek/deepseek-chat → 协议推断为 deepseek
  • google/gemini-2.5-pro-exp-03-25 → 协议推断为 gemini

OpenRouter 返回的 usage 字段是 OpenRouter 统计而非原始模型统计(可能包含缓存命中标记等扩展字段),$response->getUsage() 原样透传。

通过 OpenRouter 查看实时模型状态:

$ai = AI::create([
    'protocol' => 'openrouter',
    'api_key'  => 'sk-or-v1-xxx',
]);
$models = $ai->setModel('openai/gpt-4o')->listModels(true);
// 返回含 id、pricing、context_length 等的完整模型信息

其他常见 AI 中转/聚合服务

以下中转站和网关均使用 OpenAI 兼容协议(protocol=openai),只需配置 base_urlendpoint

// API2D(国内 OpenAI 中转)
AI::create(['model'=>'gpt-4o', 'protocol'=>'openai', 'api_key'=>'fkxxxxx',
            'base_url'=>'https://openapi.api2d.com']);

// Cloudflare AI Gateway(官方聚合网关)
AI::create(['model'=>'@cf/meta/llama-3-8b-instruct', 'protocol'=>'openai', 'api_key'=>'xxx',
            'base_url'=>'https://gateway.ai.cloudflare.com/v1/{account_id}/{gateway_id}');

// one-api / new-api(自建聚合网关,最通用)
AI::create(['model'=>'glm-4.6', 'protocol'=>'openai', 'api_key'=>'sk-xxx',
            'base_url'=>'https://gateway.example.com']);

// 自建 Anthropic 兼容网关(Agent 工具调用需要 claude 协议)
AI::create(['model'=>'my-agent-model', 'protocol'=>'anthropic', 'api_key'=>'k',
            'base_url'=>'http://127.0.0.1:8080/gw']);
// => http://127.0.0.1:8080/gw/v1/messages

// 内网自建服务(无需 Key,用私有鉴权头)
AI::create(['model'=>'llama3', 'protocol'=>'openai',
            'base_url'=>'http://10.0.0.9:11434/v1',
            'headers' =>['Authorization'=>null, 'X-Internal-Token'=>'t']]);

// 阿里云百炼(OpenAI 兼容模式)
AI::create(['model'=>'qwen-max', 'protocol'=>'openai', 'api_key'=>'sk-xxx',
            'base_url'=>'https://dashscope.aliyuncs.com/compatible-mode/v1']);

以上所有接入方式均支持流式输出、附件、回调等完整功能。

模型列表端点listModels() 会跟随 base_url 走同一个网关;只配了 endpoint 时,库按对话端点同源推导(如 .../v1/chat/completions.../v1/models)。若网关的模型列表路径特殊,用 endpoint_models 单独完整覆盖(仅对 listModels() 生效)。OpenRouter 的模型列表接口返回完整定价数据,listModels(true) 可获取。

当前实际请求端点可随时查询:

echo $ai->resolveEndpoint();   // 返回按配置解析后的实际端点

流式输出(SSE)

调用 setStream(true) 后,chat() 会在接收模型数据的同时直接向输出缓冲区写 SSE 数据(自动设置响应头、关闭 Nginx 缓冲),无需注册回调:

$ai = AI::create(['model' => 'deepseek-chat', 'api_key' => 'sk-xxx']);

$response = $ai->setStream(true)->chat('写一篇关于人工智能的文章');

// 流式结束后仍可拿到完整内容与 tokens
$full = $response->getContent();
$used = $response->tokens();

服务端实际输出的报文格式(固定协议,前端按此解析):

data: {"type":"stream_chunk","content":"人工"}

data: {"type":"stream_chunk","content":"智能"}

data: {"type":"stream_end","data":{"content":"人工智能……","model":"deepseek-chat","usage":{"prompt_tokens":12,"completion_tokens":300,"total_tokens":312}}}

data: [DONE]

对应的前端消费代码:

const res = await fetch('/ai/chat', { method: 'POST', body: formData });
const reader = res.body.getReader();
const decoder = new TextDecoder();
let buffer = '';

while (true) {
    const { done, value } = await reader.read();
    if (done) break;
    buffer += decoder.decode(value, { stream: true });

    const parts = buffer.split('\n\n');
    buffer = parts.pop();

    for (const part of parts) {
        const line = part.replace(/^data:\s*/, '').trim();
        if (line === '' || line === '[DONE]') continue;
        const ev = JSON.parse(line);
        if (ev.type === 'stream_chunk') output.innerHTML += ev.content;
        if (ev.type === 'stream_end')   console.log('tokens:', ev.data.usage.total_tokens);
    }
}

真实用例——后台聊天接口(含代理、附件、流式):

$ai = new \Ai\AI();

if (!empty($siteConfig['PROXY_SOCKS5'])) $ai->setProxy($siteConfig['PROXY_SOCKS5']);

try {
    $ai->setStream(true)
       ->setConfig(['model' => $model, 'api_key' => $apiKey])
       ->setAttachments($attachments)
       ->chat($message);
} catch (\Ai\Exceptions\AIException $e) {
    // 流式已开始输出时,异常信息也只能顺着流写出去
    echo "data: " . json_encode(['type' => 'error', 'message' => $e->getMessage()]) . "\n\n";
}

PHP 环境注意:流式输出会清空并关闭所有输出缓冲。如果使用会话锁(session_start()),建议在流式开始前 session_write_close(),否则同一用户的其它请求会被阻塞。

附件(多模态)

use Ai\Helpers\AIFile;

$image = AIFile::fromPath('/path/to/image.jpg');            // 本地文件,自动识别 MIME
$image = AIFile::fromPath($tmpName, $_FILES['x']['type']);  // 指定 MIME
$image = AIFile::fromUrl('https://example.com/image.jpg');  // 远程 URL

$response = $ai->setAttachments([$image])->chat('描述这张图片');

附件格式由模型层适配:视觉模型(如 gpt-4o)转成各平台的图片块;不支持多模态的模型(如 DeepSeek 系列)会把附件信息以文本形式追加到最后一条用户消息,避免请求直接报错。

附件在每次 chat() 后自动清空,不会影响下一轮对话。

多轮对话上下文

本库不维护历史记录,多轮对话由业务层自行拼装(这样才能自由决定截断策略与持久化方式)。

// 取最近 N 条历史 + 本次消息
$messages = [];
foreach (array_slice($history, -20) as $h) {
    if (!in_array($h['role'], ['user', 'assistant'], true)) continue;
    $messages[] = ['role' => $h['role'], 'content' => $h['content']];
}
$messages[] = ['role' => 'user', 'content' => $message];

$response = $ai->chat([
    'system'   => $systemPrompt,   // Claude 协议
    'messages' => $messages,
]);

// 回复成功后再追加进历史并持久化
$history[] = ['role' => 'user',      'content' => $message, 'time' => time()];
$history[] = ['role' => 'assistant', 'content' => $response->getContent(), 'time' => time()];

请求前后回调

$ai->onBefore(function (&$payload) {
    // 请求前:可审计、可改写 payload
    log_message('debug', json_encode($payload));
    $payload['temperature'] = 0.5;
});

$ai->onAfter(function ($response) {          // onResponse() 是它的别名
    // 请求后:统计 tokens、写入用量表
    log_usage($response->getUsage());
});

回调内抛出的异常会被捕获并记录到 error_log,不会中断主流程。

响应对象

chat() 返回 Ai\Contracts\AIResponseInterface

方法 说明
getContent(): string 回复文本(流式模式下为累积后的完整文本)
getRaw(): array 平台原始响应体(Agent 解析 tool_use 块靠它)
getUsage(): array 完整用量对象,含 prompt_tokens / completion_tokens / total_tokens 及平台返回的扩展字段(prompt_tokens_details.cached_tokenscache_creation_input_tokens 等,因平台而异)
tokens(): int 总 tokens
getModel(): string 实际返回的模型名
isSuccess(): bool 是否成功
cost(array $pricing): float 按传入价格表估算费用,如 ['prompt'=>0.005,'completion'=>0.015](单位:每 1K tokens)
toArray() / __toString() 转数组 / 直接当字符串用

异常处理

use Ai\Exceptions\AIException;
use Ai\Exceptions\ConfigException;
use Ai\Exceptions\RequestException;

try {
    $response = $ai->chat($prompt);
} catch (ConfigException $e) {
    // 配置错误:模型不存在、未设置模型、协议未初始化
} catch (AIException $e) {
    // 请求失败:网络、鉴权、限流、平台报错,均在 chat() 内被包装成 AIException
    echo $e->getMessage();
    echo $e->getPlatform();      // 出错平台,如 'openai'
    echo $e->getErrorCode();     // 平台错误码
    print_r($e->getRawResponse()); // 平台原始错误响应,排查问题的关键
}

RequestException 由传输层抛出,chat() 内部会将其转成携带平台信息的 AIException,业务层通常只需捕获 AIException

Agent:工具调用循环

Ai\Agent\Agent 实现完整的 agentic 循环:模型决定调用哪个工具 → 库执行工具 → 结果回填给模型 → 继续,直到模型给出最终答复或达到迭代上限。

仅支持 Claude 协议的模型claude-3-opusdeepseek-anthropic)。

工具定义

$tools = [
    'sql_query' => [
        'description'  => '执行只读 SQL 查询。仅支持 SELECT/SHOW/DESCRIBE/EXPLAIN,最多返回 200 行。',
        'input_schema' => [
            'type'       => 'object',
            'properties' => [
                'sql' => ['type' => 'string', 'description' => '要执行的 SQL'],
            ],
            'required'   => ['sql'],
        ],
        'handler' => function (array $input) {
            $sql = trim((string)($input['sql'] ?? ''));
            if (!is_readonly_sql($sql)) return 'ERROR: 只允许只读查询';
            return json_encode(db_query($sql), JSON_UNESCAPED_UNICODE);
        },
    ],
];

handler 返回的字符串会作为 tool_result 回填给模型;抛出的异常会被自动转成 ERROR: 异常信息 交给模型,不会中断循环。

运行

$ai = new \Ai\AI();
$ai->setConfig([
    'model'      => 'deepseek-anthropic',
    'api_key'    => $apiKey,
    'max_tokens' => 1024 * 64,
]);

$emit = function ($ev) {
    // 把 Agent 过程实时推给前端
    echo "data: " . json_encode($ev, JSON_UNESCAPED_UNICODE) . "\n\n";
    flush();
};

$agent = (new \Ai\Agent\Agent($ai))
    ->setSystem($systemPrompt)
    ->setTools($tools)
    ->setMaxIter(128)      // 需要逐页分析的任务要给足迭代次数,默认 25
    ->onEvent($emit);

$agent->run([['role' => 'user', 'content' => $message]]);

$reply = $agent->lastText();   // 最终自然语言回复

事件类型

onEvent() 回调会依次收到:

事件 字段 含义
thinking iter 第几轮迭代开始
agent_text text 模型输出的自然语言
tool_call nameinput 模型决定调用某工具
done 正常结束
error message 出错或达到最大迭代步数

工具内部的细粒度事件(如 diff、进度)由各 handler 自行通过闭包发出,库不做假设。

Editor:AI 代码编辑

Ai\Editor\* 提供一套「让 AI 改代码」的完整协议:把编辑器现场(当前文件、光标、选区、已打开文件、工作区规范)结构化后交给模型,模型返回可校验、可执行的编辑动作。

use Ai\Editor\EditContext;
use Ai\Editor\EditProtocol;
use Ai\Editor\EditExecutor;
use Ai\Editor\EditAction;

// 1. 组装编辑上下文
$ctx = (new EditContext(FCPATH))
    ->setFile('templates/default/index.php')
    ->setLanguage('php')
    ->setContent($fileContent)
    ->setCursor(['line' => 42, 'column' => 8])
    ->setSelection(['start' => [...], 'end' => [...]], $selectedText)
    ->setOpenedFiles($openedFiles)
    ->setWorkspace($workspace);      // Ai\Editor\Workspace,限定可写根目录与编码规范

// 2. 生成系统提示词(内含编辑协议说明)+ 上下文 JSON
$system  = EditProtocol::systemPrompt($ctx);
$ctxJson = json_encode($ctx->toPromptJson(), JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);

$response = $ai->chat([
    'system'   => $system,
    'messages' => [['role' => 'user', 'content' => $message . "\n\n[CONTEXT]\n```json\n{$ctxJson}\n```"]],
]);

// 3. 解析模型返回的编辑计划
$plan = EditProtocol::parse($response->getContent());

// 4. 校验并执行
$executor = new EditExecutor($workspace->getRoot());   // 越界路径会被拒绝
foreach ($plan->toArray()['actions'] as $a) {
    $action = EditAction::fromArray($a);
    if (!$action->validate()) continue;
    $abs        = $executor->resolveAbsolute($action->file);   // 路径安全解析
    $newContent = $executor->computeContent(file_get_contents($abs), $action);
    file_put_contents($abs, $newContent);                      // 建议先备份
}

配合 Agent 可实现三种工作模式:plan(只读规划)、approval(产出待人工审核的建议)、auto(自动写入并备份)。

Tools:安全网页抓取

让模型联网读网页时,最大的风险是 SSRF。Ai\Tools\HttpFetch 内置纵深防御:

  • 仅允许 http/https,拒绝带 user:pass@ 的 URL
  • 端口白名单(默认 80/443)
  • 解析主机的所有 A/AAAA 记录,任一 IP 落在私有/保留/回环/链路本地/云元数据段即整体拒绝
  • CURLOPT_RESOLVE 把连接钉死到已校验 IP,防 DNS rebinding
  • 不自动跟随重定向,逐跳重新校验
  • 超过 max_bytes 立即中断;校验 TLS;不带 Cookie;不走站点代理
use Ai\Tools\HttpFetch;
use Ai\Tools\WebContent;

$fetcher = new HttpFetch(['max_bytes' => 1500 * 1024, 'timeout' => 15]);
$res     = $fetcher->fetch($url);
// $res = ['ok'=>bool, 'status'=>int, 'content_type'=>string, 'final_url'=>string, 'bytes'=>int, 'body'=>string, 'error'=>string]

if ($res['ok']) {
    // 按需渲染成模型友好的格式:text 纯文本 / md Markdown / source 原始源码
    $text = WebContent::render($res['body'], $res['content_type'], 'md', 16000);
}

把它包成 Agent 工具即可让模型自主上网:

'fetch_url' => [
    'description'  => '抓取一个公网网页并返回正文,用于查证实时信息。',
    'input_schema' => [
        'type' => 'object',
        'properties' => [
            'url'    => ['type' => 'string'],
            'format' => ['type' => 'string', 'enum' => ['text', 'md', 'source']],
        ],
        'required' => ['url'],
    ],
    'handler' => function ($input) use ($fetcher) {
        $r = $fetcher->fetch($input['url']);
        if (!$r['ok']) return 'ERROR: ' . $r['error'];
        return WebContent::render($r['body'], $r['content_type'], $input['format'] ?? 'md');
    },
],

Memory:Agent 长期记忆

把一个 Markdown 文件当作 Agent 的持久记忆(类似 CLAUDE.md)。文件位置由业务层决定,库不认识任何具体路径。

use Ai\Agent\Memory;

$mem = new Memory(FCPATH . 'writable/agent/memory.md', 20000);  // 第二参数:注入对话时的最大字符数

$block = $mem->forPrompt();          // 读取并截断,空记忆返回 ''
if ($block !== '') {
    $system .= "\n\n# 长期记忆\n" . $block;
}

$mem->append('用户偏好深色主题');    // 追加一条
$mem->write($fullContent);           // 覆盖整份

完整业务案例:批量 JSON 翻译

一个真实场景——把多语言词条按批交给 AI 翻译,要求模型严格返回 {"记录ID":"译文"} 的 JSON,并做失败重试、格式校验与结果回写。

use Ai\AI;
use Ai\Exceptions\AIException;

// 1. 组装待翻译数据:{ 记录ID: 原文 }
$translateData = [];
foreach ($batch as $rec) {
    $translateData[(int)$rec['id']] = $rec['text_source'];
}

// JSON_UNESCAPED_SLASHES 很关键:否则 </p> 会被转义成 <\/p>,
// 模型会把 \/ 当字面字符照抄进译文,导致译文出现错误转义
$dataJson = json_encode($translateData, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);

$prompt = "把下面 JSON 中每个值从 {$from} 翻译成 {$to}"
        . "保持键不变、保留 HTML 标签,只返回 JSON:\n{$dataJson}";

// 2. 调用,带重试与 JSON 校验
$ai = new AI();
$ai->setConfig(['model' => $model, 'api_key' => $apiKey, 'max_tokens' => 1024 * 256])
   ->setTimeout(300);

$content = '';
for ($loop = 1; $loop <= 3; $loop++) {
    try {
        $content = trim($ai->chat($prompt)->getContent());
    } catch (AIException $e) {
        log_message('error', 'AI翻译异常: ' . $e->getMessage());
        break;
    }
    // 去掉模型可能包裹的 ```json ``` 围栏后校验
    $content = preg_replace('@^\s*```(json)?\s*(.+?)\s*```\s*$@is', '$2', $content);
    if ($content !== '' && json_decode($content, true) !== null) break;
    $content = '';
}

// 3. 回写
$result = json_decode($content, true);
if (is_array($result)) {
    foreach ($result as $id => $text) {
        if (!isset($translateData[(int)$id]) || trim($text) === '') continue;
        update_translation((int)$id, trim($text));
    }
}

实战经验:

  • 务必带 JSON_UNESCAPED_SLASHES,并在收到结果后兜底 str_replace('\\/', '/', $text)
  • 模型常把 JSON 包在 ```json 围栏里,解析前先剥离;
  • 总字符数而不是条数切批(例如单批 10 万字符上限),超长的单条 HTML 单独成批;
  • 失败时把模型返回的原文一并记录下来,否则无从排查。

扩展开发

新增模型

namespace Ai\Models\OpenAI;

use Ai\Models\BaseModel;

class GPT4Turbo extends BaseModel
{
    protected $name     = 'gpt-4-turbo';                        // 发给平台的真实模型名
    protected $platform = 'openai';
    protected $protocol = 'Ai\\Protocol\\OpenAI';               // 复用协议
    protected $endpoint = 'https://api.openai.com/v1/chat/completions';
    protected $features = ['chat', 'stream', 'vision'];
    protected $config   = ['max_tokens' => 4096, 'temperature' => 0.7];
}

然后在 AI::$modelMap 中注册 'gpt-4-turbo' => 'Ai\Models\OpenAI\GPT4Turbo'

需要特殊附件处理的模型,重写 processAttachments(array $payload, array $attachments): array 即可。

只是想临时接一个新模型/新接口,不必写模型类——直接用 model + protocol + base_url 配置即可,库会在运行时构造 Ai\Models\CustomModel。也可以自己 new CustomModel([...]) 传给 setModel()

新增平台

  1. 实现 Ai\Contracts\ProtocolInterfacebuildRequestparseResponsebuildHeadersparseStreamChunkisStreamEndlistModels; 可选实现 defaultBaseUrl() / chatPath() / modelsPath(),供自定义模型自动组装端点;
  2. 创建该平台的模型类,$protocol 指向新协议;或直接把协议类名传给 protocol 配置项:
    AI::create(['model'=>'x', 'protocol'=>'App\\Protocol\\MyApi', 'base_url'=>'https://api.my.com']);
  3. AI::$modelMap 注册模型标识(可选,仅为提供快捷标识)。

传输层 Ai\Transport\CurlTransport 与协议无关,通常无需改动。

架构

php-ai/
├── src/                    # 源代码(PSR-4 命名空间 Ai\)
│   ├── AI.php              # 主入口:配置、模型解析、对话、流式、回调
│   ├── Agent/              # Agent 循环 + 长期记忆
│   ├── Contracts/          # 接口定义:Model / Protocol / Transport / AIResponse
│   ├── Editor/             # AI 代码编辑:上下文 / 协议 / 动作 / 执行器 / 工作区
│   ├── Exceptions/         # AIException / ConfigException / RequestException
│   ├── Helpers/            # AIFile(附件封装)、Endpoint(端点解析)、Protocols(协议注册表)、Headers(请求头合并)
│   ├── Models/             # 模型层:各平台模型的名称、端点、能力、默认配置
│   │   ├── BaseModel.php
│   │   ├── CustomModel.php # 通用模型:任意模型名 + 手选协议 + 自定义接口地址
│   │   ├── OpenAI/  Claude/  Gemini/  DeepSeek/
│   ├── Protocol/           # 协议层:OpenAI / Claude / Gemini / DeepSeek / OpenRouter
│   ├── Response/           # 统一响应对象
│   ├── Tools/              # HttpFetch(SSRF 防护)、WebContent(格式化)
│   └── Transport/          # cURL 传输层(含 SSE 解析、代理、超时)
├── autoload.php            # PSR-4 加载器(不用 Composer 时引入)
├── composer.json
├── examples*.php           # 使用示例
├── LICENSE
├── README.md
└── .gitignore

设计上分四层:模型层声明「是什么」(名称、端点、能力),协议层负责「怎么说」(请求/响应/流式格式),传输层负责「怎么发」(cURL、代理、超时、SSE),主入口负责编排。新增平台只动前两层。

已知限制

  • setSessionId() 与配置项 rounds 目前只是占位,库内部不会据此保存或拼接历史对话,多轮上下文需业务层自行维护;
  • 工具调用(tools)仅 Claude 协议实现,OpenAI 的 function calling 尚未接入;
  • 自定义模型的 supports() 能力是乐观默认值(对方接口实际支持什么库无从得知),需要准确值时用 features 配置项自行声明;
  • Ai\Protocol\Gemini::convertMessages() 未被调用——Gemini 走的是 OpenAI 兼容端点,消息直接透传;
  • cost() 需自行传入价格表,库不内置各平台价格。

许可证

MIT License