`
zsxxsz
  • 浏览: 450491 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

利用ACL开发并发网络服务器

阅读更多

1、概述
    本节结合 "利用ACL库开发高并发半驻留式线程池程序" 和 "利用ACL库快速创建你的网络程序" 两篇文章的内容,创建一个简单的线程池网络服务器程序。
2、并发式网络通信实例

#include "lib_acl.h"  /* 先包含ACL库头文件 */
#include <stdio.h>
#include <stdlib.h>

/**
 * 单独的线程处理来自于客户端的连接
 * @param arg {void*} 添加任务时的对象
 */
static void echo_client_thread(void *arg)
{
	ACL_VSTREAM *client = (ACL_VSTREAM*) arg;
	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);
}

/**
 * 创建半驻留线程池的过程
 * @return {acl_pthread_pool_t*} 新创建的线程池句柄
 */
static acl_pthread_pool_t *create_thread_pool(void)
{
	acl_pthread_pool_t *thr_pool;  /* 线程池句柄 */
	int  max_threads = 100;  /* 最多并发100个线程 */
	int  idle_timeout = 10;  /* 每个工作线程空闲10秒后自动退出 */
	acl_pthread_pool_attr_t attr;  /* 线程池初始化时的属性 */

	/* 初始化线程池对象属性 */
	acl_pthread_pool_attr_init(&attr);
	acl_pthread_pool_attr_set_threads_limit(&attr, max_threads);
	acl_pthread_pool_attr_set_idle_timeout(&attr, idle_timeout);

	/* 创建半驻留线程句柄 */
	thr_pool = acl_pthread_pool_create(&attr);
	assert(thr_pool);
	return (thr_pool);
}

/**
 * 开始运行
 * @param addr {const char*} 服务器监听地址,如:127.0.0.1:8081
 */
static void run(const char *addr)
{
	const char *myname = "run";
	acl_pthread_pool_t *thr_pool;
	ACL_VSTREAM *sstream;
	char  ebuf[256];

	thr_pool = create_thread_pool();

	/* 监听一个本地地址 */
	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) {
		/* 等待接受客户端的连接 */
		ACL_VSTREAM *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)));
			break;
		}
		printf("accept one\r\n");
		/* 获得一个客户端连接流 */
		/* 开始处理该客户端连接流 */

		/**
		 * 向线程池中添加一个任务
		 * @param thr_pool 线程池句柄
		 * @param echo_client_thread 工作线程的回调函数
		 * @param client 客户端数据流
		 */
		acl_pthread_pool_add(thr_pool, echo_client_thread, client);
	}

	/* 销毁线程池对象 */
	acl_pthread_pool_destroy(thr_pool);
}

/**
 * 初始化过程
 */
static void init(void)
{
	/* 初始化ACL库 */
	acl_init();
}

/**
 * 使用提示接口
 * @param procname {cosnt char*} 程序名
 */
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);
	getchar();  
}

int main(int argc, char *argv[])
{
	if (argc != 2) {
		usage(argv[0]);
		return (0);
	}

	init();
	run(argv[1]);
	return (0);
}

 


    由上可以看出,创建一个并发式服务器程序也是如此的简单。 该例子可以同时运行在WIN32平台及UNIX平台(Linux, FreeBSD, Solaris-x86).

3、小结
    由以上例子可以看出,ACL库屏蔽底层SOCKET的细节操作,使网络编程变得简单,使使用者可以专心于其应用,而不是拘泥于SOCKET操作上,另外结合半驻留线程池的ACL库就可以开发高效的并发网络应用来。
  当然,以上例子也存在一个缺点,那就是当客户端并发连接比较高时,因为一个连接占用一个线程,所以高并发时就需要更多的线程(为了启动更多的线程,可以通过 acl_pthread_pool_set_stacksize 或 acl_pthread_pool_attr_set_stacksize 设置每个线程的堆栈为较小的值,如 500KB);而采用ACL库里的另一种编程技术--非阻塞式IO,可以使一个线程同时处理多个并发TCP连接,同时可以启动多个这样的非阻塞线程,从而可以更好地利用多核(一般是一个核可以启用一个非阻塞IO线程),将来,我们将会对此类问题进行讨论,并给出具体实例。

   acl 库的下载地址:http://acl.sourceforge.net/
   acl 库的在线帮助地址:http://acl.sourceforge.net/acl_help/index.html

 

4 参考

1)  利用ACL库快速创建你的网络程序--ACL_VSTREAM 流的使用

2)  利用ACL库开发高并发半驻留式线程池程序

 

下载:http://sourceforge.net/projects/acl/

svn:svn checkout svn://svn.code.sf.net/p/acl/code/trunk acl-code

github:https://github.com/acl-dev/acl

QQ 群:242722074

国内镜像:http://git.oschina.net/acl-dev/acl
微博:http://weibo.com/zsxxsz/

分享到:
评论
8 楼 zsxxsz 2017-05-03  
2202877 写道
你好,请问一下acl库是否可以移植到arm平台上,是否可以把要注意的地方说一下。谢谢

目前已经完全支持 Android, IOS 平台。
7 楼 zsxxsz 2012-12-26  
2202877 写道
acl_pthread.h中如果有pthread库(ACL_HAS_PTHREAD有定义),则将acl_pthread_coond_create在第40行重定义成pthread_cond_create,但是pthread库里好像没有pthread_cond_create函数,这里是不是有问题?

是的,这个函数是我扩展的,在UNIX平台下应该注掉。
6 楼 2202877 2012-12-26  
acl_pthread.h中如果有pthread库(ACL_HAS_PTHREAD有定义),则将acl_pthread_coond_create在第40行重定义成pthread_cond_create,但是pthread库里好像没有pthread_cond_create函数,这里是不是有问题?
5 楼 zsxxsz 2012-12-25  
2202877 写道
这两天做了个小程序,试用了这个库,还不错,非常感谢。
只是DOXYGEN生成的文档感觉还不是很理想,找api比较费劲,如果能弄成和apr的文档一样最好http://apr.apache.org/docs/apr-util/1.4/modules.html,个人意见哈,也可能是我不太习惯这种方式。


要想生成doxygen文档,必须先将 acl 里的头文件由 gb2312 格式转成utf-8格式,doxygen 自己的转码器有问题,我写过一个转码器来专门做这件事。不过我已经把生成的 API 文档上传到 sourceforge 了,http://sourceforge.net/projects/acl/files/doc/ 下的 acl_help_html.zip
4 楼 2202877 2012-12-25  
这两天做了个小程序,试用了这个库,还不错,非常感谢。
只是DOXYGEN生成的文档感觉还不是很理想,找api比较费劲,如果能弄成和apr的文档一样最好http://apr.apache.org/docs/apr-util/1.4/modules.html,个人意见哈,也可能是我不太习惯这种方式。

3 楼 2202877 2012-12-21  
zsxxsz 写道
ACL主要依赖于系统基本的库(其中库 lib_acl 当需要支持 mysql 时需要 mysql 的客户端库, 库 lib_protocol 仅依赖系统基础库,库 lib_acl_cpp 需要支持 zlib/polarssl 时也得需要这两个库, lib_tls 需要 openssl 库,lib_dict 需要 bdb 库)按道理说是可以移植到ARM上的,目前它支持LINUX/BSD/MAC/WIN32四个平台,如果有相应的开发环境,就可以移植。

好的,谢谢,我先试试。
2 楼 zsxxsz 2012-12-21  
ACL主要依赖于系统基本的库(其中库 lib_acl 当需要支持 mysql 时需要 mysql 的客户端库, 库 lib_protocol 仅依赖系统基础库,库 lib_acl_cpp 需要支持 zlib/polarssl 时也得需要这两个库, lib_tls 需要 openssl 库,lib_dict 需要 bdb 库)按道理说是可以移植到ARM上的,目前它支持LINUX/BSD/MAC/WIN32四个平台,如果有相应的开发环境,就可以移植。
1 楼 2202877 2012-12-21  
你好,请问一下acl库是否可以移植到arm平台上,是否可以把要注意的地方说一下。谢谢

相关推荐

    acl框架库是一个C语言网络框架库,主要包含:服务器开发框架、同步异步网络通讯、常用数据结构、进程池线程池、流式xmljson

    1. **服务器开发框架**:ACL框架提供了一套完整的服务器开发工具,使得开发者可以快速构建高性能、高并发的网络服务。它包含了请求处理、连接管理、会话维护等核心模块,简化了网络服务器的开发流程。 2. **同步...

    acl project

    开发者可以利用ACL库中的API来创建、连接、监听和接受网络连接,处理网络数据的发送与接收。此外,可能还包括异步I/O、多路复用技术(如epoll、kqueue或select)以提高并发性能。 2. **服务器框架**:服务器框架是...

    网络与服务器编程框架库

    服务器框架库是用于构建高性能、高并发服务器应用的核心组件。它们提供了一种结构化的模式来组织代码,处理请求、路由、响应、中间件等。例如,Node.js的Express框架,Python的Django和Flask框架,Java的Spring ...

    acl.rar_epoll server

    综上所述,这个“acl”库很可能是一个集成了epoll技术的服务器开发框架,提供了多平台兼容性、丰富的数据处理能力以及强大的网络通信支持。开发者可以利用它来快速构建高性能、可扩展的网络服务,如Web服务器、API...

    基于Linux的私有文件服务器,采用reactor模式开发.zip

    在创建基于Linux的私有文件服务器时,开发人员通常会利用Linux内核提供的丰富的网络支持,如套接字API、epoll(用于I/O多路复用)和线程管理功能。反应器模式利用了这些特性,通过一个中心调度器(Reactor)来分发...

    FTP客户端与服务器的源代码

    在VC++中,你可以利用MFC(Microsoft Foundation Classes)库或WinAPI来实现FTP客户端和服务器。MFC提供了丰富的类库来简化网络编程,而WinAPI则提供了底层的网络功能。对于多线程编程,VC++支持内置的`std::thread`...

    acl project 2008.9

    在"ACL项目2008.9"中,开发者可以利用这些技术,构建出能够灵活应对高并发请求、低延迟响应的服务器程序。源代码文件"acl_project.src"可能包含了实现这些功能的详细代码,供学习者研究和参考。通过深入理解并实践...

    Linux高性能服务器编程高清原版PDF+源码

    网络编程是Linux服务器开发的重点,包括TCP/IP协议栈、套接字API的使用、并发连接处理、Socket选项设置等。高性能服务器通常需要处理大量并发连接,因此,如何优雅地实现并发模型,比如线程池、事件驱动编程(如使用...

    MQTT Server服务器源代码

    IOCP利用操作系统的异步I/O机制,将I/O操作的完成通知与实际处理工作分离,从而提高服务器的并发性能。在MQTT Server中,使用IOCP可以显著提升服务端处理客户端请求的能力,降低延迟,确保在高并发场景下的稳定性和...

    vb+ftp服务器管理_vb6FTP服务器_vb6_vb6ftp_

    在VB6.0环境下,FTP(File Transfer Protocol)服务器的管理是一个常见的任务,尤其是在...不过,现代的开发环境中,如.NET或Node.js提供了更强大、更现代化的FTP解决方案,更适合处理高并发和复杂网络环境下的需求。

    飞鸽传书,文件共享服务器

    总的来说,"飞鸽传书,文件共享服务器"是一个实用的工具,它融合了网络通信、并发处理、权限控制和存储管理等多个IT领域的知识。对于想要学习和实践文件共享服务的开发者来说,这是一个宝贵的资源,不仅可以提升技术...

    Unity Render Streaming相关的webserver服务运行文件

    6. **性能优化**:为了确保流畅的用户体验,Web服务器还需要进行性能优化,例如通过负载均衡分散流量,使用缓存减少重复数据传输,或者利用多线程处理并发请求。 7. **安全性**:由于涉及到敏感的用户交互和实时...

    17计算机网络流媒体务器.ppt

    - 性能优化:根据服务器硬件资源和网络条件,调整服务器参数,例如并发连接数、缓冲区大小、带宽限制等,以达到最佳性能。 总之,搭建计算机网络流媒体服务器是一个涉及网络基础、服务器配置、多媒体技术等多个领域...

    网络游戏-虚拟网络中的虚拟机多播广播.zip

    总的来说,这个压缩包中的文档可能详细阐述了如何在虚拟网络环境下,利用虚拟机技术实现多播广播,以支持网络游戏的高效运行和大规模并发。这种技术的掌握对于网络游戏开发者和运维人员来说至关重要,能够提升游戏...

    Java物联网开发“尚方宝剑”之EMQ

    它利用Erlang OTP的并发性和分布式特性,可以轻松处理百万级别的设备连接,同时保持低内存占用和高效的消息处理。EMQ还支持多种身份认证方式,如基于用户名密码、TLS证书、ACL(访问控制列表)等,保障了物联网环境...

    partysip SIP代理服务器

    1. **代理服务**:作为SIP网络中的一个节点,Partysip可以作为代理服务器转发SIP消息,处理注册、呼叫建立、媒体协商等多个环节,帮助用户连接到其他SIP实体。 2. **路由功能**:通过配置路由规则,Partysip能够...

    VOD.rar_QT 视频_QT 视频服务器_linux视频_点播_视频点播

    服务器可能需要支持不同的视频编码格式,如H.264、AV1等,并且需要处理多路并发请求,以满足多个用户同时点播的需求。 3. **视频点播技术**:视频点播(VOD)允许用户按需选择并观看视频内容,而非传统的直播模式。...

    深入理解Nginx模块开发与架构解析

    同时,Nginx还可以通过防火墙规则、访问控制列表(ACL)等方式限制非法访问,增强服务器安全性。 总的来说,《深入理解Nginx模块开发与架构解析》这本书将帮助读者深入了解Nginx的内部运作,包括其高效的设计、模块...

    mfchat-server:用于具有专用 ACL 的实时信使的服务器小程序

    在JavaScript开发领域,mfchat-server的实现利用了Node.js,这是一个基于Chrome V8引擎的JavaScript运行环境,用于构建可伸缩的网络应用。Node.js使用非阻塞I/O模型,使其非常适合用于实时、数据密集型的跨平台应用...

    CICS联机程序开发与调试

    优化策略可能包括减少I/O操作,优化数据库查询,合理分配资源,以及利用CICS特性如缓冲池和并发控制。 9. **安全性**:CICS提供了安全机制,如访问控制列表(ACL)、审计日志和加密,以保护系统和数据免受未经授权...

Global site tag (gtag.js) - Google Analytics