C# SuperSocket 消息推送

 服务端使用Nuget引用SuperSocket.WebSocket和SuperSocket.Engine

 

 

 

 

 

 

 

 

服务器端代码【控制台】

using SuperSocket.WebSocket;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace Server
{
    class Program
    {
        static void Main(string[] args)
        {
            WebSocketServer server = new WebSocketServer();
            server.NewSessionConnected += server_NewSessionConnected;
            server.NewMessageReceived += server_NewMessageReceived;
            server.SessionClosed += server_SessionClosed;
            try
            {
                server.Setup("127.0.0.1", 40001);//设置端口
                server.Start();//开启监听
                PushMsg();
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
            Console.ReadKey();
        }

        static void PushMsg()
        {
            Thread.Sleep(1000);
            try { sessionList.ForEach(o => { o.Send("测试消息推送"); }); }
            catch (Exception ex) { }
            PushMsg();
        }

        public static List<WebSocketSession> sessionList = new List<WebSocketSession>();

        static void server_SessionClosed(WebSocketSession session, SuperSocket.SocketBase.CloseReason value)
        {
            sessionList.Remove(session);
            Console.WriteLine(session.Origin);
        }

        static void server_NewMessageReceived(WebSocketSession session, string value)
        {
            Console.WriteLine(value);
            session.Send(value);
        }

        static void server_NewSessionConnected(WebSocketSession session)
        {
            sessionList.Add(session);
            Console.WriteLine(session.Origin);
        }
    }
}

View Code