Go 快速开始

快速开始

通过一个 hellowworld 例子带领大家快速上手Dubbo-go框架。

协议：Dubbo
编码：Hessian2
注册中心：Zookeeper

  • Go编程环境
  • 启动zookeeper服务，也可以使用远程实例
  1. 编写需要被编码的结构体，由于使用 Hessian2 作为编码协议，User 需要实现 JavaClassName 方法，它的返回值在dubbo中对应User类的类名。
  1. 编写业务逻辑，UserProvider 相当于dubbo中的一个服务实现。需要实现 Reference 方法，返回值是这个服务的唯一标识，对应dubbo的 beans 和 path 字段。
  1. type UserProvider struct {
  2. }
  4. func (u *UserProvider) GetUser(ctx context.Context, req []interface{}) (*User, error) {
  5.     println("req:%#v", req)
  6.     rsp := User{"A001", "hellowworld", 18, time.Now()}
  7.     println("rsp:%#v", rsp)
  8.     return &rsp, nil
  9. }
  11.     return "UserProvider"
  12. }
  1. 注册服务和对象
  1. func init() {
  2.     config.SetProviderService(new(UserProvider))
  3.     // ------for hessian2------
  4.     hessian.RegisterPOJO(&User{})
  5. }

第二步：编写主程序

  1. 引入必需的dubbo-go包
  1. main 函数
  1. func main() {
  2.     config.Load()
  3. }
  1. 参考 log 和 编辑配置文件。

  • registries 结点下需要配置zk的数量和地址

  • services 结点下配置服务的具体信息，需要配置 interface 配置，修改为对应服务的接口名，服务的key对应第一步中 Provider 的 Reference 返回值

  1. 把上面的两个配置文件分别配置为环境变量
  1. export CONF_PROVIDER_FILE_PATH="xxx"
  2. export APP_LOG_CONF_FILE="xxx"

第一步：编写客户端 Provider

  1. 参考服务端第一步的第一点。

  1. 注册服务和对象
  2.     hessian.RegisterPOJO(&User{})
  3. }
  1. 引入必需的dubbo-go包
  1. import (
  2.     hessian "github.com/apache/dubbo-go-hessian2"
  3.     "github.com/apache/dubbo-go/config"
  4.     _ "github.com/apache/dubbo-go/registry/protocol"
  5.     _ "github.com/apache/dubbo-go/common/proxy/proxy_factory"
  6.     _ "github.com/apache/dubbo-go/filter/impl"
  7.     _ "github.com/apache/dubbo-go/cluster/cluster_impl"
  8.     _ "github.com/apache/dubbo-go/cluster/loadbalance"
  9.     _ "github.com/apache/dubbo-go/registry/zookeeper"
  11.     _ "github.com/apache/dubbo-go/protocol/dubbo"
  12. )
  1. main 函数

第三步：编写配置文件并配置环境变量

  1. 参考 log 和 编辑配置文件。

主要编辑以下部分：

  • registries 结点下需要配置zk的数量和地址

  • references 结点下配置服务的具体信息，需要配置 interface 配置，修改为对应服务的接口名，服务的key对应第一步中 Provider 的 Reference 返回值

  1. 把上面的两个配置文件费别配置为环境变量，为防止log的环境变量和服务端的log环境变量冲突，建议所有的环境变量不要做全局配置，在当前起效即可。
  1. export CONF_CONSUMER_FILE_PATH="xxx"