VueWebApi/Tools/TestSocket.cs
@@ -18,32 +18,40 @@
        public void socketServer()
        {
            string serverIP = System.Configuration.ConfigurationManager.AppSettings["FileIP"]; //服务器IP地址
            var server = new WebSocketServer(serverIP);
            server.Start(socket =>//服务开始
            try
            {
                var userid = socket.ConnectionInfo.Path.Split('?')[1].Split('=')[1];
                string serverIP = System.Configuration.ConfigurationManager.AppSettings["serverIP"]; //服务器IP地址
                var server = new WebSocketServer(serverIP);
                server.Start(socket =>//服务开始
                {
                    var userid = socket.ConnectionInfo.Path.Split('?')[1].Split('=')[1];
                socket.OnOpen = () =>
                {
                    Console.WriteLine("Open!");
                    allSockets.Add(userid, socket);
                };
                socket.OnClose = () =>
                {
                    Console.WriteLine("Close!");
                    allSockets.Remove(userid);
                };
                socket.OnMessage = message =>
                {
                    //客户端交互的消息
                    //System.Timers.Timer t = new System.Timers.Timer(10000);//实例化Timer类,设置间隔时间为10000毫秒;
                    //t.Elapsed += new System.Timers.ElapsedEventHandler(theout);//到达时间的时候执行事件;
                    //t.AutoReset = true;//设置是执行一次(false)还是一直执行(true);
                    //t.Enabled = true;//是否执行System.Timers.Timer.Elapsed事件;
                    allSockets.ToList().ForEach(s => s.Value.Send("Echo: " + msg));
                };
            });
                    socket.OnOpen = () =>
                    {
                        Console.WriteLine("Open!");
                        allSockets.Add(userid, socket);
                    };
                    socket.OnClose = () =>
                    {
                        Console.WriteLine("Close!");
                        allSockets.Remove(userid);
                    };
                    socket.OnMessage = message =>
                    {
                        //客户端交互的消息
                        //System.Timers.Timer t = new System.Timers.Timer(10000);//实例化Timer类,设置间隔时间为10000毫秒;
                        //t.Elapsed += new System.Timers.ElapsedEventHandler(theout);//到达时间的时候执行事件;
                        //t.AutoReset = true;//设置是执行一次(false)还是一直执行(true);
                        //t.Enabled = true;//是否执行System.Timers.Timer.Elapsed事件;
                        allSockets.ToList().ForEach(s => s.Value.Send("Echo: " + msg));
                    };
                });
            }
            catch (Exception ex)
            {
                throw new Exception(ex.Message);
            }
        }
        /// <summary>