APNs功能之Node.js和Mysql应用总结.doc

这篇文档主要是总结Node.js和Mysql的学习心得体会。当然也可以看作是此前所写的消息推送服务的续篇。 简单描述下应用背景，我们的应用需要实现苹果的消息推送服务APNs，之前已经实现了iOS客户端配置和功能代码，也实现了推送通知的本地Provider功能代码，具体参考此前的系列总结。好比一个三角形，A点代表iOS移动设备端，B点代表苹果的消息推送服务器，C点代表应用开发者的本地服务器，现在A和B连接好了，B和C也连接好了，就差A和B建立连接沟通。 这样一来，很明显就是要在本地搭建一个服务器了，可以处理A发送的请求；当然也少不了数据库，用来存储相关数据。 说到这里，不同技术背景的人会有不同的方案，在此我采用了Node.js+Mysql的解决方案。当然其他方案如ASN.NET、JSP、PHP加上SQLServer、Mysql、MongoDB等等就不谈论了。纯粹作为技术学习和新方案的尝试。 Node.js 作为这篇文档的重点内容，Node.js肯定是要优先总结的。 我这种刚学习Node.js的新手，就不敢把此文当做Node.js的入门资料了，只是简单介绍一下，然后直接根据应用需求实现代码。 Node.js实现了服务端Javascript，通过简单快捷的环境搭建，就可以实现一个运行Javascript的服务器。1、 去官网下载最新的Node.js安装程序。说明一下，我是在Windows32位操作系统上安装，所以下载Windows对应安装程序即可。我的版本为：node-v0.10.24-x86。2、 安装Node.js。3、 在开始所有程序中，找到Node.js的命令行程序Node.js command prompt并运行好了，至此，你已经可以开始编程了。就是这么简单快捷。或许很多人还是很困惑，那在哪里写代码呢，命令行？在此，我要说一下刚接触时候我的感受：我觉得很郁闷，不知道从何入手。对于很多新手，大家需要的是把事情说明白一点，而不是玄乎。可以这样理解，Node.js就是一个服务器，用于搭载Javascript、CSS、Html等网页所可以有的一切。但是他本身不集成IDE。再具体点，他的出现，使我们可以不用熟悉的IIS、Apache、Tomcat来部署了，只需要运行Node.js，然后通过一句话“node xxx.js”，加载已经写好的Javascript，就一切OK了。是的，Javascript，那用你熟悉的任何方式和工具去书写吧。Notepad+是我选择的工具。一定还有疑惑，没关系，我们先来看实例。下列实例实现一个可以上传图片文件并预览的页面，还有一个向数据库插入一条数据的请求。先看这个例子NodejsDemo的文件夹结构说明：index.js是入口，server.js用于启动服务，router.js用于路由请求，requesHandlers.js用于处理路由后的对应请求，mysqlOperation.js用于处理数据库操作，mysqlDBHelper.js用于连接数据库并操作接下就是具体代码部分了，太多语法我无法一下说清楚，在需要的地方，我会稍加说明，想了解更多，建议去官网查看API说明，毕竟是抛砖引玉哈。 Index.js的代码： 1 var server = require(./server); 2 3 var router = require(./router); 4 5 var requestHandlers = require(./requestHandlers); 6 7 8 9 var handle = 10 11 handle/ = requestHandlers.start;12 13 handle/start = requestHandlers.start;14 15 handle/upload = requestHandlers.upload;16 17 handle/show = requestHandlers.show;18 19 handle/sendMyInfo = requestHandlers.sendMyInfo;20 21 22 23 server.start(router.route, handle);View Code 说明：这是示例的入口，最后一句，调用server中的start方法，并传递两个参数，第一个是router中route函数，第二个是类似字典实例的handle。 server.js的代码： 1 var http = require(http); 2 3 var url = require(url); 4 5 function start(route, handle) 6 7 function onRequest(req,res) 8 9 var pathname = url.parse(req.url).pathname;10 11 console.log(Request for + pathname + received.);12 13 14 15 route(handle, pathname, res,req); 16 17 18 19 http.createServer(onRequest).listen(1337, Your IP);20 21 console.log(Server running at http:/Your IP:1337/);22 23 24 25 26 27 exports.start = start;View Code 说明：与require(“./server”)调用同级目录js文件不同，require(http)是生成一个http对象实例的方法。url.parse(string).pathname用于获取url字符串中路径名称。Your IP为本机的IP地址。http.createServer(function).listen(端口号，IP)用于通过一个方法创建一个服务，并在设置的iP和端口号监听。Exports.start=start为其他js对象调用本方法暴露接口。route.js的代码 1 function route(handle, pathname, res, req) 2 3 console.log(About to route a request for + pathname); 4 5 if(typeof handlepathname = function) 6 7 handlepathname(res, req); 8 9 else10 11 console.log(No request handler found for + pathname);12 13 res.writeHead(404, Content-Type: text/plain);14 15 res.end(404 route not found);16 17 18 19 20 21 22 23 exports.route = route;View Code 说明：路由请求，当请求未定义的路径时，则在response的head里面返回404错误。requestHanlders.js的代码： 1 var querystring = require (querystring); 2 3 var url = require(url); 4 5 var fs = require(fs); 6 7 var formidable = require(formidable); 8 9 var util = require(util); 10 11 var mysqlOperation = require(./mysqlOperation); 12 13 var testPicPath = /testPic/test.png; 14 15 function start(res, req) 16 17 console.log(Request handler start was called.); 18 19 var body = + 20 21 + 22 23 + 26 27 + 28 29 + 30 31 + 32 33 + 34 35 + 36 37 + 38 39 + 40 41 ; 42 43 res.writeHead(200, Content-Type: text/html); 44 45 res.end(body); 46 47 48 49 50 51 function upload(res, req) 52 53 console.log(Request handler upload was called.); 54 55 56 57 var form = new formidable.IncomingForm(); 58 59 60 61 console.log(about to parse); 62 63 64 65 form.parse (req, function(error, fields, files) 66 67 console.log(parsing done); 68 69 /* res.writeHead(200,Content-type:text/plain); 70 71 res.write(received upload:nn); 72 73 res.write(util.inspect(fields:fields,files:files); */ 74 75 76 77 fs.rename(files.upload.path, /testPic/ + , function(err) 78 79 if(err) throw err; 80 81 console.log(renamed complete); 82 83 testPicPath = /testPic/ + ; 84 85 86 87 res.writeHead (200, Content-Type: text/html); 88 89 90 91 res.write (received image:); 92 93 94 95 res.write (); 96 97 98 99 res.end();100 101 ); 102 103 );104 105 106 107 108 109 function show(res, req) 110 111 console.log(Request handler show was called.);112 113 fs.readFile (testPicPath, binary, function(error, file) 114 115 if(error) 116 117 res.writeHead (500, Content-Type: text/plain);118 119 res.write (Image error: + error + n);120 121 res.end();122 123 else 124 125 res.writeHead (200, Content-Type: image/png);126 127 res.write (file, binary);128 129 res.end();130 131 132 133 );134 135 136 137 138 139 function sendMyInfo(res,req)140 141 console.log(Request handler sendMyInfo was called.);142 143 var urlstring = url.parse(req.url).query;144 145 var user = 146 147 name : querystring.parse(urlstring).name,148 149 country : querystring.parse(urlstring).country,150 151 city : querystring.parse(urlstring).city,152 153 street : querystring.parse(urlstring).street154 155 ;156 157 158 159 if( = undefined | user.country = undefined160 161 | user.city = undefined | user.street = undefined)162 163 res.writeHead (500, Content-Type: text/plain);164 165 res.write (error: paras undefined.);166 167 res.end();168 169 console.log(error: paras undefined.);170 171 return;172 173 174 175 176 177 console.log(user);178 179 mysqlOperation.storeUserInfo(user,res);180 181 182 183 184 185 exports.start = start;186 187 exports.upload = upload;188 189 exports.show = show;190 191 exports.sendMyInfo = sendMyInfo;View Code 说明：这个js文件是处理请求的主要地方，当路由路径后，会找到相应方法。这里需要重点说一下start方法。在返回response内容时候，直接采用字符串方式表达body，当然这是不好的习惯，那么在疑惑页面的朋友就可以在这里找到答案了。Node.js有负责加载页面的API，还有类似于模板页的结构，以前熟悉的方式依然可以使用。至于其他方法，相信你会看明白的。还有，为什么错误返回码总是500呢，因为是我随意设置的。 至此，一个简单的Node.js的demo就完成了，噢，忘了方法sendMyInfo，那是等下继续要说的。马上运行Node.js的命令行程序，然后在“路径”后面输入“node index.js路径”，回车就可以看到Server running的输出提示了。在浏览器里面访问“Your IP：Your port/”。多说一句，index.js的全路径是绝对无误的，当index.js处于用户根目录时，可以直接输入“node index.js”；当index.js处于node.js的安装磁盘根目录时候，可以直接输入“node /index.js”。 在方法sendMyInfo中，我试图向数据库中插入一条记录。那就接着进入node.js的数据库连接和操作吧。 Node.js的数据库操作之创建数据库我们可以先在Mysql数据库里面创建好一个新的database和一个用户表users。也可以通过Node.js来创建，代码如下： 1 var mysql = require(mysql); 2 3 var db_options = 4 5 host: localhost, 6 7 port: 3306, 8 9 user: root, 10 11 password: Your password 12 13 ; 14 15 var client = new mysql.createConnection(db_options); 16 17 18 19 /要创建的数据库名 20 21 var TEST_DATABASE = NodeJsTest, 22 23 /要创建的表名 24 25 TEST_TABLE = Users; 26 27 28 29 client.query(show databases, function(err, rows, fields) 30 31 if(err) 32 33 console.log(err); 34 35 else 36 37 console.log(rows); 38 39 40 41 ); 42 43 44 45 client.query(CREATE DATABASE +TEST_DATABASE, function(err) 46 47 if (err & err.number != client.ERROR_DB_CREATE_EXISTS) 48 49 throw err; 50 51 52 53 ); 54 55 56 57 / If no callback is provided, any errors will be emitted as error 58 59 / events by the client 60 61 client.query(USE +TEST_DATABASE); 62 63 client.query( 64 65 CREATE TABLE +TEST_TABLE+ 66 67 name VARCHAR(255), + 68 69 country VARCHAR(255),+ 70 71 city VARCHAR(255), + 72 73 street VARCHAR(255), 74 75 ); 76 77 78 79 client.query( 80 81 INSERT INTO +TEST_TABLE+ + 82 83 SET name = ?, country = ?, city = ?, street = ?, 84 85 Li Lei, China, Bei jing, 86 87 ); 88 89 90 91 client.query(USE +TEST_DATABASE); 92 93 client.query( 94 95 SELECT * FROM +TEST_TABLE, 96 97 function selectCb(err, results, fields) 98 99 if (err) 100 101 throw err; 102 103 104 105 106 107 console.log(results);108 109 console.log();110 111 console.log(results.length); 112 113 console.log(fields); 114 115 116 117 ); 118 119 120 121 client.end();View Code 说明：Your password为你的Mysql数据库密码。好了，可以将代码所在的js文件直接加载到命令行中，方法还是“node xxxx.js”。如果你之前已经在运行index.js了，那么按下crtrl+C停下之前的服务。我想运行结果会成功的，除非node.js的API又升级了，这个时候就去查官网API吧。 Node.js的数据库操作之插入数据 1 var mysql = require(mysql); 2 3 var db_options = 4 5 host: localhost, 6 7 port: 3306, 8 9 user: root, 10 11 password: Your password 12 13 ; 14 15 16 17 /database name 18 19 var DATABASE = NodeJsTest, 20 21 /table name 22 23 TABLE = Users; 24 25 function storeUserInfo(user, res) 26 27 if( = ) 28 29 res.writeHead (600, Content-Type: text/plain); 30 31 res.write (error: name can not be empty.n); 32 33 res.end(); 34 35 return; 36 37 38 39 var client = new mysql.createConnection(db_options); 40 41 client.query(USE +DATABASE); 42 43 44 45 client.query( 46 47 SELECT * FROM + TABLE + WHERE name = ?, 48 49 , 50 51 function(err, results, fields) 52 53 if (err) 54 55 client.end(); 56 57 res.writeHead (700, Content-Type: text/plain); 58 59 res.write (error: + err); 60 61 res.end(); 62 63 return; 64 65 66 67 68 69 console.log(results.length); 70 71 if(results.length 1) 72 73 /Added new record 74 75 client.query( 76 77 INSERT INTO + TABLE + SET name = ?, country = ?, city = ?, street = ? , , user.country, user.city, user.street, 78 79 function(err, results, fields) 80 81 if (err) 82 83 client.end(); 84 85 res.writeHead (700, Content-Type: text/plain); 86 87 res.write (error: + err); 88 89 res.end(); 90 91 return; 92 93 94 95 96 97 client.end(); 98 99 res.writeHead (200, Content-Type: text/plain);100 101 res.write (added new user);102 103 res.end();104 105 console.log(results); 106 107 console.log(fields); 108 109 110 111 ); 112 113 else if(results.length = 1)114 115 /Update record116 117 client