RPC

grassroots2011 · · 701 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

RPC

RPC引擎目前支持Thrift(client & serve)

Thrift安装

go get github.com/adolphlxm/atc/rpc/thrift

Thrift服务端使用步骤

第一步:引入包

import(
    "github.com/adolphlxm/atc/rpc/thrift"
)

第二步:初始化服务

// 创建服务实例
ThriftRPC := thrift.NewThriftServe(`{"addr":"127.0.0,1:9090"}`)
// DEBUG
ThriftRPC.Debug(true)
// 设置传输层、协议层
ThriftRPC.Factory("binary", "framed")
// 设置超时时间
ThriftRPC.Timeout(10)

第三步:启动服务

ThriftRPC.Run()

第四步:根据逻辑设置平滑退出

ctx, _ := context.WithTimeout(context.Background(), time.Duration(Aconfig.ThriftQTimeout)*time.Second)
ThriftRPC.Shutdown(ctx)

开始使用

Thrift RPC 路由 router.go

func init() {
    processor := micro.NewMicroThriftProcessor(&MicroHandler{})
    atc.ThriftRPC.RegisterProcessor("user", processor)
}
  • Go的Thrift包已经整合在ATC框架内了,无需重新安装和下载了!
  • 使用.thrift IDL 生成 .go 请使用 atc-tool 工具(不然可能会报错.)

thrift命令行工具,用于 thrift IDL .go 文件生产

$ atc-tool thrift [options] file

具体thrift命令可使用 thrift --help 查看
atc-tool 工具

举例:

$ atc-tool thrift -r --gen go xxx.thrift

Thrift客户端使用步骤

第一步:引入包

import(
    "github.com/adolphlxm/atc/rpc/thrift"
)

第二步:初始化客户端连接池(由于thrift client 是非线程安全,So 提供了一个连接池管理)

pool := NewThriftPool(net.JoinHostPort("127.0.0.1", "9090"),10,10,10)
pool.SetFactory("binary", "framed")

第三步:开始使用

// 获取一个可用连接
conn,err := pool.Get()
if err != nil {
    return err
}
mulProtocol := conn.NewTmultiplexedProtocol("user")

// 这部分调用自动生成代码
client := micro.NewMicroThriftClientProtocol(conn.GetTtransport(), conn.GetTprotocol(), mulProtocol)

LICENSE

ATC is Licensed under the Apache License, Version 2.0 (the “License”)
(http://www.apache.org/licenses/LICENSE-2.0.html).

GITHUB源码下载

框架:ATC
工具: ATC-tool
DEMO: ATC-demo


有疑问加站长微信联系(非本文作者)

本文来自:CSDN博客

感谢作者:grassroots2011

查看原文:RPC

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:1006366459

701 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传