功能增加&修复一些已知问题，详见描述

composer.json

@@ -10,7 +10,13 @@
     "autoload": {
         "psr-4": {
             "Hyperf\\Odin\\": "src/"
-        }
+        },
+        "classmap": [
+            "src/Api/Providers/AwsBedrock/ClassMap/"
+        ],
+        "exclude-from-classmap": [
+            "vendor/aws/aws-sdk-php/src/Api/Validator.php"
+        ]
     },
     "autoload-dev": {
         "psr-4": {
@@ -28,6 +34,7 @@
         "hyperf/config": "~2.2.0 || 3.0.* || 3.1.*",
         "hyperf/di": "~2.2.0 || 3.0.* || 3.1.*",
         "hyperf/logger": "~2.2.0 || 3.0.* || 3.1.*",
+        "hyperf/retry": "~2.2.0 || 3.0.* || 3.1.*",
         "hyperf/qdrant-client": "*",
         "justinrainbow/json-schema": "^6.3",
         "yethee/tiktoken": "^0.1.2"

examples/aws/aws_chat.php

@@ -43,8 +43,10 @@
     new Logger(),
 );
 $model->setApiRequestOptions(new ApiOptions([
-    // 如果你的环境不需要代码，那就不用
+    // 如果你的环境不需要代理，那就不用
     'proxy' => env('HTTP_CLIENT_PROXY'),
+    // HTTP 处理器配置 - 支持环境变量 ODIN_HTTP_HANDLER
+    'http_handler' => env('ODIN_HTTP_HANDLER', 'auto'),
 ]));
 
 $messages = [

examples/aws/aws_chat_stream.php

@@ -44,8 +44,10 @@
 );
 
 $model->setApiRequestOptions(new ApiOptions([
-    // 如果你的环境不需要代码，那就不用
+    // 如果你的环境不需要代理，那就不用
     'proxy' => env('HTTP_CLIENT_PROXY'),
+    // HTTP 处理器配置 - 支持环境变量 ODIN_HTTP_HANDLER
+    'http_handler' => env('ODIN_HTTP_HANDLER', 'auto'),
 ]));
 
 echo '=== AWS Bedrock Claude 流式响应测试 ===' . PHP_EOL;

examples/aws/aws_tool_use_agent.php

@@ -196,6 +196,19 @@
     }
 );
 
+$taskTool = new ToolDefinition(
+    name: 'trigger_task',
+    description: '触发任务执行',
+    parameters: ToolParameters::fromArray([
+        'type' => 'object',
+        'properties' => [],
+        'required' => [],
+    ]),
+    toolHandler: function () {
+        return ['status' => 'success', 'message' => '任务 已触发'];
+    }
+);
+
 // 创建带有所有工具的代理
 $agent = new ToolUseAgent(
     model: $model,
@@ -204,6 +217,7 @@
         $calculatorTool->getName() => $calculatorTool,
         $weatherTool->getName() => $weatherTool,
         $translateTool->getName() => $translateTool,
+        $taskTool->getName() => $taskTool,
     ],
     temperature: 0.6,
     logger: $logger
@@ -213,7 +227,7 @@
 echo "===== 顺序工具调用示例 =====\n";
 $start = microtime(true);
 
-$userMessage = new UserMessage('请计算 23 × 45，然后查询北京的天气，最后将"你好"翻译成英语。请详细说明每一步。');
+$userMessage = new UserMessage('请计算 23 × 45，然后查询北京的天气，最后将"你好"翻译成英语，和触发任务。请详细说明每一步。');
 $response = $agent->chat($userMessage);
 
 $message = $response->getFirstChoice()->getMessage();

examples/aws/aws_tools.php

@@ -0,0 +1,138 @@
+<?php
+
+declare(strict_types=1);
+/**
+ * This file is part of Hyperf.
+ *
+ * @link     https://www.hyperf.io
+ * @document https://hyperf.wiki
+ * @contact  group@hyperf.io
+ * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
+ */
+! defined('BASE_PATH') && define('BASE_PATH', dirname(__DIR__, 2));
+
+require_once dirname(__FILE__, 3) . '/vendor/autoload.php';
+
+use Hyperf\Context\ApplicationContext;
+use Hyperf\Di\ClassLoader;
+use Hyperf\Di\Container;
+use Hyperf\Di\Definition\DefinitionSourceFactory;
+use Hyperf\Odin\Api\RequestOptions\ApiOptions;
+use Hyperf\Odin\Logger;
+use Hyperf\Odin\Message\AssistantMessage;
+use Hyperf\Odin\Message\SystemMessage;
+use Hyperf\Odin\Message\ToolMessage;
+use Hyperf\Odin\Message\UserMessage;
+use Hyperf\Odin\Model\AwsBedrockModel;
+use Hyperf\Odin\Model\ModelOptions;
+use Hyperf\Odin\Tool\Definition\ToolDefinition;
+use Hyperf\Odin\Tool\Definition\ToolParameters;
+
+use function Hyperf\Support\env;
+
+ClassLoader::init();
+
+$container = ApplicationContext::setContainer(new Container((new DefinitionSourceFactory())()));
+
+// 创建 AWS Bedrock 模型实例
+// 使用 Claude 3 Sonnet 模型 ID
+$model = new AwsBedrockModel(
+    'us.anthropic.claude-3-7-sonnet-20250219-v1:0',
+    [
+        'access_key' => env('AWS_ACCESS_KEY'),
+        'secret_key' => env('AWS_SECRET_KEY'),
+        'region' => env('AWS_REGION', 'us-east-1'),
+    ],
+    new Logger(),
+);
+$model->setModelOptions(new ModelOptions([
+    'function_call' => true,
+]));
+$model->setApiRequestOptions(new ApiOptions([
+    // 如果你的环境不需要代码，那就不用
+    'proxy' => env('HTTP_CLIENT_PROXY'),
+]));
+
+echo '=== AWS Bedrock Claude 工具调用测试 ===' . PHP_EOL;
+echo '支持函数调用功能' . PHP_EOL . PHP_EOL;
+
+// 定义一个天气查询工具
+$weatherTool = new ToolDefinition(
+    name: 'weather',
+    description: '查询指定城市的天气信息',
+    parameters: ToolParameters::fromArray([
+        'type' => 'object',
+        'properties' => [
+            'city' => [
+                'type' => 'string',
+                'description' => '要查询天气的城市名称',
+            ],
+        ],
+        'required' => ['city'],
+    ]),
+    toolHandler: function ($params) {
+        $city = $params['city'];
+        // 模拟天气数据
+        $weatherData = [
+            '北京' => ['temperature' => '25°C', 'condition' => '晴朗', 'humidity' => '45%'],
+            '上海' => ['temperature' => '28°C', 'condition' => '多云', 'humidity' => '60%'],
+            '广州' => ['temperature' => '30°C', 'condition' => '阵雨', 'humidity' => '75%'],
+            '深圳' => ['temperature' => '29°C', 'condition' => '晴朗', 'humidity' => '65%'],
+        ];
+
+        if (isset($weatherData[$city])) {
+            return $weatherData[$city];
+        }
+        return ['error' => '没有找到该城市的天气信息'];
+    }
+);
+
+$toolMessages = [
+    new SystemMessage('你是一位有用的天气助手，可以查询天气信息。'),
+    new UserMessage('同时查询明天 深圳和东莞的天气'),
+    AssistantMessage::fromArray(json_decode(
+        <<<'JSON'
+{
+    "content": "我可以帮您查询明天深圳和东莞的天气信息",
+    "tool_calls": [
+        {
+            "id": "tooluse_NPtHekdGQpSCu0JphjkdHQ",
+            "function": {
+                "name": "weather",
+                "arguments": "{\"city\":\"深圳\"}"
+            },
+            "type": "function"
+        },
+        {
+            "id": "tooluse_eJJQosmHSDWThQN53aeOJA",
+            "function": {
+                "name": "weather",
+                "arguments": "{\"city\":\"东莞\"}"
+            },
+            "type": "function"
+        }
+    ]
+}
+JSON,
+        true
+    )),
+    new ToolMessage('25 度', 'tooluse_NPtHekdGQpSCu0JphjkdHQ', 'weather', [
+        'city' => '深圳',
+    ]),
+    new ToolMessage('26 度', 'tooluse_eJJQosmHSDWThQN53aeOJA', 'weather', [
+        'city' => ' 东莞',
+    ]),
+];
+
+$start = microtime(true);
+
+// 使用工具进行API调用
+$response = $model->chat($toolMessages, 0.7, 0, [], [$weatherTool]);
+
+// 输出完整响应
+$message = $response->getFirstChoice()->getMessage();
+if ($message instanceof AssistantMessage) {
+    echo $message->getContent();
+}
+
+echo '耗时' . (microtime(true) - $start) . '秒' . PHP_EOL;

examples/chat.php

@@ -17,6 +17,7 @@
 use Hyperf\Di\ClassLoader;
 use Hyperf\Di\Container;
 use Hyperf\Di\Definition\DefinitionSourceFactory;
+use Hyperf\Odin\Api\RequestOptions\ApiOptions;
 use Hyperf\Odin\Logger;
 use Hyperf\Odin\Message\AssistantMessage;
 use Hyperf\Odin\Message\SystemMessage;
@@ -40,6 +41,11 @@
     new Logger(),
 );
 
+$model->setApiRequestOptions(new ApiOptions([
+    // HTTP 处理器配置 - 支持环境变量 ODIN_HTTP_HANDLER
+    'http_handler' => env('ODIN_HTTP_HANDLER', 'auto'),
+]));
+
 $messages = [
     new SystemMessage(''),
     new UserMessage('请解释量子纠缠的原理，并举一个实际应用的例子'),

examples/chat_doubao.php

@@ -47,7 +47,7 @@
 $start = microtime(true);
 
 // 使用非流式API调用
-$request = new ChatCompletionRequest($messages);
+$request = new ChatCompletionRequest($messages, maxTokens: 8096);
 $request->setThinking([
     'type' => 'disabled',
 ]);

examples/exception/azure_server_error_retry_example.php

@@ -0,0 +1,115 @@
+<?php
+
+declare(strict_types=1);
+/**
+ * This file is part of Hyperf.
+ *
+ * @link     https://www.hyperf.io
+ * @document https://hyperf.wiki
+ * @contact  group@hyperf.io
+ * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
+ */
+require_once __DIR__ . '/../../vendor/autoload.php';
+
+use GuzzleHttp\Exception\RequestException;
+use GuzzleHttp\Psr7\Request;
+use GuzzleHttp\Psr7\Response;
+use Hyperf\Odin\Exception\LLMException\ErrorMappingManager;
+use Hyperf\Odin\Exception\LLMException\LLMNetworkException;
+use Hyperf\Odin\Exception\LLMException\Model\LLMContentFilterException;
+
+echo "=== Azure OpenAI 异常分类与重试机制演示 ===\n\n";
+
+// 模拟两种不同的 Azure OpenAI 500 错误
+$testCases = [
+    'model_error (内容过滤)' => [
+        'error_type' => 'model_error',
+        'message' => 'The model produced invalid content. Consider modifying your prompt if you are seeing this error persistently.',
+        'expected_exception' => LLMContentFilterException::class,
+        'retryable' => false,
+        'user_action' => '修改提示词内容',
+    ],
+    'server_error (服务故障)' => [
+        'error_type' => 'server_error',
+        'message' => 'The server had an error while processing your request. Sorry about that!',
+        'expected_exception' => LLMNetworkException::class,
+        'retryable' => true,
+        'user_action' => '自动重试',
+    ],
+];
+
+$errorMappingManager = new ErrorMappingManager();
+
+foreach ($testCases as $caseName => $testCase) {
+    echo "🧪 测试场景: {$caseName}\n";
+    echo "   Azure错误类型: {$testCase['error_type']}\n";
+    echo "   Azure错误消息: {$testCase['message']}\n";
+
+    // 创建模拟的Azure错误响应
+    $errorBody = json_encode([
+        'error' => [
+            'message' => $testCase['message'],
+            'type' => $testCase['error_type'],
+            'param' => null,
+            'code' => null,
+        ],
+    ]);
+
+    $request = new Request('POST', 'https://test-azure-openai.example.com/openai/deployments/test-gpt/chat/completions');
+    $response = new Response(500, ['Content-Type' => 'application/json'], $errorBody);
+
+    $requestException = new RequestException(
+        "Server error: {$testCase['message']}",
+        $request,
+        $response
+    );
+
+    // 通过异常映射管理器处理
+    $mappedException = $errorMappingManager->mapException($requestException);
+
+    echo "   ✅ 映射结果:\n";
+    echo '      异常类型: ' . get_class($mappedException) . "\n";
+    echo "      异常消息: {$mappedException->getMessage()}\n";
+    echo "      HTTP状态码: {$mappedException->getStatusCode()}\n";
+    echo "      错误代码: {$mappedException->getErrorCode()}\n";
+
+    // 检查重试逻辑
+    $isRetryable = $mappedException instanceof LLMNetworkException;
+    echo '      可重试: ' . ($isRetryable ? '✅ 是' : '❌ 否') . "\n";
+    echo "      用户操作: {$testCase['user_action']}\n";
+
+    // 验证分类正确性
+    $isCorrectType = $mappedException instanceof $testCase['expected_exception'];
+    echo '      分类正确: ' . ($isCorrectType ? '✅ 是' : '❌ 否') . "\n";
+
+    echo "\n";
+}
+
+echo "=== 重试机制逻辑演示 ===\n";
+echo "在 AbstractModel::callWithNetworkRetry 中的重试条件:\n";
+echo "```php\n";
+echo "return \$throwable instanceof LLMNetworkException\n";
+echo "    || (\$throwable && \$throwable->getPrevious() instanceof LLMNetworkException);\n";
+echo "```\n\n";
+
+echo "📊 改进前后对比:\n";
+echo "┌─────────────┬─────────────────────────┬────────────────────────────┐\n";
+echo "│ 错误类型    │ 改进前                   │ 改进后                      │\n";
+echo "├─────────────┼─────────────────────────┼────────────────────────────┤\n";
+echo "│ model_error │ LLMContentFilterException│ LLMContentFilterException  │\n";
+echo "│             │ ❌ 不可重试              │ ❌ 不可重试 (正确)          │\n";
+echo "├─────────────┼─────────────────────────┼────────────────────────────┤\n";
+echo "│ server_error│ LLMApiException         │ LLMNetworkException        │\n";
+echo "│             │ ❌ 不可重试              │ ✅ 可重试 (正确)            │\n";
+echo "└─────────────┴─────────────────────────┴────────────────────────────┘\n\n";
+
+echo "🎯 **重要改进**:\n";
+echo "1. ✅ Azure OpenAI 服务故障 (server_error) 现在可以自动重试\n";
+echo "2. ✅ 内容过滤错误 (model_error) 仍然不会重试，需要用户修改提示词\n";
+echo "3. ✅ 状态码和错误信息都被正确保留\n";
+echo "4. ✅ 为用户提供了更准确的错误处理建议\n\n";
+
+echo "💡 **对你的 OpenAI 代理接口的影响**:\n";
+echo "- 暂时性服务故障会自动重试，提升可用性\n";
+echo "- 用户收到更准确的错误类型和处理建议\n";
+echo "- 减少因 Azure 服务抖动造成的请求失败\n";