文档章节

Golang通过Thrift框架完美实现跨语言调用

qinerg
 qinerg
发布于 2013/09/29 17:41
字数 1226
阅读 27845
收藏 249

  每种语言都有自己最擅长的领域,Golang 最适合的领域就是服务器端程序。

  做为服务器端程序,需要考虑性能同时也要考虑与各种语言之间方便的通讯。采用http协议简单,但性能不高。采用TCP通讯,则需要考虑封包、解包、粘包等等很多因素,而且想写个高效的TCP服务,也很难。

  其实,对于此类需求,采用RPCRemote Procedure Call Protocol编程最靠谱。使用 RPC 编程被认为是在分布式环境中运行的客户机和服务器应用程序之间进行可靠通信的最强大、最高效的方法之一。

  Golang内置了对RPC支持,但只能适用于go语言程序之间调用,且貌似序列化、反序列化性能不高。如果go语言能使用Thrift开发,那么就如虎添翼了。可惜,thrift虽然很早就包含了golang的代码,但一直都存在各种问题无法正确执行,以至于GitHub上有许多大牛小牛自行实现的Thrift代码,但依然各种问题……直到0.9.1版本的发布!

  是的,最近,Apache Thrift 0.9.1正式发布了。新版的Thrift终于对Golang提供了完美的支持。经过实验,服务器端、客户端已经完美支持跨语言调用,且性能、尤其是内存占用上,编译型语言的特点展现出来,比java版的实现强了很多。

  下面,我们采用golang实现一个ThriftServer端和Client端程序。

一、开发前准备

1、安装golangThrift包:

go get git.apache.org/thrift.git/lib/go/thrift

2、产生协议库:

  这是我定义的测试用IDL,为检验兼容性,采用了多种数据结构:
RpcService.thrift

namespace go demo.rpc
namespace java demo.rpc

// 测试服务
service RpcService {

	// 发起远程调用
	list<string> funCall(1:i64 callTime, 2:string funCode, 3:map<string, string> paramMap),

}

    3、生成开发库

  下载开发库编译器 http://www.apache.org/dyn/closer.cgi?path=/thrift/0.9.1/thrift-0.9.1.exe

  thrift-0.9.1.exe  -gen go RpcService.thrift

  自动生成出的源码结构如下:

其中 constants.gorpc_service.gottypes.go 是协议库,编写程序需要用到。rpc_service-remote.go 是自动生成的例程,可以不用。

二、go语言实现

1、服务器端

下面,我们来写服务器端程序:

package main

import (
	"demo/rpc"
	"fmt"
	"git.apache.org/thrift.git/lib/go/thrift"
	"os"
)

const (
	NetworkAddr = "127.0.0.1:19090"
)

type RpcServiceImpl struct {
}

func (this *RpcServiceImpl) FunCall(callTime int64, funCode string, paramMap map[string]string) (r []string, err error) {
	fmt.Println("-->FunCall:", callTime, funCode, paramMap)

	for k, v := range paramMap {
		r = append(r, k+v)
	}
	return
}

func main() {
	transportFactory := thrift.NewTFramedTransportFactory(thrift.NewTTransportFactory())
	protocolFactory := thrift.NewTBinaryProtocolFactoryDefault()
	//protocolFactory := thrift.NewTCompactProtocolFactory()

	serverTransport, err := thrift.NewTServerSocket(NetworkAddr)
	if err != nil {
		fmt.Println("Error!", err)
		os.Exit(1)
	}

	handler := &RpcServiceImpl{}
	processor := rpc.NewRpcServiceProcessor(handler)

	server := thrift.NewTSimpleServer4(processor, serverTransport, transportFactory, protocolFactory)
	fmt.Println("thrift server in", NetworkAddr)
	server.Serve()
}

  加空行也不过才43行,怎么样简单吧。

2、客户端程序

package main

import (
	"demo/rpc"
	"fmt"
	"git.apache.org/thrift.git/lib/go/thrift"
	"net"
	"os"
	"time"
)

func main() {
	startTime := currentTimeMillis()
	transportFactory := thrift.NewTFramedTransportFactory(thrift.NewTTransportFactory())
	protocolFactory := thrift.NewTBinaryProtocolFactoryDefault()

	transport, err := thrift.NewTSocket(net.JoinHostPort("127.0.0.1", "19090"))
	if err != nil {
		fmt.Fprintln(os.Stderr, "error resolving address:", err)
		os.Exit(1)
	}

	useTransport := transportFactory.GetTransport(transport)
	client := rpc.NewRpcServiceClientFactory(useTransport, protocolFactory)
	if err := transport.Open(); err != nil {
		fmt.Fprintln(os.Stderr, "Error opening socket to 127.0.0.1:19090", " ", err)
		os.Exit(1)
	}
	defer transport.Close()

	for i := 0; i < 1000; i++ {
		paramMap := make(map[string]string)
		paramMap["name"] = "qinerg"
		paramMap["passwd"] = "123456"
		r1, e1 := client.FunCall(currentTimeMillis(), "login", paramMap)
		fmt.Println(i, "Call->", r1, e1)
	}

	endTime := currentTimeMillis()
	fmt.Println("Program exit. time->", endTime, startTime, (endTime - startTime))
}

// 转换成毫秒
func currentTimeMillis() int64 {
	return time.Now().UnixNano() / 1000000
}

  分别编译,先启动服务器端,然后在执行客户端程序。可以看到控制台正确打印出了信息,说明调用通过。

-->FunCall: 1380446325199 login map[name:qinerg passwd:123456]

三、Java版实现

  为了验证跨语言调用,下面我们分别再用java实现一下服务器端和客户端:

  生成Java版开发库:

  thrift-0.9.1.exe  -gen java RpcService.thrift

1、Java服务器版

package demo.rpc;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;

import org.apache.thrift.TException;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TBinaryProtocol.Factory;
import org.apache.thrift.server.TNonblockingServer;
import org.apache.thrift.server.TServer;
import org.apache.thrift.transport.TNonblockingServerSocket;
import org.apache.thrift.transport.TNonblockingServerTransport;
import org.apache.thrift.transport.TTransportException;

/**
 * Thrift测试服务器
 */
public class Server implements RpcService.Iface {

	public static void main(String[] as) {
		TNonblockingServerTransport serverTransport = null;
		try {
			serverTransport = new TNonblockingServerSocket(19090);
		} catch (TTransportException e) {
			e.printStackTrace();
		}

		RpcService.Processor<RpcService.Iface> processor = new RpcService.Processor<RpcService.Iface>(
				new Server());

		Factory protFactory = new TBinaryProtocol.Factory(true, true);
		//TCompactProtocol.Factory protFactory = new TCompactProtocol.Factory();

		TNonblockingServer.Args args = new TNonblockingServer.Args(
				serverTransport);
		args.processor(processor);
		args.protocolFactory(protFactory);
		TServer server = new TNonblockingServer(args);
		System.out.println("Start server on port 19090 ...");
		server.serve();
	}

	@Override
	public List<String> funCall(long callTime, String funCode,
			Map<String, String> paramMap) throws TException {
		System.out.println("-->FunCall:" + callTime + " " + funCode + " "
				+ paramMap);
		List<String> retList = new ArrayList<>();

		for (Entry<String, String> entry : paramMap.entrySet()) {
			retList.add(entry.getKey() + entry.getValue());
		}

		return retList;
	}
}

2、Java客户端版

package demo.rpc;

import java.util.HashMap;
import java.util.Map;

import org.apache.thrift.TException;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.transport.TFramedTransport;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransport;

/**
 * Thrift测试客户端
 */
public class Client {

	public static void main(String[] args) {
		
		long startTime = System.currentTimeMillis();
		try {
			TTransport transport = new TFramedTransport(new TSocket("localhost", 19090));
			
			TBinaryProtocol protocol = new TBinaryProtocol(transport);
			//TCompactProtocol protocol = new TCompactProtocol(transport);
			
			RpcService.Client client = new RpcService.Client(protocol);
			transport.open();
			
			Map<String, String> param = new HashMap<String, String>();
			param.put("name", "qinerg");
			param.put("passwd", "123456");
			
			for (int i = 0; i < 1000; i++) {
				System.out.println(client.funCall(System.currentTimeMillis() , "login", param));
			}
			
			transport.close();
		} catch (TException x) {
			x.printStackTrace();
		}
		long endTime = System.currentTimeMillis();
		System.out.println(" 本次调用完成时间:" + endTime + "   " + startTime + "  " + (endTime - startTime));
	}
}

  好了,现在启动java版服务器端,用golang版客户端调用,完全没有问题。启动golang版服务器端程序,用java版客户端调用,同样OK。

  完美实现了跨语言调用。

© 著作权归作者所有

qinerg

qinerg

粉丝 132
博文 15
码字总数 24206
作品 1
架构师
私信 提问
加载中

评论(19)

ayanmw
ayanmw
七年前的文章了,现在直接使用protobuf3-rpc就可以了的吧。?
思维忒
思维忒
为啥够浪只有simpleserver??? NonblockingServer呢???
caiya928
caiya928
正在学习,表示很受益
m
moshen867
mark
********
********
mark
l
lsl
mark
Risol
Risol

引用来自“viney”的评论

golang实现分布式调用,直接自带的rpc就够了。
如果是夸语言调用,Thrift是不错。不过楼主举得例子,怎么是golang的客户端和golang的服务端调用。
应该golang的服务端,java的客户端互调才符合标题吧!

本来就是java和golang可以相互调用的,作者把所有的实现都写出来了而已
viney
viney
golang实现分布式调用,直接自带的rpc就够了。
如果是夸语言调用,Thrift是不错。不过楼主举得例子,怎么是golang的客户端和golang的服务端调用。
应该golang的服务端,java的客户端互调才符合标题吧!
荆棘谷-部落-我要么
荆棘谷-部落-我要么
原来我一直认为 python 最简洁,直到我发现了另外一种语言
榕树下_
榕树下_
正需要,不知道好用不
比较跨语言通讯框架:Apache Thrift和Google Protobuf

前两天想在微博上发表一个观点:在现在的技术体系中,能用于描述通讯协议的方式很多,xml,json,protobuf,thrift,如果在有如此众多选择的基础上,在设计系统时,还自造协议,自己设计协议类...

摆渡者
2014/07/12
6K
0
Thrift RPC 框架分析

前言 工作中用到Thrift,一直想深入研究一下。今天这篇博客以提问的方式,分析Thrift的源码。文章部分参考自:Thrift源码分析。 本来计划的题目是:「Thrift RPC 源码分析」,可是写了两个小...

被称为L的男人
2018/12/01
0
0
Thrift入门初探--thrift安装及java入门实例

  公司的一些平台服务框架底层封装了thrift提供服务,最近项目不是很紧,于是研究了一下,刚刚入门,理解得不深,写这篇博文来整理一下思路. 什么是thrift?   简单来说,是Facebook公布的一款开...

冬至饮雪
2017/02/21
0
0
轻量级RPC框架--harpc

基于Thrift的跨语言、高可用、高性能、轻量级的RPC框架。 功能介绍 跨语言通信 方便的使Java、Python、C++三种程序可以相互通信 负载均衡和容灾处理 方便的实现任务的分布式处理 支持服务的水...

dsfan
2015/10/17
5.3K
0
接口协议工具thrift1快速入门

简介 Thrift是一种接口描述语言和二进制通讯协议,它被用来定义和创建跨语言的服务。它被当作远程过程调用(RPC)框架来使用,是由Facebook为“大规模跨语言服务开发”而开发的。它通过一个代...

python人工智能找电子书
2018/10/09
0
0

没有更多内容

加载失败,请刷新页面

加载更多

Excel数据透视表基础:数据透视表的正确数据格式

1.数据透视表:是一种数据分析方法, 一.使用数据透视表必须用正确的数据格式: 1.数据必须有标题: 2.数据表不能有相同的标题 3.数据表中不能有合并单元格 4.不能有 小计、合计、空行、分类...

东方墨天
6分钟前
1
0
聊聊nacos的NacosDiscoveryAutoConfiguration

序 本文主要研究一下nacos的NacosDiscoveryAutoConfiguration NacosDiscoveryAutoConfiguration nacos-spring-boot-project/nacos-discovery-spring-boot-autoconfigure/src/main/java/com/a......

go4it
39分钟前
4
0
如何保证消息的顺序性?

面试题 如何保证消息的顺序性? 面试官心理分析 其实这个也是用 MQ 的时候必问的话题,第一看看你了不了解顺序这个事儿?第二看看你有没有办法保证消息是有顺序的?这是生产系统中常见的问题...

米兜
44分钟前
7
0
网络安全市场需求

最近,网络安全技能差距的热门话题流传开来。技能差距经常被紧急讨论,可以看出它在实践中的作用是很大的。但信息安全是一门广泛的学科,所以在谈论“技能差距”时需要更具体。有专家表示,真...

linuxCool
今天
3
0
饿了么快应用初体验

作者:饿了么 顾诚 为什么我们选择了快应用 在很长一段时间里,原生饿了么应用对于新用户来说体验成本略高,对于迫切想要点餐的老用户操作有点繁琐;而 Web 版的饿了么应用在体验、速度、功能...

前端老手
今天
5
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部