1#include <sys/socket.h> 
2int socket (int domain, int type, int protocol); 
3//成功时返回文件描述符,失败时返回-1。
4//domain 套接字中使用的协议族(Protocol Family)信息。
5//type 套接字数据传输类型信息。
6//protocol 计算机间通信中使用的协议信息。

 1// Socket 函数创建一个新的套接字，并返回其文件描述符和可能的错误。
 2// domain 参数指定了套接字的协议族（例如，AF_INET 代表 IPv4，AF_INET6 代表 IPv6）。
 3// typ 参数指定了套接字的类型（例如，SOCK_STREAM 代表 TCP，SOCK_DGRAM 代表 UDP）。
 4// proto 参数指定了套接字使用的协议（例如，IPPROTO_TCP 代表 TCP，IPPROTO_UDP 代表 UDP）。
 5func Socket(domain, typ, proto int) (fd int, err error) {
 6    // 如果 domain 是 AF_INET6（即，我们正在尝试创建一个 IPv6 套接字），
 7    // 但是 SocketDisableIPv6 为 true（即，我们禁用了 IPv6），则返回错误 EAFNOSUPPORT。
 8    if domain == AF_INET6 && SocketDisableIPv6 {
 9        return -1, EAFNOSUPPORT
10    }
11    // 调用底层的 socket 函数创建套接字。
12    fd, err = socket(domain, typ, proto)
13    return
14}
15
16
17
18
19// socket 函数创建一个新的套接字，并返回其文件描述符和可能的错误。
20// domain 参数指定了套接字的协议族（例如，AF_INET 代表 IPv4，AF_INET6 代表 IPv6）。
21// typ 参数指定了套接字的类型（例如，SOCK_STREAM 代表 TCP，SOCK_DGRAM 代表 UDP）。
22// proto 参数指定了套接字使用的协议（例如，IPPROTO_TCP 代表 TCP，IPPROTO_UDP 代表 UDP）。
23// rawSyscall 函数执行一个底层的系统调用，其参数是系统调用的编号和参数。
24// 如果系统调用失败，它返回一个非零的错误号 e1，我们将其转换为 Go 的 error 类型并返回。
25func socket(domain int, typ int, proto int) (fd int, err error) {
26    r0, _, e1 := rawSyscall(abi.FuncPCABI0(libc_socket_trampoline), uintptr(domain), uintptr(typ), uintptr(proto))
27    fd = int(r0)
28    if e1 != 0 {
29        err = errnoErr(e1)
30    }
31    return
32}

 1package main
 2
 3import (
 4	"fmt"
 5	"log"
 6	"os"
 7	"strconv"
 8	"syscall"
 9)
10
11func main() {
12	if len(os.Args) != 2 {
13		fmt.Printf("Usage: %s <port>\n", os.Args[0])
14	}
15	port, _ := strconv.Atoi(os.Args[1])
16
17	//1.创建一个 TCP 套接字。
18	fd, err := syscall.Socket(syscall.AF_INET, syscall.SOCK_STREAM, 0)
19	if err != nil {
20		fmt.Printf("socket() error: %v", err)
21	}
22	//2.将套接字绑定到指定的 IP 地址和端口号。
23	// 创建一个 SockaddrInet4 结构体实例，并设置端口号
24	servAddr := &syscall.SockaddrInet4{Port: port}
25	// 将 IP 地址设置为 0.0.0.0，这样服务器可以接受来自任何客户端的连接
26	copy(servAddr.Addr[:], []byte{0, 0, 0, 0})
27
28	err = syscall.Bind(fd, servAddr)
29	if err != nil {
30		log.Fatalf("bind() error: %v", err)
31	}
32	//3.将套接字转为可接收连接状态
33	err = syscall.Listen(fd, 10)
34	if err != nil {
35		log.Fatalf("listen() error: %v", err)
36	}
37	//4.Accept()接收连接
38	connFd, _, err := syscall.Accept(fd)
39	if err != nil {
40		log.Fatalf("accept() error: %v", err)
41	}
42	//5.write()发送信息
43	message := "Hello world!"
44	_, err = syscall.Write(connFd, []byte(message))
45	if err != nil {
46		log.Fatalf("write() error: %v", err)
47	}
48	syscall.Close(connFd)
49	syscall.Close(fd)
50
51}

 1package main
 2
 3import (
 4	"fmt"
 5	"io"
 6	"log"
 7	"net"
 8	"os"
 9	"strconv"
10	"syscall"
11)
12
13func main() {
14	if len(os.Args) != 3 {
15		log.Fatalf("Usage: %s <IP> <port>\n", os.Args[0])
16	}
17	ip := os.Args[1]
18	portStr := os.Args[2]
19
20	port, err := strconv.Atoi(portStr)
21	if err != nil {
22		log.Fatalf("Invalid port number: %s\n", portStr)
23	}
24
25	fd, _ := syscall.Socket(syscall.AF_INET, syscall.SOCK_STREAM, 0)
26	// 设置服务器的地址和端口
27	servAddr := &syscall.SockaddrInet4{Port: port}
28	copy(servAddr.Addr[:], net.ParseIP(ip).To4())
29
30	// 使用 syscall.Connect 函数将套接字连接到服务器
31	err = syscall.Connect(fd, servAddr)
32	if err != nil {
33		log.Fatalf("connect() error: %v", err)
34	}
35	// 使用 syscall.Read 接收信息
36	buf := make([]byte, 1024)
37	message := make([]byte, 0)
38	for {
39		n, err := syscall.Read(fd, buf)
40		if err != nil {
41			if err != io.EOF {
42				log.Fatalf("Read error: %v", err)
43			}
44			break
45		}
46		if n == 0 {
47			break
48		}
49		message = append(message, buf[:n]...)
50	}
51	fmt.Printf("Message from server: %s\n", message)
52	fmt.Printf("Function read() read %d bytes\n", len(message))
53	syscall.Close(fd)
54
55}

1go build -o ch2/tcpServer/tcp_server ch2/tcpServer/tcp_server.go 
2go build -o ch2/tcpClient/tcp_client ch2/tcpClient/tcp_client.go 
3
4./ch2/tcpServer/tcp_server 8888              
5./ch2/tcpClient/tcp_client 127.0.0.1 8888
6
7Message from server: Hello world!
8Function read() read 12 bytes