软件简介

Go-MOA 是使用redis get请求协议的RPC 框架。

MOA Server使用方式

• 安装：

安装ZooKeeper $Zookeeper/bin/zkServer.sh start

    go get  github.com/blackbeans/go-moa/core
go get  github.com/blackbeans/go-moa/proxy

• 定义服务的接口对应

      //接口
  

  type DemoResult struct {
          Hosts []string json:"hosts"
          Uri   string   json:"uri"
      }

  type IGoMoaDemo interface {
          GetDemoName(serviceUri, proto string) (DemoResult, error)
      }
      //服务实现
      type GoMoaDemo struct {
      }

  func (self GoMoaDemo) GetDemoName(serviceUri, proto string) (DemoResult, error)      {
          return DemoResult{[]string{“fuck gfw”}, serviceUri}, nil
      }

  • 例如接口为：

• 服务端启动启动：

      func main(){
  

  app := core.NewApplcation(“./conf/cluster_test.toml”, 
          func() []proxy.Service {
              return []proxy.Service{
                  proxy.Service{
                      ServiceUri: ”/service/bibi/go-moa”,
                      Instance:   GoMoaDemo{},
                      Interface:  (*IGoMoaDemo)(nil)}}
          })

  //设置启动项
          ch := make(chan os.Signal, 1)
          signal.Notify(ch, os.Kill)
          //kill掉的server
          <-ch
          app.DestoryApplication()
      }

• 说明

  • Service为一个服务单元，对应了本服务对外的服务名称、以及对应的接口

  • Applcation需要对应的Moa的配置文件，toml类型，具体配置参见./conf/cluster_test.toml

• 发布服务成功可以使用客户端进行测试，具体客户端的使用请参考

*** Benchmark

env:Macbook Pro 2.2 GHz Intel Core i7

go test --bench=".*" github.com/blackbeans/go-moa/core -run=BenchmarkApplication

BenchmarkApplication-8     20000         64517 ns/op