Bagaimana untuk terus berhubung di golang

Dalam beberapa tahun kebelakangan ini, disebabkan peningkatan beransur-ansur dalam senario aplikasi seperti pelayan teragih dan pemprosesan data besar, Golang (bahasa Go) telah beransur-ansur menjadi bahasa pengaturcaraan yang popular. Dengan keupayaan pemprosesan selaras yang cekap dan sintaks yang mudah dipelajari, Golang digunakan secara meluas dalam membangunkan aplikasi selaras tinggi berprestasi tinggi. Antaranya, sambungan panjang adalah kaedah komunikasi yang biasa. Dalam artikel ini, kami akan meneroka cara menggunakan Golang untuk melaksanakan teknologi sambungan panjang.

1. Apakah sambungan panjang

Sebelum memahami sambungan panjang, kita perlu memahami sambungan pendek terlebih dahulu. Sambungan pendek ialah mod sambungan antara klien dan pelayan Pelanggan akan memutuskan sambungan selepas menyelesaikan komunikasi dengan pelayan. Kelebihan kaedah ini ialah ia boleh mengawal kos beban pelayan, tetapi dalam beberapa senario adalah perlu untuk mengekalkan sambungan berterusan, seperti penstriman audio, penstriman video dan senario lain dengan trafik data yang besar.

Sambungan yang panjang bermakna selepas sambungan diwujudkan, pelanggan dan pelayan kekal bersambung tanpa memutuskan sambungan. Dalam kes ini, pelayan boleh bertindak balas kepada permintaan pelanggan dalam masa nyata tanpa mewujudkan semula sambungan. Kaedah ini mempunyai kelebihan berikut:

1. Kecekapan penghantaran data yang tinggi: sambungan panjang tidak memerlukan berbilang jabat tangan dan gelombang selepas penubuhan, dan data boleh dihantar dengan lebih cekap.
2. Penggunaan memori yang rendah: sambungan pendek memerlukan penubuhan dan pemutusan sambungan yang kerap, dan setiap penubuhan sambungan memerlukan penggunaan memori sistem, manakala sambungan panjang boleh mengelakkan pekerjaan ini.
3. Kestabilan tinggi: Disebabkan sambungan panjang berterusan, sambungan itu akan menjadi lebih stabil daripada sambungan pendek.

2. Kaedah pelaksanaan sambungan panjang di Golang

Ia juga sangat mudah untuk melaksanakan sambungan panjang di Golang. Kita boleh melaksanakan teknologi ini melalui soket TCP dan kawalan Goroutine.

1. Sambungan panjang melalui soket TCP

Di Golang, adalah perkara biasa untuk menggunakan soket TCP untuk melaksanakan sambungan rangkaian. Berikut ialah kod sampel sambungan panjang soket TCP:

// 建立tcp连接
conn, err := net.DialTimeout("tcp", "localhost:9000", time.Second*time.Duration(5))
if err != nil {
    fmt.Println("dial error!", err)
    return
}

//进行读写操作，长时间不操作会断开链接
for {
    _, err := conn.Write([]byte("hello"))
    if err != nil {
        fmt.Println("write err", err)
        return
    }

    time.Sleep(time.Millisecond * time.Duration(500))
}

Dalam kod tersebut, kami mewujudkan sambungan TCP melalui kaedah net.DialTimeout() dan melaksanakan operasi baca dan tulis dalam gelung for. Pada masa yang sama, kami menggunakan fungsi time.Sleep() untuk membuat tinjauan secara kerap bagi memastikan pelayan responsif kepada pelanggan.

2. Mencapai sambungan panjang melalui Goroutine

Cara lain untuk melaksanakan sambungan panjang ialah menggunakan teknologi Goroutine. Goroutine ialah benang ringan yang unik di Golang Ia boleh memulakan berbilang benang ringan pada masa yang sama untuk mencapai kesesuaian tinggi dan pemprosesan komunikasi yang cekap. Berikut ialah contoh kod yang menggunakan Goroutine untuk melaksanakan sambungan panjang:

// 建立tcp连接
conn, err := net.DialTimeout("tcp", "localhost:9000", time.Second*time.Duration(5))
if err != nil {
    fmt.Println("dial error!", err)
    return
}

//开一个协程并发读取数据
go func() {
    for {
        _, err = ioutil.ReadAll(conn)
        if err != nil {
            fmt.Println("read err", err)
            return
        }
    }
}()

//开一个协程并发写入数据
go func() {
    for {
        _, err := conn.Write([]byte("hello"))
        if err != nil {
            fmt.Println("write err", err)
            return
        }

        time.Sleep(time.Millisecond * time.Duration(500))
    }
}()

//阻塞主线程，避免程序运行结束
select {}

Dalam kod, kami mula-mula menggunakan kaedah net.DialTimeout() untuk mewujudkan sambungan TCP, dan kemudian menggunakan dua coroutine Goroutine untuk melaksanakan membaca dan menulis operasi. Goroutine ialah utas yang berjalan pada utas utama Kami tidak menggunakan kaedah pengundian berjadual gelung, tetapi memulakan dua coroutine Goroutine untuk membaca dan menulis data. Di Golang, keupayaan pemprosesan serentak Goroutine sangat cemerlang dan mempunyai kecekapan pemprosesan yang agak tinggi.

3. Langkah berjaga-jaga untuk sambungan panjang

Dalam proses menggunakan teknologi sambungan panjang, anda juga perlu memberi perhatian kepada perkara berikut:

1. Sejak sambungan panjang berada di sisi klien Sambungan ke pelayan sentiasa dikekalkan, jadi jika terdapat sambungan jangka panjang, pelayan mungkin menyambung terlalu banyak pelanggan, mengakibatkan kuasa pemprosesan CPU yang berlebihan.
2. Apabila menggunakan sambungan yang panjang, keupayaan mengimbangi beban pelayan harus dipertingkatkan. Jika pelayan menghadapi terlalu banyak permintaan sambungan, ia harus diperuntukkan secara automatik kepada pelayan lain untuk memastikan operasi normal pelayan.
3. Memandangkan sambungan panjang perlu aktif secara berterusan, lapisan bawah perlu direka bentuk dengan roda masa, dsb. Oleh itu, semasa pembangunan, anda harus cuba mengelak daripada tersilap melaksanakan mekanisme pemantauan "ping-pong" yang menggunakan terlalu banyak prestasi.

4. Ringkasan

Sambungan panjang ialah kaedah komunikasi yang sangat cekap, yang sangat biasa digunakan apabila memproses sejumlah besar data seperti penstriman data. Di Golang, ia juga sangat mudah untuk melaksanakan sambungan panjang, yang boleh dicapai melalui soket TCP atau teknologi Goroutine. Sudah tentu, apabila menggunakan sambungan yang panjang, kami juga perlu memberi perhatian kepada beberapa isu seperti keselamatan dan pengimbangan beban ini memerlukan kami untuk terus meringkaskan dan mengumpul pengalaman semasa proses pembangunan khusus untuk mencapai aplikasi yang lebih cekap dan stabil.

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