socket 客户端

socket 客户端 的一些想法

-----------------包头--------------------------

4byte　　4byte　　2byte　　2byte

数据长　　数据长　  约定数字  0

------------------------------------------------

1.登录

2.每隔15秒发送心跳包

3.死循环接收数据，把收到的byte[]塞到List<byte>(队列，先进先出)（生产者）

4.List<byte> 要有同步锁

5.死循环读取List<byte>，把数据解析出来（消费者）（可以多消费者）

----------------------------------2017/3/22 更新------------------------------------------------------

感觉好慢，不能即时展现数据

1.心跳包

        #region 服务器心跳连接

        private static readonly System.DateTime Jan1st1970 = new System.DateTime(1970, 1, 1, 0, 0, 0, System.DateTimeKind.Utc);

        /// <summary>
        /// 服务器心跳连接
        /// </summary>
        public void keepAlive()
        {
            while (readyFlag)
            {
                //获取与弹幕服务器保持心跳的请求数据包 按照需求生成心跳包并转成byte[]
                byte[] keepAliveRequest = DyMessage.getKeepAliveData((int)(((long)(System.DateTime.UtcNow - Jan1st1970).TotalMilliseconds) / 1000));

                try
                {
                    //向弹幕服务器发送心跳请求数据包
                    bos.Write(keepAliveRequest, 0, keepAliveRequest.Length);
                    bos.Flush();
                    //sendToText("exMsg","发送心跳包成功！");

                    //设置间隔45秒再发送心跳协议
                    Thread.Sleep(45000);        //keep live at least once per minute

                }
                catch (Exception e)
                {
                    //e.printStackTrace();
                    sendToText("exMsg", "错误：发送心跳包失败！");
                    readyFlag = false;
                }
            }
        }
        #endregion

2.接受数据

        #region 新获取弹幕

        //缓存池
        private List<byte> list = new List<byte>();
        //同步锁
        private object myLock = new object();
        private Semaphore TaskSemaphore = new Semaphore(0, 256);

　　　　　//解析数据
        public void KeepRead(object data)
        {
            //int Index = (int)data;

            while (readyFlag)//死循环
            {
                TaskSemaphore.WaitOne();//等待
                string dataStr = "";
                lock (myLock)//同步锁
                {
                    if (list.Count > 12)//12个长度的包头
                    {
                        byte[] topBytes = list.Take(12).ToArray();//拿出包头

                        byte[] packSizeBuffer1 = new byte[4];//4 字节小端整数，表示整条消息（包括自身）长度（字节数）。
                        Array.Copy(topBytes, 0, packSizeBuffer1, 0, 4);//消息长度 
                        int packSize1 = BitConverter.ToInt32(packSizeBuffer1, 0);//转成长度

                        byte[] packSizeBuffer2 = new byte[4];//4 字节小端整数，表示整条消息（包括自身）长度（字节数）。
                        Array.Copy(topBytes, 4, packSizeBuffer2, 0, 4);//消息长度 
                        int packSize2 = BitConverter.ToInt32(packSizeBuffer2, 0);//转成长度

                        byte[] packTypeBuffer = new byte[4];//4 字节小端整数，表示整条消息（包括自身）长度（字节数）。
                        Array.Copy(topBytes, 8, packTypeBuffer, 0, 2);//消息长度 
                        int packType = BitConverter.ToInt32(packTypeBuffer, 0);//转成长度

                        if (packSize1 == packSize2 && packType == DY_MESSAGE_TYPE_SERVER)//根据需求验证包头
                        {
                            int packSize = packSize1 + 4;//一个包长度 = 包头长+数据长

                            if (list.Count >= packSize)//如果缓存数据够一个包的长度
                            {
                                byte[] totalBytes = list.Take(packSize).ToArray();//拿到一个包的数据
                                //Console.WriteLine("截取数据：" + Newtonsoft.Json.JsonConvert.SerializeObject(totalBytes));

                                list.RemoveRange(0, packSize);//取出后删除  
                                //Console.WriteLine("截取后源数据：" + Newtonsoft.Json.JsonConvert.SerializeObject(list));

                                dataStr = Encoding.UTF8.GetString(totalBytes, 12, totalBytes.Length - 12);//包的数据转换成string
                                //Console.WriteLine("截取数据输出：" + dataStr);

                                //对单一数据包进行解析
                                MsgView msgView1 = new MsgView(dataStr);
                                //分析该包的数据类型，以及根据需要进行业务操作
                                parseServerMsg(msgView1.getMessageList());

                                //Console.WriteLine(Index + "");
                            }
                        }
                    }
                }
            }
        }

        public void KeepMsgToList()
        {
            while (readyFlag)
            {
                if (client == null || !client.Connected)//如果tcpclient为null或断开连接
                {
                    break;
                }
                else 
                {
                    try
                    {
                        byte[] bytes = new byte[client.ReceiveBufferSize];
                        int readSize = m_Reader.Read(bytes, 0, (int)client.ReceiveBufferSize);//读取数据
                        if (readSize > 0)//说明是有读到数据的
                        {
                            byte[] totalBytes = new byte[readSize];//C#神器，byte[]会自动延长
                            Array.Copy(bytes, 0, totalBytes, 0, readSize);//消息长度 
                            //totalBytes = totalBytes.Concat(bytes).ToArray();//C#神器，byte[]会自动延长
                            lock (myLock)//同步锁
                            {
                                list.AddRange(totalBytes);//把数据加到List<byte>中 先进先出
                            }
                            TaskSemaphore.Release(1);   // 每添加一个任务，信号量加1
                        }
                    }
                    catch (Exception e)
                    {
                        if (client == null || client.Connected == false)
                        {
                            shutdown();//注销登录，断开连接，readyFlag=false 等操作
                            sendToText("exMsg", "尝试重新连接！");
                        }
                        else
                        {
                            sendToText("exMsg", "错误：获取弹幕失败！");
                        }
                    }
                }
            }
        }

        #endregion

启动线程

            //保持弹幕服务器心跳
            //KeepAlive alive = new KeepAlive();
            keepAlive = new Thread(new ThreadStart(danmuClient.keepAlive));
            keepAlive.IsBackground = true;
            keepAlive.Start();
            //AddTalkMessage("开始发送心跳包！
");

            //获取弹幕服务器发送的所有信息
            //KeepGetMsg msg = new KeepGetMsg();
            keepGetMsg = new Thread(new ThreadStart(danmuClient.KeepMsgToList));
            keepGetMsg.IsBackground = true;
            keepGetMsg.Start();
            //AddTalkMessage("开始获取弹幕！
");

            //解析信息
            for (int i = 0; i < 10; i++)  
            {  
                Thread keepReadMsg = new Thread(new ParameterizedThreadStart(danmuClient.KeepRead));  
                keepReadMsg.IsBackground = true;
                keepReadMsg.Start(i);
            } 

 -----------------------------修改----------------------------------------

        public void KeepMsgToString()
        {
            while (readyFlag)
            {
                if (client == null || !client.Connected)
                {
                    break;
                }
                else //if (ntwStream.DataAvailable)//说明是有读到数据的
                {
                    try
                    {
                        byte[] bytes = new byte[client.ReceiveBufferSize];
                        int readSize = m_Reader.Read(bytes, 0, (int)client.ReceiveBufferSize);
                        if (readSize > 0)//说明是有读到数据的
                        {
                            byte[] totalBytes = new byte[readSize];//C#神器，byte[]会自动延长
                            Array.Copy(bytes, 0, totalBytes, 0, readSize);//消息长度 
                            list.AddRange(totalBytes);

                            //获取数据完成，开始解析
                            
                                string dataStr = "";
                                while (list.Count > 12)
                                {
                                    byte[] topBytes = list.Take(12).ToArray();

                                    byte[] packSizeBuffer1 = new byte[4];//4 字节小端整数，表示整条消息（包括自身）长度（字节数）。
                                    Array.Copy(topBytes, 0, packSizeBuffer1, 0, 4);//消息长度 
                                    int packSize1 = BitConverter.ToInt32(packSizeBuffer1, 0);//转成长度

                                    byte[] packSizeBuffer2 = new byte[4];//4 字节小端整数，表示整条消息（包括自身）长度（字节数）。
                                    Array.Copy(topBytes, 4, packSizeBuffer2, 0, 4);//消息长度 
                                    int packSize2 = BitConverter.ToInt32(packSizeBuffer2, 0);//转成长度

                                    byte[] packTypeBuffer = new byte[4];//4 字节小端整数，表示整条消息（包括自身）长度（字节数）。
                                    Array.Copy(topBytes, 8, packTypeBuffer, 0, 2);//消息长度 
                                    int packType = BitConverter.ToInt32(packTypeBuffer, 0);//转成长度

                                    if (packSize1 == packSize2 && packType == DY_MESSAGE_TYPE_SERVER)
                                    {
                                        int packSize = packSize1 + 4;//一个包长度

                                        if (list.Count >= packSize)
                                        {
                                            byte[] totalBytes1 = list.Take(packSize).ToArray();
                                            //Console.WriteLine("截取数据：" + Newtonsoft.Json.JsonConvert.SerializeObject(totalBytes));

                                            list.RemoveRange(0, packSize);//取出后删除  
                                            //Console.WriteLine("截取后源数据：" + Newtonsoft.Json.JsonConvert.SerializeObject(list));

                                            dataStr = Encoding.UTF8.GetString(totalBytes1, 12, totalBytes1.Length - 12);
                                            //Console.WriteLine("截取数据输出：" + dataStr);

                                            //对单一数据包进行解析
                                            MsgView msgView1 = new MsgView(dataStr);
                                            //分析该包的数据类型，以及根据需要进行业务操作
                                            parseServerMsg(msgView1.getMessageList());

                                        }
                                        else
                                        {
                                            break;
                                        }
                                    }
                                }
                            
                        }
                    }
                    catch (Exception e)
                    {
                        if (client == null || client.Connected == false)
                        {
                            shutdown();
                            sendToText("exMsg", "尝试重新连接！");
                        }
                        else
                        {
                            sendToText("exMsg", "错误：获取弹幕失败！");
                        }
                    }
                }
            }
        }