Go语言进程间通信：利用通道实现安全高效的数据交换

package main

import (
    "fmt"
    "net"
    "sync"
)

func main() {
    listener, err := net.Listen("tcp", ":8080")
    if err != nil {
        fmt.Println("Error listening:", err.Error())
        return
    }
    defer listener.Close()

    fmt.Println("Listening on :8080")

    conn, err := listener.Accept()
    if err != nil {
        fmt.Println("Error accepting: ", err.Error())
        return
    }
    defer conn.Close()

    // 创建一个通道
    ch := make(chan string)

    // 启动一个goroutine来接收数据
    go func() {
        for {
            buf := make([]byte, 1024)
            n, err := conn.Read(buf)
            if err != nil {
                fmt.Println("Error reading:", err.Error())
                close(ch) // 关闭通道，通知发送方
                return
            }
            ch <- string(buf[:n]) // 将接收到的数据放入通道
        }
    }()

    // 模拟从通道接收数据
    for msg := range ch {
        fmt.Println("Received:", msg)
    }

    fmt.Println("Server finished")
}

package main

import (
    "fmt"
    "net"
    "time"
)

func main() {
    conn, err := net.Dial("tcp", "localhost:8080")
    if err != nil {
        fmt.Println("Error connecting:", err.Error())
        return
    }
    defer conn.Close()

    fmt.Println("Connected to server")

    // 创建一个通道
    ch := make(chan string)

    // 启动一个goroutine来发送数据
    go func() {
        messages := []string{"Hello", "World", "From", "Client"}
        for _, msg := range messages {
            ch <- msg // 将数据放入通道
            time.Sleep(time.Second) // 模拟发送间隔
        }
        close(ch) // 发送完毕，关闭通道
    }()

    // 模拟从通道发送数据
    for msg := range ch {
        _, err := conn.Write([]byte(msg)) // 将数据写入Socket
        if err != nil {
            fmt.Println("Error writing:", err.Error())
            return
        }
        fmt.Println("Sent:", msg)
    }

    fmt.Println("Client finished")
}