WebSocket

Scut在6.7.9.5以上版本提供了支持WebSocket协议的服务端与客户端，支持WebSocket协议的版本:Hybi00, Hybi10和Rfc6455版本;

##服务端WebSocket

###GameWebSocketHost类

提供注册事件

• OnHandshaked: 注册客户端握手成功事件
• OnPing: 注册客户端发送Ping命令处理事件
• OnPong: 注册客户端Ping应答命令事件
• OnError: 注册接收消息处理出错事件

###WebSocket协议使用

• MainClass类继承GameWebSocketHost类

    public class MainClass : GameWebSocketHost
    {
        public MainClass()
        {
            GameEnvironment.Setting.ActionDispatcher = new WebSocketActionDispatcher();
        }

        protected override void OnStartAffer()
        {
        }

        protected override void OnServiceStop()
        {
        }

        protected override void OnHandshaked(ISocket sender, ConnectionEventArgs e)
        {
            Console.WriteLine("client:{0}", e.Socket.Handshake.Url);
            base.OnHandshaked(sender, e);
        }

        protected override void OnRequested(ActionGetter actionGetter, BaseGameResponse response)
        {
            Console.WriteLine("parma action:{0}", actionGetter.GetActionId());
            base.OnRequested(actionGetter, response);
        }

    }

• 定义WebSocketActionDispatcher类

    public class WebSocketActionDispatcher : ScutActionDispatcher
    {

        public override ActionGetter GetActionGetter(RequestPackage package, GameSession session)
        {
            // 可以实现自定的ActionGetter子类
            return new HttpGet(package, session) { OpCode = OpCode.Text };
        }

        public override void ResponseError(BaseGameResponse response, ActionGetter actionGetter, int errorCode, string errorInfo)
        {
            //实现出错处理下发
            response.BinaryWrite(Encoding.UTF8.GetBytes(errorCode + "-" + errorInfo));
        }
    }

• 定义Action接口协议

排行榜例子:

    public class Action1001 : JsonAction
    {
        private int PageIndex;
        private int PageSize;
        private List<UserRanking> rankingList;

        public Action1001(ActionGetter actionGetter)
            : base(1001, actionGetter)
        {

        }
	
	public override bool GetUrlElement()
        {
            if (httpGet.GetInt("PageIndex", ref PageIndex)
                 && httpGet.GetInt("PageSize", ref PageSize))
            {
                return true;
            }
            return false;
        }
	
        public override bool TakeAction()
        {
            var cache = new ShareCacheStruct<UserRanking>();
            rankingList = cache.FindAll(false);
            rankingList = MathUtils.QuickSort<UserRanking>(rankingList, compareTo);
            rankingList = rankingList.GetPaging(PageIndex, PageSize, out PageCount);
            return true;
	}

        protected override string BuildResponsePack()
        {
            return MathUtils.ToJson(rankingList);         
        }
    }

##客户端WebSocket

###ClientWebSocket类

提供方法和注册事件

• ReadyState: 连接状态属性, 0:未连接, 1:已连接, 2:关闭

• Connect: 建立WebSocket连接

• ConnectAsync: 异步建立WebSocket连接

• Ping: 发送Ping命令

• OnOpened: 注册成功打开WebSocket连接事件

• OnMessage: 注册接收WebSocket消息事件

• OnClosed: 注册WebSocket关闭事件

• OnError: 注册WebSocket异常事件

• OnPing: 注册接收到服务端Ping命令事件

• OnPong: 注册服务端Ping应答命令事件

###WebSocket协议使用

    AutoResetEvent closeEvent = new AutoResetEvent(false);
    int messageLen = 0;
    AutoResetEvent messageEvent = new AutoResetEvent(false);
    ClientWebSocket client = new ClientWebSocket("ws://127.0.0.1:" + port + "/chat?d=xx", new string[] { "chat" }, "http:///127.0.0.1/", 8);
    client.OnOpened += (sender, args) => { Console.WriteLine("client open ok"); };
    client.OnMessage += (sender, args) =>
    {
        messageLen = args.Data.Length;
        messageEvent.Set();
    };
    client.OnError += (sender, args) => { Console.WriteLine("client open error "); };
    client.OnPong += (sender, args) => { Console.WriteLine("client ping response: " + args.Source.Message); };
    client.OnClosed += (sender, args) =>
    {
	closeEvent.Set();
    };
    client.Connect();
    //client.ConnectAsync();
    while (true)
    {
	Thread.Sleep(1000);
	if (client.ReadyState == ConnectState.Success)
	{
	    break;
	}
    }
    client.Ping();