推荐文章

using iService.SocketParam;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Web.Script.Serialization;
using SocketServer;
namespace iService
{
    public class SocketHost
    {
        private IDictionary<Socket, byte[]> socketClientSesson = new Dictionary<Socket, byte[]>();

        public int Port { get; set; }

        public void Start()
        {
            var socketThread = new Thread(() =>
            {
                Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                IPEndPoint iep = new IPEndPoint(IPAddress.Any, this.Port);
                //绑定到通道上
                socket.Bind(iep);
                //侦听
                socket.Listen(100000);
                //通过异步来处理
                socket.BeginAccept(new AsyncCallback(Accept), socket);

            });
            socketThread.Start();
            Error.WriteToFile("Socket服务器已启动");
        }
        /// <summary>
        /// 链接
        /// </summary>
        /// <param name="ia"></param>
        private void Accept(IAsyncResult ia)
        {
            try
            {
                Socket socket = ia.AsyncState as Socket;
                var client = socket.EndAccept(ia);

                socket.BeginAccept(new AsyncCallback(Accept), socket);

                byte[] buf = new byte[1024];
                this.socketClientSesson.Add(client, buf);
                string sessionId = client.Handle.ToString();

                client.BeginReceive(buf, 0, buf.Length, SocketFlags.None, new AsyncCallback(Receive), client);

                //保存客户端

                //保存完成
                Error.WriteToFile(string.Format("客户端({0})已连接", sessionId));
            }
            catch (Exception ex)
            {
                Error.WriteToFile("监听请求时出错：\r\n" + ex.ToString());
            }
        }
        /// <summary>
        /// 接收信息
        /// </summary>
        /// <param name="ia"></param>
        private void Receive(IAsyncResult ia)
        {
            var client = ia.AsyncState as Socket;

            if (client == null || !this.socketClientSesson.ContainsKey(client))
            {
                return;
            }

            int count = client.EndReceive(ia);

            byte[] buf = this.socketClientSesson[client];
            //byte[] buf = new byte[1024];

            string sessionId = client.Handle.ToString();

            if (count > 0)
            {
                try
                {
                    client.BeginReceive(buf, 0, buf.Length, SocketFlags.None, new AsyncCallback(Receive), client);
                    string context = Encoding.UTF8.GetString(buf, 0, count);
                    Param.AddCache(sessionId, context);
                    ArrayList ai = Param.OutCache(sessionId);
                    foreach (object o in ai)
                    {
                        string s = o.ToString();
                        Error.WriteToFile(string.Format("接收的数据为:{0}", s));
                        this.Response(client, s);
                        Thread.Sleep(1000);
                    }
                }
                catch (Exception ex)
                {
                    Error.WriteToFile(string.Format("接收的数据出错:{0}", ex.ToString()));
                }
            }
            else
            {
                try
                {

                    client.Disconnect(true);

                    this.socketClientSesson.Remove(client);
                    Param.RemoveCache(sessionId);
                    Error.WriteToFile(string.Format("客户端({0})已断开", sessionId));
                }
                catch (Exception ex)
                {
                    Error.WriteToFile(string.Format("客户端已断开出错" + ex.ToString()));
                }
            }
        }

        private void Response(Socket sender, string context)
        {
            SocketRequest request = null;
            JavaScriptSerializer jss = new JavaScriptSerializer();
            request = jss.Deserialize(context, typeof(SocketRequest)) as SocketRequest;

            if (request == null)
            {
                return;
            }

            var typeName = "SocketServer." + request.API + "ResponseManager";
            Error.WriteToFile(string.Format("反射类名为：{0}", typeName));

            Type type = Type.GetType(typeName);
            if (type == null)
            {
                Error.WriteToFile(string.Format("Type反射为空"));
                return;
            }

            var manager = Activator.CreateInstance(type) as IResponseManager;
            manager.Exec(sender, this.socketClientSesson.Select(s => s.Key).ToList(),
                request.Data as IDictionary<string, object>,request.Sign);
        }
    }
}