把联机带进
你的启动器。

import json, subprocess
p = subprocess.Popen(["python", "-m", "hookup", "bridge"], stdin=subprocess.PIPE,
                     stdout=subprocess.PIPE, text=True, encoding="utf-8")
def rpc(i, method, params):
    p.stdin.write(json.dumps({"jsonrpc":"2.0", "id":i,
        "method":method, "params":params}) + "\n")
    p.stdin.flush(); reply = json.loads(p.stdout.readline())
    if "error" in reply: raise RuntimeError(reply["error"]["message"])
    return reply["result"]
rpc(1, "bridge.initialize", {"protocol":1})
node = rpc(2, "node.add", {"code": access_code})["node"]
room = rpc(3, "room.join", {"node":node, "invite":invite, "transport":"auto"})
launch_minecraft(room["address"])
rpc(4, "room.close", {"session":room["session"]})

// Use CreateProcess pipes (Windows) or pipe/posix_spawn (Unix) for the bridge process.
// Keep stderr separate; write_line/read_line exchange one UTF-8 JSON frame each.
#include <nlohmann/json.hpp>
using json = nlohmann::json;
json rpc(BridgeProcess& bridge, int id, const char* method, json params) {
  json request={{"jsonrpc","2.0"},{"id",id},{"method",method},{"params",params}};
  bridge.write_line(request.dump());
  auto response=json::parse(bridge.read_line(8192));
  if (response.contains("error")) throw std::runtime_error(response["error"]["message"].get<std::string>());
  return response.at("result");
}
auto init=rpc(bridge,1,"bridge.initialize",{{"protocol",1}});
auto node=rpc(bridge,2,"node.add",{{"code",access_code}}).at("node");
auto room=rpc(bridge,3,"room.join",{{"node",node},{"invite",invite},{"transport","auto"}});
launch_minecraft(room.at("address").get<std::string>());
rpc(bridge,4,"room.close",{{"session",room.at("session")}});

var process = new ProcessBuilder(pythonPath, "-m", "hookup", "bridge").start();
var in = new java.io.BufferedWriter(new java.io.OutputStreamWriter(process.getOutputStream(), java.nio.charset.StandardCharsets.UTF_8));
var out = new java.io.BufferedReader(new java.io.InputStreamReader(process.getInputStream(), java.nio.charset.StandardCharsets.UTF_8));
var json = new com.fasterxml.jackson.databind.ObjectMapper();
var sequence = new java.util.concurrent.atomic.AtomicInteger();
java.util.function.BiFunction<String, java.util.Map<String,Object>, com.fasterxml.jackson.databind.JsonNode> rpc = (method, params) -> {
  try {
    var q=java.util.Map.of("jsonrpc","2.0", "id",sequence.incrementAndGet(), "method",method, "params",params);
    in.write(json.writeValueAsString(q)); in.newLine(); in.flush();
    var reply=json.readTree(out.readLine());
    if (reply.has("error")) throw new RuntimeException(reply.get("error").toString());
    return reply.get("result");
  } catch (java.io.IOException e) { throw new RuntimeException(e); }
};
rpc.apply("bridge.initialize", java.util.Map.of("protocol",1));
var node=rpc.apply("node.add", java.util.Map.of("code",accessCode)).get("node").asText();
var room=rpc.apply("room.join", java.util.Map.of("node",node, "invite",invite, "transport","auto"));
launchMinecraft(room.get("address").asText());
rpc.apply("room.close", java.util.Map.of("session",room.get("session").asText()));

var start = new System.Diagnostics.ProcessStartInfo(pythonPath, "-m hookup bridge") {
    RedirectStandardInput=true, RedirectStandardOutput=true, UseShellExecute=false, CreateNoWindow=true };
using var bridge = System.Diagnostics.Process.Start(start)!;
async System.Threading.Tasks.Task<System.Text.Json.JsonElement> Rpc(int id, string method, object parameters) {
  var q=System.Text.Json.JsonSerializer.Serialize(new { jsonrpc="2.0", id, method, @params=parameters });
  await bridge.StandardInput.WriteLineAsync(q); await bridge.StandardInput.FlushAsync();
  using var doc=System.Text.Json.JsonDocument.Parse((await bridge.StandardOutput.ReadLineAsync())!);
  var root=doc.RootElement; if (root.TryGetProperty("error",out var error)) throw new Exception(error.ToString());
  return root.GetProperty("result").Clone();
}
await Rpc(1,"bridge.initialize",new { protocol=1 });
var node=(await Rpc(2,"node.add",new { code=accessCode })).GetProperty("node").GetString();
var room=await Rpc(3,"room.join",new { node, invite, transport="auto" });
LaunchMinecraft(room.GetProperty("address").GetString());
await Rpc(4,"room.close",new { session=room.GetProperty("session").GetString() });