Chinaunix首页 | 论坛 | 博客
  • 博客访问: 1071322
  • 博文数量: 646
  • 博客积分: 288
  • 博客等级: 二等列兵
  • 技术积分: 5375
  • 用 户 组: 普通用户
  • 注册时间: 2010-07-08 14:33
个人简介

为了技术,我不会停下学习的脚步,我相信我还能走二十年。

文章分类

全部博文(646)

文章存档

2014年(8)

2013年(134)

2012年(504)

分类:

2012-06-29 22:41:03

原文地址:RPC的实现 作者:Aquester

全文下载: RPC的实现.pdf   


目录


1. 前言

RPC全称为Remote Procedure Call,即远过程调用。如果没有RPC,那么跨机器间的进程通讯通常得采用消息,这会降低开发效率,也会增加网络层和上层的耦合度,RPC可以帮助我们解决这些问题。

从上图可以看出,RPC是基于消息实现的,只不过它处于更上层,做了一层抽象和封装。 实现上有很多现存的RPC实现,如Facebook出品Thrift、微软的COM/DCOM/COM+、跨平台的Corba、以及ACE提供的Tao等。本文将力图用比较简单的语言阐述一个RPC是如何实现的。

2. 基本概念

在正式讲解之前,先介绍一下与RPC有关的基本概念:

2.1. IDL

IDL的全称是Interface Definition Language,即接口定义语言(有时也叫作接口描述语言)。因为RPC通常是跨进程、跨机器、跨系统和跨语言的,IDL是用来解决这个问题的,它与语言无关,借助编译器将它翻译成不同的编程语言。

Google开源的ProtoBuf中的“.proto”文件就是一种IDL文件:

message Person {
  required int32 id = 1;
  required string name = 2;
  optional string email = 3;
}

.proto文件中message类似于C语言中的struct的,转换成C++语言后,它对应于C++中的一个类。有关ProtoBuf的更多信息,可参考:

请注意,IDL中的数据类型(如ProtoBuf中的int32)是独立于任何语言的,但它通常会和目标语言中的数据类型有着映射关系,否则将无法把IDL文件编译成目标语言文件。

2.2. 代理(Proxy

代理(Proxy是RPC的客户端实现,客户端代码总是通过代理来与RPC服务端通讯。Proxy的代码完全由IDL编译器生成。

2.3. 存根(Stub

存根(Stub)是RPC的服务端实现。在服务端,需要实现IDL文件中定义的接口;而在客户端直接使用。代理和存根的关系如下图所示:

3. 三要素

要实现一个完整的RPC,需要完成以下三件事,在这里我们把这三件事称作三要素:

3.1. 网络通讯

负责将客户端的请求发送到服务端,和将服务端的响应回送给客户端。这是大家都熟悉的一块,主要就是高性能网络程序的实现。

3.2. 消息编解码

IDL中定义接口、函数和数据等,需要在发送前编码成字节流,在收到后进行解码。比如将函数名、参数类型和参数值等编码成字节流,然后发送给对端,然后对端进行解码,还原成函数调用。ProtoBuf就是一个非常好的编解码工具。

请注意IDL支持的所有数据类型要求是可编解码的,IDL编译器需要知道如何将它编码到字节流,和从字节流里解码还原出来。

3.3. IDL编译器

对大多数人来说,这块的工作是陌生的,因为日常开发接触不多。也因为如此,一般人都会觉得这块很难高深。其实只要克服心理障碍,学习它比想象中的要容易许多。总而言之,上手并不难,特别是在阅读了本文之后。但是如果需要实现一个类似于HiveGCC东东,那是有相当大的难度的,其中对优化语法树就是一个非常大的挑战。

为了能够使用RPC,需要将IDL文件编译成指定的语言代码。ProtoBuf实际上已经实现了这个功能。如果基于ProtoBuf实现一个RPC,则这IDL编译这一步可以跳过,将只需要实现网络通讯,以及实现google::protobuf::RpcControllergoogle::protobuf::RpcChannel两个接口即可。

本文是为了介绍RPC的实现,目标是让读者能够自己实现一套RPC,而对于三要素中的网络通讯和消息编解码,一般人都容易理解和上手,但对于IDL编译这块相对会陌生许多。为此,本文余下部分将着重介绍IDL编译的实现,所有的实现都将基于FlexBison两个开源的工具,当然也可使用JavaCCSableCCAntlrANother Tool for Language Recognition)等。

4. flexbison

经典的lexyacc由贝尔实验室在1970年代开发,flexbison是它们的现代版本。lexMike Lesk(埃里克-施密特,GoogleCEO)设计,yacc则由Stephen C.Johnson开发,它们的主页为:

如果想深入学习FlexBison,推荐阅读《flexbison》一书,这是一本非常精彩的书,是经典O'Reilly系列书籍《lex & yacc》的续篇

4.1. 准备概念

在阅读后续章节时,最好对以下几个概念有些了解,当然不了解也成,但可能会有些懵懂。本节是全文最晦涩的部分,可以尝试跳过本节往后看,或者有需要时再回头看看,但最终还是需要了解的。《flexbison》一书对编译原理的概念讲得不多,但如果多懂一点,将更有利于学习flexbison,因此辅以阅读《编译原理》是非常有帮助的,下面介绍的有些概念就摘自《编译原理 第2》一书。

4.1.1. 正则表达式(regex/regexp

正则表达式(regular expression),这个太重要了,一定要先懂一点,不然后面没法玩。如有需要,可参考百度百科:

4.1.2. 符号∈

“∈”是数学中的一种符号,读作“属于”。

通常用大写拉丁字母ABC,…表示集合,用小写拉丁字母abc,…表示集合中的元素。如果a是集合A的元素,就说a属于(belong to)集合A,记作∈ A。例如,我们用A表示“1~20以内的所有素数”组成的集合,则有∈ A

百度百科:。

4.1.3. 终结符/非终结符/产生式

维基百科:。


C/C++/Java等语言中的if-else语句,通常具有如下的形式:

        if (expression) statement else statement

即一个if-else语句由关键字if、左括号、表达式、右括号、语句、关键字else和另一个语句连接而成。如果用变量expr表示表达式,用变量stmt表示语句,那么这个构造规则可表示成:

        stmt → if ( expr ) stmt else stmt

其中箭头(→)可以读作“可以具有如下形式”,在BNF中使用双冒号(::)来替代箭头,而在bison规则部分,则使用单冒号(:)替代箭头。这样的规则称为产生式(production)。在一个产生式中,像关键字if、else和括号这样的词法元素称为终结符(terminal),像expr和stmt这样的变量称为非终结符(nonterminal)。

4.1.4. 记号(Token

终结符和非终结符,都是Token。在flexbison中,记号由两部分组成:记号编号和记号值,其中不同的记号值可以有不同的类型,具体由bison中的“%union”控制。记号的值要存储在全局变量yyval中。

记号的编号在bison编译时自动按顺连续分配,最小值从258开始。之所以从258开始,是因为258之前的数值是ACSII字符的值。

4.1.5. 形式文法

一个形式文法G是下述元素构成的一个元组(N, Σ, P, S):

1) 非终结符号集合N

2) 终结符号集合Σ(Σ与N无交)

3) 起始符号S∈ N

4) 取如下形式的一组产生式规则P

    (Σ ∪ N)*中的字串 -> (Σ ∪ N)* 中的字串,并且产生式左侧的字串中必须至少包括一个非终结符号。


百度百科:。


l 举例

考虑如下的文法G,其中N = {S, B},Σ = {a, b, c}P包含下述规则:

1) S -> aBSc

2) S -> abc

3) Ba -> aB

4) Bb -> bb

非终结符号S作为初始符号。下面给出字串推导的例子:(推导使用的产生规则用括号标出,替换的字串用黑体标出):

S -> (2) abc

S -> (1) aBSc -> (2) aBabcc -> (3) aaBbcc -> (4) aabbcc

S -> (1) aBSc -> (1) aBaBScc -> (2) aBaBabccc -> (3) aaBBabccc -> (3) aaBaBbccc -> (3) aaaBBbccc -> (4) aaaBbbccc -> (4) aaabbbccc

从这可以看出,这个文法定义了语言 { anbncn | n > 0 } ,这里 an 表示含有 个 的字串。

4.1.6. 上下文无关文法(CFG

一个形式文法 G =N,∑,PS),如果它的产生式规则都取如下的形式:V -> w ,这里 Vw(N∪∑)*,上下文无关文法取名为“上下文无关”的原因就是因为字符 总可以被字串 自由替换,而无需考虑字符 出现的上下文。

一个上下文无关文法(Context-Free Grammar由四个部分组成:

1) 终结符集合

终结符是文法所定义语言的基本符号的集合。

2) 非终结符集合

每个非终结符表示一个终结符的集合,非终结符给出了语言的层次结构,而这种层次结构是语法分析和翻译的关键,因此规则部分是bison语法文件的核心部分。

3) 产生式集合

每个产生式包含一个称为产生式头或左侧的非终结符,一个箭头,和一个称为产生式右侧的由终结符、非终结符组成的序列。上下文无关文法要求产生式左侧只能包含一个非终结符号。

4) 开始符号

开始符号总是一个非终结符。


l 举例

可以产生变量 xy的算术表达式:

S -> T + S | T - S | T


T -> T * T | T / T | ( S ) | x | y | z


字串“( x + y ) * x - z * y / ( x + x )”就可以用这个文法来产生。

4.1.7. BNF

Backus-Naur Form(巴科斯范式)的缩写,是由John BackusPeter Naur首先引入的用来描述计算机语言语法的符号集,经常用来表达上下文无关文法。

百度百科:。

4.1.8. 推导

4.1.9. 语法树

语法分析器的工作是推导出Token之间的关系,语法树经常被用来表达这种关系。算术表达式“1 * 2 + 3 * 4 + 5”的语法树如下图所示:

由于乘法比加法具有更高的优先级,所以前两个表达式为“1 * 2”和“3 * 4”。这颗树的每个分支都显示了Token之间或Token与下面子树的关系。

4.1.10. LL(k)

一种自顶向下分析的分析方法,LL(1)LL(k)的特例,其中的k则表示向前看k个符号,百度百科:

4.1.11. LR(k)

一种从左至右扫描和自底向上的语法分析方法。

百度百科:。

4.1.12. LALR(k)

自左向右向前查看一个记号。bison默认使用LALR1)分析方法。

百度文库:。

4.1.13. GLR

通用的自左向右。当bison使用LALR1)不能用任的时候,可以选择使用GLR作为分析方法。

4.1.14. 移进/归约

移进(shift),归约(reduction

4.2. flexbison文件格式

不管是flex的词法文件,还是bison的语法文件,格式均为:

。。。定义部分。。。

%%

。。。规则部分。。。

%%

。。。用户子例程部分。。。

4.2.1. 定义部分

flexbison的定义部分都可以包含由“%{”和“%}”括起来的块,这块的内部按照C/C++规则来写,通常会有一些“#include”和一些“extern”声明等。除此之外,还可以包含一些在flexbison章节介绍到的信息。

4.2.2. 规则部分

在规则部分:对于flex,主要是定义“模式”和“模式对应的动作”;对于bison,主要是定义推导规则。在flexbison再分开讲解。

不管是flex还是bison,在规则部分都可以添加注释,但两者方式有不同之处:

1) flex

注释不能顶格写,“/*”前至少要有一个空格或Tab,“*/”可以顶格,还可以与“/*”不在同一行,这段会被照搬到lex.yy.c文件中。

flex的规则部分也可以使用双斜杠“//”注释,但只能使用到规则的开始部分,也就是所有的模式之前才可以使用,否则只能使用“/*。。。*/”注释,并且都不能顶格写。

2) bison

注释可以顶格写,而且可以使用双斜杠“//”,这段不会被搬到.tab.c文件中,而是被忽略掉了。

4.2.3. 用户子例程部分

这部分是按C/C++规则编写的代码或注释等,经flexbison编译后,会被原样搬到相应的.c文件中。

4.3. flex基础

flex是一个快速的词法分析(lexical analysis,或简称scanning)工具。flex通过分析输入流,得到一个个Token,如:“flex and bison”被解析成三个Tokenflexandbison。可以定义不同类型的Toekn,由bison中的“%union”控制。

flex词法文件名一般习惯以“.l”或“.ll”结尾,使用flex编译“.l”或“.ll”文件后,会生成名称为lex.yy.c文件,这是默认时候生成的文件名。

Token实际上为flex规则部分定义的“单词”,只是这个“单词”可能是普通意义上的单词,也可能不是,它可能为普通意义上的短语等。

简单的说,flex的工作就是将输入分解成一个个的Token,并且在分析出一个Token时,可以执行指定的动作,动作以C/C++代码方式表示,也可以没有任何动作。

4.3.1. flex文件格式

定义部分可包含:

1) 选项(总是以%option打头)

2) C/C++代码块,要求使用“%{”和“%}”包含起来

3) 名字定义(类似于C中的宏定义)

4) 开始条件

5) 转换

6) 以空格和Tab开始的行(这些将被原样的搬到lex.yy.c文件中)

%%

词法规则部分包含:

1) 模式行

2) C/C++代码和注释

%%

。。。用户子例程部分。。。

4.3.2. 选项

选项要求顶格写,前面不能有任何空格或Tab,用它来指示flex编译行为的,和GCC的编译选项有些类似,经常用的选项有:

1) %option yylineno

表示定义一个int类型的全局变量yylineno,其值代表当前的行号。

2) %option noyywrap

表示不需要提供int yywrap()函数,否则必须显示的实现yywrap()函数,不然链接时会报找不到yywrap符号错误。

3) %option yywrap

这个是默认的,隐式存在的option

4.3.3. 名字定义

名字定义类似于C语言中的宏定义,目的是方便在词法规则部分引用,格式为:

NAME definition

名字NAME可以包含字母、数字、连字符“-”和下划线,且不能以数字打头。definition为正则表达式。

在词法部分需要引用它时,需要使用花括号“{}括起来,如:{NAME}NAME会在词法规则部分被展开成由一对圆括号括住的该名字的定义,即{NAME}展开成(definition)

 假如有两个名字定义:DIG [0-9]CHR [a-zA-Z],则{DIG}{CHR}等价于([0-9])([a-zA-Z])。

4.3.4. 词法规则

1) 模式行

模式行包含一个模式、一些空白字符、以入模式匹配时执行的C/C++代码,如果C/C++代码超过一条语句或跨越多行,则必须用“{ }”或“%{ %}”包含起来。


2) C/C++代码和注释

这里又包含两种情况:

a. 以空格或Tab打头的行

b. 处于“%{”和“%}”之间的内容


它们都会被原样的搬到yylex()函数中。而位于模式行之前的,则会被搬到yylex()函数的开头。

4.3.5. 匹配规则

flex词法分析器运行时,它根据词法规则部分定义的模式进行匹配,每发现一个匹配(匹配的输入称为记号Token)时,就执行这个模式所关联的C/C++代码。

如果模式后面紧跟一个竖线“|”,而不是C/C++代码,则该模式使用下一个模式相同的C/C++代码。

如果输入字符或字符串无法匹配任何模式,则认为它匹配了代码为ECHO的模式,该记号会被输出。

如果模式后什么也没有,则相当于“{ }”,也就是空动作。

格式

示例

备注

Pattern C-statement

[,]  return ',';

一条语句时,可以不用“{ }

Pattern { C-statement }

{int16}  { yylval.sval = strdup(yytext); return int16; }

超过一条语句必须使用“{ }

Pattern { 

C-statement 

}

{int16}  { 

    yylval.sval = strdup(yytext); 

    return int16; 

}

{”必须和模式处于同一行,其它则无约束

Pattern |

Pattern C-statement

[,]  |

[;]  { printf("%s", yytext); }

相当于:

[,]  { printf("%s", yytext); }

[;]  { printf("%s", yytext); }

Pattern

[,] {}

动作部分为空

Pattern

[,]

相当于:

[,] {}

除了上面列出的外,还可以使用“%{ %}”替代“{ }”。

4.3.6. %option

flex提供了几百个选项,用以控制编译词法分析器的行为。大多数选项可写成“%option name”的形式,如果需要关闭一个选项,只需要将name换成noname即可。flex自带文档中的“Index of Scanner Options”一节列出了所有的选项,也可以访问网址:

下表为部分经常使用到的选项:

选项

作用

%option yylineno

启用内置的全局变量yylineno,该变量记录了行号

%option noyywrap

不使用yywrap()函数

4.3.7. 全局变量yytext

flex使用yytext来存放当前记号,它总是一个字符串类型。

4.3.8. 全局变量yyval

用来保存Token的值,通常为一个union,以支持不同的Token类型,它和yytext紧密联系,但两者是有区别的,通过后面的实例即可看出。

4.3.9. 全局变量yyleng

flex使用yyleng存放yytext的长度,因为yyleng的值和strlen(yytext)相等。

4.3.10. 全局函数yylex

yylex()词法分析的入口函数,通常无参数,它借助全局变量和函数与其它部分交互。bisonyyparse()函数调用yylex()来做词法分析,如果不使用flex,则可自定义一个yylex()函数。

4.3.11. 全局函数yywrap

yywrap()是一个回调函数,由选项来控制是否需要它。当flex词法分析器到达文件尾时,可选择调用yywrap()来决定下一步操作。

如果yywrap()返回0,将继续分析;如果返回1,则返回一个0记号来表示文件结束。如果不使用yywrap(),选项“%option noyywrap”可以用来屏蔽对yywrap()的调用。

当需要处理多个文件时,这个函数就可以派上用场了。

4.4. bison基础

bison是一个语法分析(syntax analysis,或简称为parsing)工具。

bison词法文件名一般习惯以“.y”或“.yy”结尾,使用bison编译“.y”或“.yy”文件后,会生成带后缀“.tab.c”文件。如果带参数“-d”,则还会生成后缀为“.tab.h”的头文件,一般这个头文件供flex词法文件使用,因为其中定义了yyvalToken的编号等。假设bison语法文件名为“x.y”,则使用“bison x.y”编译后,会生成文件x.tab.c;如果使用“bison -d x.y”编译,则会生成x.tab.cx.tab.h两个文件。

简单的说,bison的工作就是推导出Token之间的关系,每推导出一个关系后,都可执行指定的动作,动作以C/C++代码方式表示,也可以没有任何动作。。

4.4.1. bison文件格式

定义部分可包含:

1) C/C++代码块,要求使用“%{”和“%}”包含起来

2) 各种声明,包括:

a) %union

b) %token

c) %type

d) %left

e) %right

f) %nonassoc

%%

。。。语法规则部分。。。

%%

。。。用户子例程部分。。。

4.4.2. %union

如果有不同类型的Token,只需要使用“%union”,假如有整数和字符串两种类型的Token,则:

%union

{

    int text;

    char* ival;

};

经过bison编译后,“%union”会被翻译成C语言的union,如:

typedef union YYSTYPTE {

    int ival;

    char* sval;

} YYSTYPE;

在编译后生成的“.tab.c”文件中,即可看到该union的定义。

4.4.3. %token

定义记号。只有定义后,“bison -d”才会在“.tab.h”文件中定义记号的编号,flex词法文件会用到记号的编号,如果漏定义,则会报找不到编译错误。bison用这些记号的编号做状态跳转。

4.4.4. 全局函数yyerror()

yyerror()是一个回调函数,原型为:

void yyerror(const char* s)


bison语法分析器检测到语法错误时,通过回调yyerror()来报告错误,参数为描述错误的字符串。

4.4.5. 全局函数yyparse()

bison生成的请求分析器的入口函数就是yyparse()。当程序调用yyparse()时,语法分析器将试图分析输入流或指定的Buffer,如果分析成功则返回0,否则返回非0值。和yylex()一样,该函数通常不带任何参数。

4.5. 例1:单词计数

4.5.1. 目的

单词计数的实现只需要用到flex,不需要bison,实现非常简单,适合第一次接触。编程语言喜欢以“Hello World”作为入门,而编译领域喜欢以“单词计数”和“算术表达式”作为入门学习。

4.5.2. flex词法文件wc.l

 // 使用内置的行号全局变量yylineno请注意注释不能顶格写,需以空格或Tab打头

%option yylineno

 // 不使用yywrap()函数

%option noyywrap

%{

// 这个区域是纯粹的C/C++代码(也因此,注释顶格写是可以的)


#include   // 需要用到printf函数


static int num_chars = 0;   // 记录字符个数

static int num_words = 0;  // 记录单词个数


%}


%%

 // 这里是规则定义区间,注释不有顶格写

[a-zA-Z]    { ++ num_chars;  /* 花括号间是C/C++代码域,是模式对应的动作代码 */ }

[a-zA-Z]+   { ++ num_words ; }


%%


int main()

{

    printf("chars: %d, words=%d, lines=%d\n", num_chars, num_words, yylineno);

    return 0;

}

4.5.3. Makefile

wc: wc.l wc.y

        flex wc.l

        g++ -g -o wc lex.yy.c


clean:

        rm -f wc

使用flex编译wc.l后,会生成lex.yy.c文件,wc即是单词计数程序,可以这样使用:

./wc < 被统计的文件,如:./wc < wc.l

4.6. 例2:表达式

4.6.1. 目的

介绍一个可以内嵌到程序中使用的表达式实现。

4.6.2. flex词法exp.l

 // 从这里开始,是词法文件的定义部分,请注意这里的注释不能顶格写

%option noyywrap

%{

#include "exp.tab.h"

#include 

%}


 // 名字定义,类型C语言中的宏定义,number相当于宏名,“[0-9]+”相当于宏的内容

number [0-9]+


%%


{number} { yylval = atoi(yytext); return NUMBER; }

"+"      { return ADD; }

"-"      { return SUB; }

"*"      { return MUL; }

"/"      { return DIV; }

[\n]     { return EOL; }

[ \t]    { }

.        { printf("invalid: %s\n", yytext); }


%%

4.6.3. bison语法exp.y

%{


#include 


extern char* yytext;

extern int yylex(void);

extern void yyerror(const char* s);


%}


%token NUMBER

%left ADD SUB MUL DIV

%token EOL


%%


explist:

        | explist exp EOL

        {

                // $2代表exp的值

                printf("= %d\n", $2);

        }

        ;


// 这里需要考虑优先级问题,加减法的优先级低于乘除法,所以分成两步推导方式

exp: factor

        | exp ADD factor 

        {

                // $$代表“exp: factor”中的exp

                // $1代表“exp ADD factor”中的exp的值

                // $3代表“exp ADD factor”中的factor的值

                // $2代表ADD

                $$ = $1 + $3; 

        }

        | exp SUB factor 

        { 

                $$ = $1 - $3;

        }

        ;


factor: NUMBER

        | factor MUL NUMBER { $$ = $1 * $3; }

        | factor DIV NUMBER { $$ = $1 / $3; }

        ;


%%


void yyerror(const char* s) 

{

        printf("Error: %s: %s\n", s, yytext);

}


int main(int argc, char* argv[])

{

        // yyparse是语法分析函数,它内部会调用yylex()进行词法分析

        yyparse();

        return 0;

}

4.6.4. Makefile

exp: exp.l exp.y

        flex exp.l

        bison -d exp.y

        g++ -g -o exp lex.yy.c exp.tab.c -I.


clean:

        rm -f exp

Make成功后,会在当前目录下生成一个可执行文件exp,然后运行echo "1+1*2" | ./exp即可查看到效果,也可以交互式方式运行./exp。

4.6.5. 代码集成

上述的实现,是从标准输入读入需要计算的表达式,但要嵌入到程序中使用,则需要支持从指定的字符串中读入需要计算的表达式,flex对这个提供了很好的支持,在lex.yy.c中有三个函数可以使用:

YY_BUFFER_STATE yy_scan_buffer (char *base,yy_size_t size  );

YY_BUFFER_STATE yy_scan_string (yyconst char *yy_str  );

YY_BUFFER_STATE yy_scan_bytes (yyconst char *bytes,int len  );

其中YY_BUFFER_STATE实际为:typedef struct yy_buffer_state *YY_BUFFER_STATE;。这个时候,只需要将main函数改成如下实现:

// 请注意,需要加上的声明yy_scan_string,否则会报该函数未声明,

// 除了将声明放在main()函数前外,还可以将声明放在exp.y文件头部。

extern struct yy_buffer_state* yy_scan_string(const char* s);

int main(int argc, char* argv[]) 

{

        // 如果没有带参数,则仍从标准输入stdin读入表达式

        if (argc > 1)

        {

                std::string exp = argv[1];


                // c.y中定义的语法要求以换行符结尾,

                // 如果不想有append这一句,则需要去掉“explist exp EOL”中的“EOL”,

                // 并且不能使用flex选项“%option noyywrap”,这时可显示定义

                // yywrap()函数,并让它返回 1

                exp.append("\n");

                yy_scan_string(exp.c_str());  // 使用exp替代stdin作为输入

        }


        yyparse();

        return 0;

}

通过这个改进,就不难知道,如何实现一个可集成到程序中的表达式解析器了。

4.7. 例3:函数

4.7.1. 目的

介绍如何编译IDL函数,但在这里不会真正去实现一个RPC函数,因为那会让问题变得复杂起来。但有了语法树后,也就有了函数的描述信息,在此基础上实现RPC函数就有眉目了。

4.7.2. func.h

// 这里定义了语法树,

// 这里语法树只有三个结点:

// 1) 根结点g_func_set

// 2) 第一级子结点Function

// 3) 第二级子结点Parameter,第二级子结点可能为空,因为函数不一定要有参数

#ifndef _FUNC_H

#define _FUNC_H


#include 

#include 

#include 

#include 

using std::string;

using std::vector;


struct Parameter  // 函数参数定义

{

        string name; // 函数参数的名称

        string type; // 函数参数的类型

        void clear() // 重置,以便用于下一个参数

        {

                name.clear();

                type.clear();

        }

};


struct Function  // 函数定义,根据它就可以将IDL中定义的函数翻译成不同的语言版本

{

        string name; // 函数名

        string type; // 函数的返回类型

        vector params; // 函数的参数列表

        void clear() // 重置,以便用于下一个函数

        {

                name.clear();

                type.clear();

                params.clear();

        }

};


extern vector g_func_set; // 根结点,保存所有的函数


#endif // _FUNC_H

4.7.3. func.c

#include "func.h"

#include 

using std::cout;

using std::endl;


vector g_func_set;


extern int yyparse(); // 实现在x.tab.c文件中

int main(int argc, char* argv[])

{

        yyparse(); // 调用语法分析函数,它内部会调用词法分析函数yylex()


        // 遍历所有的函数,

        // g_func_set.size()的值为函数的个数

        for (vector::size_type i=0; i

        {

                const Function& func = g_func_set[i];

                cout << "function name: " << func.name << endl; // 输出函数名

                cout << "return type: " << func.type << endl; // 输出函数返回类型


                cout << "parameters:" << endl; // 提示输出参数信息

                if (func.params.empty())

                {

                        cout << "\tempty" << endl; // 如果函数没有参数,则输入empty

                }

                else

                {

                        // 遍历函数的所有参数

                        for (vector::size_type j=0; j

                        {

                                const Parameter& param = func.params[j];

                                cout << "\tname: " << param.name << ", type: " << param.type << endl;

                        }

                }

                cout << endl;

        }


        return 0;

}

4.7.4. IDL代码func.idl

int32 foo();

int16 zoo(int16 zz);

int16 zoo(int16 zz, int32 yy);


请注意:为了简化词法和语法,不支持注释等,仅支持不带引用和指针类型参数、返回值的函数,否则会增加词法和语法的复杂度,不利于初次学习。当你掌握之后,可尝试加入注释等。当然仍可以在idl写入其它的内容,但会报编译错误。

4.7.5. flex词法func.l

 // 从这里开始,是词法文件的定义部分,请注意这里的注释不能顶格写

%option yylineno

%{

// 这区间完全是C/C++代码,所以按照C/C++风格来写即可,

// flex编译后,会被搬到lex.yy.c文件中


#include "func.h" // 要用到func.h中定义的g_lineno

#include "func.tab.h" // 要用到func.tab.h中定义的tokenyylval


%}


 /* 名字定义,有点类似于C语言中的宏,但在使用的时候需要使用花括号“{}”括起来,

    如:chars类似于宏名,[a-zA-Z]类似于宏的值

 */

chars            [a-zA-Z]

number          [0-9]

int16            (int16)

int32            (int32)

xname           ({chars})+(\_|{chars}|{number})*


 // 从这里开始,是词法的文件的规则部分

%%

 // 模式和该模式的动作,动作为C/C++代码

 // 在这里使用了前面定义的名字,注意要用花括号“{}”括起来

 // 返回的Token值,要求在func.y文件中定义,或自己显示的定义出来。

 // 动作部分为花括号{}括起来的C/C++代码,因此可以使用C/C++规则。

{int16}            { yylval.sval = strdup(yytext); return int16; }

{int32}            { yylval.sval = strdup(yytext); return int32; }

{xname}           { yylval.sval = strdup(yytext); return xname; }


[\(]    { return '('; }

[\)]    { return ')'; }

[,]     { return ','; }

[;]     { return ';'; }

[\t]     { /* 什么也不做,花括号都可以省掉,如下就省掉了花括号 */ }

[ ]

[\n]

.      { return ERROR;  /* 非法字符 */ }


 /* 从这里开始,是词法的文件的用户子例程部分(这里不能用双斜杠注释) */

%%

// 从这开始,又是全C/C++代码区间了,将完全被搬到func.tab.c文件的最尾部,

// 包括这个注释


int yywrap() // 这个函数非必须的,可以使用%option noyywrap表示不用

{

        return 1;

}

4.7.6. bison语法func.y

%{

// 这区间完全是C/C++代码,所以按照C/C++风格来写即可,

// 这个区间内的代码,会原原本本搬到func.tab.c文件的顶部(但不是最顶部)


#include "func.h"

#include 

#include 


extern int yylineno;    // flex编译func.l后,定义在lex.yy.c

extern char* yytext; // 在编译func.l后生成的lex.yy.c中定义

extern void yyerror(const char *s); // 下面的代码将使用到,所以需要事先声明一下

extern int yylex(void); // 在编译func.l后生成的lex.yy.c中定义,用来做词法分析


static string g_type; // 用来存储当前正解析到的函数返回类型或参数类型

static struct Parameter s_param; // 用来存储当前正解析到的参数信息

static struct Function s_func; // 用来存储当前正解析到的函数信息


%}


// Token存在不同类型时,%union就可派上用场了

// 使用bison编译后,会变成:

// typedef union YYSTYPE {

//     int ival;

//     char* sval;

// } YYSTYPE;

// 此外,还会定义全局变量yylval

// extern YYSTYPE yylval;

// 这样,在flex文件(本例为func.l)即可使用yylval了。

%union

{

        int ival; // 存储整数类型的Token

        char* sval; // 存储字符串类型的Token,本示例只有它,无整数类型的Token

};


// 所有的Token,都必须在这里声明

// 并且在bison编译后,会变成:

// #ifndef YYTOKENTYPE

// # define YYTOKENTYPE

// enum yytokentype {

//     int16 = 258,

//     int32 = 259,

//     xname = 260,

//     ERROR = 261

// };

// #endif

// Token的值总是从258开始,以避免与abc等字符值产生冲突。

// 同时,还会定义等值的宏:

// #define int16 258

// #define int32 259

// #define xname 260

// #define ERROR 261

%token  int16

%token  int32

%token  xname // 函数名、参数名等,如果规则不一样,可取不同name

%token  ERROR // 其它的非法输入


%%

// 函数集,用以支持多个函数,但是也可以只有一个函数,所以有两个规则

function_set: function_prototype

        | function_set function_prototype

        ;


// 函数原型,函数可以带参数,也可以无参数,

// 花括号{}内的是C/C++代码,因此适用C/C++规则。

function_prototype:  return_type xname '(' ')' ';'

        {

                // 无参数

                s_func.name = $2; // 保存函数名

                g_func_set.push_back(s_func); // 当前函数完整了

                s_func.clear(); // 以便s_func.用于下一个函数

        }

        | return_type xname '(' parameter_list ')' ';'

        {

                // 有参数

                s_func.name = $2;

                g_func_set.push_back(s_func);

                s_func.clear();

        }

        ;


// 可以只有一个参数,也可以是多个参数

parameter_list: parameter_define

        | parameter_list ',' parameter_define

        ;


// 参数的定义

parameter_define: parameter_type xname

        {

                s_param.name = $2;

                s_func.params.push_back(s_param);

                s_param.clear();

        }

        ;


// 参数类型

parameter_type: data_type

        {

                // 记下参数类型

                s_param.type = g_type;

        }

        ;


// 函数返回值类型

return_type: data_type

        {

                // 记下函数返回类型

                s_func.type = g_type;

        }

        ;


// 支持的基本数据类型,可自行扩展

// 需要分成parameter_typereturn_type两个是因为需要给s_params_func区开赋值

data_type: int16 { g_type = $1; }

        | int32 

        {

                // 类型的名称用g_type存储起来

                g_type = $1;

        }

        ;


%%

// 从这开始,又是全C/C++代码区间了,将完全被搬到func.tab.c文件的最尾部,

// 包括这个注释


// 遇到错误就在屏幕上打印出来

void yyerror(const char* s) 

{

        printf("Error(%d): %s: %s\n", yylineno, s, yytext);

}


4.7.7. Makefile

func: func.l func.y func.h func.c

        flex func.l # 编译词法文件

        bison -d func.y # 编译语法文件,这里将会产生func.tab.hfunc.tab.c两个文件

        g++ -g -o func lex.yy.c func.tab.c func.c -I.    # 生成IDL编译器func


clean:

        rm -f func

Make成功后,会在当前目录下生成一个可执行文件func,然后运行./func < func.idl即可查看到效果。

5. 进阶

掌握以上基础后,就具备了实现RPC的能力。在上一节中的“函数”实现过去简单,还不能直观的理解RPC函数是如何调用和被调用的,这一节就要解决这个问题。为了降低复杂度,这里采用伪代码方式。

从前面的讲解可以知道,RPC函数的实现是分客户端和服务端的,这里的就分别讲解它们是如何实现的。

5.1. 客户端函数实现

客户端函数完全由IDL编译器实现,用伪代码表示,实现如下:

void Proxy::foo(Callback* cb_func, int m, int n)

{

string  bytes_stream;


encode(&bytes_stream, "foo");  // 将函数名编码到字符流

encode(&bytes_stream, m);     // 将参数m编码到字符流

encode(&bytes_stream, n);     // 将参数n编码到字符流


// RPC因网络超时或网络故障失败时,异步回调cb_func;

// 或者RPC请求收到响应时,异步回调cb_func,

// 实际中也可以同步调用,但性能低

// RpcSession应当是基于Socket的,它能容忍网络连接断开,执行自动重连重试,

// 它需要维护一个RPC调用的状态和上下文关系。

RpcSession session = get_rcp_session(cb_func);

// 通过send将编码后的字节流发送到服务端

session->send(bytes_stream.data(), bytes_stream.size());

}

从上面的实现可以看出,要求RPC函数的参数必须是可编码类型的,否则无法将它序列化到字节流中,返回类型同样要求是可编码的。如果不想自己实现一套编解码函数,可以直接使用ProtoBuf来做这件事。

5.2. 服务端函数实现

服务端函数的实现需要分成两部分:一是Stub部分的实现,另一部分是用户代码自己的实现。

5.2.1. Stub部分实现

NetThread表示网络线程,用于接收网络数据。

void NetThread::run()

{

while (true)

{

    string  bytes_stream;

    socket->receive(bytes_stream, nums_bytes);


    // 下面这部分代码都是IDL编译器依据IDL文件生成的

    string func_name;

    decode(&bytes_stream, &func_name);  // 解码出函数名


    // 根据不同函数名做不同调用

    switch (func_name)

    {

        case foo:

        {

            typedef void (*FOO)(int, int);

            FOO  foo = (FOO)map[func_name];


            int m = 0;

            int n = 0;

            decode(&bytes_stream, &m);  // 解码出参数m

            decode(&bytes_stream, &n);  // 解码出参数n

            (*foo)(m, n);  // 调用服务端的foo()实现

            break;

        }

        case woo:

        {

            。。。。

        }

    }

}

}

从实现的效率出发,一般不直接对函数名编码,而是对函数编号,这样一个下标即可确定是对哪个函数的调用,性能会高出很多。

5.2.2. 用户部分实现

void Server::foo(int m, int n)

{

    // Do something or response

}

这部分代码是由用户实现的,而非IDL编译器生成,如果只是C代码,则可采用函数指针方式,如果是C++代码,则可以使用接口。

6. 参考资料

《百度百科及其它网上资料》

《flexbison》/(美)John Levine著;陆军译;东南大学出版社出版

《编译原理第2版》/(美)Alfred V.Aho Monica S.Lam Ravi Sethi Jeffrey D.Ullman著;

                   赵建华 郑滔 戴新宇 译

                   机械工业出版社出版




阅读(926) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~