这里使用了一个单例的SocketManager类：
1: conn = new Socket();
2:
3: conn.addEventListener(Event.CLOSE, onSocketCloseHandler);
4: conn.addEventListener(Event.CONNECT, onSocketConnectHandler);
5: conn.addEventListener(IOErrorEvent.IO_ERROR, onSocketIOErrorHandler);
6: conn.addEventListener(SecurityErrorEvent.SECURITY_ERROR, onSocketSecurityHandler);
7: conn.addEventListener(ProgressEvent.SOCKET_DATA, onSocketDataHandler);
SocketManager最多在连接失败时，进行5次重连。建立socket连接代码：
1: public function connSocket(url:String, port:Number, _endian:String=""):void
2: { 3: if (conn == null)
4: { 5: initSocket();
6: }
7:
8: if (_endian == '')
9: { 10: _endian = Endian.BIG_ENDIAN;
11: }
12:
13: CURR_RECONN_NUM = 0;
14:
15: conn.endian = _endian;
16:
17: socket_url = url;
18: socket_port = port;
19:
20: conn.connect(socket_url, socket_port);
21: }
如果需要发送socket数据，直接调用send方法：
1: /**
2: * 发送数据
3: */
4: private function send(bytes:IMeteoricByteArray):Boolean
5: { 6: if (checkConnIsSuc() == false)
7: { 8: return false;
9: }
10:
11: var bytes_len:uint = bytes.size();
12:
13: var byteArr:ByteArray = new ByteArray();
14:
15: byteArr.writeInt(bytes_len + headLen);
16: byteArr.writeBytes(bytes.getByte());
17:
18: conn.writeBytes(byteArr);
19: conn.flush();
20:
21: bytes.dispose();
22:
23: return true;
24: }
格式：数据包头部长度(int-带符号的32位整数)|消息标识(short-16位整数)|消息返回标识(short-16位整数)|…
bytes.();
bytes.();
bytes.writeShort();
bytes…
根据不同的消息标识（唯一），后台获取标识后调用不同的解析方法，解析客户端发送的数据
前台as3建立socket，发送数据、解析数据，网上很多例子，这里不重点说了。这里重点介绍node.js如何解析消息（不使用任何第三方库）：
1: var net = require('net'); 2: var clients = [];
3:
4: var HOST = '127.0.0.1';
5: var PORT = 7000;
6:
7: net.createServer(function(socket) { 8:
9: console.log('Connected: ' + socket.remoteAddress +':'+ socket.remotePort); 10:
11: clients.push(socket);
12:
13: socket.on('data', function(data) { 14: console.log('receive data：' + socket.remoteAddress +':'+ socket.remotePort); 15:
16: var isBuffer = Buffer.isBuffer(data);
17:
18: if (isBuffer) { 19: var offset = data['readInt32BE'](0);
20: var headCode = data['readInt16BE'](offset);
21: offset += 2;
22: var headBackCode = data['readInt16BE'](offset);
23: offset += 2;
24:
25:
26: var len = data['readInt16BE'](offset);
27: offset += 2;
28:
29: var msg = data.toString('utf8', offset, offset + len) 30:
31: console.log(headCode + '-' + headBackCode + '-' + msg);
32:
33: broadcast(msg, socket);
34: } else { 35: console.log('Message is not Buffer!'); 36: }
37:
38: });
39:
40: socket.on('end', function() { 41: console.log('Close Connected: ' + socket); 42: clients.splice(clients.indexOf(socket));
43: });
44:
45: function broadcast(message, sender) { 46: clients.forEach(function(client) { 47: //if (client === sender) { 48: client.write(message);
49: // }
50: });
51: }
52:
53: }).listen(PORT, HOST);
54:
55:
56: console.log('服务已启动');
如果一切正常，前台发送数据时，控制台上能看到解析的数据：
1000是头标识，10为消息返回标识，abcdefg为发送的字符串。
1: var data:MeteoricSocketSendDataProxy = SocketManager.getInstance().getSocketSendDataProxy(1000, 10) as MeteoricSocketSendDataProxy;
2: data.addStringData(msg);
3:
4: SocketManager.getInstance().sendDataProxy(data);
上面的解析过程可能比较繁琐，你可以使用Node.js的ByteBuffer ()
作者：play175
使用方法也比较简单：
//使用ByteBuffer进行解包操作 var buf = new ByteBuffer(data); var arr = buf.int32() .short() .short() .string() .unpack(); console.log(arr); broadcast(arr[3], socket); /*************************************************/ //原方法 var offset = data['readInt32BE'](0); var headCode = data['readInt16BE'](offset); offset += 2; var headBackCode = data['readInt16BE'](offset); offset += 2; var len = data['readInt16BE'](offset); offset += 2; var msg = data.toString('utf8', offset, offset + len) console.log(headCode + '-' + headBackCode + '-' + msg); broadcast(msg, socket);
有兴趣的可以下载全部源码(Flex-SDK4.5 + node.js)，
参考资料：