学步园

    实际工作中，会遇到各种不同的应用程序开发需求，每个应用程序都有很多公共的功能，比如日志操作、配置文件管理、数据库操作、Socket编程等等，每次准备开发一个应用程序的时候如果这些功能都已经整合好，无疑是非常美好的事情；开发人员可以更多的关注业务部分的实现；

    近期研究了Poco C++ Library的Poco::Util::Application的实现，其设计方案已经初步实现了上述思想；本篇将系统的整合之前独立的文章和实现类，初步实现上述思想；

    本篇的代码带有浓厚的个人使用习惯的色彩，在通用性方面还未投入更多的精力，希望看到该篇文章的coder们交流指导；

    对于那些已经独立撰写的文章，这里只提供链接，请各位耐心调阅；

开发环境搭建篇：

1、搭建Oracle 10g Proc+VS2008开发环境：http://blog.csdn.net/ishow99/archive/2009/12/02/4922148.aspx

2、搭建POCO-1.3.6-all+VS2008开发环境：http://blog.csdn.net/ishow99/archive/2009/12/02/4921739.aspx

3、搭建ACE-5.7.4+VS2008开发环境：http://blog.csdn.net/ishow99/archive/2009/11/19/4835161.aspx

功能实现类：

1、常用函数封装：http://blog.csdn.net/ishow99/archive/2010/09/30/5915723.aspx

2、ACE读取配置文件二次封装：http://blog.csdn.net/ishow99/archive/2010/07/09/5723677.aspx

3、ACE实现的轻量级日志系统：http://blog.csdn.net/ishow99/archive/2009/06/13/4266099.aspx

4、ACE实现FTP客户端：http://blog.csdn.net/ishow99/archive/2009/08/12/4439169.aspx

5、PROC++框架：http://blog.csdn.net/ishow99/archive/2009/06/15/4270299.aspx

app_main.h

/*==================================================================================================<br /> * 项目名称: 主程序封装框架<br /> * 功能: 搭建主程序基础框架，封装常用功能，如日志、配置文件、信号、数据库等，简化应用程序开发准备过程<br /> * 作者: huangjf<br /> * 联系: huangjf@ffcs.cn<br /> * 最近修改: 2010-7-16<br /> * 版本: v1.0.0<br /> ==================================================================================================*/</p> <p>#ifndef _Application_Main_<br /> #define _Application_Main_</p> <p>#include <memory><br /> #include <signal.h></p> <p>#include <ace/OS.h><br /> #include <ace/Reactor.h><br /> #include <ace/Event_Handler.h><br /> #include <ace/Thread_Manager.h><br /> #include <ace/Time_Value.h></p> <p>#include "ffcs_common.h"<br /> #include "ffcs_logger.h"<br /> #include "ffcs_config.h"<br /> #include "ffcs_db_proc.h"</p> <p>#define CONFIG_FILE ACE_TEXT("../config/config.cfg")</p> <p>class Application : public ACE_Event_Handler<br /> {<br /> public:<br /> Application(Logger& _logger, ConfigUpdate& _config) : active_(false), logger_(_logger), config_(_config)<br /> {<br /> /*ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) Application start/n")));*/<br /> }</p> <p> virtual ~Application()<br /> {<br /> /*ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) Application stop/n")));*/<br /> }</p> <p> /************************************************************************/</p> <p> virtual int usage(int argc, char* argv[])<br /> {<br /> /*TODO 实现该方法，执行命令行操作*/<br /> return 0;<br /> }</p> <p> virtual void init()<br /> {<br /> /*TODO 实现该方法，执行程序初始化工作*/<br /> return this->initialize();<br /> }</p> <p> virtual int run()<br /> {<br /> /*TODO 实现该方法，执行主程序逻辑*/<br /> return this->app_main();<br /> }</p> <p> virtual void exit()<br /> {<br /> /*TODO 实现该方法，执行程序退出资源回收工作*/<br /> return this->uninitialize();<br /> }</p> <p> /************************************************************************/</p> <p> Logger& logger()<br /> {<br /> return logger_;<br /> }</p> <p> ConfigUpdate& config()<br /> {<br /> return config_;<br /> }</p> <p>protected:<br /> virtual int handle_timeout(const ACE_Time_Value &_current_time, const void *act = 0)<br /> {<br /> return 0;<br /> }</p> <p> virtual int handle_signal(int _signum, siginfo_t * = 0, ucontext_t * = 0)<br /> {<br /> this->active_ = false;<br /> this->logger().warn("Receive system signal: %d/n", _signum);<br /> ACE_Reactor::instance ()->end_reactor_event_loop();<br /> return 0;<br /> }</p> <p> bool active_;</p> <p>private:<br /> void initialize()<br /> {<br /> /*设置事件处理能力*//*一次handle_events()调用中处理的notify()最大数目*/<br /> ACE_Reactor::instance()->max_notify_iterations(100);</p> <p> /*注册信号*/<br /> ACE_Reactor::instance()->register_handler (SIGINT, this);<br /> ACE_Reactor::instance()->register_handler (SIGQUIT, this);<br /> ACE_Reactor::instance()->register_handler (SIGABRT, this);<br /> ACE_Reactor::instance()->register_handler (SIGTERM, this);<br /> ACE_Reactor::instance()->register_handler (SIGSEGV, this);</p> <p> /*启动*/<br /> this->active_ = true;</p> <p> /*初始化日志系统*/<br /> this->logger().load_config(CONFIG_FILE);<br /> this->logger().open_logger();</p> <p> /*初始化配置系统*/<br /> this->config().open_config();</p> <p> /*初始化数据库系统*/<br /> DB_CONNECT::multi_thread();<br /> }</p> <p> void uninitialize()<br /> {<br /> ACE_Time_Value timeout(3, 0);</p> <p> /*停止*/<br /> this->active_ = false;</p> <p> /*关闭配置系统*/<br /> this->config().close_config();</p> <p> /*关闭日志系统*/<br /> this->logger().close_logger();</p> <p> /*关闭所有线程*/<br /> ACE_Thread_Manager::instance()->cancel_all();<br /> ACE_Thread_Manager::instance()->wait(&timeout);</p> <p> ACE_Reactor::instance()->close();<br /> }</p> <p> int app_main()<br /> {<br /> if (this->active_ == true)<br /> {<br /> ACE_Reactor::instance()->run_reactor_event_loop();<br /> }<br /> return RT_OK;<br /> }</p> <p>private:<br /> Logger& logger_;<br /> ConfigUpdate& config_;<br /> };</p> <p>#define FFCS_APP_MAIN(App) /<br /> Logger g_logger; /<br /> ConfigUpdate g_configupdate; /<br /> int ACE_TMAIN(int argc, ACE_TCHAR* argv[]) /<br /> { /<br /> std::auto_ptr<App> pApp(new App(g_logger, g_configupdate)); /<br /> if (pApp->usage(argc, argv) != 0) return RT_OK; /<br /> try /<br /> { /<br /> pApp->init(argc, argv); /<br /> pApp->run(); /<br /> } /<br /> catch (std::exception& exc) /<br /> { /<br /> pApp->logger().error("std::exception:%s/n", exc.what()); /<br /> } /<br /> catch (...) /<br /> { /<br /> pApp->logger().error("system exception/n"); /<br /> } /<br /> pApp->exit(); /<br /> return RT_OK; /<br /> }</p> <p>#endif</p> <p>

main.cpp

/*==================================================================================================<br /> * 项目名称: XX项目<br /> * 功能: XX功能<br /> * 作者: huangjf<br /> * 联系: huangjf@ffcs.cn<br /> * 最近修改: 2010-9-20<br /> * 版本: v1.0.0<br /> ==================================================================================================*/</p> <p>#include <stdio.h><br /> #include <stdlib.h></p> <p>#include <iostream><br /> #include <fstream><br /> #include <string><br /> #include <vector></p> <p>#include <ace/OS.h><br /> #include <ace/Reactor.h><br /> #include <ace/Time_Value.h><br /> #include <ace/Event_Handler.h><br /> #include <ace/Thread_Manager.h><br /> #include <ace/Get_Opt.h></p> <p>#include <Poco/Timespan.h><br /> #include <Poco/DateTime.h><br /> #include <Poco/LocalDateTime.h><br /> #include <Poco/DateTimeFormatter.h></p> <p>#include "ffcs_common.h"<br /> #include "ffcs_logger.h"<br /> #include "ffcs_config.h"<br /> #include "ffcs_db_proc.h"</p> <p>#include "app_main.h"</p> <p>class App1: public Application<br /> {<br /> public:<br /> App1(Logger& _logger, ConfigUpdate& _config) : Application(_logger, _config)<br /> {</p> <p> }</p> <p> virtual ~App1()<br /> {</p> <p> }</p> <p>public:<br /> /*初始化*/<br /> void init(int argc, ACE_TCHAR* argv[])<br /> {<br /> ACE_Time_Value tvDelay(3, 0), tvInterval;</p> <p> Application::init();</p> <p> /*参数配置*/<br /> ConfigParameter <int> p_logger_1(CONFIG_FILE, "LOGGER", "LOGMEDIA", FFCS_LOGMEDIA_ALL, this->logger().media_);<br /> ConfigParameter <int> p_logger_2(CONFIG_FILE, "LOGGER", "LOGLEVEL", FFCS_LOGLEVEL_MESSAGE, this->logger().level_);<br /> ConfigParameter <int> p_logger_3(CONFIG_FILE, "LOGGER", "LOGCLEANER", FFCS_LOGCLEANER_OPEN, this->logger().cleaner_switch_);<br /> ConfigParameter <int> p_logger_4(CONFIG_FILE, "LOGGER", "LOGSAVEDMONTH", DEFAULT_SAVED_MONTH, this->logger().saved_month_);</p> <p> ConfigParameter <int> p_system_1(CONFIG_FILE, "SYSTEM", "SYS_INTERVAL", 15, this->g_iInterval);<br /> ConfigParameter <int> p_system_2(CONFIG_FILE, "SYSTEM", "SYS_NOTIFY_ITERATIONS", 10, this->g_iNotifyIterations);</p> <p> ConfigParameter<std::string> p_database_1(CONFIG_FILE, "DATABASE", "CONNSTR_0", "NULL", this->g_dbString);<br /> ConfigParameter<std::string> p_database_2(CONFIG_FILE, "DATABASE", "LINKNAME_0", "NULL", this->g_dbName);</p> <p> this->config().add(p_logger_1);<br /> this->config().add(p_logger_2);<br /> this->config().add(p_logger_3);<br /> this->config().add(p_logger_4);</p> <p> this->config().add(p_system_1);<br /> this->config().add(p_system_2);</p> <p> this->config().add(p_database_1);<br /> this->config().add(p_database_2);</p> <p> /*this->config().dump();*/</p> <p> /*设置事件处理能力*//*一次handle_events()调用中处理的notify()最大数目*/<br /> ACE_Reactor::instance()->max_notify_iterations(this->g_iNotifyIterations);</p> <p> /*任务调度*/<br /> tvInterval.sec(this->g_iInterval);<br /> ACE_Reactor::instance()->schedule_timer(this, NULL, tvDelay, tvInterval);</p> <p> return;<br /> }</p> <p> /*执行*/<br /> int run()<br /> {<br /> /*<br /> DB_CONNECT conn(svc_dbstring, svc_dbname);</p> <p> conn.start();<br /> if (conn.connect() == RT_OK)<br /> {<br /> conn.DML_DEMO_1();</p> <p> conn.DML_DEMO_2(1);<br /> conn.DML_DEMO_2(2);<br /> conn.DML_DEMO_2(3);<br /> conn.DML_DEMO_2(3);<br /> conn.DML_DEMO_2(3);<br /> conn.DML_DEMO_2(4);<br /> conn.DML_DEMO_2(5);</p> <p> conn.DML_DEMO_3(1);<br /> conn.DML_DEMO_3(3);<br /> }<br /> conn.disconnect();<br /> conn.stop();<br /> */</p> <p> ACE_Time_Value tv(0, 100*1000);<br /> struct timespec rqt;<br /> rqt.tv_sec = 0;<br /> rqt.tv_nsec = 100*1000*1000;</p> <p> while (this->active_ == true)<br /> {<br /> if (ACE_Reactor::instance()->handle_events(tv) == -1) break;</p> <p> ACE_OS::nanosleep(&rqt);<br /> }</p> <p> return 0;<br /> /*return Application::run();*/<br /> }</p> <p> /*退出*/<br /> void exit()<br /> {<br /> return Application::exit();<br /> }</p> <p> /*参数处理，0:程序继续执行，1:程序中断退出*/<br /> int usage(int argc, char* argv[])<br /> {<br /> int c;<br /> ACE_Get_Opt get_opt(argc, argv, "hv");</p> <p> while ((c = get_opt ()) != EOF)<br /> {<br /> switch (c)<br /> {<br /> case 'v':<br /> {<br /> Util::fun_copyright();<br /> }<br /> return 1;<br /> case 'h':<br /> default:<br /> {<br /> ACE_OS::printf("/n/n");<br /> ACE_OS::printf("Usage: ./app_main_ace [OPTIONS] /n");<br /> ACE_OS::printf(" -h display this usage message/n");<br /> ACE_OS::printf(" -v display version/n");<br /> ACE_OS::printf("/n/n");<br /> }<br /> return 1;<br /> }<br /> }</p> <p> return 0;<br /> }</p> <p>protected:<br /> /*定时任务*/<br /> int handle_timeout(const ACE_Time_Value &_current_time, const void *act = 0)<br /> {<br /> Poco::LocalDateTime ldt_now;</p> <p> this->logger().debug("心跳正常，程序还活着! 下次看到心跳预计时间:[%s]/n/n", Poco::DateTimeFormatter::format(ldt_now+Poco::Timespan(this->g_iInterval, 0), "%Y-%m-%d %H:%M:%S").c_str());</p> <p> return 0;<br /> }</p> <p>private:<br /> int g_iInterval;<br /> int g_iNotifyIterations;</p> <p> std::string g_dbString, g_dbName;<br /> };</p> <p>FFCS_APP_MAIN(App1);</p> <p>