Menggunakan ZooKeeper dan Kurator untuk penyelarasan dan pengurusan yang diedarkan di Beego

Dengan perkembangan pesat Internet, sistem yang diedarkan telah menjadi salah satu infrastruktur dalam banyak perusahaan dan organisasi. Untuk sistem teragih berfungsi dengan baik, ia perlu diselaraskan dan diuruskan. Dalam hal ini, ZooKeeper dan Curator ialah dua alat yang patut digunakan.

ZooKeeper ialah perkhidmatan penyelarasan teragih yang sangat popular, yang boleh membantu kami menyelaraskan status dan data antara nod dalam kelompok. Kurator ialah perpustakaan sumber terbuka yang merangkumi ZooKeeper, yang boleh membantu kami menggunakan ZooKeeper dengan lebih mudah.

Dalam artikel ini, kami akan memperkenalkan cara menggunakan ZooKeeper dan Kurator untuk penyelarasan dan pengurusan yang diedarkan di Beego. Secara khusus, kami akan menerangkannya dari aspek berikut:

1. Memperkenalkan pergantungan Kurator dalam projek Beego

Sebelum menggunakan Kurator, kami perlu memasangnya terlebih dahulu dalam projek Beego Memperkenalkan kebergantungan Kurator. Kita boleh mencapai matlamat ini dengan mengubah suai fail go.mod projek. Langkah-langkah khusus adalah seperti berikut:

Mula-mula, buka terminal dan masukkan laluan di mana projek Beego berada.

Kemudian, laksanakan arahan berikut untuk membuka fail go.mod:

$ go mod edit -require github.com/apache/curator@v4.2.0

Arahan ini akan menambah rekod pergantungan pada baris terakhir fail go.mod, dengan menyatakan nombor versi Kurator yang perlu diimport. Dalam contoh ini, kami memilih versi v4.2.0, tetapi anda juga boleh memilih versi lain mengikut keperluan.

Akhir sekali, laksanakan perintah berikut untuk memuat turun kebergantungan Kurator:

$ go mod tidy

Arahan ini akan memuat turun pakej kebergantungan yang diperlukan berdasarkan maklumat kebergantungan yang direkodkan dalam fail go.mod.

2. Buat klien ZooKeeper dalam projek Beego

Selepas memperkenalkan pergantungan Kurator, kami boleh mula menggunakannya untuk menyambung ke ZooKeeper. Sebelum melakukan ini, kita perlu mencipta pelanggan ZooKeeper dalam projek Beego. Langkah-langkah khusus adalah seperti berikut:

Mula-mula, buat fail baharu dalam modul projek Beego, contohnya, dipanggil "zk_client.go".

Dalam fail ini, kami perlu mengimport pakej Kurator yang berkaitan dan mentakrifkan pembolehubah pelanggan ZooKeeper global Kodnya adalah seperti berikut:

package main

import (
    "fmt"

    "github.com/apache/curator-go/curator"
)

var zkClient curator.CuratorFramework

Selepas mentakrifkan pembolehubah klien ZooKeeper, kami memerlukan Apabila. projek Beego bermula, mulakan ia. Khususnya, kami boleh menambah kod berikut pada fungsi utama projek Beego:

func main() {
    // 启动ZooKeeper客户端
    err := initZKClient()
    if err != nil {
        panic(err)
    }
    
    // 启动Beego服务
    beego.Run()
}

func initZKClient() error {
    // 创建ZooKeeper客户端配置对象
    config := &curator.Config{
        Retry: &curator.RetryPolicy{
            MaxRetry:  3,
            SleepTime: time.Second,
        },
        Namespace: "myapp",
    }

    // 创建ZooKeeper客户端
    client, err := curator.NewClient([]string{"127.0.0.1:2181"}, config)
    if err != nil {
        return err
    }

    // 启动ZooKeeper客户端
    client.Start()

    // 等待ZooKeeper客户端连接成功
    if ok := client.WaitForConnection(curator.DefaultTimeout); !ok {
        return fmt.Errorf("failed to connect to ZooKeeper")
    }

    // 设置全局ZooKeeper客户端变量
    zkClient = client

    return nil
}

Dalam kod di atas, kami mula-mula mentakrifkan objek konfigurasi klien ZooKeeper bernama "config". Dalam objek ini, kami menentukan strategi cuba semula dan ruang nama ZooKeeper. Seterusnya, kami mencipta klien ZooKeeper menggunakan objek konfigurasi dan memulakannya. Akhir sekali, kami menunggu pelanggan berjaya menyambung dan menetapkannya kepada pembolehubah pelanggan ZooKeeper global yang ditakrifkan sebelum ini.

3. Menggunakan ZooKeeper dalam Projek Beego

Dalam langkah sebelumnya, kami telah berjaya mencipta pelanggan ZooKeeper. Kini, kita boleh menggunakan klien ini untuk melaksanakan beberapa fungsi koordinasi dan pengurusan yang diedarkan. Berikut ialah beberapa contoh kod menggunakan ZooKeeper.

3.1 Cipta nod ZooKeeper

Kami boleh menggunakan kod berikut untuk mencipta nod baharu dalam ZooKeeper:

func createZKNode(path string, data []byte) error {
    // 创建ZooKeeper节点
    _, err := zkClient.Create().
        WithMode(curator.PERSISTENT).
        WithACL(curator.DigestACL("user:password", []byte("rw"))).
        ForPathWithData(path, data)
    if err != nil {
        return err
    }

    return nil
}

Dalam kod di atas, kami menggunakan kaedah Cipta pelanggan ZooKeeper untuk mencipta nod baharu. Kaedah ini menerima laluan dan tatasusunan bait data sebagai parameter input dan mengembalikan laluan nod yang baru dibuat. Selain itu, kami menentukan mod penciptaan dan kebenaran ACL nod.

3.2 Dapatkan data nod ZooKeeper

Kami boleh menggunakan kod berikut untuk mendapatkan data nod ZooKeeper:

func getZKNodeData(path string) ([]byte, error) {
    // 从ZooKeeper中获取数据
    data, _, err := zkClient.GetData().ForPath(path)
    if err != nil {
        return nil, err
    }

    return data, nil
}

Dalam kod di atas, kami menggunakan Pelanggan ZooKeeper kaedah GetData untuk mendapatkan data nod yang sepadan. Kaedah ini menerima laluan nod sebagai parameter input dan mengembalikan tatasusunan bait data.

3.3 Kemas kini data nod ZooKeeper

Kami boleh menggunakan kod berikut untuk mengemas kini data nod ZooKeeper:

func setZKNodeData(path string, data []byte) error {
    // 更新ZooKeeper节点的数据
    _, err := zkClient.SetData().ForPathWithData(path, data)
    if err != nil {
        return err
    }

    return nil
}

Dalam kod di atas, kami menggunakan Kaedah SetData klien ZooKeeper untuk mengemas kini data nod yang sepadan. Kaedah ini menerima laluan nod dan tatasusunan bait data sebagai parameter input dan tidak mengembalikan sebarang hasil.

4. Ringkasan

Dalam artikel ini, kami memperkenalkan cara menggunakan ZooKeeper dan Kurator dalam Beego untuk penyelarasan dan pengurusan yang diedarkan. Khususnya, kami memperkenalkan pergantungan Kurator, mencipta klien ZooKeeper dan menggunakan klien ZooKeeper untuk melaksanakan beberapa fungsi koordinasi dan pengurusan yang diedarkan. Saya harap artikel ini dapat membantu pembangun yang perlu membina sistem teragih.

Atas ialah kandungan terperinci Menggunakan ZooKeeper dan Kurator untuk penyelarasan dan pengurusan yang diedarkan di Beego. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!