egret的sockect连接及数据处理
新建ts文件写入sockect工具类,具体如下:class MySockect {private static _manager: MySockect;public static get Instance() {if (MySockect._manager == null) {MySockect._manager = new MySockect();}return MySockect._manag
·
关注微信公众号:每日玩机 获取ios、Android、tv、mac黑科技软件
新建ts文件写入sockect工具类,具体如下:
class MySockect {
private static _manager: MySockect;
public static get Instance() {
if (MySockect._manager == null) {
MySockect._manager = new MySockect();
}
return MySockect._manager;
}
public constructor() {
}
private socket: egret.WebSocket;
//连接服务器----------------------------------------------
public connectionSockect() {
//创建 WebSocket 对象
this.socket = new egret.WebSocket();
//连接服务器
//设置数据格式为二进制,默认为字符串
this.socket.type = egret.WebSocket.TYPE_STRING;
//添加收到数据侦听,收到数据会调用此方法
this.socket.addEventListener(egret.ProgressEvent.SOCKET_DATA, this.onReceiveMessage, this);
//添加链接打开侦听,连接成功会调用此方法
this.socket.addEventListener(egret.Event.CONNECT, this.onSocketOpen, this);
//添加链接关闭侦听,手动关闭或者服务器关闭连接会调用此方法
this.socket.addEventListener(egret.Event.CLOSE, this.onSocketClose, this);
//添加异常侦听,出现异常会调用此方法
this.socket.addEventListener(egret.IOErrorEvent.IO_ERROR, this.onSocketError, this);
this.socket.connect("192.168.0.8", 3399);
}
//手动关闭连接------------------------------------------------------
public closeSockect() {
this.socket.close();
}
//检测sockect是否已经连接-----------------------------------------
public isConnection() {
return this.socket.connected;
}
//发送数据----------------------------------------------
public sendData(data): void {
let sendData:string = JSON.stringify(data);
console.log("正在发送数据............");
this.socket.writeUTF(sendData);
console.log("发送数据完成");
}
//Sockect连接成功----------------------------------------------
private onSocketOpen(): void {
console.log("Sockect连接成功");
}
//Sockect连接失败----------------------------------------------
private onSocketClose(): void {
console.log("Sockect连接失败");
}
//Sockect连接关闭----------------------------------------------
private onSocketError(): void {
console.log("Sockect连接关闭");
}
//收到数据----------------------------------------------
public onReceiveMessage() {
//读取数据
let msg = this.socket.readUTF();
let data = JSON.parse(msg);
// 在此对收到的数据进行处理.....
}
}
工具类的使用方法
- sockect连接
MySockect.Instance.connectionSockect();
- 发送数据
let data = { "path": "test1", "data": { "msg": "test1" } };
MySockect.Instance.sendData(data);
- 其他使用,具体看工具类里的方法…使用MySockect.Instance.调用

魔乐社区(Modelers.cn) 是一个中立、公益的人工智能社区,提供人工智能工具、模型、数据的托管、展示与应用协同服务,为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作,由全产业链共同建设、共同运营、共同享有,推动国产AI生态繁荣发展。
更多推荐
所有评论(0)