iericzheng / websocket

Based on .net core websoket framework

WebSocket

Based on .net core websoket framework

Nuget:Install-Package WS.Core

websocket url:/

test url:/example/index.html

javascript:/example/chat.js

调试：可以直接实用.net core命令 dotnet run运行，也可以实用用vs2017调试开发，但注意修改配置文件里的启动url地址和websocket的连接地址

备注：消息采用protobuffer进行序列化，js端使用需要先申明proto数据格式（参考例子里的proto_market.json）

内存调优配置：appsettings.json=>WebSocket

Example usage:

@消息定义

    [Msg(ReceiveCommand.ClientUserChat)]//申明消息Command
    [ProtoContract(ImplicitFields = ImplicitFields.AllPublic)]
    public class Chat : IMsg
    {
        [ProtoMember(1)]
        public string Name { get; set; }
        [ProtoMember(2)]
        public string Content { get; set; }
        [ProtoMember(3)]
        public string SourceId { get; set; }
    }

@申明控制器

    [WSRoute(1, true)]//申明控制器编号
    public class ChatController : WSController
    {
        public ChatController()//支持依赖注入
        {
            //注册Action,Action只允许两个参数，第一个为session,第二个为自定义消息
            RegisterWSHandler<Chat>(SendChat);
        }

        public async Task SendChat(WSSession session, IMsg messag)
        {
            var data = messag as Chat;
            if (data != null)
            {
                await Broadcast(data);
            }
        }
        public override Task Receive(WSSession session, WSArraySegment buffer, int count)
        {
            throw new NotImplementedException();
        }
    }

@javascript端调用

//发送聊天内容
$("#btn_Send").unbind("click").click(function () {
    var content = $("#txt_Content").val();
    var name = $("#txt_Name").val();
    var newchat = Chat.create({ Name: name, Content: content, SourceId: "聊天室1" });
    var dataBuffer = Chat.encode(newchat).finish();
    var buffer = GenerateCmdBuffer(Controllers.ChatController, SendCommand.ClientUserChat, dataBuffer);

    if (ws.readyState === WebSocket.OPEN) {
        ws.send(buffer);
    } else {

    }
});
//构造发送数据(pare1:控制器id,pare2:消息command，pare3:对象的byte数组)
function GenerateCmdBuffer(controller, command, dataBuffer) {
    var controllerLittleEndian = new dcodeIO.ByteBuffer(4).writeUint32(controller, 0).flip();
    var controllerBigEndian = new Uint8Array(4);
    controllerBigEndian[0] = controllerLittleEndian.view[3];
    controllerBigEndian[1] = controllerLittleEndian.view[2];
    controllerBigEndian[2] = controllerLittleEndian.view[1];
    controllerBigEndian[3] = controllerLittleEndian.view[0];
    var commandLittleEndian = new dcodeIO.ByteBuffer(2).writeUint16(command, 0).flip();
    var commandBigEndian = new Uint8Array(2);
    commandBigEndian[0] = commandLittleEndian.view[1];
    commandBigEndian[1] = commandLittleEndian.view[0];
    var allBuffer = dcodeIO.ByteBuffer.concat([controllerBigEndian, commandBigEndian, dataBuffer], "binary");
    return allBuffer.view;
}