在上一篇文章中,说到了"流程"的由来,以及我对流程的使用. 这一片就是对流程的应用.前一篇文章中说到了三条流程 check_log_measure, check_env_measure, check_update_measure.先来看看chenck_log_measure的源码:
1 --小岩<[email protected]>
2 --2015-5-28 1:29
3 local clm = class("check_log_measure", fw.measure)
4
5 function clm:ctor(dispatcher, next_m)
6 clm.super.ctor(self, dispatcher, next_m)
7 end
8
9 function clm:onlaunch()
10 local appconf = fw.classickv.new("conf/app_conf")
11 if appconf:get("syslog_enabled") then
12 local sys_logger = fw.logger.new(appconf:get("syslog_limit_level"))
13 if appconf:get("syslog_console_enabled") then
14 local sys_clogger
15 if appconf:get("syslog_console_printfun") then
16 sys_clogger = fw.console_logger.new(appconf:get("syslog_console_printfun"), 0)
17 else
18 sys_clogger = fw.console_logger.new(print, 0)
19 end
20 sys_logger:add_log_chanel(sys_clogger)
21 end
22
23 if appconf:get("syslog_file_enabled") then
24 fw.fileutil.make_dir(appconf:get("syslog_file_dir"))
25 local sys_flogger = fw.file_logger.new(
26 appconf:get("syslog_file_path"),
27 "w+b",
28 appconf:get("syslog_file_autoflush"),
29 0,
30 appconf:get("syslog_file_parser")
31 )
32 sys_logger:add_log_chanel(sys_flogger)
33 sys_logger:info("%s", "创建sylog 日志文件 " .. appconf:get("syslog_file_path") .. "!")
34 end
35
36 fw.objpool.set_object(sys_logger, string.upper("sys_logger"))
37 end
38 fw.objpool.set_object(appconf, string.upper("appconf"))
39
40 _G.sys_logger = {
41 critical = function(fmt, ...)
42 if fw.objpool.get_object(string.upper("appconf")):get("syslog_enabled") then
43 fw.objpool.get_object(string.upper("sys_logger")):critical(fmt, ...)
44 end
45 end,
46 err = function(fmt, ...)
47 if fw.objpool.get_object(string.upper("appconf")):get("syslog_enabled") then
48 fw.objpool.get_object(string.upper("sys_logger")):error(fmt, ...)
49 end
50 end,
51 warning = function(fmt, ...)
52 if fw.objpool.get_object(string.upper("appconf")):get("syslog_enabled") then
53 fw.objpool.get_object(string.upper("sys_logger")):warning(fmt, ...)
54 end
55 end,
56 info = function(fmt, ...)
57 if fw.objpool.get_object(string.upper("appconf")):get("syslog_enabled") then
58 fw.objpool.get_object(string.upper("sys_logger")):info(fmt, ...)
59 end
60 end,
61 debug = function(fmt, ...)
62 if fw.objpool.get_object(string.upper("appconf")):get("syslog_enabled") then
63 fw.objpool.get_object(string.upper("sys_logger")):debug(fmt, ...)
64 end
65 end
66 }
67
68 self:finish()
69 end
70
71 function clm:onfinish()
72 sys_logger.info("%s", "执行check_log_measure结束,启动sys_logger成功!")
73 self:remove()
74 end
75
76 function clm:onremove()
77 sys_logger.info("%s", "移除check_log_measure!")
78 end
79
80 return clm
这边是启动sys_logger, 我在启动结束的时候添加到全局表,这样方便操作.启动sys_logger以后,方便记录app在运行时候的情况.出现了问题也方便定位.当然,不同开发者对于问题的处理方式是不一样的,我是习惯这样做.然后给出check_env_measure的源码:
1 --小岩<[email protected]>
2 --2015-5-27 17:53
3 local cem = class("check_env_measure", fw.measure)
4
5 function cem:ctor(dispatcher, next_m)
6 cem.super.ctor(self, dispatcher, next_m)
7 end
8
9 function cem:onlaunch()
10 sys_logger.info("%s", "启动check_env_measure!")
11 local envconf = fw.classickv.new("conf/env_conf")
12 fw.fileutil.set_search_paths(envconf:get("search_paths"))
13
14 local envprofile_cls = require "game.env_profile"
15 local envprofile = envprofile_cls.new()
16
17 envprofile:set_os_code(fw.platform.arch_code)
18 envprofile:set_os_name(fw.platform.arch_name)
19 envprofile:set_os_lancode(fw.platform.arch_lancode)
20 envprofile:set_os_lanname(fw.platform.arch_lanname)
21
22 envprofile:set_checkupdate(envconf:get("check_update"))
23 envprofile:set_updatealways(envconf:get("update_always"))
24 envprofile:set_http_server_url(envconf:get("http_server_url"))
25
26 envprofile:set_network_enabled(fw.network.is_network_enabled())
27 envprofile:set_network_type(fw.network.get_network_type())
28
29 fw.objpool.set_object(envconf, string.upper("envconf"))
30 fw.objpool.set_object(envprofile, string.upper("envprofile"))
31
32 self:finish()
33 end
34
35 function cem:onfinish()
36 sys_logger.info("%s", "执行check_env_measure结束,检查env成功!")
37 self:remove()
38 end
39
40 function cem:onremove()
41 sys_logger.info("%s", "移除check_env_measure!")
42 end
43
44 return cem
check_env主要是对平台的一些处理,我模仿操作系统去初始化一些环境变量,并以oop的方式添加到env_profile里面，env_profile主要是简单数据结构,提供的只是getter/setter方法。这里有一点需要注意的是,我根据配置文件修改了searchpaths,这主要是应对我们的更新模块,如果更新了新的文件,放在writable_path下面的一个指定目录,那么应该先从这个目录搜索,然后再去搜索apk中的资源目录.其他的环境变量有一些是配置文件配置的,有一些则是网络启用相关的判断,当然,在启动的过程中，依次初始化判定网络状态是不可靠的,因为网络状态可能随时关闭,不过我有仔细想过这个问题:在这么极短的时间内,我们可以认为这个环境变量是可靠的,所以不需要要担心这个问题了.
下面是配置文件env_conf:
1 search_paths = {
2 fw.platform.get_writable_path() .. "res",
3 fw.platform.get_writable_path() .. "src",
4 "res",
5 "src",
6 },
7
8 check_update = true,
9 update_always= true,
10
11 http_server_url = "http://192.168.1.131:8000/web/serverInfo",
配置文件我是使用classickv模式读取的,也就是支持lua syntax的,所以我们可以直接使用之前初始化的lua模块.这样很方便.我现在主要是配置了searchpath和更新模块的相应参数.下面看一下更新流程的源码:
1 --小岩<[email protected]>
2 --2015-5-27 17:59
3 local cum = class("check_update_measure", fw.measure)
4
5 function cum:ctor(dispatcher, next_m)
6 cum.super.ctor(self, dispatcher, next_m)
7 self.proxy_ = fw.proxy.new(self.dispatcher_)
8 self.percent_ = 0
9 end
10
11 function cum:onlaunch()
12 sys_logger.info("%s", "启动check_update_measure!")
13
14 self.proxy_:add_listener(fw.ircu.START_IRCU_UPDATE,
15 function(e)
16 self:on_START_IRCU_UPDATE(e)
17 end, self:get_name() .. "tag")
18 :add_listener(fw.ircu.CANNOT_CONN_TO_HOST,
19 function(e)
20 self:on_CANNOT_CONN_TO_HOST(e)
21 end, self:get_name() .. "tag")
22 :add_listener(fw.ircu.IRCU_UPDATE_FINISH_SUCC,
23 function(e)
24 self:on_IRCU_UPDATE_FINISH_SUCC(e)
25 end, self:get_name() .. "tag")
26 :add_listener(fw.ircu.IRCU_UPDATE_FINISH_PART,
27 function(e)
28 self:on_IRCU_UPDATE_FINISH_PART(e)
29 end, self:get_name() .. "tag")
30 :add_listener(fw.ircu.IRCU_UNCOMPRESS_FILE,
31 function(e)
32 self:on_IRCU_UNCOMPRESS_FILE(e)
33 end, self:get_name() .. "tag")
34 :add_listener(fw.ircu.ALREADY_NEWEST,
35 function(e)
36 self:on_ALREADY_NEWEST(e)
37 end, self:get_name() .. "tag")
38 :add_listener(fw.ircu.IRCU_UPDATE_START_PART,
39 function(e)
40 self:on_IRCU_UPDATE_START_PART(e)
41 end, self:get_name() .. "tag")
42
43 local envprofile = fw.objpool.get_object(string.upper("envprofile"))
44
45 if not envprofile:get_network_enabled() then
46 sys_logger.info("%s", "本地网络没开启, 不执行check_update!")
47 self:finish()
48 return
49 end
50 sys_logger.info("%s", "本地网络已开启,执行check_update!")
51
52 local ircu_update = fw.ircu.new(
53 self.dispatcher_,
54 envprofile:get_http_server_url(),
55 envprofile:get_network_type()
56 )
57
58 ircu_update:check_update()
59 end
60
61 function cum:on_START_IRCU_UPDATE(e)
62 sys_logger.info("%s", "------------------")
63 sys_logger.info("%s", "开始执行版本更新!")
64 end
65
66 function cum:on_CANNOT_CONN_TO_HOST(e)
67 sys_logger.info("%s", e.name)
68 sys_logger.info("%s", "执行版本更新失败!")
69 self:finish()
70 end
71
72 function cum:on_IRCU_UPDATE_FINISH_SUCC(e)
73 sys_logger.info("%s", e.name)
74 sys_logger.info("%s", "执行版本更新成功!")
75 self:finish()
76 end
77
78 function cum:on_IRCU_UPDATE_FINISH_PART(e)
79 sys_logger.info("%s", e.name)
80 sys_logger.info("%s [%s]", "成功更新版本", e.patch)
81 end
82
83 function cum:on_IRCU_UNCOMPRESS_FILE(e)
84 sys_logger.info("%s", e.name)
85 sys_logger.info("%s, -->[%s] [%.4f]", "成功解压", e.file, e.percent)
86 self.percent_ = self.percent_ + e.percent
87 sys_logger.info("%s --> [%.4f]", "更新总进度", self.percent_)
88 end
89
90 function cum:on_ALREADY_NEWEST(e)
91 sys_logger.info("%s", e.name)
92 sys_logger.info("%s", "已经是最新版本了, 不需要更新!")
93 self:finish()
94 end
95
96 function cum:on_IRCU_UPDATE_START_PART(e)
97 sys_logger.info("%s", e.name)
98 sys_logger.info("%s --[%s] [%.4f]", "开始下载", e.path, e.size/e.total*100)
99 end
100
101 function cum:onfinish()
102 sys_logger.info("%s", "执行check_update_measure结束!")
103 self:remove()
104 end
105
106 function cum:onremove()
107 sys_logger.info("%s", "移除check_update_measure!")
108 self.proxy_:remove_all_listeners()
109 end
110
111
112 return cum
可以看到这个流程其实主要都是处理ircu模块抛出的事件,然后就执行流程跳转的相关操作.根据之前的env_conf配置文件中的相关参数,我们可以给项目添加debug开关，如果在开发过程中可以屏蔽掉更新模块,当然我是没有添加
这个也很容易做到.在合适的配置添加:
1 if not envprofile:get("check_update") then
2 sys_logger.info("%s", "更新模块没有开启!“)
3 self:finish()
4 return
5 end
这个还是很简单的.下面就看看ircu模块,也就是我们的增量更新模块：
1 --小岩<[email protected]>
2 --2015-5-28 17:44
3 local network = require "fw.util.network"
4 local fileutil= require "fw.util.fileutil"
5 local encrypt = require "fw.util.encrypt"
6 local ini = require "fw.util.ini"
7
8 local ircu = class("ircu")
9
10 ircu.CANNOT_CONN_TO_HOST = "CANNOT_CONNECTION_TO_HOST"
11 ircu.START_IRCU_UPDATE = "START_IRCU_UPDATE"
12 ircu.ALREADY_NEWEST = "ALREADY_NEWEST"
13 ircu.IRCU_UPDATE_FINISH_SUCC = "IRCU_UPDATE_FINISH_SUCC"
14 ircu.IRCU_UPDATE_FINISH_PART = "IRCU_UPDATE_FINISH_PART"
15 ircu.IRCU_UNCOMPRESS_FILE = "IRCU_UNCOMPRESS_FILE"
16 ircu.IRCU_UPDATE_START_PART = "IRCU_UPDATE_START_PART"
17
18 ircu.TMP = fileutil.get_writable_path() .. "TMP"
19
20 function ircu:ctor(dispatcher, http_server_url, network_type)
21 self.dispatcher_ = dispatcher
22 self.http_server_url_ = http_server_url
23 self.http_request_ = cc.XMLHttpRequest:new()
24 self.responseType = cc.XMLHTTPREQUEST_RESPONSE_STRING
25 self.network_type_ = network_type
26 end
27
28 function ircu:check_update()
29 self:check_local_version_file()
30 self:requrest_http_server_url()
31 end
32
33 --检查本地版本文件
34 function ircu:check_local_version_file()
35 local local_version_file = fileutil.get_writable_path() .. "version"
36 if not fileutil.is_exists(local_version_file) then
37 fileutil.write_content(local_version_file, encrypt.encrypt("[current]\nv=0"), "wb")
38 end
39 end
40
41 --请求http服务器地址
42 function ircu:requrest_http_server_url()
43 self.http_request_:open("GET", self.http_server_url_)
44 self.http_request_:registerScriptHandler(function()
45 if self.http_request_.readyState == 4 and (self.http_request_.status >= 200 and self.http_request_.status <= 207) then
46 self.dispatcher_:dispatch({name = ircu.START_IRCU_UPDATE})
47 self:requrest_version_file(self.http_request_.response)
48 elseif self.http_request_.readyState == 1 then
49 self.dispatcher_:dispatch({name = ircu.CANNOT_CONN_TO_HOST})
50 end
51 end)
52 self.http_request_:send()
53 end
54
55 --请求版本文件
56 function ircu:requrest_version_file(version_file_url)
57 self.http_request_:open("GET", version_file_url)
58 self.http_request_:registerScriptHandler(function()
59 if self.http_request_.readyState == 4 and (self.http_request_.status >= 200 and self.http_request_.status <= 207) then
60 if self.network_type_ == network.t.WIFI then
61 self:update_wifi_mode(self.http_request_.response)
62 elseif self.network_type_ == network.t.GPRS then
63 self:update_gprs_mode(self.http_request_.response)
64 end
65 elseif self.http_request_.readyState == 1 then
66 self.dispatcher_:dispatch({name = ircu.CANNOT_CONN_TO_HOST})
67 end
68 end)
69 self.http_request_:send()
70 end
71
72 function ircu:update_wifi_mode(version_file_content)
73 local tmp_version_file = fileutil.get_writable_path() .. "tmp_version"
74 fileutil.write_content(tmp_version_file, encrypt.encrypt(version_file_content), "wb")
75 self.tmp_ini = ini.new(tmp_version_file)
76
77 local tmp_t = {}
78 local total_size = 0
79
80 for s, _ in pairs(self.tmp_ini.props_) do
81 table.insert(tmp_t, s)
82 end
83
84 --给版本排序
85 table.sort(tmp_t, function(v1, v2)
86 return tonumber(v1) <= tonumber(v2)
87 end)
88
89 self.local_version_ini_ = ini.new(fileutil.get_writable_path() .. "version")
90 local local_version = self.local_version_ini_:get("current", "v")
91
92 --检查是不是最新版本
93 if tonumber(local_version) == tonumber(tmp_t[#tmp_t]) then
94 self.dispatcher_:dispatch({name = ircu.ALREADY_NEWEST})
95 return
96 end
97
98 local tt = {}
99
100 for _, v in ipairs(tmp_t) do
101 if tonumber(v) >= tonumber(local_version) then
102
103 table.insert(tt, v)
104 total_size = total_size + tonumber(self.tmp_ini:get(v, "size"))
105 end
106 end
107
108 self.new_version_t_ = tt
109 self.total_size_ = total_size
110
111 self:download_patch()
112 end
113
114 function ircu:update_gprs_mode(version_file_content)
115
116 end
117
118 function ircu:download_patch()
119 if #self.new_version_t_ == 0 then
120 self.dispatcher_:dispatch({name = ircu.IRCU_UPDATE_FINISH_SUCC})
121 fileutil.remove(ircu.TMP)
122 return
123 end
124
125 fw.ircu_helper.download(self.tmp_ini:get(self.new_version_t_[1], "path"), ircu.TMP,
126 function(code) end,
127 function(p)
128 if p == 100 then
129 local patch_size = tonumber(self.tmp_ini:get(self.new_version_t_[1], "size"))
130 local patch_percent = patch_size / self.total_size_
131 self.dispatcher_:dispatch({
132 name = ircu.IRCU_UPDATE_START_PART,
133 path = self.new_version_t_[1],
134 size = patch_size,
135 total= self.total_size_
136 })
137
138
139 fw.ircu_helper.uncompress(fileutil.get_writable_path(), ircu.TMP,
140 function(f, n, t)
141 self.dispatcher_:dispatch({
142 name = ircu.IRCU_UNCOMPRESS_FILE,
143 file = f,
144 num = n,
145 total = t,
146 percent = 1/t*patch_percent * 100,
147 })
148 end,
149
150 function()
151 self.local_version_ini_:update("current", "v", self.new_version_t_[1])
152 self.local_version_ini_:save()
153 self.dispatcher_:dispatch({name = ircu.IRCU_UPDATE_FINISH_PART, patch=self.new_version_t_[1]})
154 table.remove(self.new_version_t_, 1)
155 self:download_patch()
156 end)
157 end
158 end
159 )
160 end
161
162 return ircu
这个模块使用很简单,需要注意的就是下面这几个抛出的事件就行了,我将这个模块独立封装出来,就是依靠事件来保持低耦合的.
1 ircu.CANNOT_CONN_TO_HOST = "CANNOT_CONNECTION_TO_HOST" 2 ircu.START_IRCU_UPDATE = "START_IRCU_UPDATE" 3 ircu.ALREADY_NEWEST = "ALREADY_NEWEST" 4 ircu.IRCU_UPDATE_FINISH_SUCC = "IRCU_UPDATE_FINISH_SUCC" 5 ircu.IRCU_UPDATE_FINISH_PART = "IRCU_UPDATE_FINISH_PART" 6 ircu.IRCU_UNCOMPRESS_FILE = "IRCU_UNCOMPRESS_FILE" 7 ircu.IRCU_UPDATE_START_PART = "IRCU_UPDATE_START_PART"
当然,这几个事件除了错误代码之外,其他都是用来做更新界面百分比显示,以及显示更新信息的.ircu模块中使用了我写的c++的异步下载和解压函数.也就是fw.ircu_helper.download/uncompress.下面我给出我的这个C++模块:
1 #include "lua_ircu.h"
2 #include "tolua_fix.h"
3 #include "CCLuaEngine.h"
4 #include <curl/curl.h>
5 #include <curl/easy.h>
6 #include <stdio.h>
7 #include <vector>
8 #include <thread>
9
10 #include <cocos2d.h>
11
12 #if (CC_TARGET_PLATFORM != CC_PLATFORM_WIN32) && (CC_TARGET_PLATFORM != CC_PLATFORM_WP8) && (CC_TARGET_PLATFORM != CC_PLATFORM_WINRT)
13 #include <sys/types.h>
14 #include <sys/stat.h>
15 #include <errno.h>
16 #include <dirent.h>
17 #endif
18
19 #ifdef MINIZIP_FROM_SYSTEM
20 #include <minizip/unzip.h>
21 #else
22 #include "unzip.h"
23 #endif
24
25 #if __cplusplus
26 extern "C" {
27 #endif
28 #include <lualib.h>
29 #include <lauxlib.h>
30 #if __cplusplus
31 }
32 #endif
33
34 #define BUFFER_SIZE 8192
35 #define MAX_FILENAME 512
36
37 #define LOW_SPEED_LIMIT 1L
38 #define LOW_SPEED_TIME 5L
39
40 bool createDirectory(const char *path)
41 {
42 #if (CC_TARGET_PLATFORM == CC_PLATFORM_WINRT) || (CC_TARGET_PLATFORM == CC_PLATFORM_WP8)
43 return FileUtils::getInstance()->createDirectory(_storagePath.c_str());
44 #elif (CC_TARGET_PLATFORM == CC_PLATFORM_WIN32)
45 BOOL ret = CreateDirectoryA(path, nullptr);
46 if (!ret && ERROR_ALREADY_EXISTS != GetLastError())
47 {
48 return false;
49 }
50 return true;
51 #else
52 mode_t processMask = umask(0);
53 int ret = mkdir(path, S_IRWXU | S_IRWXG | S_IRWXO);
54 umask(processMask);
55 if (ret != 0 && (errno != EEXIST))
56 {
57 return false;
58 }
59
60 return true;
61 #endif
62 }
63
64 static int
65 lua_fw_ircu_download(lua_State* lua_state) {
66 std::string url = lua_tostring(lua_state, 1);
67 std::string tmppath = lua_tostring(lua_state, 2);
68 int h1 = toluafix_ref_function(lua_state, 3, 0);
69 int h2 = toluafix_ref_function(lua_state, 4, 0);
70 auto t = std::thread(fw::ircu::download, url, tmppath, h1, h2);
71 t.detach();
72 return 0;
73 }
74
75 static int
76 lua_fw_ircu_uncompress(lua_State* lua_state) {
77 std::string dstpath = lua_tostring(lua_state, 1);
78 std::string filepath = lua_tostring(lua_state, 2);
79 int h1 = toluafix_ref_function(lua_state, 3, 0);
80 int h2 = toluafix_ref_function(lua_state, 4, 0);
81 auto t = std::thread(fw::ircu::uncompress, dstpath, filepath, h1, h2);
82 t.detach();
83 return 0;
84 }
85
86 namespace fw {
87
88 static size_t
89 downloadPatch(void *ptr, size_t size, size_t nmemb, void *userdata) {
90 FILE *fp = (FILE*)userdata;
91 size_t written = fwrite(ptr, size, nmemb, fp);
92 return written;
93 }
94
95 static int
96 downloadProgressFunc(void *ptr, double totalToDownload, double nowDownloaded, double totalToUpLoad, double nowUpLoaded) {
97 typedef cocos2d::LuaStack LuaStack;
98 typedef cocos2d::LuaEngine LuaEngine;
99 LuaStack *pStack = LuaEngine::getInstance()->getLuaStack();
100 static int percent = 0;
101 int tmp = (int)(nowDownloaded / totalToDownload * 100);
102 if (percent != tmp)
103 {
104 percent = tmp;
105 cocos2d::Director::getInstance()->getScheduler()->performFunctionInCocosThread([=]{
106 pStack->pushInt(tmp);
107 pStack->executeFunctionByHandler((int)ptr,1);
108 });
109 }
110 return 0;
111 }
112
113
114 void
115 ircu::download(const std::string& url, const std::string& tmppath, int h1, int h2) {
116 typedef cocos2d::LuaStack LuaStack;
117 typedef cocos2d::LuaEngine LuaEngine;
118 LuaStack *pStack = LuaEngine::getInstance()->getLuaStack();
119
120 FILE *fp = fopen(tmppath.c_str(), "wb");
121 if(!fp) {
122 cocos2d::Director::getInstance()->getScheduler()->performFunctionInCocosThread([=]{
123 if (h1)
124 pStack->pushInt(ircu::CREATE_FILE);
125 pStack->executeFunctionByHandler(h1,1);
126 });
127 return;
128 }
129 void *_curl;
130 _curl = curl_easy_init();
131
132 if(!_curl) {
133 return;
134 }
135
136 CURLcode res;
137 curl_easy_setopt(_curl, CURLOPT_URL, url.c_str());
138 curl_easy_setopt(_curl, CURLOPT_WRITEFUNCTION, downloadPatch);
139 curl_easy_setopt(_curl, CURLOPT_WRITEDATA, fp);
140 curl_easy_setopt(_curl, CURLOPT_NOPROGRESS, false);
141 curl_easy_setopt(_curl, CURLOPT_PROGRESSFUNCTION, downloadProgressFunc);
142 curl_easy_setopt(_curl, CURLOPT_PROGRESSDATA, h2);
143 curl_easy_setopt(_curl, CURLOPT_NOSIGNAL, 1L);
144 curl_easy_setopt(_curl, CURLOPT_LOW_SPEED_LIMIT, LOW_SPEED_LIMIT);
145 curl_easy_setopt(_curl, CURLOPT_LOW_SPEED_TIME, LOW_SPEED_TIME);
146 curl_easy_setopt(_curl, CURLOPT_FOLLOWLOCATION, 1 );
147
148 res = curl_easy_perform(_curl);
149 curl_easy_cleanup(_curl);
150
151 if (res != 0 ) {
152 cocos2d::Director::getInstance()->getScheduler()->performFunctionInCocosThread([=]{
153 pStack->pushInt(ircu::NETWORK);
154 pStack->executeFunctionByHandler(h1,1);
155 });
156 fclose(fp);
157 return;
158 }
159
160 fclose(fp);
161 return;
162 }
163
164 void
165 ircu::uncompress(const std::string& dstpath, const std::string& filepath, int h1, int h2) {
166 typedef cocos2d::LuaStack LuaStack;
167 typedef cocos2d::LuaEngine LuaEngine;
168 LuaStack *pStack = LuaEngine::getInstance()->getLuaStack();
169
170 unzFile zipFile = cocos2d::unzOpen(filepath.c_str());
171 if (!zipFile) {
172 return;
173 }
174 cocos2d::unz_global_info global_info;
175 if (cocos2d::unzGetGlobalInfo(zipFile, &global_info) != UNZ_OK) {
176 cocos2d::unzClose(zipFile);
177 return ;
178 }
179 char readBuffer[BUFFER_SIZE];
180 uLong i;
181
182 for (i = 0; i < global_info.number_entry; ++i)
183 {
184 cocos2d::unz_file_info fileInfo;
185 char fileName[MAX_FILENAME];
186 if (cocos2d::unzGetCurrentFileInfo(zipFile,
187 &fileInfo,
188 fileName,
189 MAX_FILENAME,
190 nullptr,
191 0,
192 nullptr,
193 0) != UNZ_OK)
194 {
195 cocos2d::unzClose(zipFile);
196 return;
197 }
198
199 const std::string fullPath = dstpath + "/" + fileName;
200
201 const size_t filenameLength = strlen(fileName);
202 if (fileName[filenameLength-1] == ‘/‘)
203 {
204 if (!createDirectory(fullPath.c_str()))
205 {
206 cocos2d::unzClose(zipFile);
207 return;
208 }
209 }
210 else
211 {
212 const std::string fileNameStr(fileName);
213
214 size_t startIndex=0;
215
216 size_t index=fileNameStr.find("/",startIndex);
217
218 while(index != std::string::npos)
219 {
220 const std::string dir=dstpath+fileNameStr.substr(0,index);
221
222 FILE *out = fopen(dir.c_str(), "r");
223
224 if(!out)
225 {
226 if (!createDirectory(dir.c_str()))
227 {
228 cocos2d::unzClose(zipFile);
229 return;
230 }
231 else
232 {
233 //CCLOG("create directory %s",dir.c_str());
234 }
235 }
236 else
237 {
238 fclose(out);
239 }
240
241 startIndex=index+1;
242
243 index=fileNameStr.find("/",startIndex);
244
245 }
246
247 if (cocos2d::unzOpenCurrentFile(zipFile) != UNZ_OK)
248 {
249 cocos2d::unzClose(zipFile);
250 return;
251 }
252
253 FILE *out = fopen(fullPath.c_str(), "wb");
254 if (! out)
255 {
256 cocos2d::unzCloseCurrentFile(zipFile);
257 cocos2d::unzClose(zipFile);
258 return;
259 }
260
261 int error = UNZ_OK;
262 do
263 {
264 error = cocos2d::unzReadCurrentFile(zipFile, readBuffer, BUFFER_SIZE);
265 if (error < 0)
266 {
267 cocos2d::unzCloseCurrentFile(zipFile);
268 cocos2d::unzClose(zipFile);
269 return;
270 }
271
272 if (error > 0)
273 {
274 fwrite(readBuffer, error, 1, out);
275 }
276 } while(error > 0);
277
278 fclose(out);
279
280
281 }
282 cocos2d::Director::getInstance()->getScheduler()->performFunctionInCocosThread([=](){
283 pStack->pushString(fullPath.c_str());
284 pStack->pushInt(i+1);
285 pStack->pushInt(global_info.number_entry);
286 pStack->executeFunctionByHandler(h1, 3);
287 });
288
289 cocos2d::unzCloseCurrentFile(zipFile);
290
291 if ((i+1) < global_info.number_entry)
292 {
293 if (cocos2d::unzGoToNextFile(zipFile) != UNZ_OK)
294 {
295 cocos2d::unzClose(zipFile);
296 return;
297 }
298 }
299 }
300 cocos2d::Director::getInstance()->getScheduler()->performFunctionInCocosThread([=](){
301 pStack->executeFunctionByHandler(h2, 0);
302 });
303
304 cocos2d::unzClose(zipFile);
305 return;
306 }
307
308 const luaL_reg g_ircu_funcs[] = {
309 {"download", lua_fw_ircu_download},
310 {"uncompress", lua_fw_ircu_uncompress},
311 {NULL, NULL},
312 };
313
314 void
315 register_fw_ircu(lua_State* lua_state) {
316 luaL_register(lua_state, "fw.ircu_helper", g_ircu_funcs);
317 }
318 }
好吧,就到这里了.下面来说一下log. 之前我也写过log模块,但是没有文件记录模块,我这边想要的功能就是同时在终端显示,然后又可以写入到文件.好了,从这个需求出发,我到Github去浏览了一下lua的代码,最后发现了zengrong的仓库, 这里给出他的地址: github.com/zengrong.所以我就从他的log模块取出了部分修改了一下:
1 --小岩<[email protected]>
2 --2015-5-28 1:37
3 local l = class("logger")
4
5 l.CRITICAL = 50
6 l.ERROR = 40
7 l.WARNING = 30
8 l.INFO = 20
9 l.DEBUG = 10
10 l.NOSET = 0
11
12 function l:ctor(level, ...)
13 self:set_limit_level(level or l.NOSET)
14 self.chanels_ = {...}
15 end
16
17 function l:set_limit_level(ll)
18 self.ll_ = ll
19 end
20
21 function l:get_limit_level()
22 return self.ll_
23 end
24
25 function l:add_log_chanel(lc)
26 self.chanels_[#self.chanels_ + 1] = lc
27 end
28
29 function l:clear_chanel()
30 self.chanels_ = {}
31 end
32
33 function l:flush()
34 for __, lc in pairs(self.chanels_) do
35 lc:flush()
36 end
37 end
38
39 function l:log(level, fmt, ...)
40 if level < self.ll_ then
41 return
42 end
43 args = {...}
44 for __, lc in pairs(self.chanels_) do
45 lc:emit(level, fmt, args)
46 end
47 end
48
49 function l:critical(fmt, ...)
50 self:log(l.CRITICAL, fmt, ...)
51 end
52
53 function l:error(fmt, ...)
54 self:log(l.ERROR, fmt, ...)
55 end
56
57 function l:warning(fmt, ...)
58 self:log(l.WARNING, fmt, ...)
59 end
60
61 function l:info(fmt, ...)
62 self:log(l.INFO, fmt, ...)
63 end
64
65 function l:debug(fmt, ...)
66 self:log(l.DEBUG, fmt, ...)
67 end
68
69 return l
我这边只是给出了logger的接口,如果需要的话,请直接去看zr的github.请原谅我并没有在源码中给出引用出处.下面就是app配置Logger的文件:
1 luagarbage_setpause_val = 100,
2 luagarbage_setstepmul_val = 5000,
3
4 app_name = "firework 小岩<[email protected]>",
5
6 gl_win_size = cc.rect(0,0,960, 640),
7 gl_frame_size = cc.size(1140, 650),
8
9 dr_size = cc.size(480, 320),
10 dr_policy = cc.ResolutionPolicy.FIXED_HEIGHT,
11
12 show_status = false,
13
14 animation_interval = 1/60,
15
16 app = "game.application",
17
18 syslog_enabled = true,
19 syslog_console_enabled = true,
20 syslog_console_printfun = function(str)
21 print(">> syslog " .. str)
22 end,
23 syslog_limit_level = fw.logger.NOSET,
24
25 syslog_file_enabled = true,
26 syslog_file_autoflush = true,
27 syslog_file_parser = function(str)
28 return fw.encrypt.encrypt(str .. ‘\n‘)
29 end,
30 syslog_file_dir = fw.platform.get_writable_path() .. "log",
31 syslog_file_path= fw.platform.get_writable_path() .. "log/sys_log",
当然,这份是app配置文件，可以看到在logger写入函数我采用了xxtea加密方式写入,如果在开发期,可以屏蔽掉加密.直接写入就好了.当然也可以不写.好了,就到这里了.
这里是可以添加测试用例的,方法就是修改其中的app属性配置,从app.lua继承实现一个自己的test_application,然后修改配置文件，启动的时候就切换了入口.看需求添加吧,如果是有独立封装的ui类库以及其他独立功能可以考虑添加测试用例.又或者是需要添加工具,也可以在这里做考虑。
这次的文章篇幅比较的长,希望大家耐心点看. 终于我算是完成了自己的承诺了. 嘻嘻嘻嘻嘻~
时间： 2024-10-05 23:09:14