.net , java webSocket 连接 Socket.io (1.4.4版本) 问题
jopen
9年前
.net版Socketio4net类库和java版socket.io-java-client类库 连接socket.io 1.4版本都不行，网上大多是socket.io 0.9版本的，socket.io 更新之后就不支持了。本人已研究
成功连接socket.io 1.4版本的方法，例子采用C#。
一、socket.io 几个重要要文件
1、node_modules\socket.io\node_modules\engine.io\node_modules\engine.io-parser\lib\index.js
var packets = exports.packets = { open: 0 // non-ws , close: 1 // non-ws , ping: 2 , pong: 3 , message: 4 , upgrade: 5 , noop: 6 }; 这几个是定义消息类型的 websocket连接的时候在open事件里需要发送一个send("5[\"simple\",{\"name\":\"simple\"}]"); 类型为5的消息。
exports.decodePacket = function (data, binaryType, utf8decode) { // String data console.log('解析数据'+data); if (typeof data == 'string' || data === undefined) { if (data.charAt(0) == 'b') { return exports.decodeBase64Packet(data.substr(1), binaryType); } var type = data.charAt(0); if (utf8decode) { try { data = utf8.decode(data); } catch (e) { return err; } } console.log('解析数据3:'+type); if (Number(type) != type || !packetslist[type]) { return err; } if (data.length > 1) { return { type: packetslist[type], data: data.substring(1) }; } else { return { type: packetslist[type] }; } } // Binary data if (binaryType === 'arraybuffer') { var type = data[0]; var intArray = new Uint8Array(data.length - 1); for (var i = 1; i < data.length; i++) { intArray[i - 1] = data[i]; } return { type: packetslist[type], data: intArray.buffer }; } var type = data[0]; return { type: packetslist[type], data: data.slice(1) }; }; View Code 从客户端发过来的消息会从这里解析出来，得到消息类型。
2、node_modules\socket.io\node_modules\engine.io\lib\socket.js
从上面解析出来的消息字符串会到这里
Socket.prototype.onPacket = function (packet) { console.log('engine.io-lib-Socket.js==OnPacket///'+packet); if ('open' == this.readyState) { // export packet event debug('packet'); this.emit('packet', packet); // Reset ping timeout on any packet, incoming data is a good sign of // other side's liveness this.setPingTimeout(); console.log('engine.io-lib-Socket.js==OnPacket>>>'+packet.type);//upgrade switch (packet.type) { case 'ping': debug('got ping'); this.sendPacket('pong'); this.emit('heartbeat'); break; case 'error': this.onClose('parse error'); break; case 'message': this.emit('data', packet.data); this.emit('message', packet.data); break; } } else { debug('packet received with closed socket'); console.log('packet received with closed socket'); } }; View Code 3、node_modules\socket.io\node_modules\socket.io-parser\index.js
function decodeString(str) { console.log('socket.io-parser-index.js-encodeAsString4---'+str); var p = {}; var i = 0; // look up type p.type = Number(str.charAt(0)); if (null == exports.types[p.type]) return error(); // look up attachments if type binary if (exports.BINARY_EVENT == p.type || exports.BINARY_ACK == p.type) { console.log("---------1"); var buf = ''; while (str.charAt(++i) != '-') { buf += str.charAt(i); if (i == str.length) break; } if (buf != Number(buf) || str.charAt(i) != '-') { throw new Error('Illegal attachments'); } p.attachments = Number(buf); } // look up namespace (if any) if ('/' == str.charAt(i + 1)) { p.nsp = ''; while (++i) { var c = str.charAt(i); if (',' == c) break; p.nsp += c; if (i == str.length) break; } } else { p.nsp = '/'; } // look up id var next = str.charAt(i + 1); if ('' !== next && Number(next) == next) { p.id = ''; while (++i) { var c = str.charAt(i); if (null == c || Number(c) != c) { --i; break; } p.id += str.charAt(i); if (i == str.length) break; } p.id = Number(p.id); } // look up json data if (str.charAt(++i)) { try { console.log("---------21/"+str.substr(i)); p.data = json.parse(str.substr(i)); } catch(e){ return error(); } } console.log(p); debug('decoded %s as %j', str, p); return p; } View Codeexports.types = [ 'CONNECT', 'DISCONNECT', 'EVENT', 'ACK', 'ERROR', 'BINARY_EVENT', 'BINARY_ACK' ]; /** * Packet type `connect`. * * @api public */ exports.CONNECT = 0; /** * Packet type `disconnect`. * * @api public */ exports.DISCONNECT = 1; /** * Packet type `event`. * * @api public */ exports.EVENT = 2; /** * Packet type `ack`. * * @api public */ exports.ACK = 3; /** * Packet type `error`. * * @api public */ exports.ERROR = 4; /** * Packet type 'binary event' * * @api public */ exports.BINARY_EVENT = 5; /** * Packet type `binary ack`. For acks with binary arguments. * * @api public */ exports.BINARY_ACK = 6; View Code
然后消息会传递到这里，再解析它。
4、node_modules\socket.io\node_modules\socket.io-parser\node_modules\component-emitter\index.js
最后消息会到这里找到对应的回调函数。
Emitter.prototype.emit = function(event){ // console.log(arguments); // console.log("event"); //console.log(event); // console.log("_callbacks"); // console.log( this._callbacks); this._callbacks = this._callbacks || {}; var args = [].slice.call(arguments, 1) , callbacks = this._callbacks[event]; //console.log('args'); //console.log(args); //console.log('callbacks'); if (callbacks) { // console.log('回调 正确'); callbacks = callbacks.slice(0); console.log(callbacks); for (var i = 0, len = callbacks.length; i < len; ++i) { callbacks[i].apply(this, args); // console.log('执行 正确'); } } else { console.log('回调 出错'); } return this; }; View Code 二、socket.io授权
1、.net授权获取sid
授权地址http://127.0.0.1:3000/socket.io/?eio=3&transport=polling&t=1404421022936，0.9版本的socket.io授权不一样，通过这个授权地址返回
sessionid,如下格式 0{"sid":"BrB2vsiK79ZoLdMcAAAK","upgrades":["websocket"],"pingInterval":25000,"pingTimeout":60000}，解析得到sid.
protected SocketIOHandshake requestHandshake(Uri uri) { string value = string.Empty; string errorText = string.Empty; SocketIOHandshake handshake = null; using (WebClient client = new WebClient()) { try { client.Headers.Add("cookie:io=3435456567567567355"); // client.Headers.Add("cookie:express.sid=3435456567567567355"); //client.Headers.Add("cookie:sid=3435456567567567355"); value = client.DownloadString("http://127.0.0.1:3000/socket.io/?eio=3&transport=polling&t=1404421022936"); int ii = value.IndexOf("\","); int im = value.IndexOf("\":\""); value = value.Substring(im+3, ii-im-3); //value = "3435456567567567355"; //value = client.DownloadString(string.Format("{0}://{1}:{2}/socket.io/1/{3}", uri.Scheme, uri.Host, uri.Port, uri.Query)); // #5 tkiley: The uri.Query is available in socket.io's handshakeData object during authorization value = value+":55000:60000:websocket"; if (string.IsNullOrEmpty(value)) errorText = "Did not receive handshake string from server"; } catch (Exception ex) { errorText = string.Format("Error getting handsake from Socket.IO host instance: {0}", ex.Message); //this.OnErrorEvent(this, new ErrorEventArgs(errMsg)); } } if (string.IsNullOrEmpty(errorText)) handshake = SocketIOHandshake.LoadFromString(value); else { handshake = new SocketIOHandshake(); handshake.ErrorMessage = errorText; } return handshake; } View Code 以下是socket.io接收到的授权消息，能够取到客户端传来的cookie,可以用过控制重复登录。
io.set('authorization', function(handshakeData, callback) { // callback(handshakeData, true); callback(null, true); return if (handshakeData.headers.cookie) { //console.log(handshakeData.headers.cookie); handshakeData.cookie = cookie.parse(handshakeData.headers.cookie); //console.log(handshakeData.cookie); handshakeData.cookie['express.sid']=handshakeData.cookie.io; handshakeData.sessionID = handshakeData.cookie['express.sid']; //console.log(handshakeData.sessionID); //console.log(handshakeData.cookie['express.sid']); console.log("handshakeData:" + handshakeData.headers.cookie + "-----" + handshakeData.cookie); //var connect_sid = handshakeData.cookie['connect.sid']; //console.log("connect_sid="+connect_sid); handshakeData.session = handshakeData.sessionID; if (handshakeData.cookie['express.sid'] == handshakeData.sessionID) { console.log('1-true'); return callback(null, true); } //return callback('Cookie is invalid.', false); } else { console.log('12-err'); //return callback('No cookie transmitted.', false); } }); View Code 三、websocket 连接
websocket连接地址ws://127.0.0.1:3000/socket.io/?eio=3&t=124324324324&transport=websocket&sid=" + this.HandShake.SID，这个很重要
public void Connect() { lock (padLock) { if (!(this.ReadyState == WebSocketState.Connecting || this.ReadyState == WebSocketState.Open)) { try { this.ConnectionOpenEvent.Reset(); this.HandShake = this.requestHandshake(uri);// perform an initial HTTP request as a new, non-handshaken connection if (this.HandShake == null || string.IsNullOrWhiteSpace(this.HandShake.SID) || this.HandShake.HadError) { this.LastErrorMessage = string.Format("Error initializing handshake with {0}", uri.ToString()); this.OnErrorEvent(this, new ErrorEventArgs(this.LastErrorMessage, new Exception())); } else { String sss = "ws://127.0.0.1:3000/socket.io/?eio=3&t=124324324324&transport=websocket&sid=" + this.HandShake.SID; //sss = "ws://127.0.0.1:3000/socket.io/?transport=polling&t=12434324324324&sid=" + this.HandShake.SID; //string.Format("{0}://{1}:{2}/socket.io/1/websocket/{3}", wsScheme, uri.Host, uri.Port, this.HandShake.SID) string wsScheme = (uri.Scheme == Uri.UriSchemeHttps ? "wss" : "ws"); this.wsClient = new WebSocket( sss, string.Empty, this.socketVersion); this.wsClient.EnableAutoSendPing = false; // #4 tkiley: Websocket4net client library initiates a websocket heartbeat, causes delivery problems this.wsClient.Opened += this.wsClient_OpenEvent; this.wsClient.MessageReceived += this.wsClient_MessageReceived; this.wsClient.Error += this.wsClient_Error; this.wsClient.Closed += wsClient_Closed; this.wsClient.Open(); } } catch (Exception ex) { Trace.WriteLine(string.Format("Connect threw an exception...{0}", ex.Message)); this.OnErrorEvent(this, new ErrorEventArgs("SocketIO.Client.Connect threw an exception", ex)); } } } } View Code 连接之后在open 事件里需要发送一个类型为5（upgrade）的消息websocket.send("5[\"simple\",{\"name\":\"simple\"}]");,然后websocket会收到一个“40”消息，
40代表连接功能了，可以进行通信了。
一般发送消息的格式为："42[\"simple\",{\"name\":\"tstssss\"}]"
42：代表消息类型,simple为socket.io的事件名称。