golang套接字的实现

卓雪

目录

• 1. 基本概念
  
• 2. TCP 套接字示例
  
  
  
  • 服务器端代码
    
  • 客户端代码
    
  
  
• 3. UDP 套接字示例
  
  
  
  • 服务器端代码
    
  • 客户端代码
    
  
  
• 4. 运行示例
  
• 总结
  

在 Go 语言中，使用标准库

1. net

复制代码

来实现套接字编程。以下是有关 Go 套接字的基本概念和示例。

1. 基本概念

• 网络类型：
  
  
  
  • TCP：流套接字，提供可靠的、面向连接的通信。
    
  • UDP：数据报套接字，无连接，适用于快速传输。
    
  
  

2. TCP 套接字示例



服务器端代码

1. package main
   
2. 
   
3. import (
   
4.     "fmt"
   
5.     "net"
   
6. )
   
7. 
   
8. func main() {
   
9.     // 创建 TCP 套接字
   
10.     listener, err := net.Listen("tcp", ":12345")
    
11.     if err != nil {
    
12.         fmt.Println("Error starting server:", err)
    
13.         return
    
14.     }
    
15.     defer listener.Close()
    
16. 
    
17.     fmt.Println("Waiting for a connection...")
    
18.     for {
    
19.         // 接受连接
    
20.         conn, err := listener.Accept()
    
21.         if err != nil {
    
22.             fmt.Println("Error accepting connection:", err)
    
23.             continue
    
24.         }
    
25.         fmt.Println("Connection established from", conn.RemoteAddr())
    
26. 
    
27.         // 处理连接
    
28.         go handleConnection(conn)
    
29.     }
    
30. }
    
31. 
    
32. func handleConnection(conn net.Conn) {
    
33.     defer conn.Close()
    
34.     message := "Hello, Client!"
    
35.     conn.Write([]byte(message))
    
36.     fmt.Println("Message sent to client:", message)
    
37. }

复制代码

客户端代码

1. package main
   
2. 
   
3. import (
   
4.     "fmt"
   
5.     "net"
   
6. )
   
7. 
   
8. func main() {
   
9.     // 连接到服务器
   
10.     conn, err := net.Dial("tcp", "localhost:12345")
    
11.     if err != nil {
    
12.         fmt.Println("Error connecting to server:", err)
    
13.         return
    
14.     }
    
15.     defer conn.Close()
    
16. 
    
17.     // 接收数据
    
18.     buffer := make([]byte, 1024)
    
19.     n, err := conn.Read(buffer)
    
20.     if err != nil {
    
21.         fmt.Println("Error reading from server:", err)
    
22.         return
    
23.     }
    
24. 
    
25.     fmt.Println("Received message from server:", string(buffer[:n]))
    
26. }

复制代码

3. UDP 套接字示例

服务器端代码

1. package main
   
2. 
   
3. import (
   
4.     "fmt"
   
5.     "net"
   
6. )
   
7. 
   
8. func main() {
   
9.     // 创建 UDP 套接字
   
10.     address, err := net.ResolveUDPAddr("udp", ":12345")
    
11.     if err != nil {
    
12.         fmt.Println("Error resolving address:", err)
    
13.         return
    
14.     }
    
15. 
    
16.     conn, err := net.ListenUDP("udp", address)
    
17.     if err != nil {
    
18.         fmt.Println("Error listening:", err)
    
19.         return
    
20.     }
    
21.     defer conn.Close()
    
22. 
    
23.     fmt.Println("Waiting for a connection...")
    
24.     for {
    
25.         buffer := make([]byte, 1024)
    
26.         n, addr, err := conn.ReadFromUDP(buffer)
    
27.         if err != nil {
    
28.             fmt.Println("Error reading from UDP:", err)
    
29.             continue
    
30.         }
    
31.         fmt.Println("Received message from", addr, ":", string(buffer[:n]))
    
32. 
    
33.         // 发送响应
    
34.         response := []byte("Hello, UDP Client!")
    
35.         conn.WriteToUDP(response, addr)
    
36.     }
    
37. }

复制代码

客户端代码

1. package main
   
2. 
   
3. import (
   
4.     "fmt"
   
5.     "net"
   
6. )
   
7. 
   
8. func main() {
   
9.     // 发送 UDP 数据包
   
10.     address, err := net.ResolveUDPAddr("udp", "localhost:12345")
    
11.     if err != nil {
    
12.         fmt.Println("Error resolving address:", err)
    
13.         return
    
14.     }
    
15. 
    
16.     conn, err := net.DialUDP("udp", nil, address)
    
17.     if err != nil {
    
18.         fmt.Println("Error connecting:", err)
    
19.         return
    
20.     }
    
21.     defer conn.Close()
    
22. 
    
23.     message := []byte("Hello, Server!")
    
24.     conn.Write(message)
    
25. 
    
26.     // 接收响应
    
27.     buffer := make([]byte, 1024)
    
28.     n, _, err := conn.ReadFromUDP(buffer)
    
29.     if err != nil {
    
30.         fmt.Println("Error reading from server:", err)
    
31.         return
    
32.     }
    
33. 
    
34.     fmt.Println("Received message from server:", string(buffer[:n]))
    
35. }

复制代码

4. 运行示例

• 首先在一个终端中运行服务器代码。
  
• 然后在另一个终端中运行客户端代码。
  

总结

Go 语言的

1. net

复制代码

包使得套接字编程变得简单而高效。通过使用 TCP 或 UDP 套接字，你可以轻松实现网络通信。
到此这篇关于golang套接字的实现的文章就介绍到这了,更多相关golang套接字内容请搜索晓枫资讯以前的文章或继续浏览下面的相关文章希望大家以后多多支持晓枫资讯！

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

flying4h

路过，支持一下

灼日

感谢楼主分享。