Linux编程之从零开始搭建RPC分布式系统，linux从零开始rpc
Linux编程之从零开始搭建RPC分布式系统，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[1024]; }; 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; /* 过程号 = 1 */ } = 1; /* Version number = 1 */ version MY_RPC_VERS2 { my_io_data_t MY_RPCC(my_io_data_t) = 1; /* 过称号 = 1 */ } = 2; /* 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 | 保留程序号 |
执行该指令后，文件夹下将出现以下几个文件。
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[1024]; }; 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 */View Code
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 = { 25, 0 }; int * my_rpcc_1(my_io_data_t *argp, CLIENT *clnt) { static int clnt_res; memset((char *)&clnt_res, 0, 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, 0, 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); }View Code
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, 0, 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 (1); } 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, 0, 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 (1); } 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(1); } 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(1); } 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(1); } transp = svctcp_create(RPC_ANYSOCK, 0, 0); if (transp == NULL) { fprintf (stderr, "%s", "cannot create tcp service."); exit(1); } 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(1); } 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(1); } svc_run (); fprintf (stderr, "%s", "svc_run returned"); exit (1); /* NOTREACHED */ }View Code
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, 1024, 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; }View Code
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 (1); } #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 (1); } #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 < 2) { printf ("usage: %s server_host\n", argv[0]); exit (1); } host = argv[1]; my_rpc_prog_1 (host); my_rpc_prog_2 (host); exit (0); }View Code 现在我们就可以在该文件编写客户端的代码了。 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; }View Code
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 (1); } #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 (1); } #endif /* DEBUG */ my_rpcc_2_arg.mtype = 3; my_rpcc_2_arg.len = 18; 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 < 2) { printf ("usage: %s server_host\n", argv[0]); exit (1); } host = argv[1]; //my_rpc_prog_1 (host); my_rpc_prog_2 (host); exit (0); }View Code
值得注意的是，我们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 = 33; result.len = 12; return &result; }View Code 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端
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 -1; } #endif /* DEBUG */ result_1 = my_rpcc_1(in_msg, clnt); if (result_1 == (int *) NULL) { clnt_perror (clnt, "call failed"); return -1; } return 0; } 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, 0, 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, 0, 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(1); get_compute_result(SERVER_IP, RPC_ADD, 6, 3); sleep(1); get_compute_result(SERVER_IP, RPC_SUB, 6, 3); sleep(1); get_compute_result(SERVER_IP, RPC_MUL, 6, 3); sleep(1); get_compute_result(SERVER_IP, RPC_DIV, 6, 3); sleep(1); server_switch(SERVER_IP, RPC_disable); //server close return 0; }当然改了以上的两个函数，我们当然也需要在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;View Code
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 = { 25, 0 }; int * my_rpcc_1(my_io_data_t *argp, CLIENT *clnt) { static int clnt_res; memset((char *)&clnt_res, 0, 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, 0, 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); }View Code
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[1024]; }; 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 */View Code
实验结果： 编译这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程序 同时观察两个主机的输出情况：
评论暂时关闭