Linux编程之从零开始搭建RPC分布式系统

我一毕业进公司就接触到了RPC，主要是使用前辈们搭建好的RPC框架以及封装好的RPC函数进行业务开发，虽说使用RPC框架开发已经近半年了，但一直想知道如何从零开始搭建起这么一个好用的分布式通信系统框架，近日心血来潮，虽说没人教怎么搭建，但自己在网上查阅了大量资料后，开始自己一手一脚从零搭建这么一个RPC框架，所以就有了以下这篇文章，以记录我的搭建过程。

首先对RPC做一个简要介绍。

RPC的全称是Remote Procedure Call，它能够在本地以函数调用的形式来实现网络操作，让程序员集中关注于业务逻辑，不用关心底层的数据通信。

网络通信的应用程序大多数是使用显式网络编程（explicit network programming）的方式编写的，比如我们所熟悉的socket编程。客户端调用socket、connect、read和write，服务器则调用socket、bind、listen等函数。我们熟悉的大多数应用程序（Web浏览器、Web服务器、Telnet客户、Telnet服务器等程序）就是以这种方式编写的。

编写分布式应用程序的另一种方法就是使用隐式网络编程（implicit network programming）。远程过程调用（RPC）提供了这么一个工具。使用隐式网络编程的好处就是，程序员不需要把把大量精力放在网络通信程序的编写上，因为这一块工作已经有RPC框架帮你实现了，所以程序员可以把更多精力放在业务逻辑的开发上去。

这里就不对RPC做进一步详细的理论性解析，这篇文章主要讲述RPC的实践，我们将一步一步搭建起一个基于RPC的完整的分布式通信系统框架。本文分为两个部分，第一部分讲述如何利用rpcgen工具搭建起来RPC通用骨架，第二部分我们就使用该骨架进行进一步完善，增加相应的处理函数，把血肉补充完全，做一个简单的分布式计算系统demo。

一、使用rpcgen工具生成RPC底层骨架

1.生成my.x文件，然后在该文件编写以下程序

首先创建文件夹rpc（mkdir rpc），以后的所有文件都放在这个文件夹下。

创建my.x文件(my为文件名，.x为后缀)：vi my.x

在my.x填入下面代码：

#define MY_RPC_PROG_NUM         0x38000010   //程序号

struct my_io_data_s        //定义消息结构
{
    int mtype;
    int len;
    char data[];
};

typedef struct my_io_data_s my_io_data_t;

program MY_RPC_PROG { 

    version MY_RPC_VERS1 {
        int MY_RPCC(my_io_data_t) = ;    /* 过程号 = 1 */
    } = ;        /* Version number = 1 */

    version MY_RPC_VERS2 {
        my_io_data_t MY_RPCC(my_io_data_t) = ;    /* 过称号 = 1 */
    } = ;        /* Version number = 2 */

} = MY_RPC_PROG_NUM;    /* Program number */

这里我创建了两个版本，version1和version2,版本的数量是可以自己定制的，如果你需要一个的话定义一个即可。因为我打算定义一个版本用于SET的操作，一个用于GET操作，所以定义了两个版本。

上面使用了RPC语言，我对以上几个特殊名词做一下解释。

每个RPC过程由程序号、版本号和过程号来唯一确定。

RPC版本号：程序号标志一组相关的远程过程，程序号的是有范围的，我们需要在范围内填写程序号。

程序号范围	简述
0x00000000 - 0x1FFFFFFF	由Sun公司定义，提供特定服务
0x20000000 - 0x3FFFFFFF	由程序员自己定义，提供本地服务或用于调试
0x40000000 - 0x5FFFFFFF	用于短时间使用的程序，例如回调程序
0x60000000 - 0xFFFFFFFF	保留程序号

这里我们使用的范围当然是0x20000000 - 0x3FFFFFFF，我填的是0x38000010。

版本号：在version的大括号里我们定义两个我们将要使用的RPC调用函数的类型，比如：

version 1：我们定义了int MY_RPCC(my_io_data_t)，这表明我们以后PRC框架使用的RPC调用函数的函数类型那个将会是：int * my_rpcc_1(my_io_data_t *argp, CLIENT *clnt)

version 2：my_io_data_t MY_RPCC(my_io_data_t) 则会变成 my_io_data_t * my_rpcc_2(my_io_data_t *argp, CLIENT *clnt)

所以我们可以根据我们需要的类型模仿编写即可。

2.使用rpcgen指令生成以下几个文件

使用rpcgen my.x生成系列文件（可以加参数-C,表示使用ANSI C）

执行该指令后，文件夹下将出现以下几个文件。

my.h:

/*
 * Please do not edit this file.
 * It was generated using rpcgen.
 */

#ifndef _MY_H_RPCGEN
#define _MY_H_RPCGEN

#include <rpc/rpc.h>

#ifdef __cplusplus
extern "C" {
#endif

struct my_io_data_s {
    int mtype;
    int len;
    char data[];
};
typedef struct my_io_data_s my_io_data_s;

typedef my_io_data_s my_io_data_t;

#define MY_RPC_PROG 666
#define MY_RPC_VERS1 1

#if defined(__STDC__) || defined(__cplusplus)
#define MY_RPCC 1
extern  int * my_rpcc_1(my_io_data_t *, CLIENT *);
extern  int * my_rpcc_1_svc(my_io_data_t *, struct svc_req *);
extern int my_rpc_prog_1_freeresult (SVCXPRT *, xdrproc_t, caddr_t);

#else /* K&R C */
#define MY_RPCC 1
extern  int * my_rpcc_1();
extern  int * my_rpcc_1_svc();
extern int my_rpc_prog_1_freeresult ();
#endif /* K&R C */
#define MY_RPC_VERS2 2

#if defined(__STDC__) || defined(__cplusplus)
extern  my_io_data_t * my_rpcc_2(my_io_data_t *, CLIENT *);
extern  my_io_data_t * my_rpcc_2_svc(my_io_data_t *, struct svc_req *);
extern int my_rpc_prog_2_freeresult (SVCXPRT *, xdrproc_t, caddr_t);

#else /* K&R C */
extern  my_io_data_t * my_rpcc_2();
extern  my_io_data_t * my_rpcc_2_svc();
extern int my_rpc_prog_2_freeresult ();
#endif /* K&R C */

/* the xdr functions */

#if defined(__STDC__) || defined(__cplusplus)
extern  bool_t xdr_my_io_data_s (XDR *, my_io_data_s*);
extern  bool_t xdr_my_io_data_t (XDR *, my_io_data_t*);

#else /* K&R C */
extern bool_t xdr_my_io_data_s ();
extern bool_t xdr_my_io_data_t ();

#endif /* K&R C */

#ifdef __cplusplus
}
#endif

#endif /* !_MY_H_RPCGEN */

my_clnt.c:

/*
 * Please do not edit this file.
 * It was generated using rpcgen.
 */

#include <memory.h> /* for memset */
#include "my.h"

/* Default timeout can be changed using clnt_control() */
static struct timeval TIMEOUT = { ,  };

int *
my_rpcc_1(my_io_data_t *argp, CLIENT *clnt)
{
    static int clnt_res;

    memset((char *)&clnt_res, , sizeof(clnt_res));
    if (clnt_call (clnt, MY_RPCC,
        (xdrproc_t) xdr_my_io_data_t, (caddr_t) argp,
        (xdrproc_t) xdr_int, (caddr_t) &clnt_res,
        TIMEOUT) != RPC_SUCCESS) {
        return (NULL);
    }
    return (&clnt_res);
}

my_io_data_t *
my_rpcc_2(my_io_data_t *argp, CLIENT *clnt)
{
    static my_io_data_t clnt_res;

    memset((char *)&clnt_res, , sizeof(clnt_res));
    if (clnt_call (clnt, MY_RPCC,
        (xdrproc_t) xdr_my_io_data_t, (caddr_t) argp,
        (xdrproc_t) xdr_my_io_data_t, (caddr_t) &clnt_res,
        TIMEOUT) != RPC_SUCCESS) {
        return (NULL);
    }
    return (&clnt_res);
}

my_svc.c

/*
 * Please do not edit this file.
 * It was generated using rpcgen.
 */

#include "my.h"
#include <stdio.h>
#include <stdlib.h>
#include <rpc/pmap_clnt.h>
#include <string.h>
#include <memory.h>
#include <sys/socket.h>
#include <netinet/in.h>

#ifndef SIG_PF
#define SIG_PF void(*)(int)
#endif

static void
my_rpc_prog_1(struct svc_req *rqstp, register SVCXPRT *transp)
{
    union {
        my_io_data_t my_rpcc_1_arg;
    } argument;
    char *result;
    xdrproc_t _xdr_argument, _xdr_result;
    char *(*local)(char *, struct svc_req *);

    switch (rqstp->rq_proc) {
    case NULLPROC:
        (void) svc_sendreply (transp, (xdrproc_t) xdr_void, (char *)NULL);
        return;

    case MY_RPCC:
        _xdr_argument = (xdrproc_t) xdr_my_io_data_t;
        _xdr_result = (xdrproc_t) xdr_int;
        local = (char *(*)(char *, struct svc_req *)) my_rpcc_1_svc;
        break;

    default:
        svcerr_noproc (transp);
        return;
    }
    memset ((char *)&argument, , sizeof (argument));
    if (!svc_getargs (transp, (xdrproc_t) _xdr_argument, (caddr_t) &argument)) {
        svcerr_decode (transp);
        return;
    }
    result = (*local)((char *)&argument, rqstp);
    if (result != NULL && !svc_sendreply(transp, (xdrproc_t) _xdr_result, result)) {
        svcerr_systemerr (transp);
    }
    if (!svc_freeargs (transp, (xdrproc_t) _xdr_argument, (caddr_t) &argument)) {
        fprintf (stderr, "%s", "unable to free arguments");
        exit ();
    }
    return;
}

static void
my_rpc_prog_2(struct svc_req *rqstp, register SVCXPRT *transp)
{
    union {
        my_io_data_t my_rpcc_2_arg;
    } argument;
    char *result;
    xdrproc_t _xdr_argument, _xdr_result;
    char *(*local)(char *, struct svc_req *);

    switch (rqstp->rq_proc) {
    case NULLPROC:
        (void) svc_sendreply (transp, (xdrproc_t) xdr_void, (char *)NULL);
        return;

    case MY_RPCC:
        _xdr_argument = (xdrproc_t) xdr_my_io_data_t;
        _xdr_result = (xdrproc_t) xdr_my_io_data_t;
        local = (char *(*)(char *, struct svc_req *)) my_rpcc_2_svc;
        break;

    default:
        svcerr_noproc (transp);
        return;
    }
    memset ((char *)&argument, , sizeof (argument));
    if (!svc_getargs (transp, (xdrproc_t) _xdr_argument, (caddr_t) &argument)) {
        svcerr_decode (transp);
        return;
    }
    result = (*local)((char *)&argument, rqstp);
    if (result != NULL && !svc_sendreply(transp, (xdrproc_t) _xdr_result, result)) {
        svcerr_systemerr (transp);
    }
    if (!svc_freeargs (transp, (xdrproc_t) _xdr_argument, (caddr_t) &argument)) {
        fprintf (stderr, "%s", "unable to free arguments");
        exit ();
    }
    return;
}

int
main (int argc, char **argv)
{
    register SVCXPRT *transp;

    pmap_unset (MY_RPC_PROG, MY_RPC_VERS1);
    pmap_unset (MY_RPC_PROG, MY_RPC_VERS2);

    transp = svcudp_create(RPC_ANYSOCK);
    if (transp == NULL) {
        fprintf (stderr, "%s", "cannot create udp service.");
        exit();
    }
    if (!svc_register(transp, MY_RPC_PROG, MY_RPC_VERS1, my_rpc_prog_1, IPPROTO_UDP)) {
        fprintf (stderr, "%s", "unable to register (MY_RPC_PROG, MY_RPC_VERS1, udp).");
        exit();
    }
    if (!svc_register(transp, MY_RPC_PROG, MY_RPC_VERS2, my_rpc_prog_2, IPPROTO_UDP)) {
        fprintf (stderr, "%s", "unable to register (MY_RPC_PROG, MY_RPC_VERS2, udp).");
        exit();
    }

    transp = svctcp_create(RPC_ANYSOCK, , );
    if (transp == NULL) {
        fprintf (stderr, "%s", "cannot create tcp service.");
        exit();
    }
    if (!svc_register(transp, MY_RPC_PROG, MY_RPC_VERS1, my_rpc_prog_1, IPPROTO_TCP)) {
        fprintf (stderr, "%s", "unable to register (MY_RPC_PROG, MY_RPC_VERS1, tcp).");
        exit();
    }
    if (!svc_register(transp, MY_RPC_PROG, MY_RPC_VERS2, my_rpc_prog_2, IPPROTO_TCP)) {
        fprintf (stderr, "%s", "unable to register (MY_RPC_PROG, MY_RPC_VERS2, tcp).");
        exit();
    }

    svc_run ();
    fprintf (stderr, "%s", "svc_run returned");
    exit ();
    /* NOTREACHED */
}

my_xdr.c

/*
 * Please do not edit this file.
 * It was generated using rpcgen.
 */

#include "my.h"

bool_t
xdr_my_io_data_s (XDR *xdrs, my_io_data_s *objp)
{
    register int32_t *buf;

    int i;
     if (!xdr_int (xdrs, &objp->mtype))
         return FALSE;
     if (!xdr_int (xdrs, &objp->len))
         return FALSE;
     if (!xdr_vector (xdrs, (char *)objp->data, ,
        sizeof (char), (xdrproc_t) xdr_char))
         return FALSE;
    return TRUE;
}

bool_t
xdr_my_io_data_t (XDR *xdrs, my_io_data_t *objp)
{
    register int32_t *buf;

     if (!xdr_my_io_data_s (xdrs, objp))
         return FALSE;
    return TRUE;
}

3.rpcgen -Sc -o my_client.c my.x 生成my_client.c

使用该指令后我们就生成了客户端.c文件，这个文件很重要，因为以后我们做业务开发就在这里做，我们的调用都会从这里开始。

 my_client.c：

/*
 * This is sample code generated by rpcgen.
 * These are only templates and you can use them
 * as a guideline for developing your own functions.
 */

#include "my.h"

void
my_rpc_prog_1(char *host)
{
    CLIENT *clnt;
    int  *result_1;
    my_io_data_t  my_rpcc_1_arg;

#ifndef    DEBUG
    clnt = clnt_create (host, MY_RPC_PROG, MY_RPC_VERS1, "udp");
    if (clnt == NULL) {
        clnt_pcreateerror (host);
        exit ();
    }
#endif    /* DEBUG */

    result_1 = my_rpcc_1(&my_rpcc_1_arg, clnt);
    if (result_1 == (int *) NULL) {
        clnt_perror (clnt, "call failed");
    }
#ifndef    DEBUG
    clnt_destroy (clnt);
#endif     /* DEBUG */
}

void
my_rpc_prog_2(char *host)
{
    CLIENT *clnt;
    my_io_data_t  *result_1;
    my_io_data_t  my_rpcc_2_arg;

#ifndef    DEBUG
    clnt = clnt_create (host, MY_RPC_PROG, MY_RPC_VERS2, "udp");
    if (clnt == NULL) {
        clnt_pcreateerror (host);
        exit ();
    }
#endif    /* DEBUG */

    result_1 = my_rpcc_2(&my_rpcc_2_arg, clnt);
    if (result_1 == (my_io_data_t *) NULL) {
        clnt_perror (clnt, "call failed");
    }
#ifndef    DEBUG
    clnt_destroy (clnt);
#endif     /* DEBUG */
}

int
main (int argc, char *argv[])
{
    char *host;

    if (argc < ) {
        printf ("usage: %s server_host\n", argv[]);
        exit ();
    }
    host = argv[];
    my_rpc_prog_1 (host);
    my_rpc_prog_2 (host);
exit ();
}

现在我们就可以在该文件编写客户端的代码了。

5.rpcgen -Ss -o my_server.c my.x生成文件my_server.c

使用该指令后我们就生成了服务器.c文件，这个文件很重要，因为以后我们做业务开发就在这里做，我们将在这里编写处理客户端请求的代码。

my_server.c:

/*
 * This is sample code generated by rpcgen.
 * These are only templates and you can use them
 * as a guideline for developing your own functions.
 */

#include "my.h"

int *
my_rpcc_1_svc(my_io_data_t *argp, struct svc_req *rqstp)
{
    static int  result;

    /*
     * insert server code here
     */

    return &result;
}

my_io_data_t *
my_rpcc_2_svc(my_io_data_t *argp, struct svc_req *rqstp)
{
    static my_io_data_t  result;

    /*
     * insert server code here
     */

    return &result;
}

6.在my_server.c和my_client.c添加测试代码

所有利用rpcgen生成的文件都已经生成完毕，接下来我们需要添加测试代码来验证该RPC骨架是否正常工作。

my_client.c：

/*
 * This is sample code generated by rpcgen.
 * These are only templates and you can use them
 * as a guideline for developing your own functions.
 */

#include "my.h"

void
my_rpc_prog_1(char *host)
{
    CLIENT *clnt;
    int  *result_1;
    my_io_data_t  my_rpcc_1_arg;

#ifndef    DEBUG
    clnt = clnt_create (host, MY_RPC_PROG, MY_RPC_VERS1, "udp");
    if (clnt == NULL) {
        clnt_pcreateerror (host);
        exit ();
    }
#endif    /* DEBUG */

    result_1 = my_rpcc_1(&my_rpcc_1_arg, clnt);
    if (result_1 == (int *) NULL) {
        clnt_perror (clnt, "call failed");
    }
#ifndef    DEBUG
    clnt_destroy (clnt);
#endif     /* DEBUG */
}

void
my_rpc_prog_2(char *host)
{
    CLIENT *clnt;
    my_io_data_t  *result_1;
    my_io_data_t  my_rpcc_2_arg;

#ifndef    DEBUG
    clnt = clnt_create (host, MY_RPC_PROG, MY_RPC_VERS2, "udp");
    if (clnt == NULL) {
        clnt_pcreateerror (host);
        exit ();
    }
#endif    /* DEBUG */
    my_rpcc_2_arg.mtype = ;
    my_rpcc_2_arg.len = ;
    result_1 = my_rpcc_2(&my_rpcc_2_arg, clnt);
    if (result_1 == (my_io_data_t *) NULL) {
        clnt_perror (clnt, "call failed");
    }
    fprintf(stderr,"recv msg from server! mtype:%d  len:%d \n",result_1->mtype,result_1->len);
#ifndef    DEBUG
    clnt_destroy (clnt);
#endif     /* DEBUG */
}

int
main (int argc, char *argv[])
{
    char *host;

    if (argc < ) {
        printf ("usage: %s server_host\n", argv[]);
        exit ();
    }
    host = argv[];
    //my_rpc_prog_1 (host);
    my_rpc_prog_2 (host);
exit ();
}

值得注意的是，我们client使用的是UDP协议，当然我们用户也可以根据自己需要选用TCP协议进行开发。

my_server.c

/*
 * This is sample code generated by rpcgen.
 * These are only templates and you can use them
 * as a guideline for developing your own functions.
 */

#include "my.h"

int *
my_rpcc_1_svc(my_io_data_t *argp, struct svc_req *rqstp)
{
    static int  result;

    /*
     * insert server code here
     */
    return &result;
}

my_io_data_t *
my_rpcc_2_svc(my_io_data_t *argp, struct svc_req *rqstp)
{
    static my_io_data_t  result;

    /*
     * insert server code here
     */
    printf("recv msg from client! len:%d, mt:%d \n",argp->len,argp->mtype);
    result.mtype = ;
    result.len = ;
    return &result;
}

7.测试现象

编译这client和server

gcc -o client my_clnt.c my_client.c my_xdr.c

gcc -o server my_svc.c my_server.c my_xdr.c

我在主机172.0.5.183运行server程序，在172.0.5.183运行client程序，测试现象如下：

server端

client端

以上测试已经证明了我们创建的RPC是可以正常通信的，那我们继续在此框架下完善代码，构建出可供业务开发的分布式系统的系统框架。

二、完善分布式系统的系统框架

以上的通信骨架过于简单了，那我们就动动手加点代码，设计一个简单的分布式计算系统。这个所谓的分布式计算系统很简单，就是我们一个客户端向一个服务器端提出计算请求，服务器端将计算得出的结果返回给客户端。

本次程序是基于本文第一部分的骨架搭建的，大多数文件不需要修改，需要修改的文件如下：
my_client、my_server.c、my_clnt.c、my.h

新增加一个文件：rpc_msg.h

首先我们重新定义一下客户端和服务器端通信消息的格式。

typedef struct my_msg_hdr_s
{
    int mtype;
    int len;
}my_msg_hdr_t;

typedef struct my_msg_s
{
    my_msg_hdr_t msg_hdr;
    int para1;
    int para2;
    int result;
}my_msg_t;

然后我们先改变一下我们的客户端程序，

my_rpc_prog_1主要负责服务器的设置，比如在该程序里，此函数就用于设置服务器的开关，所以这个函数只需要把消息发给服务器端就可以了，不需要服务器返回数据给它，所以使用了int的返回值。

而my_rpc_prog_2则需要给它返回数据结果的，所以该函数使用了my_io_data_t *作返回值。

my_client.c

/*
 * This is sample code generated by rpcgen.
 * These are only templates and you can use them
 * as a guideline for developing your own functions.
 */

#include "my.h"
#include "rpc_msg.h"

int my_rpc_prog_1(char *host, my_io_data_t* in_msg)
{
    CLIENT *clnt;
    int  *result_1;

#ifndef    DEBUG
    clnt = clnt_create (host, MY_RPC_PROG, MY_RPC_VERS1, "udp");
    if (clnt == NULL)
    {
        printf("Fail to create rpc client1!\n");
        return -;
    }
#endif    /* DEBUG */

    result_1 = my_rpcc_1(in_msg, clnt);
    if (result_1 == (int *) NULL)
    {
        clnt_perror (clnt, "call failed");
        return -;
    }

    return ;

}

my_io_data_t * my_rpc_prog_2(char *host, my_io_data_t* in_msg)
{
    CLIENT *clnt;
    my_io_data_t  *result_1 = NULL;

#ifndef    DEBUG
    clnt = clnt_create (host, MY_RPC_PROG, MY_RPC_VERS2, "udp");
    if (clnt == NULL)
    {
        printf("Fail to create rpc client1!\n");
        return NULL;
    }
#endif    /* DEBUG */

    result_1 = my_rpcc_2(in_msg, clnt);
    if (result_1 == (my_io_data_t *) NULL)
    {
        clnt_perror (clnt, "call failed");
        return NULL;
    }

    return result_1;

}

void get_compute_result(char *host, int type, int para1, int para2)
{
    my_io_data_t in_msg;
    my_msg_t* rsp;
    my_io_data_t* out_msg;
    my_msg_t* req = (my_msg_t*)&in_msg;

    memset(&in_msg, , sizeof(in_msg));
    req->msg_hdr.mtype = type;
    req->msg_hdr.len = sizeof(in_msg) - sizeof(my_msg_hdr_t);
    req->para1 = para1;
    req->para2 = para2;

    out_msg = my_rpc_prog_2(host, &in_msg);

    rsp = (my_msg_t*)out_msg;

    if(rsp == NULL)
    {
        printf("RPC call fail!\n");
        return;
    }

    printf("compute result is %d\n",rsp->result);

}

void server_switch(char *host, int type)
{
    my_io_data_t msg;
    my_msg_t* in_msg = (my_msg_t*)&msg;
    memset(&msg, , sizeof(msg));
    in_msg->msg_hdr.mtype = type;
    in_msg->msg_hdr.len = sizeof(msg) - sizeof(my_msg_hdr_t);

    if(my_rpc_prog_1(host, &msg))
    {
        printf("enable server fail!\n");
    }
    printf("Configure server successfully!\n");
}

int main (int argc, char *argv[])
{
    server_switch(SERVER_IP, RPC_enable); //server start
    sleep();
    get_compute_result(SERVER_IP, RPC_ADD, , );
    sleep();
    get_compute_result(SERVER_IP, RPC_SUB, , );
    sleep();
    get_compute_result(SERVER_IP, RPC_MUL, , );
    sleep();
    get_compute_result(SERVER_IP, RPC_DIV, , );
    sleep();
    server_switch(SERVER_IP, RPC_disable); //server close
    return ;
}

当然改了以上的两个函数，我们当然也需要在my_clnt.c和my.h作出函数声明的修改。

现在看看server端怎么处理这些请求的。

my_server.c

/*
 * This is sample code generated by rpcgen.
 * These are only templates and you can use them
 * as a guideline for developing your own functions.
 */

#include "my.h"
#include "rpc_msg.h"

int* my_rpcc_1_svc(my_io_data_t *argp, struct svc_req *rqstp)
{
    static int  result;

    switch(argp->mtype)
    {
        case RPC_enable:
        printf("server start!\n");
        break;

        case RPC_disable:
        printf("server close!\n");
        break;

        default:
        break;
    }

    return &result;
}

my_io_data_t* my_rpcc_2_svc(my_io_data_t *argp, struct svc_req *rqstp)
{
    static my_io_data_t  result;
    my_msg_t* out = (my_msg_t*)&result;
    my_msg_t* in = (my_msg_t*)argp;

    switch(in->msg_hdr.mtype)
    {
        case RPC_ADD:
        out->result = in->para1 + in->para2;
        break;

        case RPC_SUB:
        out->result = in->para1 - in->para2;
        break;

        case RPC_MUL:
        out->result = in->para1 * in->para2;
        break;

        case RPC_DIV:
        out->result = in->para1/in->para2;
        break;

        default:
        break;
    }

    return &result;
}

附上有修改的文件

rpc_msg.h

#define SERVER_IP "172.0.5.183"

enum RPC_REQ_TYPE_1
{
    RPC_enable,
    RPC_disable,
};

enum RPC_REQ_TYPE_2
{
    RPC_ADD,
    RPC_SUB,
    RPC_MUL,
    RPC_DIV,
};

typedef struct my_msg_hdr_s
{
    int mtype;
    int len;
}my_msg_hdr_t;

typedef struct my_msg_s
{
    my_msg_hdr_t msg_hdr;
    int para1;
    int para2;
    int result;
}my_msg_t;

my_clnt.c:

/*
 * Please do not edit this file.
 * It was generated using rpcgen.
 */

#include <memory.h> /* for memset */
#include "my.h"

/* Default timeout can be changed using clnt_control() */
static struct timeval TIMEOUT = { ,  };

int *
my_rpcc_1(my_io_data_t *argp, CLIENT *clnt)
{
    static int clnt_res;

    memset((char *)&clnt_res, , sizeof(clnt_res));
    if (clnt_call (clnt, MY_RPCC,
        (xdrproc_t) xdr_my_io_data_t, (caddr_t) argp,
        (xdrproc_t) xdr_int, (caddr_t) &clnt_res,
        TIMEOUT) != RPC_SUCCESS) {
        return (NULL);
    }
    return (&clnt_res);
}

my_io_data_t *
my_rpcc_2(my_io_data_t *argp, CLIENT *clnt)
{
    static my_io_data_t clnt_res;

    memset((char *)&clnt_res, , sizeof(clnt_res));
    if (clnt_call (clnt, MY_RPCC,
        (xdrproc_t) xdr_my_io_data_t, (caddr_t) argp,
        (xdrproc_t) xdr_my_io_data_t, (caddr_t) &clnt_res,
        TIMEOUT) != RPC_SUCCESS) {
        return (NULL);
    }
    return (&clnt_res);
}

my.h

/*
 * Please do not edit this file.
 * It was generated using rpcgen.
 */

#ifndef _MY_H_RPCGEN
#define _MY_H_RPCGEN

#include <rpc/rpc.h>

#ifdef __cplusplus
extern "C" {
#endif

struct my_io_data_s {
    int mtype;
    int len;
    char data[];
};
typedef struct my_io_data_s my_io_data_s;

typedef my_io_data_s my_io_data_t;

#define MY_RPC_PROG 666
#define MY_RPC_VERS1 1

#if defined(__STDC__) || defined(__cplusplus)
#define MY_RPCC 1
extern  int * my_rpcc_1(my_io_data_t *, CLIENT *);
extern  int * my_rpcc_1_svc(my_io_data_t *, struct svc_req *);
extern int my_rpc_prog_1_freeresult (SVCXPRT *, xdrproc_t, caddr_t);

#else /* K&R C */
#define MY_RPCC 1
extern  int * my_rpcc_1();
extern  int * my_rpcc_1_svc();
extern int my_rpc_prog_1_freeresult ();
#endif /* K&R C */
#define MY_RPC_VERS2 2

#if defined(__STDC__) || defined(__cplusplus)
extern  my_io_data_t * my_rpcc_2(my_io_data_t *, CLIENT *);
extern  my_io_data_t * my_rpcc_2_svc(my_io_data_t *, struct svc_req *);
extern int my_rpc_prog_2_freeresult (SVCXPRT *, xdrproc_t, caddr_t);

#else /* K&R C */
extern  my_io_data_t * my_rpcc_2();
extern  my_io_data_t * my_rpcc_2_svc();
extern int my_rpc_prog_2_freeresult ();
#endif /* K&R C */

/* the xdr functions */

#if defined(__STDC__) || defined(__cplusplus)
extern  bool_t xdr_my_io_data_s (XDR *, my_io_data_s*);
extern  bool_t xdr_my_io_data_t (XDR *, my_io_data_t*);

#else /* K&R C */
extern bool_t xdr_my_io_data_s ();
extern bool_t xdr_my_io_data_t ();

#endif /* K&R C */

#ifdef __cplusplus
}
#endif

#endif /* !_MY_H_RPCGEN */

实验结果：

编译这client和server

gcc -o client my_clnt.c my_client.c my_xdr.c

gcc -o server my_svc.c my_server.c my_xdr.c

首先在主机172.0.5.183上运行server程序，然后在主机172.0.5.182运行client程序

同时观察两个主机的输出情况：

实验证明，client的RPC调用是成功的，计算结果跟我们预计的也一样，我们的demo设计完成。

后记：

现在网上介绍RPC的文章很多，但教你如何在Linux下搭建RPC框架的技术文章是很少的，仅有的几篇文章介绍得也是很简单很模糊，我也因此走了很多弯路，自己探索很多花了很多时间才搭建起来这么一个RPC框架。希望本文帮助到那些想在Linux下搭建RPC框架却不得入门的朋友。

参考资料：

《Unix网络编程卷二》

《Linux C高级程序员指南》

《rpcgen_mannual》