RUST-调用Deepseek api

Linkmanbo

use reqwest;
use serde::{Deserialize, Serialize};
use futures_util::StreamExt;

#[derive(Debug, Clone, Serialize, Deserialize)]
struct ChatMessage {
    role: String,
    content: String,
}

#[derive(Debug, Deserialize)]
struct StreamChoice {
    delta: Delta,
}

#[derive(Debug, Deserialize)]
struct Delta {
    content: Option<String>,
}

#[derive(Debug, Deserialize)]
struct StreamResponse {
    choices: Vec<StreamChoice>,
}

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let api_key = "填你的key";
   
    println!("&#128020;&#127824;&#127774;&#127827; 正在连接 DeepSeek AI...\n");
   
    let messages = vec![
        ChatMessage {
            role: "system".to_string(),
            content: "你是一个助手。".to_string(),
        },
        ChatMessage {
            role: "user".to_string(),
            content: "请详细介绍一下吾爱破解网站。".to_string(),
        },
    ];

    let client = reqwest::Client::new();
   
    let response = client
        .post("https://api.deepseek.com/v1/chat/completions")
        .header("Authorization", format!("Bearer {}", api_key))
        .header("Content-Type", "application/json")
        .json(&serde_json::json!({
            "model": "deepseek-chat",
            "messages": messages,
            "temperature": 0.7,
            "stream": true,  // 启用ds的流式模式
        }))
        .send()
        .await?;

    if !response.status().is_success() {
        let error_text = response.text().await?;
        println!(" 请求失败：{}", error_text);
        return Ok(());
    }

    println!(" AI 开始回答：\n");
   
    let mut stream = response.bytes_stream();
    let mut full_response = String::new();
   
    while let Some(chunk) = stream.next().await {
        let chunk = chunk?;
        let text = String::from_utf8_lossy(&chunk);
        
        //解析SSE
        for line in text.lines() {
            if line.starts_with("data: ") {
                let data = &line[6..];
               
                if data.trim() == "[DONE]" {
                    break;
                }
               
                if let Ok(resp) = serde_json::from_str::<StreamResponse>(data) {
                    if let Some(choice) = resp.choices.first() {
                        if let Some(content) = &choice.delta.content {
                            print!("{}", content);
                            full_response.push_str(content);
                           
                           
                            use std::io::Write;
                            std::io::stdout().flush().unwrap();
                        }
                    }
                }
            }
        }
    }
   
    println!("\n\n 回答完成！");
    println!("完整回复长度：{} 字符", full_response.len());
   
   
    println!("\n按回车键退出...");
    let mut input = String::new();
    std::io::stdin().read_line(&mut input).unwrap();

    Ok(())
}

chlo8

请问大佬，这个用于什么呢？