thrift 在 go 语言环境的使用测试

Thrift 是通用型 rpc 框架，但是功能比较单一，只是实现了点对点(End-to-End)的通讯框架，缺乏服务治理的功能，比如服务注册和发现、 负载均衡、容灾、服务监控等功能。

Idl 介绍

传输格式

TBinaryProtocol – 二进制格式.

TCompactProtocol – 压缩格式

TJSONProtocol – JSON 格式

TSimpleJSONProtocol –提供 JSON 只写协议, 生成的文件很容易通过脚本语言解析。

TDebugProtocol – 使用易懂的可读的文本格式，以便于 debug

传输方式

TSocket -阻塞式 socker

TFramedTransport – 以 frame 为单位进行传输，非阻塞式服务中使用。

TFileTransport – 以文件形式进行传输。

TMemoryTransport – 将内存用于 I/O. java 实现时内部实际使用了简单的 ByteArrayOutputStream。

TZlibTransport – 使用 zlib 进行压缩， 与其他传输方式联合使用。当前无 java 实现。

服务模型

TSimpleServer – 简单的单线程服务模型，常用于测试

TThreadPoolServer – 多线程服务模型，使用标准的阻塞式 IO。

TNonblockingServer – 多线程服务模型，使用非阻塞式 IO（需使用 TFramedTransport 数据传输方式）

基本类型

bool: 布尔值

byte: 有符号字节

i16: 16 位有符号整型 int16

i32: 32 位有符号整型 int32

i64: 64 位有符号整型 int64

double: 64 位浮点型

string: 字符串

binary: Blob 类型 byte 数组

list: 数组

set: 集合

map<t, t>: 字典

结构体

1.struct 不能继承，但是可以嵌套，不能嵌套自己。

2.其成员都是有明确类型

3.成员是被正整数编号过的，其中的编号使不能重复的，这个是为了在传输过程中编码使用。

4.成员分割符可以是逗号（,）或是分号（;），而且可以混用

5.字段会有 optional 和 required 之分和 protobuf 一样，但是如果不指定则为无类型–可以不填充该值，但是
在序列化传输的时候也会序列化进去，optional 是不填充则部序列化，required 是必须填充也必须序列化。

6.每个字段可以设置默认值

7.同一文件可以定义多个 struct，也可以定义在不同的文件，进行 include 引入。

struct User{
  1: required string name, //改字段必须填写
  2: optional i32 age = 0; //默认值
  3: bool gender //默认字段类型为optional
}

常量定义

使用方法：在变量前面加上 const

const i32 const_int = 1;

类型定义

Thrift 支持 C/C++ 类型定义

typedef i32 myint

末尾没有逗号

Exception (异常)

异常在语法和功能上类似于结构体，差别是异常使用关键字 exception，而且异常是继承每种语言的基础异常类。

exception MyException {
    1: i32 errorCode,
    2: string message
}

Service (服务定义类型)

服务的定义方法在语义上等同于面向对象语言中的接口。

service HelloService {
    i32 sayInt(1:i32 param)
    string sayString(1:string param)
    bool sayBoolean(1:bool param)
    void sayVoid()
}

NameSpace

Thrift 中的命名空间类似于 C++ 中的 namespace 和 java 中的 package，它们提供了一种组织（隔离）代码的简便方式。名字空间也可以用于解决类型定义中的名字冲突。

Include

便于管理、重用和提高模块性/组织性，我们常常分割 Thrift 定义在不同的文件中。包含文件搜索方式与 c++ 一样。Thrift 允许文件包含其它 thrift 文件，用户需要使用 thrift 文件名作为前缀访问被包含的对象

测试

1、安装下载

下载 thrift 代码编译生成工具，可直接生成脚手架代码。

http://thrift.apache.org/download

github 下载框架代码，一定要根据代码生成工具的版本选择对应的代码版本，否则生成的代码会有异常

apache/thrift Apache Thrift. Contribute to apache/thrift development by creating an account on GitHub. GitHub - github.com

2、IDL 编写

vi   my_article_service.thrift
namespace go my_article_service
struct Article{
    1: i32      id,
    2: string   title,
    3: string   content,
}

service articleService{
    list<Article> ArticleList(),
    Article     ArticleInfo(1:i32 id),
}

在 gen-go 文件夹下生成脚手架代码

thrift -r --gen go my_article_service.thrif

3、编写 server

业务处理 handler

vi handler/article_handler.go

package handler


import (
   "thirft_test/self/gen-go/my_article_service"
)

type  ArticleService   struct{
}
func(ah ArticleService) ArticleList() ([]*my_article_service.Article, error) {
   var al []*my_article_service.Article
   ai := new(my_article_service.Article)
   ai.ID = 123
   ai.Title = "dasdas"
   ai.Content = "dsadasdsadsdsa"
   al = append(al, ai)
   return al,nil
}

func(ah ArticleService) ArticleInfo(id int32) (*my_article_service.Article, error) {
   ai := new(my_article_service.Article)
   ai.ID = id
   ai.Title = "dasdas"
   ai.Content = "dsadasdsadsdsa"
   return ai,nil
}

vi man.go

package main

import (
	"git.apache.org/thrift.git/lib/go/thrift"
	"thirft_test/self/gen-go/my_article_service"
	"thirft_test/self/handler"
)

func main() {
	errc := make(chan error)
	go func() {
		var as my_article_service.ArticleService
		as = handler.ArticleService{}

		processor := my_article_service.NewArticleServiceProcessor(as)
		transportFactory := thrift.NewTFramedTransportFactory(thrift.NewTTransportFactory())
		protocolFactory := thrift.NewTBinaryProtocolFactoryDefault()
		serverTransport, _ := thrift.NewTServerSocket("127.0.0.1:9090")
		server := thrift.NewTSimpleServer4(processor, serverTransport, transportFactory, protocolFactory)
		errc <- server.Serve()
	}()
	<-errc
}

4、编写 client

vi client/main.go

package main

import (
	"fmt"
	"git.apache.org/thrift.git/lib/go/thrift"
	"thirft_test/self/gen-go/my_article_service"
)

func main() {
	transportFactory := thrift.NewTFramedTransportFactory(thrift.NewTTransportFactory())
	protocoleFactory := thrift.NewTBinaryProtocolFactoryDefault()
	socket, err := thrift.NewTSocket("127.0.0.1:9090")
	if err != nil {

	}
	transport := transportFactory.GetTransport(socket)
	client := my_article_service.NewArticleServiceClientFactory(transport, protocoleFactory)
	transport.Open()
	article, _ := client.ArticleInfo(123)
	fmt.Println(article)
	al, _ := client.ArticleList()
	fmt.Println(al)
	transport.Close()
}

5、运行

Article({ID:123 Title:dasdas Content:dsadasdsadsdsa})
[Article({ID:123 Title:dasdas Content:dsadasdsadsdsa})]