Как одному приложению передать другому данные через signal на golang?

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

package main

import (
    "fmt"
    "os"
    "os/signal"
    "syscall"
)

func main() {
    // Создаем канал для принятия сигнала
    sigs := make(chan os.Signal, 1)
    done := make(chan bool, 1)

    // Привязываем канал к сигналу USR1
    signal.Notify(sigs, syscall.SIGUSR1)

    // Функция, которая будет выполняться при получении сигнала
    go func() {
        // Ожидаем сигнала
        sig := <-sigs
        fmt.Println("Received signal:", sig)

        // Получаем переданное значение
        if data, ok := sig.(*syscall.Signal); ok {
            fmt.Println("Received data:", *data)
        }

        done <- true
    }()

    // Отправляем сигнал с данными другому приложению
    pid := /* ID процесса, которому отправляем сигнал */
    if err := syscall.Kill(pid, syscall.SIGUSR1); err != nil {
        fmt.Println("Failed to send signal:", err)
    }

    // Ожидаем завершения работы
    <-done
    fmt.Println("Done")
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

// Первый процесс

package main

import (
    "fmt"
    "net"
    "os"
    "os/signal"
    "syscall"
)

func main() {
    listener, err := net.Listen("tcp", ":12345")
    if err != nil {
        fmt.Println("Failed to start listener:", err)
        return
    }

    go func() {
        conn, err := listener.Accept()
        if err != nil {
            fmt.Println("Failed to accept connection:", err)
            return
        }

        _, err = conn.Write([]byte("Hello from process A"))
        if err != nil {
            fmt.Println("Failed to send data:", err)
        }

        conn.Close()
    }()

    sigs := make(chan os.Signal, 1)
    signal.Notify(sigs, syscall.SIGINT)
    <-sigs
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

// Второй процесс

package main

import (
    "fmt"
    "net"
    "os"
)

func main() {
    conn, err := net.Dial("tcp", "localhost:12345")
    if err != nil {
        fmt.Println("Failed to connect:", err)
        return
    }

    data := make([]byte, 1024)
    _, err = conn.Read(data)
    if err != nil {
        fmt.Println("Failed to read data:", err)
        return
    }

    fmt.Println("Received data:", string(data))

    conn.Close()
}