Test.Core.Web/apis/WebSocketServerController.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using CommonUtils;
using Microsoft.AspNetCore.Mvc;
using System;
using System.Collections.Generic;
using WebSocketSharp;

namespace Test.Core.Web.apis
{
    [Route("api/[controller]/[action]")]
    public class WebSocketServerController : ControllerBase
    {
        private static Queue<string> _logs = new Queue<string>();

        private void Server_OnError(Exception obj)
        {
            _logs.Enqueue("Server error: " + obj.Message);
        }
        private void Server_OnStart()
        {
            _logs.Enqueue("Server startted!");
        }

        private void Server_OnSendMessage(string arg1, WebSocketServerSession arg2)
        {
            _logs.Enqueue("Server sended message:\r\n" + arg1 + "\r\nto " + arg2.ClientEndPoint);
        }

        private void Server_OnStop()
        {
            _logs.Enqueue("Server stopped!");
        }

        private void Server_OnSessionError(Exception arg1, WebSocketServerSession arg2)
        {
            _logs.Enqueue("Session error: " + arg1.Message + "\r\non " + arg2.ClientEndPoint);
        }

        private void Server_OnSessionConnect(WebSocketServerSession obj)
        {
            _logs.Enqueue("Session connect: " + obj.ClientEndPoint);
        }

        private void Server_OnSessionReceiveMessage(MessageEventArgs arg1, WebSocketServerSession arg2)
        {
            _logs.Enqueue("Receive message:\r\n" + arg1.Data);
        }

        private void Server_OnSessionDisconnect(WebSocketServerSession obj)
        {
            _logs.Enqueue("Session disconnect: " + obj.ClientEndPoint);
        }

        private static WebSocketServer _server;

        [HttpPost]
        public ApiResult Startup(int port, string route)
        {
            if (_server != null)
                _server.Stop();
            _server = new WebSocketServer(port, route);