Dubbo의 새로운 소식: Dubbo 생태계에서 Go 언어 적용에 대한 연구

package main

import (
    "context"
    "fmt"
    "github.com/apache/dubbo-go/common/logger"
    "github.com/apache/dubbo-go/config"
    "github.com/apache/dubbo-go/protocol/dubbo"
)

type Greeter struct{}

func (g Greeter) SayHello(name string) interface{} {
    return "Hello, " + name
}

func main() {
    config.SetConsumerService(Greeter{})
    rootConfig := &config.ConsumerConfig{
        ApplicationConfig: &config.ApplicationConfig{
            AppName: "godubbo",
        },
        ReferenceConfig: &config.ReferenceConfig{
            InterfaceName: "com.test.Greeter",
        },
    }
    referenceConfig, err := config.NewReferenceConfig(rootConfig)
    if err != nil {
        logger.Errorf("new reference config error %v", err)
    }
    var (
        resp *dubbo.RPCResult
        called = make(chan interface{})
    )
    err = referenceConfig.GetDefaultReference().Call(context.Background(), "SayHello", []interface{}{"Tom"}, &resp, called)
    if err != nil {
        logger.Errorf("error: %v", err)
    }
    fmt.Printf("Result: %v
", <-called)
}

package main

import (
    "fmt"
    "github.com/apache/dubbo-go/common/logger"
    "github.com/apache/dubbo-go/config"
    "github.com/apache/dubbo-go/protocol/dubbo"
    "net/http"
)

type Greeter struct{}

func (g Greeter) SayHello(name string) interface{} {
    return "Hello, " + name
}

func main() {
    config.SetProviderService(Greeter{})
    rootConfig := config.NewRootConfigBuilder().
        RegistryProtocol("zookeeper").
        Address("127.0.0.1:2181").
        Protocol("dubbo").
        Services("com.test.Greeter").
        Build()
    providerConfig, err := config.NewProviderConfig(rootConfig)
    if err != nil {
        logger.Errorf("new provider config error: %v", err)
    }
    err = providerConfig.Init()
    if err != nil {
        logger.Errorf("provider init error: %v", err)
    }
    http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
        w.Write([]byte("Hello, Dubbo Go!"))
    })
    logger.Infof("dubbo service start")
    http.ListenAndServe(":8080", nil)
}