golang 进程间交互

进程间通信是指在操作系统中，不同进程之间进行信息交换与共享的一种机制。在Golang中，提供了多种方式来实现进程间通信，包括共享内存、管道、socket通信等。 ## 共享内存 共享内存是一种通过将内存空间映射到多个进程的方式来实现进程间通信的方法。在Golang中，可以使用`sync`包中的`sync/atomic`来实现对共享内存的原子访问和修改。 ```go package main import ( "fmt" "sync/atomic" ) var counter uint32 = 0 func main() { var wg sync.WaitGroup for i := 0; i < 1000; i++ { wg.Add(1) go func() { atomic.AddUint32(&counter, 1) wg.Done() }() } wg.Wait() fmt.Println("Counter:", counter) } ``` 通过使用`sync/atomic`包中的原子操作函数`AddUint32`来实现对共享变量`counter`的原子递增操作。在以上代码中，创建了1000个goroutine来对`counter`进行递增操作，并通过`WaitGroup`来等待所有goroutine执行完毕。 ## 管道 管道是一种常用的进程间通信方式，在Golang中，使用`channel`类型来创建管道。 ```go package main import ( "fmt" ) func main() { ch := make(chan int) go func() { for i := 1; i <= 100; i++ { ch <- i } close(ch) }() for num := range ch { fmt.Println("Received:", num) } } ``` 在以上代码中，创建了一个整型管道`ch`，然后启动一个goroutine来向管道发送数据，并通过`close`函数关闭管道。主goroutine通过`range`语句从管道中接收数据，直到管道关闭为止。 ## Socket通信 Socket通信是一种通过网络建立连接进行进程间通信的方式。在Golang中，可以使用`net`包来实现Socket通信。 ```go package main import ( "bufio" "fmt" "net" "os" ) func handleConnection(conn net.Conn) { defer conn.Close() for { reader := bufio.NewReader(conn) data, err := reader.ReadString('\n') if err != nil { fmt.Println("Error:", err) return } fmt.Println("Received:", data) conn.Write([]byte("Message received")) } } func main() { ln, err := net.Listen("tcp", ":8080") if err != nil { fmt.Println("Error:", err) os.Exit(1) } for { conn, err := ln.Accept() if err != nil { fmt.Println("Error:", err) continue } go handleConnection(conn) } } ``` 在以上代码中，通过`net.Listen`函数创建一个`tcp`监听器，监听本地的8080端口。然后通过`Accept`函数接受客户端连接，并通过并发的方式处理客户端的请求。 ## 总结 通过共享内存、管道和Socket通信等方式，可以实现不同进程之间的数据交换与共享。在Golang中，提供了丰富的包和工具来简化进程间通信的实现。开发者可以根据需求和场景选择合适的方式来进行进程间通信，以实现高效、安全的系统交互。