278 lines
7.3 KiB
TypeScript
278 lines
7.3 KiB
TypeScript
import * as ByteBuffer from "../3rd/bytebuffer";
|
||
import SKPacket from "./SKPacket";
|
||
import SKTimeUtil from "../util/SKTimeUtil";
|
||
import GameModel from "../../core/GameModel";
|
||
import SocketUtil from "./SocketUtil";
|
||
|
||
export enum SocketCode {
|
||
SUCCESS = 0,
|
||
IP_ERROR = 1,
|
||
PORT_ERROR = 2,
|
||
TIMEOUT = 3,
|
||
ERROR = 4,
|
||
CLOSE = 5,
|
||
PING = 6,
|
||
}
|
||
|
||
export default class SKSocket {
|
||
static shared = new SKSocket();
|
||
static pbroot : any;
|
||
static pbname : string = "c2s";
|
||
static stringBlock : (msg : string) => void;
|
||
static disconnectBlock : () => void;
|
||
ip : string;
|
||
port : number;
|
||
socket : WebSocket;
|
||
sendCheckTimer : number;
|
||
pingTimer : number;
|
||
lastTime : number;
|
||
lastRunTime : number;
|
||
isReconnect : boolean = false;
|
||
lastCode : SocketCode;
|
||
/**
|
||
* 是否輸出接口請求
|
||
*/
|
||
isShowRequest : boolean = true;
|
||
isShowPing : boolean = false;
|
||
callList : { [key : string] : (data : any) => void };
|
||
|
||
constructor() {
|
||
this.callList = {};
|
||
cc.game.on(cc.game.EVENT_SHOW, function () {
|
||
console.log("SKSocket:重新返回游戲");
|
||
console.log(Date.now() - this.lastRunTime)
|
||
if (Date.now() - this.lastRunTime > 30000) {
|
||
// 超過30秒
|
||
// console.log("是否戰鬥", GameModel.isFight)
|
||
if (GameModel.isFight) {
|
||
GameModel.isFight = false
|
||
GameModel.shared.relink1()
|
||
}
|
||
}
|
||
this.lastTime = Date.now();
|
||
}, this);
|
||
cc.game.on(cc.game.EVENT_HIDE, function () {
|
||
console.log("SKSocket:遊戲進入後台");
|
||
this.lastRunTime = Date.now();
|
||
}, this);
|
||
this.lastCode = SocketCode.SUCCESS;
|
||
}
|
||
static showRequest() {
|
||
this.shared.isShowRequest = true;
|
||
}
|
||
static hideRequest() {
|
||
this.shared.isShowRequest = false;
|
||
}
|
||
static showPing() {
|
||
this.shared.isShowPing = true;
|
||
}
|
||
static hiddPing() {
|
||
this.shared.isShowPing = false;
|
||
}
|
||
static register(prefix : string, call : (data : any) => void) {
|
||
if (!prefix || prefix.length < 1) {
|
||
cc.warn(`$警告:無效的註冊前綴!`);
|
||
return;
|
||
}
|
||
if (this.shared.callList[prefix]) {
|
||
cc.warn(`$警告:${prefix}已註冊!`);
|
||
}
|
||
this.shared.callList[prefix] = call;
|
||
}
|
||
|
||
static loadProto(url : string, complteBlock : () => void) {
|
||
cc.loader.loadRes(url, cc.TextAsset, (error : Error, result : cc.TextAsset) => {
|
||
if (error) {
|
||
cc.log(`加載協議失敗${error.message}`);
|
||
return;
|
||
}
|
||
let text = result.text;
|
||
let temp = protobuf.parse(text);
|
||
this.pbroot = temp.root;
|
||
complteBlock();
|
||
})
|
||
}
|
||
|
||
static connect(ip : string, port : number, failedBlock : (code : SocketCode) => void, successBlock : () => void) {
|
||
cc.log("connect to .....", ip, port)
|
||
// this.shared.connect(ip, port, failedBlock, successBlock);
|
||
//192.168.200.28 117.187.233.158
|
||
this.shared.connect("117.187.233.158", port, failedBlock, successBlock);
|
||
}
|
||
// 重連
|
||
static reconnect(failedBlock : (code : SocketCode) => void, successBlock : () => void) {
|
||
if (this.shared.isReconnect) {
|
||
return;
|
||
}
|
||
this.shared.isReconnect = true;
|
||
this.shared.connect(this.shared.ip, this.shared.port, failedBlock, successBlock);
|
||
}
|
||
// 發送
|
||
static send(prefix : string, properties : any) {
|
||
var canSend = SocketUtil.getCanSend(prefix, properties);
|
||
if (!canSend) return;
|
||
if (this.shared.isShowRequest && prefix.indexOf("aoi") == -1 && prefix != "c2s_task_talk_npc")
|
||
console.log("%c訪問接口：'" + prefix + "',攜帶數據：", 'color:green', properties);
|
||
this.shared.send(prefix, properties);
|
||
}
|
||
// 關閉
|
||
static close() {
|
||
this.shared.close();
|
||
}
|
||
|
||
private connect(ip : string, port : number, failedBlock : (code : number) => void, successBlock : () => void) {
|
||
if (!ip || ip.length < 1) {
|
||
this.isReconnect = false;
|
||
this.lastCode = SocketCode.IP_ERROR;
|
||
failedBlock(this.lastCode);
|
||
return;
|
||
}
|
||
if (!port) {
|
||
this.isReconnect = false;
|
||
this.lastCode = SocketCode.PORT_ERROR;
|
||
failedBlock(this.lastCode);
|
||
return;
|
||
}
|
||
this.ip = ip
|
||
this.port = port;
|
||
let link = `ws://${this.ip}:${this.port}`;
|
||
console.log(link,'link')
|
||
if (this.socket) {
|
||
console.log("not get socket state, but return. maybe error!!!")
|
||
this.isReconnect = false;
|
||
successBlock();
|
||
return;
|
||
}
|
||
this.socket = new WebSocket(link);
|
||
this.socket.binaryType = "arraybuffer";
|
||
let self = this;
|
||
this.socket.onopen = (event : Event) => {
|
||
console.log(`${self.isReconnect ? "重連" : "連接"}服務器:${link}成功`);
|
||
self.onConnect();
|
||
if (successBlock) {
|
||
successBlock();
|
||
}
|
||
}
|
||
this.socket.onmessage = (event : MessageEvent) => {
|
||
self.lastTime = Date.now();
|
||
if (typeof event.data == 'string') {
|
||
if (event.data == "ping") {
|
||
if (this.isShowPing) {
|
||
console.log("%cPING_RECIVE", 'color:cyan')
|
||
console.timeEnd("Ping")
|
||
}
|
||
return;
|
||
}
|
||
if (SKSocket.stringBlock) {
|
||
SKSocket.stringBlock(event.data);
|
||
}
|
||
return;
|
||
}
|
||
// try {
|
||
let buffer = new ByteBuffer();
|
||
buffer.append(event.data);
|
||
buffer.flip();
|
||
let len = buffer.readShort();
|
||
let prefix = buffer.readString(len);
|
||
buffer.readString(2)
|
||
let call = self.callList[prefix];
|
||
if (call) {
|
||
let leftBuffer = new Uint8Array(buffer.buffer).subarray(buffer.offset, buffer.limit);
|
||
let packet = SKPacket.create(prefix);
|
||
let data = packet.decode(leftBuffer);
|
||
if (this.isShowRequest && prefix.indexOf("aoi") == -1 && prefix.indexOf("s2c_screen_msg") == -1 && prefix.indexOf("s2c_game_chat") == -1)
|
||
console.log("%c返回數據接口:", 'color:blue', data)
|
||
|
||
call(data);
|
||
if (GameModel.isDebug) {
|
||
cc.log(`接收協議:${prefix}`);
|
||
}
|
||
} else {
|
||
cc.warn(`未響應的協議:${prefix}`);
|
||
}
|
||
// } catch (error) {
|
||
// cc.warn(error);
|
||
// }
|
||
}
|
||
this.socket.onerror = (event : Event) => {
|
||
cc.warn(`連接服務器錯誤!`);
|
||
self.lastCode = SocketCode.ERROR;
|
||
failedBlock(self.lastCode);
|
||
self.close();
|
||
}
|
||
this.socket.onclose = (event : CloseEvent) => {
|
||
cc.warn(`服務器關閉!`);
|
||
self.lastCode = SocketCode.CLOSE;
|
||
failedBlock(self.lastCode);
|
||
self.close();
|
||
}
|
||
// cc.log(`開始連接服務器:${link}`);
|
||
}
|
||
|
||
onConnect() {
|
||
this.isReconnect = false;
|
||
this.lastCode = SocketCode.SUCCESS;
|
||
this.lastTime = Date.now();
|
||
SKTimeUtil.cancelLoop(this.pingTimer);
|
||
// 5秒心跳
|
||
this.pingTimer = SKTimeUtil.loop(() => {
|
||
let current = Date.now();
|
||
// 20秒超時
|
||
if (current - this.lastTime > 20000) {
|
||
console.log(`超時斷開鏈接`);
|
||
this.lastCode = SocketCode.PING;
|
||
this.close();
|
||
return;
|
||
}
|
||
if (this.socket) {
|
||
if (this.isShowPing) {
|
||
console.log("%cPING_SEND", 'color:red');
|
||
console.time("Ping")
|
||
}
|
||
|
||
this.socket.send("ping");
|
||
}
|
||
}, 5000);
|
||
|
||
this.sendCheckTimer = SKTimeUtil.loop(() => {
|
||
SocketUtil.clearSendRecord();
|
||
}, SocketUtil.clearInterval)
|
||
}
|
||
|
||
close() {
|
||
if (!this.socket) {
|
||
return;
|
||
}
|
||
SKTimeUtil.cancelLoop(this.pingTimer);
|
||
if (this.socket.readyState < 2) {
|
||
this.socket.close();
|
||
}
|
||
this.socket.onopen = null;
|
||
this.socket.onmessage = null;
|
||
this.socket.onerror = null;
|
||
this.socket.onclose = null;
|
||
this.socket = null;
|
||
if (this.isReconnect) {
|
||
this.isReconnect = false;
|
||
return;
|
||
}
|
||
if (SKSocket.disconnectBlock) {
|
||
SKSocket.disconnectBlock();
|
||
}
|
||
}
|
||
|
||
private send(prefix : string, properties : any) {
|
||
if (!this.socket || this.socket.readyState != 1) {
|
||
if (SKSocket.disconnectBlock) {
|
||
SKSocket.disconnectBlock();
|
||
}
|
||
return;
|
||
}
|
||
let packet = SKPacket.create(prefix);
|
||
let buffer = packet.encode(properties);
|
||
this.socket.send(buffer);
|
||
if (GameModel.isDebug) {
|
||
cc.log(`發送協議:${prefix}`);
|
||
}
|
||
}
|
||
} |