Bagaimana untuk melaksanakan ping dalam golang

Golang melaksanakan ping

Ping ialah alat untuk menguji sambungan rangkaian. Ia digunakan untuk menguji ketersambungan rangkaian komputer. Perintah Ping boleh menguji sama ada hos sasaran berada dalam talian, boleh diakses dan kelewatan komunikasi. Artikel ini akan memperkenalkan cara melaksanakan alat ping menggunakan bahasa pengaturcaraan golang.

1. Apakah itu Ping

Ping ialah alat penting untuk pengaturcara dan pentadbir sistem untuk melakukan penyahpepijatan rangkaian dan penyelesaian masalah. Ping ialah singkatan kepada Packet Internet Groper, dan fungsinya adalah untuk menguji ketersambungan sambungan rangkaian antara dua hos. Arahan Ping ialah salah satu perkhidmatan rangkaian paling asas di Internet Ia menyemak masa nyata dan kebolehpercayaan sambungan dengan menghantar paket ICMP ke hos sasaran dan mengukur masa tindak balas.

2. Cara Ping berfungsi

Prinsip Ping ialah menggunakan perintah "echo request" dari Internet Control Message Protocol (ICMP) untuk menghantar paket data khas kepada hos sasaran. Selepas menerima paket ini, paket "tindak balas gema" akan dikembalikan secara automatik kepada pengirim Dengan cara ini, pengirim boleh mengira masa tindak balas dan kelewatan rangkaian hos sasaran dengan mengukur masa perjalanan pergi balik paket.

3. Melaksanakan ping

Untuk melaksanakan ping, anda perlu melengkapkan 3 langkah berikut:

1 Bina paket data ICMP
2
3 .Menghuraikan maklumat respons yang dikembalikan oleh paket ICMP

1. Bina paket ICMP

Pertama, kita perlu membina paket ICMP. Menurut format ICMP, kita boleh menggunakan struktur dan fungsi yang disediakan oleh pakej "icmp" yang disertakan dengan bahasa Go untuk membina paket data ICMP. icmp.Message dan icmp.Echo menentukan jenis paket dan data berkaitan jenis, dan icmp.Marshal mendapatkan semula data ICMP yang kami bina. Kita boleh mentakrifkan PingMsg seperti berikut:

taip struct PingMsg{

icmpMessage icmp.Message
bytes []byte

}

func newEchoPingMessage(id, seq int) (*PingMsg, error){

bytes := make([]byte, 32)

//Isi kandungan paket ICMP

for i, _ := range bytes {
    bytes[i] = 'a' + byte(i%26)
}
icmpMessage := icmp.Message{
    Type: ipv4.ICMPTypeEcho, // ICMP类型
    Code: 0, // ICMP代码，置为0
    Checksum: 0, // 校验和，暂时置为0
    Body: &icmp.Echo{
        ID: id,
        Seq: seq,
        Data: bytes,
    },
}

//Sirikan paket ICMP

b, err := icmpMessage.Marshal(nil)
if err != nil {
    return nil, err
}
return &PingMsg{
    bytes: b,
    icmpMessage: icmpMessage,
}, nil

}

2 paket

Seterusnya, kita perlu menggunakan antara muka Conn yang disediakan oleh pakej bersih untuk menghantar paket ICMP yang dibina. Kita boleh menggunakan net.Dial("ip4:icmp", destination) untuk mewujudkan sambungan ICMP, gunakan Conn.Write(b []bait) untuk menghantar paket data kepada hos sasaran, dan menggunakan fungsi masa.NewTicker untuk mengawal selang masa menghantar.

ralat ping(tali tambahan) fungsi{

conn, err := net.Dial("ip4:icmp", addr)
if err != nil {
    return err
}
defer conn.Close()
pingMsg, err := newEchoPingMessage(os.Getpid()&0xffff, 1)
if err != nil {
    return err
}
timeout := 5 * time.Second // 超时时间
ticker := time.NewTicker(time.Second) //设置1秒钟的时间间隔
defer ticker.Stop()
for {
    select {
    case <- ticker.C: // 每1秒钟发送一次ICMP数据包
        if _, err = conn.Write(pingMsg.bytes); err != nil {
            return err
        }
    case <- time.After(timeout): // 超时时间到了，抛出错误
        return errors.New("request timeout")
    }
}

}

3 Menghuraikan maklumat respons yang dikembalikan oleh paket ICMP

Akhir sekali, kami perlu Dengan membaca paket ICMP yang dikembalikan, maklumat tindak balas hos dihuraikan. Kami juga menggunakan antara muka Conn yang disediakan oleh pakej bersih untuk membaca paket data yang dikembalikan, menggunakan icmp.ParseMessage untuk menghuraikan paket data dan mendapatkan maklumat respons melalui icmp.Message.Body.(*icmp.EchoReply).

ralat func receivePing(conn net.Conn){

for {
    b := make([]byte, 512)
    conn.SetReadDeadline(time.Now().Add(time.Second)) // 设置超时时间
    if n, err := conn.Read(b); err != nil {
        if netErr, ok := err.(net.Error); ok && netErr.Timeout() {
            continue
        }
        return err
    } else {
        recvMsg, err := icmp.ParseMessage(ipv4.ICMPTypeEchoReply, b[:n])
        if err != nil {
            return err
        }
        switch recvMsg.Type {
        case ipv4.ICMPTypeEchoReply:
            echoReply, _ := recvMsg.Body.(*icmp.EchoReply)
            log.Printf("ping %d bytes from %s: icmp_seq=%d time=%dms", len(echoReply.Data), conn.RemoteAddr().String(), echoReply.Seq, time.Since(time.Unix(0, echoReply.ArrivalTime().Nanoseconds())).Nanoseconds())
        default:
            log.Printf("unsupported ICMP message type %v (%v)", recvMsg.Type, recvMsg.Code)
        }
    }
}

}

4 Contoh lengkap

Kod lengkap adalah seperti berikut:

utama pakej

import (

"errors"
"fmt"
"golang.org/x/net/icmp"
"golang.org/x/net/ipv4"
"log"
"net"
"os"
"time"

)

taip struct PingMsg{

icmpMessage icmp.Message
bytes       []byte

}

func newEchoPingMessage (id, seq int) (*PingMsg, error){

bytes := make([]byte, 32)
for i, _ := range bytes {
    bytes[i] = 'a' + byte(i%26)
}
icmpMessage := icmp.Message{
    Type: ipv4.ICMPTypeEcho,
    Code: 0,
    Checksum: 0,
    Body: &icmp.Echo{
        ID: id,
        Seq: seq,
        Data: bytes,
    },
}
b, err := icmpMessage.Marshal(nil)
if err != nil {
    return nil, err
}
return &PingMsg{
    bytes: b,
    icmpMessage: icmpMessage,
}, nil

}

func ping(addr string) ralat{

conn, err := net.Dial("ip4:icmp", addr)
if err != nil {
    return err
}
defer conn.Close()
pingMsg, err := newEchoPingMessage(os.Getpid()&0xffff, 1)
if err != nil {
    return err
}
timeout := 5 * time.Second
ticker := time.NewTicker(time.Second)
defer ticker.Stop()
for {
    select {
    case <- ticker.C:
        if _, err = conn.Write(pingMsg.bytes); err != nil {
            return err
        }
    case <- time.After(timeout):
        return errors.New("request timeout")
    }
}

}

func receivePing(conn net.Conn) ralat{

for {
    b := make([]byte, 512)
    conn.SetReadDeadline(time.Now().Add(time.Second))
    if n, err := conn.Read(b); err != nil {
        if netErr, ok := err.(net.Error); ok && netErr.Timeout() {
            continue
        }
        return err
    } else {
        recvMsg, err := icmp.ParseMessage(ipv4.ICMPTypeEchoReply, b[:n])
        if err != nil {
            return err
        }
        switch recvMsg.Type {
        case ipv4.ICMPTypeEchoReply:
            echoReply, _ := recvMsg.Body.(*icmp.EchoReply)
            log.Printf("ping %d bytes from %s: icmp_seq=%d time=%dms", len(echoReply.Data), conn.RemoteAddr().String(), echoReply.Seq, time.Since(time.Unix(0, echoReply.ArrivalTime().Nanoseconds())).Nanoseconds())
        default:
            log.Printf("unsupported ICMP message type %v (%v)", recvMsg.Type, recvMsg.Code)
        }
    }
}

}

func main(){

if err := ping("www.baidu.com"); err != nil{
    log.Fatal(err)
}

}

Apabila kod ini dijalankan, paket ICMP akan dihantar kepada hos sasaran secara berterusan sehingga hos tamat masa atau menerima balasan. Apabila paket balasan diterima, program akan mengeluarkan maklumat berikut:

ping 32 bait daripada 120.92.6.25: icmp_seq=0 time=29ms

Ini bermakna paket balasan berjaya diterima Dan masa perjalanan pulang dipaparkan. Proses melaksanakan Ping adalah sangat mudah, tetapi ia membolehkan kami memahami dengan lebih baik prinsip komunikasi rangkaian.

Atas ialah kandungan terperinci Bagaimana untuk melaksanakan ping dalam golang. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!