在编写服务器应用程序时,有时会有这样一种应用场景:后端的业务数据及业务逻辑相同,但希望给前端应用提供的功能范围及协议方式有些差别。如:
场景一:希望来自于外网的客户端以只读权限访问后端数据,同时希望来自于内网的客户端可以以读/写方式访问后端数据;
场景二:希望某个网段的客户端以 HTTP 协议访问后端业务,同时希望某个网段的客户端以私有协议方式访问后端业务。
为了处理上面的应用场景,当然可以写多个服务器程序,每个服务器程序处理不同的协议格式和权限范围,但这势必会造成很多冗余代码,增加额外的工作量及出错可能性。acl 的服务器框架模型允许一个服务器进程同时监听多个地址,利用这一点便可以轻松解决上面的应用场景问题,同时大大减少了程序工作量及维护成本。
下面以一个简单的例子,说明如何使用这一特性来处理不同的协议过程。
为了简单起见,本例子使用了 使用 acl 生成向导快速创建服务器程序 文章中介绍的服务器生成向导过程来生成一个简单的 DEMO(假设让该服务器程序监听:127.0.0.1:8088 和 192.168.166.162:8080 两个地址)。假设由服务器生成向导程序生成了服务器模板类型为 master_threads (线程池模型)的程序 echo_server。然后在 echo_server 程序目录下打开 master_service.cpp 源程序,修改 函数 master_service::thread_on_accept ,master_service::thread_on_close 及 master_service::thread_on_read,内容如下:
// 当客户端连接流有数据可读/出现异常时的回调函数 bool master_service::thread_on_read(acl::socket_stream* conn) { // 获得客户端连接本地的哪个监听服务地址,其中 get_local 的参数为 true 表示要求获得 // ip:port 格式的全地址 const char* local_addr = conn->get_local(true); const char* str = (const char*) conn->get_ctx(); logger("connection from local %s on read fd %d, info: %s", local_addr, conn->sock_handle(), str); acl::string buf; // 从客户端读取一行数据 if (conn->gets(buf, false) == false) { logger("get error from client %s, local addr: %s", conn->get_peer(true), local_addr); return false; // 返回 false 通知服务器框架将连接关闭 } // 回写数据 if (conn->write(buf) == -1) { logger("write to client %s error, local addr: %s", conn->get_peer(true), local_addr); return false; } // 返回 true 通知服务器框架继续监控该客户端连接流 return true; } // 当接收到一个客户端连接时的回调函数 bool master_service::thread_on_accept(acl::socket_stream* conn) { // 获得客户端连接本地的哪个监听服务地址,其中 get_local 的参数为 true 表示要求获得 // ip:port 格式的全地址 const char* local_addr = conn->get_local(true); logger("connect from local addr: %s", local_addr); // 在此处可以根据 local_addr 的不同来区分不同的连接请求: if (strcmp(local_addr, "127.0.0.1:8088") == 0) { const char* str = strdup("from 127.0.0.1:8088"); conn->set_ctx(str); } else if (strcmp(local_addr, "192.168.166.162:8080" == 0) { const char* str = strdup("from 192.168.166.162:8080"); conn->set_ctx(str); } else { const char* str = strdup("other addr"); conn->set_ctx(str); } // 设置客户端连接流的读写超时时间(秒) conn->set_rw_timeout(10); return true; } // 当客户端连接关闭前调用的回调函数 void master_service::thread_on_close(acl::socket_stream* conn) { // 释放由 master_service::thread_on_accept 中分配的内存对象 char* str = (char*) conn->get_ctx(); if (str) free(str); }
上面代码逻辑很简单地演示了 acl 服务器框架支持监听多个地址的用处。为了支持不同的业务功能分流,应用可以在 thread_on_accept 阶段通过 socket_stream::set_ctx(void*) 设置不同的功能对象,在 thread_on_read 阶段通过 socket_stream::get_ctx() 取出设置的对象,通过对对象的功能判断进行业务功能分流。
当然,还有一点不要忘记,还得需要修改该服务器的配置文件,将 master_service 的监听地址改成多个地址,如:127.0.0.1:8088, 192.168.166.162:8080 即:master_service = 127.0.0.1:8088, 192.168.166.162:8080,同时需要将 master_type 值改为 sock,即:master_type = sock。
此外,为了在独立方式下测试服务器程序,可以打开 main.cpp 文件,将其中的 addr 的值设为 "127.0.0.1:8088, 192.168.166.162:8080" 即可。
下面写一个更加实用一点的例子,可以先设计一个虚类,里面定义一个虚方法,在接收到客户端连接 (thread_on_accept) 时,根据连接地址不同来创建该虚类的子类实例(这些子类只需实现基类中的虚方法即可),在 thread_on_read 时,通过调用子类实例的虚方法来达到协议分流的目的。如下面的例子:
class base { public: base() {} virtual ~base() {} // 纯虚方法,需要子类实现 virtual bool run(acl::socket_stream* conn) = 0; }; class child1 : public base { public: child1() {} ~child1() {} protected: bool run(acl::socket_stream* conn) // 基类虚方法实现 { acl::string buf; // 读一行数据,但第二个参数为 true 表示希望将 \r\n 自动去掉 if (conn->gets(buf, true) == false) return false; if (conn.format("child1: %s\r\n", buf.c_str()) == -1) return false; return true; } }; class child2 : public base { public: child2() {} ~child2() {} protected: bool run(acl::socket_stream* conn) // 基类虚方法实现 { acl::string buf; // 读一行数据,但第二个参数为 true 表示希望将 \r\n 自动去掉 if (conn->gets(buf, true) == false) return false; if (conn.format("child2: %s\r\n", buf.c_str()) == -1) return false; return true; } }; ///////////////////////////////////////////////////////////////////////////////// bool master_service::thread_on_read(acl::socket_stream* conn) { // 将流中参数硬转化为 base 类对象 base* obj = (base*) conn->get_ctx(); // 调用基类中的纯虚方法,而实际上是调用了子类的方法 // 从而实现了协议分流 return obj->run(conn); } bool master_service::thread_on_accept(acl::socket_stream* conn) { const char* local_addr = conn->get_local(true); if (strcmp(local_addr, "127.0.0.1:8088") = 0) { base* obj = new child1(); conn->set_ctx(obj); return true; } else if (strcmp(local_addr, "127.0.0.1:8080") == 0) { base* obj = new child2(); conn->set_ctx(obj); return true; } else return false; } void master_service::thread_on_close(acl::socket_stream* conn) { base* obj = (base*) conn->get_ctx(); if (obj) delete obj; }
参考:
acl 库下载:https://sourceforge.net/projects/acl/
svn: svn://svn.code.sf.net/p/acl/code/
github 地址:https://github.com/acl-dev/acl
QQ 群:242722074
使用 acl::master_threads 类编写多进程多线程服务器程序
相关推荐
基于springboot教育资源共享平台源码数据库文档.zip
linux开发篇,配套视频:https://www.bilibili.com/list/474327672?sid=4493702&spm_id_from=333.999.0.0&desc=1
ReadEra 这个阅读应用能够打开下列任何格式的文档: EPUB, PDF, DOC, RTF, TXT, DJVU, FB2, MOBI, 和 CHM. 基本上来说,你可以用它阅读你的设备内存中的任何书籍或者文本文档。 这个应用与划分成章节的文档兼。,有一个书签功能,可以在你阅读的时候,自动保存你的进度。另外,它让你更改页面模式,从几种不同的主题中进行挑选(夜间,白天,棕黑色调,还有控制台)。
软件环境:KEIL4 硬件环境:STM32单片机+舵机 控制原理:通过控制输出信号的占空比调节舵机旋转的角度
基于springboot仓库管理系统源码数据库文档.zip
酒店管理系统源码C++实现的毕业设计项目源码.zip,个人大四的毕业设计、经导师指导并认可通过的高分设计项目,评审分98.5分。主要针对计算机相关专业的正在做毕设的学生和需要项目实战练习的学习者,也可作为课程设计、期末大作业。 酒店管理系统源码C++实现的毕业设计项目源码.zip,酒店管理系统源码C++实现的毕业设计项目源码.zip个人大四的毕业设计、经导师指导并认可通过的高分设计项目,评审分98.5分。主要针对计算机相关专业的正在做毕设的学生和需要项目实战练习的学习者,也可作为课程设计、期末大作业。酒店管理系统源码C++实现的毕业设计项目源码.zip酒店管理系统源码C++实现的毕业设计项目源码.zip酒店管理系统源码C++实现的毕业设计项目源码.zip,个人大四的毕业设计、经导师指导并认可通过的高分设计项目,评审分98.5分。主要针对计算机相关专业的正在做毕设的学生和需要项目实战练习的学习者,也可作为课程设计、期末大作业。酒店管理系统源码C++实现的毕业设计项目源码.zip,个人大四的毕业设计、经导师指导并认可通过的高分设计项目,评审分98.5分。主要针对计算机相关专业的正在做毕
58商铺全新UI试客试用平台网站源码
springboot vue3前后端分离 基于SpringBoot+Vue的轻量级定时任务管理系统.zip
该资源内项目源码是个人的课程设计、毕业设计,代码都测试ok,都是运行成功后才上传资源,答辩评审平均分达到96分,放心下载使用! ## 项目备注 1、该资源内项目代码都经过严格测试运行成功才上传的,请放心下载使用! 2、本项目适合计算机相关专业(如计科、人工智能、通信工程、自动化、电子信息等)的在校学生、老师或者企业员工下载学习,也适合小白学习进阶,当然也可作为毕设项目、课程设计、作业、项目初期立项演示等。 3、如果基础还行,也可在此代码基础上进行修改,以实现其他功能,也可用于毕设、课设、作业等。 下载后请首先打开README.md文件(如有),仅供学习参考, 切勿用于商业用途。
4D毫米波雷达点云数据处理方法研究.caj
S M 2 2 5 8 X T 量产工具供大家下载使用
基于springboot的文物管理系统源码数据库文档.zip
基于springboot的电影院售票管理系统源码数据库文档.zip
基于Java web 实现的仓库管理系统源码,适用于初学者了解Java web的开发过程以及仓库管理系统的实现。
美容美发项目,使用django框架,前后端一体化项目
在线票务:2023年中国在线票务行业市场规模约为24.99亿元,挖掘市场蓝海新机遇 在数字浪潮的席卷下,传统的票务销售模式正经历着前所未有的变革。纸质门票逐渐淡出人们的视野,取而代之的是便捷、高效的数字和移动票务。这一转变不仅为消费者带来了前所未有的购票体验,更为在线票务平台开辟了广阔的发展空间和市场机遇。随着国民经济的持续增长和文体娱乐行业的蓬勃发展,中国在线票务行业正站在时代的风口浪尖,等待着每一位有志之士的加入。那么,这片蓝海市场究竟蕴藏着怎样的潜力?又该如何把握机遇,实现突破?让我们一同探索。 市场概况: 近年来,中国在线票务行业市场规模持续扩大,展现出强劲的增长势头。据QYResearch数据显示,2023年中国在线票务行业市场规模约为24.99亿元,尽管受到宏观经济的影响,市场规模增速放缓,但整体趋势依然向好。这一增长主要得益于国民人均收入的不断提高、电影及演出行业的快速发展以及政府政策的支持。例如,2023年财政部、国家电影局发布的《关于阶段性免征国家电影事业发展专项资金政策的公告》,为电影行业注入了强劲动力,进而推动了在线票务市场规模的扩大。 技术创新与趋势: 技术进步
基于SpringBoot的养老院管理系统源码数据库文档.zip
该资源内项目源码是个人的课程设计、毕业设计,代码都测试ok,都是运行成功后才上传资源,答辩评审平均分达到96分,放心下载使用! ## 项目备注 1、该资源内项目代码都经过严格测试运行成功才上传的,请放心下载使用! 2、本项目适合计算机相关专业(如计科、人工智能、通信工程、自动化、电子信息等)的在校学生、老师或者企业员工下载学习,也适合小白学习进阶,当然也可作为毕设项目、课程设计、作业、项目初期立项演示等。 3、如果基础还行,也可在此代码基础上进行修改,以实现其他功能,也可用于毕设、课设、作业等。 下载后请首先打开README.md文件(如有),仅供学习参考, 切勿用于商业用途。
内容概要:本文档是一份详细的Go语言教程,从基础概念介绍到高级主题均有覆盖。主要内容包括Go语言的基础语法、数据类型、控制结构、函数、结构体、接口和并发编程等方面。通过具体示例介绍了如何使用Go语言进行开发。 适合人群:初学者和有一定经验的程序员都可以从这篇教程中受益,特别是那些想要快速掌握Go语言并应用于实际项目的开发者。 使用场景及目标:适用于初学者系统学习Go语言的基础知识和常用功能;也可以作为已有开发经验者的参考资料,帮助他们解决具体的编程问题,提高开发效率。 其他说明:本教程不仅包含了Go语言的基本知识点,还重点讲解了其独特的并发编程模型。读者在学习过程中应该注重理论与实践相结合,通过实际编写代码来加深理解和记忆。
基于springboot计算机基础网上考试系统源码数据库文档.zip