Node 服务器开发入门
很久没有更新博客了，应该最近在负责一个车联网项目，里面用到Node 的TCP相关Api和Http相关Api，最近抽空就写下相关主要的笔记以便遗忘。
1、Node 简介?
2、Node 环境搭建?
3、Node Http Api?
4、Node Socket Api?
5、怎么样结合两者实现Http 向Tcp 发消息?
本篇博客主要介绍下，Node在硬件通讯方面的实践。
1、Node 简介?
现在主流的前端服务端框架，只要稍微有点关注前端技术的童鞋应该都知道这个框架，它是一个基于 Chrome V8 引擎的 JavaScript 运行库，使用高效、轻量级的事件驱动、非阻塞 I/O 模型，当然以上来自官方文档 nodejs.org,更加详细的介绍大家可以直接翻阅官方文档，任何时候最好的学习资料都是官方文档，后面会用到的Api 也基本是翻阅了官方文档。
2、Node 环境搭建?
一 windows
Node 在window下安装很简单，直接下载msi 安装包，双击安装即可。Node安装完成后会自带安装Npm，Npm是一个包管理器，有点类似于Java中的Maven,通过Npm我们可以直接下载很多三方包，而不必自己去下载引入。更多资料可以查看Npm 官网Npm官网;Node安装好了后，直接在控制台中输入下面的命令查看版本。如果正确输出，代表安装成功。Npm 官方默认的仓库下载速度会比较慢，大家可以用淘宝的镜像仓库Cnpm，具体怎么切换可以百度这里不说明。
npm -v 或者 node -v
二 Linux
1.下载源码，你需要在https://nodejs.org/en/download/下载最新的Nodejs版本，本文以v0.10.24为例:
cd /usr/local/src/
wget http://nodejs.org/dist/v0.10.24/node-v0.10.24.tar.gz
- 解压文件
tar zxvf node-v0.10.24.tar.gz
- 编译安装
cd node-v0.10.24
./configure --prefix=/usr/local/node/0.10.24
make
make install
- 配置NODE_HOME，进入profile编辑环境变量
vim /etc/profile
#set for nodejs
export NODE_HOME=/usr/local/node/0.10.24
export PATH=$NODE_HOME/bin:$PATH
:wq保存并退出，编译/etc/profile 使配置生效
source /etc/profile
- 验证是否安装配置成功
node -v
输出版本号即表示安装成功。
3 Node Http Api?
使用node搭建Http服务器本身就很简单的，官方文档给的demo就几十行，下面是我们实际中可以会比较经常用到的：
/**************************************************************
* 定义HTTP服务器
**************************************************************/
//引入Http模块
var http = require('http');
//日志模块
var log4js = require('./log4j');
var logger = log4js.log4j();
var url = require('url');
// 创建服务器
var HttpServer = http.createServer();
HttpServer.on("request", function(req, res){
req.setEncoding('utf-8'); // 设置接收数据编码格式为 UTF-8
// 解析URL参数
var head = url.parse(req.url, true).query;
// 解析POST数据
var postData = "";
req.addListener("data", function (postDataChunk) {
postData += postDataChunk;
});
// POST数据接收完毕
req.addListener("end", function () {
if(postData==null||postData==undefined){
res.writeHead(code,
{
"Content-Type": "text/plain;charset=utf-8"
});
res.end(msg);
return;
}
//解析HTTP请求数据
var body = JSON.parse(postData);
//todo 接来就可以根据参数处理去数据库查询或者插入
});
});
HttpServer.listen(8181);
console.log('-- http server is running : 8181 ... ');
这样一个Http 服务器就搭建好了，可以直接Node + 文件名.js 启动，然后监听8181;之后就可以http 请求了。具体更多的可以参考Api;
4 Node Socket Api?
node搭建Tcp服务器就更简单了，很少的代码：
/**************************************************************
* TCP连接管理服务
**************************************************************/
// 创建服务器
var TcpServer = net.createServer();
TcpServer.on('connection', function(socket){
console.log('NEW SOCKET: ' + socket.remoteAddress + ':' + socket.remotePort);
socket.setKeepAlive(true, 60000);
socket.on('data', function(data) {
//根据收到的data处理tcp请求
});
// 设置连接断开事件
socket.on('close', function(data) {
console.log('CLOSED :' + socket.remoteAddress + ':' + socket.remotePort);
}
});
5 怎么样结合两者实现Http 向Tcp 发消息?
要知道每一个Tcp链接就是一个socket，那么只要我们Http请求（imei）能够知道对应哪个socket，那么就可以像这个socket write数据，即通过Http请求参数拿到对应的socket，在通过socket用向设备写入数据；所以我们最开始系统启动时就要维护一个全局的容器，里面是socket和imei对应关系，设备都会有唯一的硬件号，我们发Http请求也会根据这个号，那么对应关系imei --->socket,完整代码如下:
var querystring = require('querystring');
var net = require('net');
var http = require('http');
var url = require('url');
//日志模块
var log4js = require('./log4j');
var logger = log4js.log4j();
/**************************************************************
* 数据库配置
**************************************************************/
var PoolOption = {
connectionLimit : 10,
host: 'www.demo.cpm',
user: 'root',
password: 'root&&',
database: 'database',
port: 63946
};
var pool = {};
module.exports.pool = pool;
// 连接对象 imei->socket 初始化连接池对象;
mcfish.init(PoolOption);
/**************************************************************
* 定义HTTP服务器
**************************************************************/
// 创建服务器
var HttpServer = http.createServer();
HttpServer.on("request", function(req, res){
req.setEncoding('utf-8'); // 设置接收数据编码格式为 UTF-8
// 解析URL参数
console.log('-------http cmd---------');
var head = url.parse(req.url, true).query;
console.log('-------url encode---------')
console.log(head);
// 解析POST数据
var postData = "";
req.addListener("data", function (postDataChunk) {
postData += postDataChunk;
});
// POST数据接收完毕
req.addListener("end", function () {
console.log("http data:"+postData)
if(postData==null||postData==undefined){
mcfish.http_response(res, 200, 'ret=-1&msg=miss parameter.\n');
return;
}
var body = JSON.parse(postData);
if (head.cmd == undefined || head.imei == undefined){
mcfish.http_response(res, 200, 'ret=-1&msg=miss parameter cmd/imei.\n');
return;
}
// 通过池里拿出socket向设备转发消息消息
var sess = pool[head.imei.trim()];
if (!sess){
console.log("ret=-1&msg=device offline\n");
return;
}
// 通过拿到的socket 向设备响应业
var ret = JT8080.dispatch(sess.socket, head, body);
//打印设备返回消息
console.log("ret="+ret);
if (ret != 0){
}else{
}
});
});
HttpServer.listen(8181);
console.log('-- http server is running : 8181 ... ');
/**************************************************************
* TCP连接管理服务
**************************************************************/
// 创建服务器
var TcpServer = net.createServer();
TcpServer.on('connection', function(socket){
console.log('NEW SOCKET: ' + socket.remoteAddress + ':' + socket.remotePort);
socket.setKeepAlive(true, 60000);
socket.on('data', function(data) {
//处理socket业务
});
// 设置连接断开事件
socket.on('close', function(data) {
console.log('CLOSED :' + socket.remoteAddress + ':' + socket.remotePort);
console.log(socket.imei);
if (socket.imei != undefined && socket.imei !=null){
logger.info('离线设备编号 :' + socket.imei + " ； IP ："+socket.remoteAddress + ' PORT:' + socket.remotePort);
var sess = pool[socket.imei.trim()];
console.log(pool);
if (sess != null){
delete pool[socket.imei];
sess.auth = null;
}
}
});
代码中用到很多模块化的东西，然后调用mysql的连接池创建方法：
mcfish.init = function(PoolOption){
this.PoolOption = PoolOption
this.pool = mysql.createPool(PoolOption);
this.MqttServer = null;
this.TcpServer = null;
console.log('-----pool is init-----');
};
本文介绍了Node Http 和socket的基本用法，更多常用的请参考官方API 文档;
下一篇文章将介绍websocket和socket.io 的区别和联系。
