編集履歴

回答編集履歴

変数の型をvarにTask.Factory.StartNewを追加

2018/04/10 06:48

投稿

スコア5846

answer CHANGED Viewed

@@ -29,8 +29,13 @@
     }
 }
 public void OnRequested(IAsyncResult res){
-    HttpListener listener = (HttpListener)res.AsyncState;
+    var listener = res.AsyncState as HttpListener;
+    if (!listener.IsListening)
+    {
+       // 受信開始→終了でOnRequestedイベントが発火するため、受信待機状態でない時はSkip
+       return;
+    }
-    HttpListenerContext context = listener.EndGetContext(res);
+    var context = listener.EndGetContext(res);
     listener.BeginGetContext(this.OnRequested, listener);
 　　//　以下はやりたいこと。
@@ -69,13 +74,15 @@
     }
 }
 public void OnRequested(IAsyncResult res){
-    TcpListener listener = res.AsyncState as TcpListener;
+    var listener = res.AsyncState as TcpListener;
-    TcpClient client = listener.EndAcceptTcpClient(res);
+    var client = listener.EndAcceptTcpClient(res);
     listener.BeginAcceptTcpClient(this.OnRequested, listener);
+    Task.Factory.StartNew(() =>
+    {
-　　//　これ以下は各クライアントでやりたいこと。async/awaitなどの並列化処理を使ってください。
+　　     //これ以降は各クライアントで行いたい処理。
-    client.Client.RemoteEndPoint;
+        client.Client.RemoteEndPoint;
-    NetworkStream stream = client.GetStream();
+        var stream = client.GetStream();
+    });
 }
 ```

追記

2018/04/10 06:48

投稿

umyu

スコア5846

answer CHANGED Viewed

@@ -73,7 +73,7 @@
     TcpClient client = listener.EndAcceptTcpClient(res);
     listener.BeginAcceptTcpClient(this.OnRequested, listener);
-　　//　これ以下は各クライアントでやりたいこと。
+　　//　これ以下は各クライアントでやりたいこと。async/awaitなどの並列化処理を使ってください。
     client.Client.RemoteEndPoint;
     NetworkStream stream = client.GetStream();

追記

2018/04/10 06:18

投稿

umyu

スコア5846

answer CHANGED Viewed

@@ -70,11 +70,12 @@
 }
 public void OnRequested(IAsyncResult res){
     TcpListener listener = res.AsyncState as TcpListener;
-    TcpClient context = listener.EndAcceptTcpClient(res);
+    TcpClient client = listener.EndAcceptTcpClient(res);
     listener.BeginAcceptTcpClient(this.OnRequested, listener);
 　　//　これ以下は各クライアントでやりたいこと。
+    client.Client.RemoteEndPoint;
-　　// context にはクライアントのIPアドレスとStreamがあるはずです。
+    NetworkStream stream = client.GetStream();
 }
 ```

追記

2018/04/10 05:49

投稿

umyu

スコア5846

answer CHANGED Viewed

@@ -41,4 +41,40 @@
 ◇参考情報
 0. [TcpListener#BeginAcceptTcpClient](https://msdn.microsoft.com/ja-jp/library/system.net.sockets.tcplistener.beginaccepttcpclient(v=vs.110).aspx)
-1. [HttpListener クラス](https://msdn.microsoft.com/ja-jp/library/system.net.httplistener(v=vs.110).aspx)
+1. [HttpListener クラス](https://msdn.microsoft.com/ja-jp/library/system.net.httplistener(v=vs.110).aspx)
+---
+コンパイル通してませんが、TcpListener の場合はこのような形です。
+```C#
+private TcpListener server = new TcpListener();
+private readonly object locker = new object();
+public Action<string> OnLogWrite;// ログ出力用
+public void Start()
+{
+    lock (this.locker)
+    {
+        // ここらへんでlistenとbindが必要なはず。
+        // start
+        this.server.Start();
+        this.server.BeginAcceptTcpClient(this.OnRequested, this.server);
+    }
+}
+public void Stop()
+{
+    lock (this.locker)
+    {
+        this.server.Close();
+        this.server = new TcpListener();
+    }
+}
+public void OnRequested(IAsyncResult res){
+    TcpListener listener = res.AsyncState as TcpListener;
+    TcpClient context = listener.EndAcceptTcpClient(res);
+    listener.BeginAcceptTcpClient(this.OnRequested, listener);
+　　//　これ以下は各クライアントでやりたいこと。
+　　// context にはクライアントのIPアドレスとStreamがあるはずです。
+}
+```

追記

2018/04/10 05:22

投稿

umyu

スコア5846

answer CHANGED Viewed

@@ -1,6 +1,7 @@
-◇大前提
+◇ベストカレントプラティクス
-今なら、`WebSocket`で作られた方が楽に作れるような気がしますが。
+`WebSocket`で作成されるのが一番だと思います。
+◇以下は処理案です。
 1,あまりコードをよく見ていませんが、`server.AcceptTcpClient`の戻り値をスレッドプールで処理するのも一つの手ですが、クライアントのメッセージを受信部分は非同期処理の`server.BeginAcceptTcpClient`を使うのも一つの手かと。
 2,`RunRecvMessageAsync`内で、 `server = new TcpListener(localAddr, PortnumSV);`を行うのではなく。`StartServer`と`StopSever`で行ってください。

tcplistenerにはBeginGetContextがなかったので訂正

2018/04/10 03:25

投稿

umyu

スコア5846

answer CHANGED Viewed

@@ -1,11 +1,11 @@
 ◇大前提
 今なら、`WebSocket`で作られた方が楽に作れるような気がしますが。
-1,あまりコードをよく見ていませんが、`server.AcceptTcpClient`の戻り値をスレッドプールで処理するのも一つの手ですが、クライアントのメッセージを受信部分は`server.BeginGetContext`を使うのも一つの手かと。
+1,あまりコードをよく見ていませんが、`server.AcceptTcpClient`の戻り値をスレッドプールで処理するのも一つの手ですが、クライアントのメッセージを受信部分は非同期処理の`server.BeginAcceptTcpClient`を使うのも一つの手かと。
 2,`RunRecvMessageAsync`内で、 `server = new TcpListener(localAddr, PortnumSV);`を行うのではなく。`StartServer`と`StopSever`で行ってください。
 3,`TcpListener`を使っても最終的には独自の通信プロトコルを作成する必要があるため、`TcpListener`ではなく`HttpListener`を使うと、プロトコルのデバック作業が楽になります。
-動作確認してませんが、こんな感じです。
+動作確認してませんが、サンプルソースです雰囲気を感じ取ってくださいな。
 ```C#
 private HttpListener server = new HttpListener();
 private readonly object locker = new object();
@@ -35,5 +35,9 @@
 　　//　以下はやりたいこと。
 }
 ```
-4.変数:`status`をクライアントの接続の度に変更しているのも複数接続で、破綻しているのではないでしょうか。
+4.`RunRecvMessageAsync`メソッド内で、変数:`status`をクライアントの接続の度に変更しているのも複数接続で、破綻しているのではないでしょうか。
-5,画面やログの書き出しは`action`を定義すると便利です。スレッドセーフを意識してくださいな。
+5,画面やログの書き出しは`action`を定義すると便利です。スレッドセーフを意識してくださいな。
+◇参考情報
+0. [TcpListener#BeginAcceptTcpClient](https://msdn.microsoft.com/ja-jp/library/system.net.sockets.tcplistener.beginaccepttcpclient(v=vs.110).aspx)
+1. [HttpListener クラス](https://msdn.microsoft.com/ja-jp/library/system.net.httplistener(v=vs.110).aspx)

追記

2018/04/10 03:04

投稿

umyu

スコア5846

answer CHANGED Viewed

@@ -1,14 +1,11 @@
+◇大前提
-今なら、WebSocketで作られた方が楽に作れるような気がしますが。
+今なら、`WebSocket`で作られた方が楽に作れるような気がしますが。
-1,あまりコードをよく見ていませんが、server.AcceptTcpClientの戻り値をスレッドプールで処理するのも一つの手ですが、クライアントのメッセージを受信部分はserver.BeginGetContextを使うのも一つの手かと。
+1,あまりコードをよく見ていませんが、`server.AcceptTcpClient`の戻り値をスレッドプールで処理するのも一つの手ですが、クライアントのメッセージを受信部分は`server.BeginGetContext`を使うのも一つの手かと。
-2,RunRecvMessageAsync内で、 server = new TcpListener(localAddr, PortnumSV);を行うのではなく。StartServerとStopSeverで行ってください。
+2,`RunRecvMessageAsync`内で、 `server = new TcpListener(localAddr, PortnumSV);`を行うのではなく。`StartServer`と`StopSever`で行ってください。
-3,TcpListenerを使っても最終的には独自の通信プロトコルを作成する必要があるため、TcpListenerではなくHttpListenerを使うと、プロトコルのデバック作業が楽になります。
+3,`TcpListener`を使っても最終的には独自の通信プロトコルを作成する必要があるため、`TcpListener`ではなく`HttpListener`を使うと、プロトコルのデバック作業が楽になります。
 動作確認してませんが、こんな感じです。
-4.変数:statusをクライアントの接続の度に変更しているのも複数接続で、破綻するのではないかと少し気になってます。
-5,画面やログの書き出しはactionを定義すると便利です。
 ```C#
 private HttpListener server = new HttpListener();
 private readonly object locker = new object();
@@ -37,4 +34,6 @@
     listener.BeginGetContext(this.OnRequested, listener);
 　　//　以下はやりたいこと。
 }
-```
+```
+4.変数:`status`をクライアントの接続の度に変更しているのも複数接続で、破綻しているのではないでしょうか。
+5,画面やログの書き出しは`action`を定義すると便利です。スレッドセーフを意識してくださいな。