Apprenez les fonctions de programmation réseau en langage Go et implémentez la communication TCP/IP

Apprenez les fonctions de programmation réseau en langage Go et implémentez la communication TCP/IP

Le langage Go est un langage de programmation open source présentant les caractéristiques d'une efficacité élevée et d'une faible latence, il est donc largement utilisé dans le domaine de la programmation réseau. Grâce aux fonctions de programmation réseau fournies par le langage Go, nous pouvons facilement implémenter la communication TCP/IP. Cet article explique comment apprendre les fonctions de programmation réseau dans le langage Go et implémenter la communication TCP/IP.

Les fonctions de programmation réseau en langage Go incluent principalement les fonctions du package net et du package bufio. Parmi eux, le package net donne accès aux sockets réseau, tandis que le package bufio fournit des fonctions de lecture et d'écriture de tampon. Grâce au travail collaboratif de ces deux packages, nous pouvons facilement gérer l'envoi et la réception des données réseau.

Tout d'abord, nous devons importer les packages net et bufio :

import (
    "net"
    "bufio"
)

Ensuite, nous pouvons créer un serveur TCP qui reçoit les demandes des clients et répond avec un message de bienvenue. Voici un exemple de code simple :

func main() {
    // 监听端口
    listen, err := net.Listen("tcp", "localhost:8080")
    if err != nil {
        log.Fatal(err)
    }
    defer listen.Close()

    // 接收客户端连接
    conn, err := listen.Accept()
    if err != nil {
        log.Fatal(err)
    }
    defer conn.Close()

    // 创建缓冲区进行读写
    reader := bufio.NewReader(conn)
    writer := bufio.NewWriter(conn)

    // 读取客户端的请求
    request, err := reader.ReadString('
')
    if err != nil {
        log.Fatal(err)
    }

    // 回复客户端的请求
    response := "欢迎光临！
"
    _, err = writer.WriteString(response)
    if err != nil {
        log.Fatal(err)
    }

    // 刷新缓冲区，确保数据发送到客户端
    err = writer.Flush()
    if err != nil {
        log.Fatal(err)
    }
}

Dans l'exemple ci-dessus, nous créons d'abord un écouteur à l'aide de la fonction net.Listen, en spécifiant le protocole TCP et le numéro de port. Ensuite, recevez la demande de connexion du client en appelant la fonction Listen.Accept et créez une connexion socket pour communiquer avec le client.

Ensuite, nous créons des objets bufio.Reader et bufio.Writer pour lire et envoyer des données à partir de la connexion socket. En appelant la fonction reader.ReadString, vous pouvez lire la requête envoyée par le client, et en appelant la fonctionwriter.WriteString, vous pouvez répondre à la requête du client.

Enfin, nous utilisons la fonctionwriter.Flush pour vider le tampon afin de garantir que les données sont envoyées au client. Après avoir terminé les étapes ci-dessus, nous avons implémenté avec succès un simple serveur TCP.

En plus de créer un serveur TCP, nous pouvons également créer un client TCP, nous connecter au serveur et envoyer des requêtes. Voici un exemple de code simple :

func main() {
    // 连接服务器
    conn, err := net.Dial("tcp", "localhost:8080")
    if err != nil {
        log.Fatal(err)
    }
    defer conn.Close()

    // 创建缓冲区进行读写
    reader := bufio.NewReader(conn)
    writer := bufio.NewWriter(conn)
    
    // 发送请求
    request := "Hello, world!
"
    _, err = writer.WriteString(request)
    if err != nil {
        log.Fatal(err)
    }

    // 刷新缓冲区，确保数据发送到服务器
    err = writer.Flush()
    if err != nil {
        log.Fatal(err)
    }

    // 读取服务器的响应
    response, err := reader.ReadString('
')
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println(response)
}

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!