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

本贴最后更新于 2425 天前,其中的信息可能已经时异事殊

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 下载框架代码,一定要根据代码生成工具的版本选择对应的代码版本,否则生成的代码会有异常

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 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})]
  • golang

    Go 语言是 Google 推出的一种全新的编程语言,可以在不损失应用程序性能的情况下降低代码的复杂性。谷歌首席软件工程师罗布派克(Rob Pike)说:我们之所以开发 Go,是因为过去 10 多年间软件开发的难度令人沮丧。Go 是谷歌 2009 发布的第二款编程语言。

    497 引用 • 1387 回帖 • 282 关注
  • 微服务

    微服务架构是一种架构模式,它提倡将单一应用划分成一组小的服务。服务之间互相协调,互相配合,为用户提供最终价值。每个服务运行在独立的进程中。服务于服务之间才用轻量级的通信机制互相沟通。每个服务都围绕着具体业务构建,能够被独立的部署。

    96 引用 • 155 回帖

相关帖子

欢迎来到这里!

我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。

注册 关于
请输入回帖内容 ...