Rust ile basit bir Minecraft sunucu launcher yaziyorum: launcher.rs · GitHub
Kodun tumu (gist'in aynisi)
use std::process::{Command, exit};
use std::path::Path;
use std::thread;
use std::fs;
use log::{info, debug, warn, error, LevelFilter};
use std::sync::{Arc, Mutex};
use std::io::BufReader;
use std::io::BufRead;
use std::sync::mpsc::Sender;
use std::io::Write;
#[derive(PartialEq)]
pub enum ServerState {
RUNNING,
STOPPED,
CRASHED,
}
pub struct ServerLauncher {
jarfile: String,
java_path: String,
server_dir: String,
server_args: Vec<String>,
server_name: String,
memory: i32,
pub state: ServerState,
process: Option<Arc<Mutex<std::process::Child>>>,
log_stream_sender: Arc<Sender<String>>,
}
impl ServerLauncher {
pub fn new(jarfile: String, java_path: String, server_dir: String, server_args: Vec<String>, server_name: String, memory: i32, log_stream_sender: Arc<Sender<String>>) -> ServerLauncher {
ServerLauncher {
jarfile,
java_path,
server_dir,
server_args,
server_name,
memory,
state: ServerState::STOPPED,
process: None,
log_stream_sender,
}
}
pub fn launch(&mut self) {
info!("Launching {}...", self.server_name);
let mut cmd = Command::new(&self.java_path);
self.check_server_dir();
cmd.current_dir(&self.server_dir);
cmd.arg(format!("-Xmx{}M", self.memory));
cmd.arg("-jar");
cmd.arg(&self.jarfile);
for arg in &self.server_args {
cmd.arg(arg);
}
cmd.arg("-nogui");
cmd.stdin(std::process::Stdio::piped());
cmd.stdout(std::process::Stdio::piped());
cmd.stderr(std::process::Stdio::piped());
debug!("Generated command: {:?}", cmd);
self.state = ServerState::RUNNING;
let process = cmd.spawn().expect("Failed to launch server");
info!("{} launched with PID {}", self.server_name, process.id());
let process = Arc::new(Mutex::new(process));
self.process = Some(Arc::clone(&process));
let process_clone = Arc::clone(&process);
let server_name = self.server_name.clone();
let sender_clone = self.log_stream_sender.clone();
thread::spawn(move || {
let output = process_clone.lock().unwrap().stdout.take().expect("Failed to capture stdout");
let reader = BufReader::new(output);
for line in reader.lines() {
let line = line.expect("Failed to read line");
sender_clone.send(line).expect("Failed to send line to GUI");
}
});
let process_clone = Arc::clone(&process);
let server_name = self.server_name.clone();
thread::spawn(move || {
let output = process_clone.lock().unwrap().wait().expect("Failed to wait on child");
if output.success() {
info!("{} has stopped with code 0.", server_name);
} else {
warn!("{} has crashed with code {}.", server_name, output.code().expect("Failed to get the exit code"));
}
});
}
pub fn stop(&mut self) {
info!("Stopping {}...", self.server_name);
if let Some(process) = &self.process {
process.lock().unwrap().kill().expect("Failed to kill server");
self.state = ServerState::STOPPED;
} else {
error!("Failed to stop server: no process found");
}
}
pub fn send_command(&mut self, command: String) {
if let Some(process) = &self.process {
let mut stdin: std::process::ChildStdin = process.lock().unwrap().stdin.take().expect("Failed to capture stdin");
stdin.write_all(command.as_bytes()).expect("Failed to write to stdin");
} else {
error!("Failed to send command to server: no process found");
}
}
fn check_server_dir(&self) {
if Path::new(&self.server_dir).exists() {
info!("Server directory {} exists.", self.server_dir);
} else {
info!("Server directory {} does not exist. Creating the folder.", self.server_dir);
fs::create_dir_all(&self.server_dir).expect("Failed to create server directory");
}
}
}
Sorun yasadigim yer surasi:
pub fn send_command(&mut self, command: String) {
if let Some(process) = &self.process {
let mut stdin: std::process::ChildStdin = process.lock().unwrap().stdin.take().expect("Failed to capture stdin");
stdin.write_all(command.as_bytes()).expect("Failed to write to stdin");
} else {
error!("Failed to send command to server: no process found");
}
}
Minecraft sunucusu (su an kullandigim papermc) process’i konsoldan komut alabiliyor. Basitce yapmak istedigim sey bir insanin konsola komut yazip enter’a basmasini Rust’ta cagirdigim child-process ile yapmak.
Python’da benzer seyi basitce yapmistim birkac gun once. Onu da birakayim gist ile: launcher.py · GitHub
Sorun ise send_command cagirildiginda tum program donup kaliyor. Ilk basta write_all, process’in stdin’i okumasini bekledigi icin boyle oluyor diye dusunuyordum ama alakasi yok. Loglardan yuklendigini anliyorum sunucunun, ki o durumda da stdin’i okuyor oluyor.
Aslinda zorlansam da cok karsilasiyorum boyle seylerle, bir sekilde hallediyorum hepsini. Bu problemi de hallederim diye dusunuyorum. Ama buraya katki saglamanin tek yolunun soru cevaplamak olmadigini dusundum. (Kalitesiz soru cevaplamak da pek eglenceli degil acikcasi zaten)
Kolay gelsin, iyi forumlar
: 