1、概述 操作系统在API层为我们提供了进行网络通讯的库(一组socket函数库),但使用起来未免复杂,而且极易出错,虽然这些socket库最初起源于BSD系统,各个操作系统厂商都提供了自身平台的接口实现,但这些接口在不同OS上又略有差别,所以当你想写一个跨平台的网络通信程序时,考试大提示工作量还是有的,并且如不知晓各个平台下的差异也极易出错。 本节向你介绍了怎样使用ACL库中的数据流(ACL_VSTREAM)来快速搭建你的网络通信程序;另外,ACL_VSTREAM 不仅是跨平台的,而且既可用于网络通信流,又可用于文件流,本节仅介绍网络流的例子。 2、网络通信实例 2.1 一个简单的服务器程序 #include "lib_acl.h" /* 先包含ACL库头文件 */ #include <stdio.h> #include <stdlib.h> static void echo_client(ACL_VSTREAM *client) { char buf[1024]; int n; /* 设置客户端流的读超时时间为30秒 */ ACL_VSTREAM_SET_RWTIMO(client, 30); /* 循环读客户端的数据,直到其关闭或出错或超时 */ while (1) { /* 等待读客户端发来的数据 */ n = acl_vstream_read(client, buf, sizeof(buf)); if (n == ACL_VSTREAM_EOF) break; /* 将读到的数据写回至客户端流 */ if (acl_vstream_writen(client, buf, n) == ACL_VSTREAM_EOF) break; } /* 关闭客户端流 */ acl_vstream_close(client); } static void run(const char *addr) { const char *myname = "run"; ACL_VSTREAM *sstream; char ebuf[256]; /* 监听一个本地地址 */ sstream = acl_vstream_listen(addr, 128); if (sstream == NULL) { printf("%s(%d): listen on %s error(%s)\r\n", myname, __LINE__, addr, acl_last_strerror(ebuf, sizeof(ebuf))); return; } printf("%s: listen %s ok\r\n", myname, addr); while (1) { /* 等待接受客户端的连接 */ client = acl_vstream_accept(sstream, NULL, 0); if (client == NULL) { printf("%s(%d): accept error(%s)\r\n", myname, __LINE__, acl_last_strerror(ebuf, sizeof(ebuf))); return; } printf("accept one\r\n"); /* 获得一个客户端连接流 */ /* 开始处理该客户端连接流 */ echo_client(client); } } static void init(void) { #ifdef ACL_MS_WINDOWS /* 在WIN32下的SOCKET需要初始化 */ acl_socket_init(); #elif defined(ACL_UNIX) /* 在UNIX下需要忽略SIGPIPE信号,以免程序异常退出 */ signal(SIGPIPE, SIG_IGN); #endif } static void usage(const char *procname) { printf("usage: %s listen_addr\r\n", procname); printf("example: %s 127.0.0.1:8081\r\n", procname); } int main(int argc, char *argv[]) { if (argc != 2) { usage(argv[0]); return (0); } init(); run(argv[1]); return (0); } 由上可以看出,创建一个服务器程序是多么的简单,考试大提示这是一个阻塞式线程的服务器程序,如果你要想提高并发度,可以在线程里处理来自客户端的连接。
2.2、一个简单的客户端程序 #include "lib_acl.h" #include <stdio.h> #include <stdlib.h> static void run(const char *addr) { const char *myname = "run"; ACL_VSTREAM *client; char ebuf[256], buf[1024]; int n, cnt = 0; /* 连接远程服务器,采用阻塞模式连接,连接超时为10秒, * 流的读超时时间为20秒,流的缓冲区大小为1024字节 */ client = acl_vstream_connect(addr, ACL_BLOCKING, 10, 20, 1024); if (client == NULL) { printf("%s(%d): connect addr %s error(%s)\r\n", myname, __LINE__, addr, acl_last_strerror(ebuf, sizeof(ebuf))); return; } printf("%s: connect %s ok\r\n", myname, addr); while (1) { /* 向服务器发送一行数据 */ n = acl_vstream_fprintf(client, ">>hi, I'm coming in...(%d)\r\n", ++cnt); if (n == ACL_VSTREAM_EOF) break; /* 从服务器读取一行数据 */ n = acl_vstream_gets(client, buf, sizeof(buf)); if (n == ACL_VSTREAM_EOF) break; /* 最多循环5次 */ if (cnt >= 5) break; /* 休息一下 */ sleep(1); } /* 关闭流 */ acl_vstream_close(client); } static void init(void) { #ifdef ACL_MS_WINDOWS /* 在WIN32下的SOCKET需要初始化 */ acl_socket_init(); #elif defined(ACL_UNIX) /* 在UNIX下需要忽略SIGPIPE信号,以免程序异常退出 */ signal(SIGPIPE, SIG_IGN); #endif } static void usage(const char *procname) { printf("usage: %s server_addr\r\n", procname); printf("example: %s 127.0.0.1:8081\r\n", procname); } int main(int argc, char *argv[]) { if (argc != 2) { usage(argv[0]); return (0); } init(); run(argv[1]); return (0); } 嗯,看来创建网络客户端程序原来也这么简单。 3、小结 由以上例子可以看出,ACL库屏蔽底层SOCKET的细节操作,使网络编程变得简单,使使用者可以专心于其应用,而不是拘泥于SOCKET操作上。 当然,若要完全编译通过,别忘了还需要包含ACL库的二进制版本 lib_acl.a (Unix) 或 lib_acl_vc2003.lib(Windows)。
|