ACE笔记（10）-ACE文件操作

peakzhang

ACE里的文件操作与平常的Win32里面的文件操作有所不同，这是因为ACE是为网络开发而设计的，里面普遍都遵循了Client/Server模式，这样在操作文件时，ACE把文件看做是一个Socket服务器，而进行文件操作的类(ACE_FILE_IO)被看做是一个Socket Client。         有了上面的认识，使用ACE的文件操作就容易理解了：
        调用ACE_FILE_IO.send(...)其实就是进行写文件的操作；
        调用ACE_FILE_IO.recv(...)其实就是进行文件的读操作。
       ACE里面的文件操作类主要包括：ACE_IO_SAP、ACE_FILE、ACE_FILE_IO、ACE_FILE_Connector。
       ACE_FILE_Connector是一个用来产生ACE_FILE_IO的类工厂。
      ACE_FILE_IO继承于ACE_FILE，ACE_FILE继承于ACE_IO_SAP。
      ACE_FILE只能够对文件进行一些整体性的操作，如：关闭文件（close）、删除文件（remove/ulink）、获取文件属性（get_info）、设置文件大小（truncate）、定位或获取文件游标位置（seek/position/tell）、获取文件路径（get_local_addr/get_remote_addr）。
      ACE_FILE_IO则能够进行文件的读写操作，如：多个版本的send/recv, send_n/recv_n,  sendv/recvv,  sendv_n/recvv_n
      ACE_FILE_Connector实际是为了使ACE_FILE类族能够符合Connector/Acceptor设计模式而设计的，只是没有相应的Acceptor。
示例代码如下：

2. #include "ace/OS_main.h"
3. #include "ace/FILE_Addr.h"
4. #include "ace/FILE_Connector.h"
5. #include "ace/FILE_IO.h"
6. #include "ace/OS_NS_string.h"
7. #include "ace/OS_NS_stdio.h"
8. ACE_RCSID(FILE_SAP, client, "client.cpp,v 4.16 2003/11/01 11:15:23 dhinton Exp")
9. int
10. ACE_TMAIN (int argc, ACE_TCHAR *argv[])
11. {
12.   if (argc < 3 || argc > 3)
13.     ACE_ERROR_RETURN ((LM_ERROR,
14.                        "usage: %s filename string\n",
15.                        argv[0]),
16.                       1);
17.   ACE_TCHAR *readback = new ACE_TCHAR[ACE_OS::strlen (argv[1]) + 1];
18.   readback[ACE_OS::strlen (argv[1])] = '\0';
19.   ACE_TCHAR *filecache = new ACE_TCHAR[1024];
20.   ACE_FILE_Info fileinfo;
21.   ACE_FILE_IO cli_file;
22.   ACE_FILE_IO file_copy;
23.   ACE_FILE_Connector con;
24.   if (con.connect (cli_file,
25.                    ACE_FILE_Addr (argv[1]),
26.      0,
27.                    ACE_Addr::sap_any, 0,
28.      O_RDWR|O_APPEND|O_CREAT,
29.                    ACE_DEFAULT_FILE_PERMS) == -1)
30.     ACE_ERROR_RETURN ((LM_ERROR,
31.                        "%p\n to %s",
32.                        "connect",
33.                        argv[1]),
34.                       -1);
35.   if (con.connect ( file_copy,
36.      ACE_FILE_Addr ("testfile_cpy.bak"),
37.      0,
38.      ACE_Addr::sap_any, 0,
39.      O_RDWR|O_APPEND|O_CREAT,
40.      ACE_DEFAULT_FILE_PERMS) == -1)
41.    ACE_ERROR_RETURN ((LM_ERROR,
42.      "%p\n to %s",
43.      "connect",
44.      "testfile_cpy.bak"),
45.      -1);
46.   ssize_t len = ACE_OS::strlen (argv[2]) + 1;
47.   if (cli_file.send (argv[2], len) != len)
48.     ACE_ERROR_RETURN ((LM_ERROR,
49.                        "%p\n",
50.                        "send"),
51.                       1);
52.   if (cli_file.get_info (&fileinfo) == -1)
53.     ACE_ERROR_RETURN ((LM_ERROR,
54.                        "%p\n",
55.                        "get_info"),
56.                       1);
57.   else
58.     ACE_OS::printf ("fileinfo : mode = %o\nno of links = %lu\nsize = %lu\n",
59.                     (u_int) fileinfo.mode_ & 0777,
60.                     ACE_static_cast(u_long ,fileinfo.nlink_),
61.                     (u_long) fileinfo.size_);
62.   off_t fpos = cli_file.position ();
63.   if (fpos == -1)
64.     ACE_ERROR_RETURN ((LM_ERROR,
65.                        "%p\n",
66.                        "position"),
67.                       1);
68.   else
69.     ACE_OS::printf ("current filepointer is at %ld\n",
70.                     (long int) fpos);
71.   if (cli_file.position (0,
72.                          SEEK_SET) == -1)
73.     ACE_ERROR_RETURN ((LM_ERROR,
74.                        "%p\n",
75.                        "position"),
76.                       1);
77.   unsigned long lfsize = (u_long) fileinfo.size_;
78.   if (lfsize <= 1024)
79.   {
80.   if (cli_file.recv(filecache, lfsize) != lfsize)
81.    ACE_ERROR_RETURN ((LM_ERROR,
82.         "%p\n",
83.         "recv"),
84.         1);
85.   if (file_copy.send (filecache, lfsize) != lfsize)
86.    ACE_ERROR_RETURN ((LM_ERROR,
87.        "%p\n",
88.        "send"),
89.        1);
90.   }
91.   else
92.   {
93.    unsigned int uiTemp = lfsize;
94.    while (uiTemp - 1024 >= 0)
95.    {
96.    if (cli_file.recv(filecache, 1024) != 1024)
97.     ACE_ERROR_RETURN ((LM_ERROR,
98.          "%p\n",
99.          "recv"),
100.          1);
101.    if (file_copy.send (filecache, 1024) != 1024)
102.     ACE_ERROR_RETURN ((LM_ERROR,
103.         "%p\n",
104.         "send"),
105.         1);
106.    uiTemp -= 1024;
107.    }
108.   }
109.   if (cli_file.recv (readback, len) != len)
110.     ACE_ERROR_RETURN ((LM_ERROR,
111.                        "%p\n",
112.                        "recv"),
113.                       1);
114.   ACE_OS::printf ("read back :%s\n",
115.                   ACE_TEXT_ALWAYS_CHAR(readback));
116.   if (cli_file.close () == -1 || file_copy.close() == -1)
117.     ACE_ERROR_RETURN ((LM_ERROR,
118.                        "%p\n",
119.                        "close"),
120.                       1);
121.   return 0;
122. }
123. 除了上面提供的基本文件操作类外，ACE还提供了对配置文件进行操作的类，如对INI文件进行操作，当然也可以对XML文件进行操作
124. 对INT文件进行操作的相关类如下：
125. ACE_Configuration_Heap 用于获得配置文件的信息
126. ACE_Ini_ImpExp 用于导入配置文件信息
127.   ACE_Configuration_Section_Key 用于定位配置文件的章节
128.   示例如下：
129. CIniFile.h 文件
130. #ifndef CINIFILE
131. #define CINIFILE
132. #include "ace/Configuration.h"
133. #include "ace/Configuration_Import_Export.h"
134. class CIniFile
135. {
136. public:
137. ~CIniFile();
138. //返回0表打开成功，－1表打开配置文件失败，－2表不存在【CRB】章节
139. int open(const ACE_TCHAR * filename);
141. int GetKeyValue(const ACE_TCHAR * name,ACE_TString &value);
142. protected:
144. private:
145. ACE_Configuration_Section_Key root_key_;
146. ACE_Ini_ImpExp * impExp_;
147. ACE_Configuration_Heap config;
148. //ACE_TCHAR[1000] tmp_;
149. };
150. #endif
152. CIniFile.cpp 文件
153. #include "CIniFile.h"
154. CIniFile::~CIniFile(){
155. delete this->impExp_;
156. }
157. int CIniFile::open(const ACE_TCHAR * filename){
158. this->config.open();
159. this->impExp_=new ACE_Ini_ImpExp(config);
160. if (this->impExp_->import_config(filename)==-1){
161.   return -1;
162. }
163. if (config.open_section(config.root_section(),ACE_TEXT("CRB"),0,this->root_key_)==-1){
164.   return -2;
165. }
166. return 0;
167. }
168. int  CIniFile::GetKeyValue(const ACE_TCHAR * name,ACE_TString &value){
170. return config.get_string_value(this->root_key_,name,value);
171. }

复制代码

SkyThinker

我参考你提供的读取配置文件的代码，然后在open的时候传入"logging.ini"的文件名称，
程序提示 打印出错误，程序提示没有该路径或者文件名。

还有程序马上崩溃！

xinshuow

#include "ace/OS_main.h"
#include "ace/FILE_Addr.h"
#include "ace/FILE_Connector.h"
#include "ace/FILE_IO.h"
#include "ace/OS_NS_string.h"
#include "ace/OS_NS_stdio.h"
ACE_RCSID(FILE_SAP, client, "client.cpp,v 4.16 2003/11/01 11:15:23 dhinton Exp")
int
ACE_TMAIN (int argc, ACE_TCHAR *argv[])
{
  if (argc < 3 || argc > 3)
    ACE_ERROR_RETURN ((LM_ERROR,
                       "usage: %s filename string\n",
                       argv[0]),
                      1);
  ACE_TCHAR *readback = new ACE_TCHAR[ACE_OS::strlen (argv[1]) + 1];
  readback[ACE_OS::strlen (argv[1])] = '\0';
  ACE_TCHAR *filecache = new ACE_TCHAR[1024];
  ACE_FILE_Info fileinfo;
  ACE_FILE_IO cli_file;
  ACE_FILE_IO file_copy;
  ACE_FILE_Connector con;
  if (con.connect (cli_file,
                   ACE_FILE_Addr (argv[1]),
     0,
                   ACE_Addr::sap_any, 0,
     O_RDWR|O_APPEND|O_CREAT,
                   ACE_DEFAULT_FILE_PERMS) == -1)
    ACE_ERROR_RETURN ((LM_ERROR,
                       "%p\n to %s",
                       "connect",
                       argv[1]),
                      -1);
  if (con.connect ( file_copy,
     ACE_FILE_Addr ("testfile_cpy.bak"),
     0,
     ACE_Addr::sap_any, 0,
     O_RDWR|O_APPEND|O_CREAT,
     ACE_DEFAULT_FILE_PERMS) == -1)
   ACE_ERROR_RETURN ((LM_ERROR,
     "%p\n to %s",
     "connect",
     "testfile_cpy.bak"),
     -1);
  ssize_t len = ACE_OS::strlen (argv[2]) + 1;
  if (cli_file.send (argv[2], len) != len)
    ACE_ERROR_RETURN ((LM_ERROR,
                       "%p\n",
                       "send"),
                      1);
  if (cli_file.get_info (&fileinfo) == -1)
    ACE_ERROR_RETURN ((LM_ERROR,
                       "%p\n",
                       "get_info"),
                      1);
  else
    ACE_OS::printf ("fileinfo : mode = %o\nno of links = %lu\nsize = %lu\n",
                    (u_int) fileinfo.mode_ & 0777,
                    ACE_static_cast(u_long ,fileinfo.nlink_),
                    (u_long) fileinfo.size_);
  off_t  fpos = cli_file.tell();    // off_t fpos = cli_file.position ();
  if (fpos == -1)
    ACE_ERROR_RETURN ((LM_ERROR,
                       "%p\n",
                       "position"),
                      1);
  else
    ACE_OS::printf ("current filepointer is at %ld\n",
                    (long int) fpos);
  // if (cli_file.position (0,
    //                     SEEK_SET) == -1)
   if (cli_file.seek (0,
                        SEEK_SET) == -1)
    ACE_ERROR_RETURN ((LM_ERROR,
                       "%p\n",
                       "position"),
                      1);
  unsigned long lfsize = (u_long) fileinfo.size_;
  if (lfsize <= 1024)
  {
  if (cli_file.recv(filecache, lfsize) != lfsize)
   ACE_ERROR_RETURN ((LM_ERROR,
        "%p\n",
        "recv"),
        1);
  if (file_copy.send (filecache, lfsize) != lfsize)
   ACE_ERROR_RETURN ((LM_ERROR,
       "%p\n",
       "send"),
       1);
  }
  else
  {
   unsigned int uiTemp = lfsize;
   while (uiTemp - 1024 >= 0)
   {
   if (cli_file.recv(filecache, 1024) != 1024)
    ACE_ERROR_RETURN ((LM_ERROR,
         "%p\n",
         "recv"),
         1);
   if (file_copy.send (filecache, 1024) != 1024)
    ACE_ERROR_RETURN ((LM_ERROR,
        "%p\n",
        "send"),
        1);
   uiTemp -= 1024;
   }
  }
  if (cli_file.seek (0,
                        SEEK_SET) == -1)    //  add
    ACE_ERROR_RETURN ((LM_ERROR,
                       "%p\n",
                       "position"),
                      1);
  if (cli_file.recv (readback, len) != len)
    ACE_ERROR_RETURN ((LM_ERROR,
                       "%p\n",
                       "recv"),
                      1);
  ACE_OS::printf ("read back :%s\n",
                  ACE_TEXT_ALWAYS_CHAR(readback));
  if (cli_file.close () == -1 || file_copy.close() == -1)
    ACE_ERROR_RETURN ((LM_ERROR,
                       "%p\n",
                       "close"),
                      1);
  return 0;
}

lihaowei2028

我用ACE_FILE_IO写文件, 发现系统缓存不断增加, 楼主知道是怎么回事吗? 写函数使用的 send

winston

lihaowei2028 发表于 2013-3-21 18:42
我用ACE_FILE_IO写文件, 发现系统缓存不断增加, 楼主知道是怎么回事吗? 写函数使用的 send ...

缓存在起作用啊。

doublequick

此贴有用！:)