封装好的socket,拿去用 - jio92_H5之家 - 中国HTML5教程资源分享第一站

一:服务端

ServerListener listener = new ServerListener();

　　1.构造函数:

　　2.事件:

//日志,内部的处理日志,主要用来看流程,实际用处不大.
listener.Log += listener_Log;   //listener_Log(string msg)
//客户端上线
listener.ClientConnected += listener_ClientConnected;  //listener_ClientConnected(BaseClient t) 
//客户端下线
listener.ClientDisconnect += listener_ClientDisconnect;  //listener_ClientDisconnect(BaseClient t)
//接收到完整消息
listener.MsgRead += listener_MsgRead;   //listener_MsgRead(BaseClient t, byte[] t2)

　　　　说明:1.Log中msg参数是执行流程的消息, 2.t是当前客户端对象, 3.t2完整消息数据

　　3.方法:

//调用start启动监听;
listener.Start();
//停止监听
listener.Stop();

//广播消息,msg发送的内容,
//type发送到客户端类型,传null发送到所有类型
//(目前只有socket和websocket2个类型)
listener.SendAll(byte[] msg, ClientType? type)

//还有一个属性
//在线客户端集合
listener.Clients

二:客户端

Client client = new Client();

　　1.构造函数:

　　2.事件

//日志
client.Log += client_Log;  //client_Log(BaseClient t, string t2)
//断开连接
client.ClientDisconnect += client_ClientDisconnect;  //client_ClientDisconnect(BaseClient t)
//连接服务器成功
client.ClientConnected += client_ClientConnected;  //client_ClientConnected(BaseClient t,bool state,string msg)
//发送完一条消息
client.MsgSend += client_MsgSend;  //client_MsgSend(BaseClient t) 
//接收到完整消息
client.MsgRead += client_MsgRead;  //client_MsgRead(BaseClient t, byte[] t2)

　　3.方法

//启动连接服务器
client.Start();
//断开连接
client.Stop();
//发送数据
client.SendData(byte[] data)

　　4.属性

/// <summary>
/// 自动重连,默认false
/// </summary>
public bool AutoChonglian { get; set; }

/// <summary>
/// Id
/// </summary>
public Guid Id { get; set; }

/// <summary>
/// 远程网络地址
/// </summary>
public EndPoint RemoteIp{get;set;}

/// <summary>
/// 本地网络地址
/// </summary>
public EndPoint LocalIp{get;set;}

/// <summary>
/// 客户端类型
/// </summary>
public ClientType ClientType { get; private set; }

/// <summary>
/// 客户端对象是否为空
 /// </summary>
public bool ClientIsNull{get;private set;}

三:WebSocket

　　websocket已经在服务段封装好了,直接连接就能通讯,这里唯一要讲一下的就是send的时候需要注意数据长度不能超过8184,超过分段发,还是给一段js出来大家自己看把

function addMsg(msg){
    $("#msg").append("<p>"+msg+"</p>");
}


var websocket  = new WebSocket("ws://ip:port/");
websocket.onopen = function onOpen() {
    addMsg("已连接到服务器");
};
 websocket.onclose = function onClose() {
    addMsg("服务器连接断开");
 };
  websocket.onerror = function onError() {
    addMsg("连接服务器失败");
}
websocket.onmessage = function onMessage(evt) {
    var data = evt.data;
    addMsg(data);
};
websocket.SendObj = function(obj) {
    return websocket.Send(obj + "⊙");
};
websocket.sendlen = 8184; //分段发送数据长度不能超过8184
websocket.Send = function (msg) {
    if (websocket != null && websocket.readyState === websocket.OPEN) {
        if (msg.length > websocket.sendlen) {
            var sendcount = Math.ceil(msg.length / websocket.sendlen);
            for (var i = 0; i < sendcount; i++) {
                var d = msg.substring(i * websocket.sendlen, websocket.sendlen * (i + 1));
                websocket.send(d);
            }
        } else {
            websocket.send(msg);
        }
        return true;
    } else {
        addMsg("指令发送失败(与服务器断开连接)");
        return false;
    }
};

websocket.SendObj("发送数据,一般是json字符串,反正随便你");