更改了大部分功能和逻辑

xiaojiao

2026-01-12 c3b60d865c3457c35054446e81b352e93e00a696

 ÏîÄ¿´úÂë/WMS/WIDESEA_WMSServer/WIDESEA.Common/ChatHub/WebSocketRover.cs

@@ -12,32 +12,32 @@
        public static string msg = "默认信息";
        public void socketServer()
        {
            string serverIP = "ws://127.0.0.1:8099"; //System.Configuration.ConfigurationManager.AppSettings["serverIP"];
            var allSockets = new List<IWebSocketConnection>();
            var server = new WebSocketServer(serverIP);
            server.Start(socket =>//服务开始
            {
                socket.OnOpen = () =>
                {
                    Console.WriteLine("Open!");
                    allSockets.Add(socket);
                };
                socket.OnClose = () =>
                {
                    Console.WriteLine("Close!");
                    allSockets.Remove(socket);
                };
                socket.OnMessage = message =>
                { //客户端交互的消息
                    System.Timers.Timer t = new System.Timers.Timer(1000);//实例化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.Send("Echo: " + msg));
            //string serverIP = "ws://127.0.0.1:8099"; //System.Configuration.ConfigurationManager.AppSettings["serverIP"];
            //var allSockets = new List<IWebSocketConnection>();
            //var server = new WebSocketServer(serverIP);
            //server.Start(socket =>//服务开始
            //{
            //    socket.OnOpen = () =>
            //    {
            //        Console.WriteLine("Open!");
            //        allSockets.Add(socket);
            //    };
            //    socket.OnClose = () =>
            //    {
            //        Console.WriteLine("Close!");
            //        allSockets.Remove(socket);
            //    };
            //    socket.OnMessage = message =>
            //    { //客户端交互的消息
            //        System.Timers.Timer t = new System.Timers.Timer(1000);//实例化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.Send("Echo: " + msg));

                    Console.WriteLine("here === ");
                };
            });
            //        Console.WriteLine("here === ");
            //    };
            //});


        }