質問編集履歴

追記

2020/08/03 01:06

投稿

tc_hiro

スコア17

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -291,3 +291,239 @@
 }
 ```
+###追記
+下記のとおりC#のソースを修正し、何度も接続することは可能になりました。
+しかし、WebSocketを起動したままで
+一度webブラウザを閉じて再度開いて接続しようとしてもできません。
+デバッグすると`var ret = await ws.ReceiveAsync(buff, CancellationToken.None);`で
+止まってしまっています。
+何かお分かりになる方、お教授お願いいたします。
+```
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Net;
+using System.Net.WebSockets;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+using System.Runtime.Serialization.Json;
+using System.IO;
+namespace webSocketServer
+{
+    class Program
+    {
+        static void Main(string[] args)
+        {
+            Run();
+            Console.ReadKey();
+        }
+        static async Task Run()
+        {
+            HttpListener s = new HttpListener();
+            s.Prefixes.Add("http://xxxx/");
+            s.Start();
+            Console.WriteLine("サーバ起動");
+            while (true)
+            {
+                var hc = await s.GetContextAsync();
+                if (hc.Request.IsWebSocketRequest)
+                {
+                    ProcessRequest(hc);
+                //クライアントからのリクエストがWebSocketでない場合は処理を中断
+                }
+                else {
+                    hc.Response.StatusCode = 400;
+                    hc.Response.Close();
+                    return;
+                }
+            }
+        }
+        static async void ProcessRequest(HttpListenerContext hc)
+        {
+            //WebSocketでレスポンスを返却
+            var wsc = await hc.AcceptWebSocketAsync(null);
+            var ws = wsc.WebSocket;
+            var response = "";
+            /// WebSocketの送受信ループ
+            while (ws.State == WebSocketState.Open)
+            {
+                try
+                {
+                    var buff = new ArraySegment<byte>(new byte[1024]);
+                    /// 受信待機
+                    var ret = await ws.ReceiveAsync(buff, CancellationToken.None);
+                    Console.WriteLine("受信");
+                    /// テキスト
+                    if (ret.MessageType == WebSocketMessageType.Text)
+                    {
+                        response = Encoding.UTF8.GetString(buff.Take(ret.Count).ToArray());
+                        Console.WriteLine(response);
+                        var serializer = new DataContractJsonSerializer(typeof(ReceiveData));
+                        var ms = new MemoryStream(Encoding.UTF8.GetBytes(response));
+                        var JsRes = (ReceiveData)serializer.ReadObject(ms);
+                        ms.Close();
+                        response = JsRes.item;
+                        //文字列をByte型に変換
+                        var buffer = Encoding.UTF8.GetBytes(response);
+                        var segment = new ArraySegment<byte>(buffer);
+                        //クライアント側に文字列を送信
+                        await ws.SendAsync(segment, WebSocketMessageType.Text, true, CancellationToken.None);
+                        Console.WriteLine(segment);
+                    }
+                    else if (ret.MessageType == WebSocketMessageType.Close) /// クローズ
+                    {
+                        Console.WriteLine("クローズ要求");
+                    }
+                }
+                catch
+                {
+                    /// 例外 クライアントが異常終了
+                    Console.WriteLine("異常終了");
+                    break;
+                }
+            }
+        }
+    }
+    public class ReceiveData
+    {
+        public string item { get; set; }
+        public int cnt { get; set; }
+    }
+}
+```