打印本文 
关闭窗口 操作系统在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)。
打印本文 关闭窗口