如何使用原生Java连接Salesforce Apex语言服务器？需可运行代码示例

前提准备 #

• 下载apex-jorje-lsp.jar包
• 确保使用JDK 11及以上版本（语言服务器依赖较新Java特性）
• 了解Language Server Protocol（LSP）核心机制：基于标准输入输出的JSON-RPC交互

核心思路 #

Apex语言服务器通过**标准输入/输出（STDIN/STDOUT）**与客户端进行JSON-RPC通信，Java代码需完成以下步骤：

1. 启动语言服务器进程
2. 建立与进程的输入输出流连接
3. 按LSP规范构造JSON请求并发送
4. 解析服务器返回的JSON响应

可运行Java代码示例 #

import com.google.gson.Gson;
import com.google.gson.JsonObject;
import java.io.*;
import java.util.Scanner;

public class ApexLspClient {
    private static Process languageServerProcess;
    private static BufferedWriter serverInput;
    private static BufferedReader serverOutput;
    private static Gson gson = new Gson();

    public static void main(String[] args) throws IOException, InterruptedException {
        // 1. 启动Apex语言服务器进程
        startLanguageServer();

        // 2. 发送初始化请求（LSP必须的第一步）
        sendInitializeRequest();

        // 3. 发送文档诊断请求示例（检测Apex代码错误）
        sendDiagnosticsRequest("public class TestClass { Integer x; public void test() { x = 'string'; } }");

        // 4. 保持客户端运行，等待响应
        Scanner scanner = new Scanner(System.in);
        System.out.println("按回车键退出...");
        scanner.nextLine();

        // 5. 关闭资源
        shutdownLanguageServer();
    }

    private static void startLanguageServer() throws IOException {
        String jarPath = "/path/to/your/apex-jorje-lsp.jar"; // 替换为你的JAR实际路径
        ProcessBuilder pb = new ProcessBuilder("java", "-jar", jarPath);
        pb.redirectErrorStream(true); // 合并错误流到输出流，方便调试
        languageServerProcess = pb.start();

        serverInput = new BufferedWriter(new OutputStreamWriter(languageServerProcess.getOutputStream()));
        serverOutput = new BufferedReader(new InputStreamReader(languageServerProcess.getInputStream()));

        // 启动线程监听服务器输出
        new Thread(() -> {
            String line;
            try {
                while ((line = serverOutput.readLine()) != null) {
                    // LSP响应格式为"Content-Length: xxx\r\n\r\n{JSON}"，需解析
                    if (line.startsWith("Content-Length:")) {
                        int contentLength = Integer.parseInt(line.split(":")[1].trim());
                        serverOutput.readLine(); // 读取空行分隔符
                        // 读取完整JSON内容
                        char[] buffer = new char[contentLength];
                        serverOutput.read(buffer, 0, contentLength);
                        String responseJson = new String(buffer);
                        System.out.println("服务器响应:\n" + responseJson);
                    }
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }).start();
    }

    private static void sendInitializeRequest() throws IOException {
        JsonObject request = new JsonObject();
        request.addProperty("jsonrpc", "2.0");
        request.addProperty("id", 1);
        request.addProperty("method", "initialize");

        JsonObject params = new JsonObject();
        params.addProperty("processId", ProcessHandle.current().pid());
        JsonObject clientCapabilities = new JsonObject();
        params.add("capabilities", clientCapabilities);
        request.add("params", params);

        sendRequest(request);
    }

    private static void sendDiagnosticsRequest(String apexCode) throws IOException {
        JsonObject request = new JsonObject();
        request.addProperty("jsonrpc", "2.0");
        request.addProperty("id", 2);
        request.addProperty("method", "textDocument/diagnostic");

        JsonObject params = new JsonObject();
        JsonObject textDocument = new JsonObject();
        textDocument.addProperty("uri", "file:///test/TestClass.cls"); // 虚拟文件URI，可替换为真实路径
        params.add("textDocument", textDocument);
        params.addProperty("text", apexCode);
        request.add("params", params);

        sendRequest(request);
    }

    private static void sendRequest(JsonObject request) throws IOException {
        String json = gson.toJson(request);
        String contentHeader = "Content-Length: " + json.length() + "\r\n\r\n";
        serverInput.write(contentHeader + json);
        serverInput.flush();
        System.out.println("发送请求:\n" + json);
    }

    private static void shutdownLanguageServer() throws IOException, InterruptedException {
        // 发送shutdown请求
        JsonObject shutdownRequest = new JsonObject();
        shutdownRequest.addProperty("jsonrpc", "2.0");
        shutdownRequest.addProperty("id", 3);
        shutdownRequest.addProperty("method", "shutdown");
        sendRequest(shutdownRequest);

        // 发送exit通知
        JsonObject exitRequest = new JsonObject();
        exitRequest.addProperty("jsonrpc", "2.0");
        exitRequest.addProperty("method", "exit");
        sendRequest(exitRequest);

        serverInput.close();
        serverOutput.close();
        languageServerProcess.waitFor();
    }
}

依赖说明 #

代码使用Google Gson处理JSON序列化/反序列化，需在项目中添加依赖：

• Maven：

<dependency>
    <groupId>com.google.code.gson</groupId>
    <artifactId>gson</artifactId>
    <version>2.10.1</version>
</dependency>

• Gradle：

implementation 'com.google.code.gson:gson:2.10.1'

关键注意事项 #

1. LSP通信格式：所有请求/响应必须遵循Content-Length: {长度}\r\n\r\n{JSON}的标准格式，否则服务器无法解析
2. 初始化请求：必须先发送initialize请求，服务器才会处理后续其他请求
3. 文件URI：示例使用虚拟URI，实际场景可替换为本地Apex文件的真实路径
4. 异常处理：示例简化了错误处理，生产环境需添加完善的流管理和异常捕获逻辑

内容的提问来源于stack exchange，提问作者Sharif Hasan