10分钟在网站上增加一个AI助手

package com.aliyun.webdemo.controller;

import com.alibaba.dashscope.app.Application;
import com.alibaba.dashscope.app.ApplicationParam;
import com.alibaba.dashscope.app.ApplicationResult;
import com.alibaba.dashscope.exception.InputRequiredException;
import com.alibaba.dashscope.exception.NoApiKeyException;
import com.google.gson.Gson;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
import io.reactivex.Flowable;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.servlet.mvc.method.annotation.ResponseBodyEmitter;

import java.util.concurrent.atomic.AtomicInteger;

/**
 * pom 配置依赖项
 * <dependency>
 *   <groupId>com.alibaba</groupId>
 *   <artifactId>dashscope-sdk-java</artifactId>
 *   <!-- 请将 'the-latest-version' 替换为查询到的最新版本号：https://mvnrepository.com/artifact/com.alibaba/dashscope-sdk-java -->
 *   <version>the-latest-version</version>
 * </dependency>
 *
 * 将API Key配置到环境变量 https://help.aliyun.com/zh/model-studio/developer-reference/configure-api-key-through-environment-variables
 */
@RestController
@RequestMapping("/chatbot")
public class ChatbotController {

    /**
     * 实现 chat 接口，支持流式返回数据
     *
     * @param query
     * @return
     */
    @RequestMapping(value = "/chat", method = RequestMethod.POST)
    public ResponseBodyEmitter streamData(@RequestBody String query) {
        ResponseBodyEmitter emitter = new ResponseBodyEmitter(180000L);
        JsonObject jsonObject = new JsonParser().parse(query).getAsJsonObject();
        try {
            streamCall(emitter, jsonObject.get("prompt").getAsString());
        } catch (NoApiKeyException | InputRequiredException e) {
            e.printStackTrace();
        }

        return emitter;
    }

    /**
     * 调用百炼应用，封装流式返回数据
     * 返回数据格式
     * id:1
     * event:result
     * :HTTP_STATUS/200
     * data:{"output":{"session_id":"xxx","finish_reason":"null","text":"相关的问题"}}
     *
     * @param emitter
     * @param query
     * @throws NoApiKeyException
     * @throws InputRequiredException
     */
    public void streamCall(ResponseBodyEmitter emitter, String query) throws NoApiKeyException, InputRequiredException {
        // appId 填入百炼应用 ID
        ApplicationParam param = ApplicationParam.builder()
                .appId("xxx")
                .prompt(query)
                .incrementalOutput(true)
                .build();

        Application application = new Application();
        Flowable<ApplicationResult> result = application.streamCall(param);
        AtomicInteger counter = new AtomicInteger(0);
        result.blockingForEach(data -> {
            int newValue = counter.incrementAndGet();
            String resData = "id:" + newValue + "\nevent:result\n:HTTP_STATUS/200\ndata:" + new Gson().toJson(data) + "\n\n";
            emitter.send(resData.getBytes(java.nio.charset.StandardCharsets.UTF_8));

            if ("stop".equals(data.getOutput().getFinishReason())) {
                emitter.complete();
            }
        });

    }
}

from flask import Flask, request, render_template, Response
from http import HTTPStatus
from dashscope import Application
import json

app = Flask(__name__)


@app.route("/")
def home(path=""):
    """
    首页
    """
    return render_template("index.html")


def call_with_stream(query):
    """
    流式调用百炼 API
    需要将API Key配置到环境变量
    https://help.aliyun.com/zh/model-studio/developer-reference/configure-api-key-through-environment-variables
    返回数据格式
    id:1
    event:result
    :HTTP_STATUS/200
    data:{"output":{"session_id":"xxx","finish_reason":"null","text":"相关的问题"}}
    """
    # appId 填入百炼应用 ID
    responses = Application.call(
        app_id="xxx",
        prompt=query,
        stream=True,
        incremental_output=True,
    )
    i = 0
    for response in responses:
        if response.status_code != HTTPStatus.OK:
            print(
                "request_id=%s\n output=%s\n usage=%s\n"
                % (response.request_id, response.output, response.usage)
            )
        else:
            data = (
                "id:"
                + str(i)
                + "\nevent:result\n:HTTP_STATUS/200\ndata:"
                + json.stringfy(response)
                + "\n\n"
            )
            yield data


@app.route("/chat", methods=["POST"])
def create():
    raw_data = request.data
    data = json.loads(raw_data.decode("utf-8"))

    return Response(
        call_with_stream(data["prompt"]), mimetype="application/octet-stream"
    )


if __name__ == "__main__":
    app.run(debug=True, port=8080)

<?php  
// 开始新会话或恢复现有会话
session_start();

// 非请求 退出
if(!isset($_SERVER['REQUEST_METHOD'])){
    exit;
}

// 初始化首页
if ($_SERVER['REQUEST_METHOD'] === 'GET') {  
    home();
}  

// AI助手post请求
if ($_SERVER['REQUEST_METHOD'] === 'POST') {  
    chat();
}  

/**
 * 展示首页
 * 首页内容请参考上述前端代码
 * 注：测试的时候请将修改前端代码中endpoint为"/"
 */
function home() {
    // HTML文件路径
    $file = 'home.html';

    if (file_exists($file)) {  
        // 文件存在，则显示内容
        header('Content-Type: text/html');
        readfile($file);
    } else {  
        // 提示文件不存在
        echo "404 Not Found. The file does not exist.";  
    }  
}

/**
 * AI助手post请求
 */
function chat() {  
    /**
     * 设置请求的URL和百炼API-KEY，将<APP_ID>替换为百炼应用ID
     */
    $url = 'https://dashscope.aliyuncs.com/api/v1/apps/<APP_ID>/completion'; // 请求的URL
    $apiKey = 'sk-xxx';

    /**
     * 设置请求头信息
     */
    $headers = [ // 请求头数组
        'Authorization: Bearer ' . $apiKey, // 认证头部
        'Content-Type: application/json', // 内容类型
        'X-DashScope-SSE: enable' // SSE启用标志
    ];

    // 初始化提示词为空字符串
    $prompt = ''; 

    // 获取输入流的内容
    $json = file_get_contents('php://input'); 
    // 尝试将JSON转换为关联数组
    $data = json_decode($json, true);
     // 检查JSON解析是否成功
     if (json_last_error() === JSON_ERROR_NONE) {
         $prompt = $data['prompt'] ?? null; // 提取prompt字段值
     }
   
    /**
     * 构建请求体
     */
    $requestBody = [ // 请求体数组
        'input' => ['prompt' => $prompt], // 输入项
        'parameters' => ['incremental_output' => true], // 参数设置
        'debug' => new stdClass(), // 调试选项（空对象）
    ];

    // 流式调用百炼 API
    call_with_stream($url, $headers, $requestBody);
} 

// 流式调用百炼 API
function call_with_stream($url, $headers, $requestBody){
    /**
     * 初始化cURL会话并设置相关属性
     */
    $ch = curl_init();

    curl_setopt_array($ch, [ // 设置cURL选项
        CURLOPT_URL => $url, // 目标URL
        CURLOPT_POST => true, // 使用POST方法
        CURLOPT_POSTFIELDS => json_encode($requestBody), // POST数据
        CURLOPT_HTTPHEADER => $headers, // 请求头
        CURLOPT_WRITEFUNCTION => function ($curl, $data) { // 自定义写回调
            echo $data; // 输出数据
            ob_flush(); // 刷新输出缓冲
            flush(); // 刷新所有输出缓冲
            return strlen($data); // 返回数据长度
        },
        CURLOPT_BUFFERSIZE => 128, // 缓冲区大小
        CURLOPT_TIMEOUT => 300, // 超时时间
        CURLOPT_RETURNTRANSFER => true, // 是否返回传输数据
        CURLOPT_HEADER => false // 不包含HTTP头部
    ]);

    /**
     * 执行cURL会话并获取响应
     */
    $response = curl_exec($ch);

    /**
     * 错误处理及响应输出
     */
    if (curl_errno($ch)) { // 检查是否存在cURL错误
        http_response_code(500); // 设置HTTP响应状态码为500
        echo 'Curl error: ' . curl_error($ch); // 输出错误信息
    } else {
        echo $response; // 输出响应结果
    }

    curl_close($ch); // 关闭cURL会话
}
?>