火山方舟java大模型对接文生文流形式接收返回值

### 使用火山方舟 Java 大模型实现文本生成并以流式方式接收返回值

为了在火山方舟平台中利用Java大模型进行文本生成功能，并采用流式传输来处理返回的数据，开发者需遵循特定的配置流程以及编码实践。

#### 创建API Key访问凭证
进入火山引擎提供的API Key管理界面之后，按照指引完成新API Key的创建过程[^3]。这一步骤对于确保后续请求能够被合法授权至关重要。

#### 初始化客户端与设置参数
当获得有效的API Key后，在应用程序内部初始化SDK实例之前，务必指定所使用的模型名称，例如`model=ep-xxxxxxxxxxxxx-yyyy`这样的形式[^2]。此操作决定了具体的预训练模型版本会被加载到运行环境中参与推理计算任务。

#### 实现代码示例
下面给出了一段基于上述说明编写的简单Java程序片段，展示了怎样构建HTTP POST请求向服务器发送待处理的消息体数据，并开启异步监听机制准备接受来自服务端分批次推送过来的结果集：

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;

public class LLMStreamExample {
    public static void main(String[] args) throws Exception {
        String apiKey = "your_api_key_here"; // 替换成实际取得的API key
        
        URL url = new URL("https://api.volcengine.com/v1/llm/generation/stream");
        HttpURLConnection conn = (HttpURLConnection)url.openConnection();
        
        // 设置必要的请求头信息
        conn.setRequestMethod("POST");
        conn.setDoOutput(true);
        conn.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
        conn.setRequestProperty("Authorization", "Bearer "+apiKey);

        // 构建JSON格式的输入payload
        String jsonInputString = "{ \"prompt\": \"你好\", \"stream\": true, \"delay_ms\": 500 }";
        byte[] inputBytes = jsonInputString.getBytes("utf-8");

        // 发送请求主体内容给远程主机
        try(OutputStream os = conn.getOutputStream()){
            os.write(inputBytes, 0, inputBytes.length);            
        }

        // 开始读取响应中的部分结果
        StringBuilder responseBuilder = new StringBuilder();
        BufferedReader br = null;
        if(conn.getResponseCode() == HttpURLConnection.HTTP_OK){
            br = new BufferedReader(new InputStreamReader((conn.getInputStream())));
            String output;
            while ((output = br.readLine()) != null ) {
                System.out.println(output.trim()); // 打印每一段接收到的内容
                Thread.sleep(100); // 模拟简单的流量控制逻辑
            }
        }else{
            br = new BufferedReader(new InputStreamReader((conn.getErrorStream())));
            System.err.println(br.lines().reduce("", String::concat));
        }
        conn.disconnect();    
    }
}

这段代码实现了基本的功能需求——即通过设定`stream=true`参数指示期望得到连续不断的输出更新；同时设置了合理的等待间隔(`Thread.sleep`)模拟了简易版的速率限制措施防止过载情况发生。