-
Notifications
You must be signed in to change notification settings - Fork 0
/
px2nodeconnector.js
81 lines (61 loc) · 2.23 KB
/
px2nodeconnector.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
// px2nodeconnector.js
var net = require('net');
px2nodeconnector = module.exports = function () {
var self = this;
self.client = null;
self.recvBuf = new Buffer(1024);
self.recvLength = 0;
self.onRecvFun = null;
px2nodeconnector.prototype.initlize = function () {
var self = this;
self.client = new net.Socket();
self.client.on('connect', function(){
console.log("connected");
});
self.client.on('data', function(data){
var dtLength = data.length;
data.copy(self.recvBuf, self.recvLength);
self.recvLength += dtLength;
if (self.recvLength > 4)
{
var bufLength = self.recvBuf.readUInt16LE(0);
var allBufLength = bufLength + 2;
var butProtoType = self.recvBuf.readUInt16LE(2);
console.log("bufLength:" + bufLength);
console.log("butProtoType:" + butProtoType);
if (self.recvLength >= allBufLength){
self.recvLength -= allBufLength;
var cntBuf = new Buffer(bufLength);
data.copy(cntBuf, 0, 4, 4+bufLength);
if (2 == butProtoType){
var cntStr = cntBuf.toString();
console.log(cntStr);
if (null != self.onRecvFun){
self.onRecvFun(cntStr);
}
}
}
}
});
};
self.initlize();
px2nodeconnector.prototype.sendStr = function(str){
var self = this;
var bufStr = new Buffer(str);
var bufLength = new Buffer(4);
bufLength.writeUInt16LE(bufStr.length + 2, 0);
bufLength.writeUInt16LE(2, 2);
var buf = new Buffer(bufStr.length + 4);
bufLength.copy(buf, 0);
bufStr.copy(buf, 4);
self.client.write(buf);
};
px2nodeconnector.prototype.onRecvStr = function(fun){
var self = this;
self.onRecvFun = fun;
};
px2nodeconnector.prototype.connect = function(ip, port){
var self = this;
self.client.connect(port, ip);
};
}