Menggunakan Zookeeper dan Dubbo untuk melaksanakan tadbir urus perkhidmatan teragih di Beego

Dengan pembangunan berterusan perniagaan Internet, satu nod perkhidmatan tidak lagi dapat memenuhi keperluan konkurensi yang tinggi dan ketersediaan yang tinggi. Oleh itu, seni bina teragih telah menjadi kaedah pembangunan moden dan salah satu teknologi yang mesti dikuasai.

Dalam seni bina yang diedarkan, tadbir urus perkhidmatan merupakan isu yang kompleks dan penting. Untuk memastikan ketersediaan, kualiti dan prestasi perkhidmatan yang tinggi, tadbir urus perkhidmatan perlu melaksanakan pelbagai fungsi seperti pendaftaran perkhidmatan, penemuan, pengimbangan beban, failover dan pemantauan. Zookeeper dan Dubbo adalah peneraju dalam tadbir urus perkhidmatan teragih Mereka boleh bekerjasama untuk merealisasikan keseluruhan proses tadbir urus perkhidmatan.

Artikel ini akan memperkenalkan cara menggunakan Zookeeper dan Dubbo untuk melaksanakan tadbir urus perkhidmatan teragih dalam rangka kerja Beego.

1. Zookeeper

Zookeeper ialah perkhidmatan penyelarasan teragih sumber terbuka Ia pada asalnya dibangunkan oleh Yahoo dan kini telah menjadi projek peringkat tertinggi Apache. Ia boleh mengurus sejumlah besar nod dan menyelaras, menyegerak dan memantaunya untuk mencapai ketersediaan tinggi dan fungsi penemuan perkhidmatan.

1. Pasang dan mulakan Zookeeper

Pertama, anda perlu memuat turun versi stabil Zookeeper dari tapak web rasmi Zookeeper https://zookeeper.apache.org/ After nyahmampat, konfigurasikan fail zoo.cfg. Untuk memulakan Zookeeper dalam mod berdiri sendiri, anda hanya perlu menambah baris konfigurasi dalam fail zoo.cfg:

server.1=localhost:2888:3888

Antaranya, 1 mewakili nombor dalam kelompok Zookeeper, localhost:2888:3888 mewakili IP, port dan port yang didengari oleh nod Zookeeper.

Seterusnya, jalankan arahan berikut untuk memulakan Zookeeper:

./zkServer.sh start

Anda boleh menggunakan arahan berikut untuk menyemak sama ada Zookeeper dimulakan dengan jayanya:

echo ruok | nc localhost 2181

Jika Zookeeper berjalan seperti biasa, "imok" dikembalikan untuk menunjukkan permulaan yang berjaya.

2. Gunakan ZkGo untuk operasi Zookeeper

Terdapat berbilang perpustakaan Zookeeper untuk dipilih dalam bahasa Go, antaranya ZkGo adalah yang lebih popular dan stabil. Menggunakan ZkGo, anda boleh menyambung dengan mudah ke Zookeeper, mencipta nod, memantau perubahan nod, dsb.

Untuk menggunakan ZkGo dalam rangka kerja Beego bahasa Go, anda perlu memasang pergantungan ZkGo dahulu:

go get github.com/samuel/go-zookeeper/zk

Kemudian, anda boleh mengendalikan nod Zookeeper dalam kod, contohnya:

package main

import (
    "fmt"
    "time"
    "github.com/samuel/go-zookeeper/zk"
)

func main() {
    // 连接Zookeeper服务器
    conn, _, err := zk.Connect([]string{"localhost:2181"}, time.Second*5)
    if err != nil {
        panic(err)
    }
    defer conn.Close()

    // 创建一个节点
    path, err := conn.Create("/test", []byte("hello world"), 0, zk.WorldACL(zk.PermAll))
    if err != nil {
        panic(err)
    }
    fmt.Println("Created znode:", path)

    // 获取该节点的值
    data, _, err := conn.Get(path)
    if err != nil {
        panic(err)
    }
    fmt.Printf("Get znode %s: %s
", path, data)

    // 删除该节点
    err = conn.Delete(path, -1)
    if err != nil {
        panic(err)
    }
    fmt.Println("Deleted znode:", path)
}

dalam Dalam contoh di atas, mula-mula sambung ke pelayan Zookeeper melalui kaedah zk.Connect, kemudian gunakan kaedah zk.Create untuk mencipta nod bernama "/test" dan gunakan rentetan "hello world" sebagai data nod. Kemudian gunakan kaedah zk.Get untuk mendapatkan data nod "/test", dan gunakan kaedah zk.Delete untuk memadamkan nod.

2. Dubbo

Dubbo ialah rangka kerja perkhidmatan teragih berprestasi tinggi dan salah satu projek sumber terbuka Alibaba. Dubbo menyediakan berbilang fungsi seperti pendaftaran perkhidmatan, penemuan, pengimbangan beban, failover, dsb., dan menyokong berbilang protokol komunikasi RPC.

1. Pasang dan mulakan Dubbo

Pertama, anda perlu memuat turun rangka kerja Dubbo Laman web rasmi ialah https://github.com/apache/dubbo-go. Selepas menyahzip, masukkan direktori dubbo /go-server/demo, gunakan arahan berikut untuk memulakan Dubbo:

go run main.go

Selepas permulaan, anda boleh melihat status berjalan Dubbo melalui konsol pengurusan Web Dubbo.

2. Gunakan Dubbo untuk mendaftar dan memanggil perkhidmatan

Penyepaduan rangka kerja Beego dan Dubbo memerlukan penggunaan DubboGo SDK, yang boleh dipasang melalui arahan berikut:

go get github.com/apache/dubbo-go

Gunakan DubboGo SDK boleh mengakses perkhidmatan RPC yang disediakan oleh Dubbo dengan mudah. Dalam rangka kerja Beego, anda boleh mendaftar dan menghubungi perkhidmatan yang disediakan oleh Dubbo melalui kod berikut:

import (
    "github.com/apache/dubbo-go/config"
    "github.com/apache/dubbo-go/registry"
)

// 注册Dubbo服务
func RegisterDubboService() {
    // 配置Dubbo服务注册中心
    config.GetApplicationConfig().Name = "my-application"
    config.GetProviderConfig().Registry = registry.NewZookeeperRegistry("127.0.0.1:2181")
    // 注册服务
    err := config.RegisterProvider(
        &config.ServiceConfig{
            InterfaceName: "org.apache.dubbo.DemoService",
            Protocol:      "dubbo",
            Ip:            "127.0.0.1",
            Port:          20880,
            MethodConfigs: []*config.MethodConfig{
                &config.MethodConfig{
                    Name: "SayHello",
                },
            },
            Registry: config.GetProviderConfig().Registry,
        },
        new(DemoServiceImpl),
    )
    if err != nil {
        panic(err)
    }
}

// 调用Dubbo服务
func CallDubboService() {
    // 配置Dubbo服务发现中心
    config.GetConsumerConfig().Registry = registry.NewZookeeperRegistry("127.0.0.1:2181")
    // 调用服务
    reference, err := config.NewReference(&config.ReferenceConfig{
        InterfaceName: "org.apache.dubbo.DemoService",
        Urls:          []string{"dubbo://127.0.0.1:20880/org.apache.dubbo.DemoService"},
        Registry:      config.GetConsumerConfig().Registry,
    })
    if err != nil {
        panic(err)
    }
    demoService := reference.(*DemoService)
    res, err := demoService.SayHello("Dubbo")
    if err != nil {
        panic(err)
    }
    fmt.Println(res)
}

Dalam kod di atas, mula-mula gunakan DubboGo SDK untuk mendaftar perkhidmatan, dan kemudian gunakan DubboGo SDK untuk memanggil perkhidmatan . Apabila mendaftar perkhidmatan, anda perlu mengkonfigurasi pusat pendaftaran perkhidmatan Dubbo dahulu, dan kemudian menentukan nama antara muka perkhidmatan, protokol, alamat IP, port, konfigurasi kaedah dan maklumat lain. Apabila memanggil perkhidmatan, anda perlu mengkonfigurasi pusat penemuan perkhidmatan Dubbo dan membuat rujukan perkhidmatan Dubbo menggunakan URL perkhidmatan dan nama antara muka yang disediakan oleh Dubbo.

3. Integrasikan Zookeeper dan Dubbo

Untuk menyepadukan Zookeeper dan Dubbo dalam rangka kerja Beego, anda perlu mendaftarkan perkhidmatan Dubbo dahulu, dan kemudian gunakan URL perkhidmatan yang disediakan oleh Dubbo untuk mendaftarkan Dubbo nod dalam Zookeeper. Ini boleh dicapai dengan kod berikut:

import (
    "github.com/apache/dubbo-go/config"
    "github.com/apache/dubbo-go/registry"
    "github.com/samuel/go-zookeeper/zk"
)

// 集成Zookeeper和Dubbo
func IntegrateZkDubbo() {
    // 配置Dubbo服务注册中心
    config.GetApplicationConfig().Name = "my-application"
    config.GetProviderConfig().Registry = registry.NewZookeeperRegistry("127.0.0.1:2181")

    // 注册Dubbo服务
    err := config.RegisterProvider(
        &config.ServiceConfig{
            InterfaceName: "org.apache.dubbo.DemoService",
            Protocol:      "dubbo",
            Ip:            "127.0.0.1",
            Port:          20880,
            MethodConfigs: []*config.MethodConfig{
                &config.MethodConfig{
                    Name: "SayHello",
                },
            },
            Registry: config.GetProviderConfig().Registry,
        },
        new(DemoServiceImpl),
    )
    if err != nil {
        panic(err)
    }

    // 将Dubbo服务URL注册到Zookeeper
    conn, _, err := zk.Connect([]string{"localhost:2181"}, time.Second*5)
    if err != nil {
        panic(err)
    }
    defer conn.Close()

    serviceURL := fmt.Sprintf("dubbo://127.0.0.1:20880/org.apache.dubbo.DemoService?anyhost=true&application=my-application&dubbo=2.0.2&generic=false&interface=org.apache.dubbo.DemoService&loadbalance=random&methods=SayHello&pid=1&side=provider&timeout=1000000")
    _, err = conn.Create("/dubbo/org.apache.dubbo.DemoService/providers/"+serviceURL, nil, zk.FlagEphemeral, zk.WorldACL(zk.PermAll))
    if err != nil {
        panic(err)
    }
}

Dalam kod di atas, mula-mula gunakan DubboGo SDK untuk mendaftarkan perkhidmatan, kemudian dapatkan URL perkhidmatan Dubbo dan daftarkan maklumat URL perkhidmatan Dubbo kepada Zookeeper. Mula-mula sambung ke pelayan Zookeeper melalui kaedah zk.Connect dan kemudian gunakan kaedah zk.Create untuk mencipta nod bernama "/dubbo/org.apache.dubbo.DemoService/providers/service URL" dalam Zookeeper, di mana data nod kosong dan jenis nod ialah zk.FlagEphemeral, menunjukkan bahawa ini adalah nod sementara. Selepas nod berjaya dibuat, perkhidmatan Dubbo akan didaftarkan di Zookeeper.

4. Pengujian

Selepas menggunakan rangka kerja Beego untuk menyepadukan Zookeeper dan Dubbo, anda boleh menguji perkhidmatan Dubbo melalui permintaan HTTP untuk mengesahkan pelaksanaan fungsi tadbir urus perkhidmatan. Anda boleh menggunakan alatan HTTP seperti Postman untuk membina pengepala permintaan HTTP menggunakan URL perkhidmatan Dubbo, dan kemudian menambah parameter permintaan dalam badan mesej untuk memulakan panggilan perkhidmatan Dubbo. Sebagai contoh, anggap bahawa URL perkhidmatan Dubbo ialah:

dubbo://127.0.0.1:20880/org.apache.dubbo.DemoService?anyhost=true&application=my-application&dubbo=2.0.2&generic=false&interface=org.apache.dubbo.DemoService&loadbalance=random&methods=SayHello&pid=1&side=provider&timeout=1000000

Apabila menggunakan Posmen untuk mensimulasikan panggilan perkhidmatan Dubbo, anda boleh menambah parameter berikut dalam badan permintaan HTTP (Content-Type is application/json):

{
    "methodName": "SayHello",
    "parameterTypes": [
        "java.lang.String"
    ],
    "arguments": [
        "Dubbo"
    ]
}

Selepas menghantar permintaan HTTP, anda boleh mendapatkan hasil panggilan perkhidmatan tersebut.

Ringkasan

Tadbir urus perkhidmatan teragih ialah isu yang kompleks dan penting Penyepaduan Zookeeper dan Dubbo dalam rangka kerja Beego boleh merealisasikan pelbagai fungsi seperti pendaftaran perkhidmatan, penemuan, pengimbangan beban, failover, dsb., dan meningkatkan kebolehpercayaan dan ketersediaan tinggi sistem teragih. Memberi perlindungan yang kuat. Kita boleh mempelajari dan menggunakan contoh kod yang disediakan dalam artikel ini, menguasai teknologi teras tadbir urus perkhidmatan teragih dan menggunakannya dalam projek sebenar.

Atas ialah kandungan terperinci Menggunakan Zookeeper dan Dubbo untuk melaksanakan tadbir urus perkhidmatan teragih di Beego. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!