C# WebSocketServer类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› c#›C#教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了C#中WebSocketServer类的典型用法代码示例。如果您正苦于以下问题：C# WebSocketServer类的具体用法？C# WebSocketServer怎么用？C# WebSocketServer使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

WebSocketServer类属于命名空间，在下文中一共展示了WebSocketServer类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的C#代码示例。

示例1: Main

        public static void Main(string [] args)
        {
            var wssv = new WebSocketServer (4649);
              //var wssv = new WebSocketServer (4649, true);
              //var wssv = new WebSocketServer ("ws://localhost:4649");
              //var wssv = new WebSocketServer ("wss://localhost:4649");
              #if DEBUG
              wssv.Log.Level = LogLevel.TRACE;
              #endif
              //var cert = ConfigurationManager.AppSettings ["ServerCertFile"];
              //var password = ConfigurationManager.AppSettings ["CertFilePassword"];
              //wssv.Certificate = new X509Certificate2 (cert, password);
              //wssv.KeepClean = false;
              wssv.AddWebSocketService<Echo> ("/Echo");
              wssv.AddWebSocketService<Chat> ("/Chat");
              //wssv.AddWebSocketService<Chat> ("/Chat", () => new Chat ("Anon#"));
              //wssv.AddWebSocketService<Echo> ("/エコー");
              //wssv.AddWebSocketService<Chat> ("/チャット");

              wssv.Start ();
              if (wssv.IsListening)
              {
            Console.WriteLine (
              "A WebSocket Server listening on port: {0} service paths:", wssv.Port);

            foreach (var path in wssv.WebSocketServices.ServicePaths)
              Console.WriteLine ("  {0}", path);
              }

              Console.WriteLine ("\nPress Enter key to stop server...");
              Console.ReadLine ();

              wssv.Stop ();
        }

开发者ID:kevleyski，项目名称:websocket-sharp，代码行数:34，代码来源:Program.cs

示例2: Main

        static void Main(string[] args)
        {
            var config = new ServerConfig {
                Name = "SuperWebSocket",
                Ip = "Any",
                Port = 2012,
                Mode = SocketMode.Tcp,
            };

            Console.WriteLine("Starting WebSocketServer on port " + config.Port + "...");

            var socketServer = new WebSocketServer();
            socketServer.Setup(new RootConfig(), config);

            socketServer.NewMessageReceived += new SessionHandler<WebSocketSession, string>(socketServer_NewMessageReceived);
            socketServer.NewSessionConnected += new SessionHandler<WebSocketSession>(socketServer_NewSessionConnected);
            socketServer.SessionClosed += new SessionHandler<WebSocketSession, CloseReason>(socketServer_SessionClosed);

            if (!socketServer.Start()) {
                Console.WriteLine("Failed to start!");
                Console.ReadKey();
                return;
            }

            Console.WriteLine("The server started successfully, press 'q' key to stop it!");

            while (Console.ReadKey().KeyChar != 'q') {
                Console.WriteLine();
                continue;
            }
            socketServer.Stop();

            Console.WriteLine("\nThe server stopped!");
        }

开发者ID:Psyborx，项目名称:c-sharp-websocket-test，代码行数:34，代码来源:Program.cs

示例3: WebSocketInterface

        public WebSocketInterface(int port)
        {
            _server = new WebSocketServer();
            var setupComplete = _server.Setup(new ServerConfig
            {
                Name = "NecroWebSocket",
                Ip = "Any",
                Port = port,
                Mode = SocketMode.Tcp,
                Security = "tls",
                Certificate = new CertificateConfig
                {
                    FilePath = @"cert.pfx",
                    Password = "necro"
                }
            });

            if (setupComplete == false)
            {
                Logger.Write($"Failed to start WebSocketServer on port : {port}", LogLevel.Error);
                return;
            }

            _server.NewMessageReceived += HandleMessage;
            _server.NewSessionConnected += HandleSession;

            _server.Start();
        }

开发者ID:CapnSplinters，项目名称:d，代码行数:28，代码来源:WebSocketInterface.cs

示例4: Context

 /// <summary>
 /// Initializes a new instance of the <see cref="Context"/> class.
 /// </summary>
 public Context(WebSocketServer server, TcpClient connection)
 {
     Server = server;
     Connection = connection;
     Buffer = new byte[_bufferSize];
     UserContext = new UserContext(this) {ClientAddress = connection.Client.RemoteEndPoint};
 }

开发者ID:realfuxx，项目名称:Alchemy-Websockets，代码行数:10，代码来源:Context.cs

示例5: Awake

        public void Awake()
        {
            // Just in case cancel all old invokes related to this instance
            CancelInvoke ();

            // Do a full sync
            //FullSync ();

            // Add all vessels to the vessel list
            foreach (Vessel vessel in FlightGlobals.Vessels) {
                if (!all_vessels.Contains (vessel)) {
                    all_vessels.Add (vessel);
                }
            }
            InvokeRepeating ("UpdateClients",1.0F,1.0F);

            if (wssv == null) {
                Debug.Log ("Establishing websocket");
                wssv = new WebSocketServer (12321); //TODO: Add possibility to configure IP
                wssv.AddWebSocketService<MissionControlService> ("/mcs", () => new MissionControlService (this));
                wssv.Start ();

                Debug.Log ("Established websocket!");
            }
        }

开发者ID:voneiden，项目名称:ksp-missioncontrol，代码行数:25，代码来源:MissionControl.cs

示例6: Main

        public static void Main()
        {
            var server = new WebSocketServer("127.0.0.1", 8080);
            server.Started += (sender, args) => Console.WriteLine("Server started!");
            server.Stopped += (sender, args) => Console.WriteLine("Server stopped!");

            Console.WriteLine("Tully WebSocket server at your command");
            var exit = false;
            server.Start();

            while (!exit)
            {
                var cmd = Console.ReadLine();

                switch (cmd)
                {
                    case "/exit":
                        exit = true;
                        break;
                    case "/start":
                        server.Start();
                        break;
                    case "/stop":
                        server.Stop();
                        break;
                    default:
                        Console.WriteLine("Unknown command " + cmd);
                        break;
                }
            }

            Console.WriteLine("Press any key to exit");
            Console.ReadKey();
        }

开发者ID:Domeee，项目名称:websockets，代码行数:34，代码来源:Program.cs

示例7: Main

        static void Main()
        {
            var allSockets = new List<IWebSocketConnection>();
            var server = new WebSocketServer("ws://localhost:8181");
            server.Start(socket =>
                {
                    socket.OnOpen = () =>
                        {
                            Console.WriteLine("Open!");
                            allSockets.Add(socket);
                        };
                    socket.OnClose = () =>
                        {
                            Console.WriteLine("Close!");
                            allSockets.Remove(socket);
                        };
                    socket.OnMessage = message =>
                        {
                            Console.WriteLine(message);
                        };
                });

            var input = Console.ReadLine();
            while (input != "exit")
            {
                foreach (var socket in allSockets.ToList())
                {
                    socket.Send(input);
                }
                input = Console.ReadLine();
            }
        }

开发者ID:emiaj，项目名称:Fleck，代码行数:32，代码来源:Server.cs

示例8: BasicRoundTrip

		public void BasicRoundTrip()
		{
			var serializer = new JsonCommonSerializer();

			var port = new Random().Next(6000, 60000);

			var listener = new WebSocketServer("ws://localhost:" + port);
			var serverTransport = listener.GenerateTransportSource("/p1");
			var serverRouter = new DefaultMessageRouter(serverTransport, serializer);
			serverRouter.AddService<IMyService>(new MyService());
			listener.Start();

			var client = new WebSocket("ws://localhost:" + port + "/p1");
			var clientTransport = client.GenerateTransportSource();
			var clientRouter = new DefaultMessageRouter(clientTransport, serializer);
			var proxy = clientRouter.AddInterface<IMyService>();
			client.Connect();

			var result = proxy.Add(3, 4).Result;
			Assert.Equal(7, result);

			clientRouter.Dispose();
			clientTransport.Dispose();
			client.Close();

			serverRouter.Dispose();
			serverTransport.Dispose();
			listener.Stop();
		}

开发者ID:BrannonKing，项目名称:Kts.Remoting，代码行数:29，代码来源:WebsocketSharpFullCircle.cs

示例9: Setup

        public void Setup()
        {
            _symbols = new List<Symbol>()
            {
                Symbol.Create("AAPL", SecurityType.Equity, Market.USA),
                Symbol.Create("AIG", SecurityType.Equity, Market.USA)
            };

            Config.Set("live-data-url", "ws://127.0.0.1");
            Config.Set("live-data-port", "8080");

            _mockServerBehavior = new MockServerBehavior();
            _dataQueueHandler = new ApiDataQueueHandler();
            var liveDataUri = new Uri(Config.Get("live-data-url"));
            var uriBuilder = new UriBuilder(liveDataUri);
            uriBuilder.Port = Config.GetInt("live-data-port");

            Task.Run(() =>
            {
                _mockServer = new WebSocketServer(uriBuilder.ToString());
                _mockServer.AddWebSocketService("/", () => _mockServerBehavior);

                Log.Trace("ApiDataQueueHandlerTests.Setup(): Starting the mock server.");
                _mockServer.Start();

                while (true)
                {
                    Thread.Sleep(1000);
                }
            });
        }

开发者ID:AlexCatarino，项目名称:Lean，代码行数:31，代码来源:ApiDataQueueHandlerTests.cs

示例10: Main

        static void Main(string[] args)
        {
            //int port = int.Parse(args[0]);
            int port = 443;
            ServerConfig serverConfig = new ServerConfig
            {
                Name = "SecureSuperWebSocket",
                Ip = "Any",
                Port = port,
                MaxRequestLength = 10485760,
                SendingQueueSize = 500,
                ReceiveBufferSize = 2050 * 1024,
                //SendBufferSize = 600 * 1024,
            };

            socketServer = new WebSocketServer();
            socketServer.NewSessionConnected += SocketServer_NewSessionConnected;
            socketServer.NewDataReceived += SocketServer_NewDataReceived;
            //socketServer.NewMessageReceived += SocketServer_NewMessageReceived;
            socketServer.Setup(serverConfig);
            socketServer.Start();

            Console.WriteLine("Server is running on port {0} ...", port);

            Console.ReadKey();
        }

开发者ID:Jackie-Innover，项目名称:3VR，代码行数:26，代码来源:Program.cs

示例11: Main

        static void Main(string[] args)
        {
            var webSocketServer = new WebSocketServer("ws://localhost:8081");
            var sockets = new List<IWebSocketConnection>();

            webSocketServer.Start(socket =>
            {
                socket.OnOpen = () =>
                {
                    sockets.Add(socket);
                };

                socket.OnMessage = mensagem =>
                {
                    foreach (var s in sockets)
                    {
                        s.Send(mensagem);
                    }
                };

                socket.OnClose = () =>
                {
                    sockets.Remove(socket);
                };
            });

            Console.ReadKey();
        }

开发者ID:jean-lourenco，项目名称:FleckWebSocketDemo，代码行数:28，代码来源:Program.cs

示例12: MainWindow

 public MainWindow()
 {
     InitializeComponent();
     wsServer = new WebSocketServer(IPAddress.Parse("127.0.0.1"), 1234);
     wsServer.AddWebSocketService<Echo>("/");
     wsServer.Start();
 }

开发者ID:NIAEFEUP，项目名称:Kommando，代码行数:7，代码来源:MainWindow.xaml.cs

示例13: Run

        public void Run()
        {
            //websocket init
            Console.WriteLine("tetris server is starting... port:{0}", Port_WebSocket);
            var listener = new WebSocketServer();
            listener.NewMessageReceived += listener_NewMessageReceived;
            listener.NewSessionConnected += listener_NewSessionConnected;

            if (!listener.Setup(Port_WebSocket))
            {
                Console.WriteLine("failed to initialize.");
                return;
            }

            if (!listener.Start())
            {
                Console.WriteLine("failed to start.");
                return;
            }

            //transceiver init
            Console.WriteLine("transceiver is starting... port:{0}", Port_Transceiver);
            var tr = new Transceiver(null, 2013);

            isRunning = true;
            Thread th = new Thread(() =>
            {
                Packet p = new Packet();
                while (isRunning)
                {
                    p.Clear();
                    tr.Receive(ref p);

                    Console.WriteLine("received a packet: {0}", p.Peek());

                    if (conn != null)
                    {
                        try
                        {
                            conn.Send((string)p.Pop());
                        }
            #pragma warning disable 0168
                        catch (Exception ex)
                        {
                            //conn = null;
                        }
            #pragma warning restore 0168
                    }
                }
                tr.Dispose();
            });
            th.Start();

            Console.WriteLine("press enter to terminate server.");
            Console.ReadLine();

            isRunning = false;
            listener.Stop();
            Console.WriteLine("terminating server...");
        }

开发者ID:Letractively，项目名称:sod-lg-smart-tv-project，代码行数:60，代码来源:TetrisWebSocket.cs

示例14: WebSocketInterface

        public WebSocketInterface(int port, Session session)
        {
            _session = session;
            var translations = session.Translation;
            _server = new WebSocketServer();
            _websocketHandler = WebSocketEventManager.CreateInstance();
            var setupComplete = _server.Setup(new ServerConfig
            {
                Name = "NecroWebSocket",
                Ip = "Any",
                Port = port,
                Mode = SocketMode.Tcp,
                Security = "tls",
                Certificate = new CertificateConfig
                {
                    FilePath = @"cert.pfx",
                    Password = "necro"
                }
            });

            if (setupComplete == false)
            {
                Logger.Write(translations.GetTranslation(TranslationString.WebSocketFailStart, port), LogLevel.Error);
                return;
            }

            _server.NewMessageReceived += HandleMessage;
            _server.NewSessionConnected += HandleSession;

            _server.Start();
        }

开发者ID:RedNax67，项目名称:NecroBot，代码行数:31，代码来源:WebSocketInterface.cs

示例15: Test1

        static void Test1()
        {
            FleckLog.Level = LogLevel.Debug;
            var allSockets = new List<IWebSocketConnection>();
            var server = new WebSocketServer("ws://localhost:8181");
            server.Start(socket =>
                {
                    socket.OnOpen = () =>
                        {
                            Console.WriteLine("Open!");
                            allSockets.Add(socket);
                        };
                    socket.OnClose = () =>
                        {
                            Console.WriteLine("Close!");
                            allSockets.Remove(socket);
                        };
                    socket.OnMessage = message =>
                        {
                            Console.WriteLine(message);
                            allSockets.ToList().ForEach(s => s.Send("Echo: " + message));
                        };
                });

            var input = Console.ReadLine();
            while (input != "exit")
            {
                foreach (var socket in allSockets.ToList())
                {
                    socket.Send(input);
                }
                input = Console.ReadLine();
            }
        }

开发者ID:vbguyny，项目名称:Fleck，代码行数:34，代码来源:Server.cs

示例16: SetUp

 public void SetUp()
 {
     server = new WebSocketServer(URI.Port);
     server.AddService<Echo>(URI.AbsolutePath);
     server.Start();
     handle = new EventWaitHandle(false, EventResetMode.AutoReset);
 }

开发者ID:wsky，项目名称:top-link，代码行数:7，代码来源:WebSocketChannelTest.cs

示例17: Start

 public void Start(string address, int port, string path)
 {
     IPAddress ipaddr = new IPAddress(address.Split('.').Select(a => (byte)a.to_i()).ToArray());
     WebSocketServer wss = new WebSocketServer(ipaddr, port, this);
     wss.AddWebSocketService<ServerReceiver>(path);
     wss.Start();
 }

开发者ID:cliftonm，项目名称:clifton，代码行数:7，代码来源:WebSocketServerService.cs

示例18: Start

        public void Start()
        {
            try
            {
                var socketServer = new WebSocketServer(this._port, this._isSSL);
                socketServer.AddWebSocketService<WSClientBehaviour>(this._path);
                if (this._isSSL)
                {
                    //configure SSL for websocket server (just to test this feature!)
                    string basedir = AppDomain.CurrentDomain.BaseDirectory;
                    string certPath = System.IO.Path.GetFullPath(System.IO.Path.Combine(basedir, @"..\serverCertificate.pfx"));
                    if (!System.IO.File.Exists(certPath))
                        throw new Exception("I did not found the SSL certificate for the websocket server");
                    var passwd = "password";
                    socketServer.SslConfiguration.ServerCertificate = new X509Certificate2(certPath, passwd);
                }
               
                socketServer.Log.Output = (logData, msg) =>
                {
                    if (logData.Level == LogLevel.Error || logData.Level == LogLevel.Fatal)
                       this.OnError(new Exception(logData.Message));
                };
               
                this._socketServer = socketServer;
                socketServer.Start();

                MessageService.Start(this);
            }
            catch (Exception ex)
            {
                this.OnError(ex);
            }
        }

开发者ID:cbsistem，项目名称:JRIAppTS，代码行数:33，代码来源:WebSockectService.cs

示例19: Initialize

	private static void Initialize () {
		wsServer = new WebSocketServer(
			WebConsoleDefinitions.SERVE_PROTOCOL + WebConsoleDefinitions.SERVE_ADDRESS + ":" + WebConsoleDefinitions.SERVE_PORT
		);
		wsServer.AddWebSocketService<WSServerInstance>("/");
		wsServer.Start();
	}

开发者ID:sassembla，项目名称:Unidon，代码行数:7，代码来源:ServerInitializer.cs

示例20: WebChat

 public WebChat()
 {
     ws = new WebSocketServer();
     ws.NewSessionConnected += ws_NewSessionConnected;
     ws.NewMessageReceived += ws_NewMessageReceived;
     ws.NewDataReceived += ws_NewDataReceived;
     ws.SessionClosed += ws_SessionClosed;
 }

开发者ID:AimilaGaven，项目名称:Magic，代码行数:8，代码来源:WebChat.cs

注：本文中的WebSocketServer类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

C# WebSocketSession类代码示例发布时间：2022-05-24

C# WebSocketMessageType类代码示例发布时间：2022-05-24

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：19158|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9981|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8320|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8690|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8633|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9649|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8617|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7994|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8647|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7531|2022-11-06

客服电话

电子邮件

C# WebSocketServer类代码示例

示例1: Main

示例2: Main

示例3: WebSocketInterface

示例4: Context

示例5: Awake

示例6: Main

示例7: Main

示例8: BasicRoundTrip

示例9: Setup

示例10: Main

示例11: Main

示例12: MainWindow

示例13: Run

示例14: WebSocketInterface

示例15: Test1

示例16: SetUp

示例17: Start

示例18: Start

示例19: Initialize

示例20: WebChat

请发表评论

全部评论

上一篇：

下一篇：

bradtraversy/iweather: Ionic 3 mobile we

joaomh/curso-de-matlab

断牙刷新位置时间（断牙属性及刷新位置介绍

微信小程序 PHP后端form表单提交实例详解

rugk/mastodon-simplified-federation: Sim

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053