Process.go

package core

import (
	"fmt"
	"os"
	"os/exec"
	"runtime"
	"strings"
	"syscall"
)

// Execute 함수는 주어진 명령어를 실행합니다.
func Execute(command string) error {
	if runtime.GOOS == "windows" {
		cmd := exec.Command("cmd", "/C", command)
		return cmd.Start()
	} else {
		cmd := exec.Command("sh", "-c", command+" > /dev/null 2>&1 &")
		return cmd.Start()
	}
}

// Spawn 함수는 주어진 바이너리와 서비스를 백그라운드에서 실행합니다.
func Spawn(bin string, service string, inputs []string) error {
	log("Spawn process.. " + service)

	if runtime.GOOS == "windows" {
		args := append([]string{"php", bin, service}, inputs...)
		cmd := exec.Command("cmd", "/C", strings.Join(args, " "))
		return cmd.Start()
	} else {
		php, err := exec.LookPath("php")
		if err != nil {
			return err
		}
		args := append([]string{php, bin, "run", service}, inputs...)
		cmd := exec.Command("sh", "-c", strings.Join(args, " ")+" > /dev/null 2>&1 &")
		return cmd.Start()
	}
}

// Fork 함수는 주어진 바이너리와 서비스를 새로운 세션에서 실행합니다.
func Fork(bin string, service string, inputs []string) error {
	log("Fork process.. " + service)

	if runtime.GOOS == "windows" {
		return fmt.Errorf("Fork is not supported on Windows")
	}

	php, err := exec.LookPath("php")
	if err != nil {
		return err
	}

	args := append([]string{php, bin, service}, inputs...)
	cmd := exec.Command(php, args...)
	cmd.SysProcAttr = &syscall.SysProcAttr{Setsid: true}
	return cmd.Start()
}

// IsRunning 함수는 주어진 PID의 프로세스가 실행 중인지 확인합니다.
func IsRunning(pid int) bool {
	if runtime.GOOS == "windows" {
		cmd := exec.Command("tasklist", "/NH", "/FO", "CSV", "/FI", fmt.Sprintf("PID eq %d", pid))
		output, err := cmd.Output()
		if err != nil {
			fmt.Println("Error checking process:", err)
			return false
		}
		return strings.Contains(string(output), fmt.Sprintf("%d", pid))
	} else {
		process, err := os.FindProcess(pid)
		if err != nil {
			return false
		}
		err = process.Signal(syscall.Signal(0))
		return err == nil
	}
}

// Destroy 함수는 주어진 PID의 프로세스를 강제 종료합니다.
func Destroy(pid int) error {
	log(fmt.Sprintf("Kill process.. %d ", pid))

	if runtime.GOOS == "windows" {
		cmd := exec.Command("taskkill", "/PID", fmt.Sprintf("%d", pid), "/F")
		return cmd.Run()
	} else {
		process, err := os.FindProcess(pid)
		if err != nil {
			return err
		}
		return process.Kill()
	}
}

// log 함수는 주어진 메시지를 출력합니다. (임시로 fmt.Println으로 대체)
func log(message string) {
	fmt.Println(message)
	// 여기에 필요한 로그 기록 로직을 추가하세요
}

주요 함수

Execute 함수
```
func Execute(command string) error {
    if runtime.GOOS == "windows" {
        cmd := exec.Command("cmd", "/C", command)
        return cmd.Start()
    } else {
        cmd := exec.Command("sh", "-c", command+" > /dev/null 2>&1 &")
        return cmd.Start()
    }
}
```
- 역할: 주어진 명령어를 백그라운드에서 실행합니다.
- 동작 방식:
  - 운영체제가 윈도우인 경우 cmd /C를 사용하여 명령어를 실행합니다.
  - 유닉스 계열인 경우 sh -c를 사용하여 명령어를 백그라운드에서 실행하고 출력은 무시합니다.
  - cmd.Start()를 호출하여 명령어를 실행합니다.

Spawn 함수

func Spawn(bin string, service string, inputs []string) error {
    log("Spawn process.. " + service)

    if runtime.GOOS == "windows" {
        args := append([]string{"php", bin, service}, inputs...)
        cmd := exec.Command("cmd", "/C", strings.Join(args, " "))
        return cmd.Start()
    } else {
        php, err := exec.LookPath("php")
        if err != nil {
            return err
        }
        args := append([]string{php, bin, "run", service}, inputs...)
        cmd := exec.Command("sh", "-c", strings.Join(args, " ")+" > /dev/null 2>&1 &")
        return cmd.Start()
    }
}

역할: 주어진 서비스와 입력으로 프로세스를 생성합니다.
동작 방식:
- 윈도우인 경우 cmd /C를 사용하여 php 실행 파일과 함께 명령어를 실행합니다.
- 유닉스 계열인 경우 exec.LookPath를 사용하여 php 실행 파일의 경로를 찾고, sh -c를 사용하여 백그라운드에서 실행합니다.
- 로그 메시지를 출력하고 명령어를 시작합니다.

Fork 함수

func Fork(bin string, service string, inputs []string) error {
    log("Fork process.. " + service)

    if runtime.GOOS == "windows" {
        return fmt.Errorf("Fork is not supported on Windows")
    }

    php, err := exec.LookPath("php")
    if err != nil {
        return err
    }

    args := append([]string{php, bin, service}, inputs...)
    cmd := exec.Command(php, args...)
    cmd.SysProcAttr = &syscall.SysProcAttr{Setsid: true}
    return cmd.Start()
}

역할: 새로운 세션에서 프로세스를 생성합니다.
동작 방식:
- 윈도우에서는 Fork가 지원되지 않으므로 에러를 반환합니다.
- 유닉스 계열에서는 php 실행 파일의 경로를 찾아 새로운 세션에서 프로세스를 생성합니다.
- syscall.SysProcAttr{Setsid: true}를 사용하여 새로운 세션에서 실행합니다.

IsRunning 함수

func IsRunning(pid int) bool {
    if runtime.GOOS == "windows" {
        cmd := exec.Command("tasklist", "/NH", "/FO", "CSV", "/FI", fmt.Sprintf("PID eq %d", pid))
        output, err := cmd.Output()
        if err != nil {
            fmt.Println("Error checking process:", err)
            return false
        }
        return strings.Contains(string(output), fmt.Sprintf("%d", pid))
    } else {
        process, err := os.FindProcess(pid)
        if err != nil {
            return false
        }
        err = process.Signal(syscall.Signal(0))
        return err == nil
    }
}

역할: 주어진 PID의 프로세스가 실행 중인지 확인합니다.
동작 방식:
- 윈도우에서는 tasklist 명령어를 사용하여 프로세스를 확인합니다.
- 유닉스 계열에서는 os.FindProcess를 사용하여 프로세스를 찾고, Signal(0)을 보내서 확인합니다.

Destroy 함수

func Destroy(pid int) error {
    log(fmt.Sprintf("Kill process.. %d ", pid))

    if runtime.GOOS == "windows" {
        cmd := exec.Command("taskkill", "/PID", fmt.Sprintf("%d", pid), "/F")
        return cmd.Run()
    } else {
        process, err := os.FindProcess(pid)
        if err != nil {
            return err
        }
        return process.Kill()
    }
}

역할: 주어진 PID의 프로세스를 종료합니다.
동작 방식:
- 윈도우에서는 taskkill 명령어를 사용하여 프로세스를 강제로 종료합니다.
- 유닉스 계열에서는 os.FindProcess를 사용하여 프로세스를 찾고 Kill 메서드를 호출하여 종료합니다.

log 함수
```
func log(message string) {
    fmt.Println(message)
    // 여기에 필요한 로그 기록 로직을 추가하세요
}
```
- 역할: 로그 메시지를 출력합니다.
- 동작 방식:
  - 주어진 메시지를 콘솔에 출력합니다.
  - 실제 로그 파일에 기록하려면 추가 로직을 작성해야 합니다.

요약

이 모듈은 운영체제에 따라 외부 명령어를 실행하고 프로세스를 관리하는 기능을 제공합니다. Execute 함수는 단순히 명령어를 실행하고, Spawn 함수는 주어진 입력으로 프로세스를 생성합니다. Fork 함수는 새로운 세션에서 프로세스를 생성하는데 윈도우에서는 지원되지 않습니다. IsRunning 함수는 특정 PID의 프로세스가 실행 중인지 확인하고, Destroy 함수는 특정 PID의 프로세스를 종료합니다. log 함수는 간단히 로그 메시지를 출력합니다.

PreviousLogger.go NextResult.go

Last updated 1 year ago

hashtag주요 함수

hashtag요약

주요 함수

요약