簡単なネットワークプログラムなのですが・・・

質問

ネットワーク通信の基礎を学ぼうと、いろいろなサイトをみながらSocket通信の簡単なメッセージ送受信を行おうとしているのですが、streamを使って送信したメッセージを送信、又は受信するときにsocketを閉じないと送信できません。
そして常に受信させたいのですが、socketを閉じているため、nullexceptionになってしまいます。
何か別の手はありますでしょうか・・・？
現在↓のような感じで行っています。

private void 待機ToolStripMenuItem_Click(object sender, EventArgs e)
{
//サーバーを開始
Int32 port = 9999;
IPAddress localAddr = IPAddress.Parse("127.0.0.1");
server = new TcpListener(localAddr, port);
server.Start();

threadA = new Thread(recvData);
threadA.Start();
}

// 受信用（マルチスレッド）
public void recvData()
{
//接続待機
this.Invoke(new MyDelegate(delegate
{
textBox1.Text = "接続待機中";
}));

TcpClient client = server.AcceptTcpClient();

//接続
this.Invoke(new MyDelegate(delegate
{
textBox1.Text = "接続されました";
}));

NetworkStream stream = client.GetStream();

// 無限ループ
while (true)
{
Byte[] bytes = new Byte[20]; //わざと小さく取ってある。
int i;

//メッセージを受信
while ((i = stream.Read(bytes, 0, bytes.Length)) != 0)
{
String data = System.Text.Encoding.UTF8.GetString(bytes, 0, i);
Console.WriteLine(String.Format("受信: {0}", data));
}
client.Close();
}

回答No.3

reset_cat · ベストアンサー

とりあえず作ってみました。エラー処理等は入っていません。
これを2つ起動して片方サーバに、もう片方をクライアントにすればいけると思います。
public partial class Form1 : Form
{
delegate void SetTextMessageHandler(String strMessage);
SetTextMessageHandler eventRead;
Thread threadRead;
TcpListener tcpListener;
TcpClient tcpClient;
NetworkStream clientStream;

public Form1()
{
InitializeComponent();

eventRead = new SetTextMessageHandler(setTextMessage);
}

private void threadStartWork()
{
if (tcpListener == null)
{
tcpListener = new TcpListener(IPAddress.Parse("127.0.0.1"), 30001);

tcpListener.Start();

TcpClient tcpServer = tcpListener.AcceptTcpClient();
NetworkStream serverStream = tcpServer.GetStream();

Byte[] aryBuffer = new Byte[100];
int nRead = serverStream.Read(aryBuffer, 0, aryBuffer.Length);
while (nRead > 0)
{
Object[] aryArgs = new Object[1];
aryArgs[0] = Encoding.UTF8.GetString(aryBuffer, 0, nRead);
this.Invoke(eventRead, aryArgs);

nRead = serverStream.Read(aryBuffer, 0, aryBuffer.Length);
}
}
}

private void setTextMessage(String strMessage)
{
textBox1.Text = strMessage;
}

private void button1_Click(object sender, EventArgs e) // 待受
{
threadRead = new Thread(new ThreadStart(threadStartWork));
threadRead.Start();
}

private void button2_Click(object sender, EventArgs e) // 接続
{
tcpClient = new TcpClient();
tcpClient.Connect(IPAddress.Parse("127.0.0.1"), 30001);
clientStream = tcpClient.GetStream();
}

private void button3_Click(object sender, EventArgs e) // 送信
{
Byte[] aryBuffer = Encoding.UTF8.GetBytes(textBox1.Text);
clientStream.Write(aryBuffer, 0, aryBuffer.Length);
}
}

お礼

ありがとうございました！
参考にさせていただきます！

回答No.2

reset_cat

このコードはC#の簡易ソケット通信のサーバ側ですね。#1さんの言うように、言語環境などが書いてないと回答する方も回答できないでしょう。

で、送信できないということは、最初にクライアント側に問題があると考えると思うのですが、そのクライアント側のコードがないので、どこに問題があるのかがわかりません。

まずはクライアント側のコードを補足されてみては？

回答No.1

koi1234

ソースのネストが全部つぶれてるためコード見るのが苦痛で
あまりちゃんと見てませんが使ってる環境（コンパイラ・OS）は何でしょうか？

個人的に見慣れない環境のような気がしてるんですが
（XPでVC6++環境の知識なので根本違ったらごめんなさい）

作ってるのはサーバ・クライアント両方ですか？
サーバのほうで言えばLisn（だっけ？）接続待ちしてるのが
どこか分かりませんがservrt.start() 関数なのでしょうか？
接続語コネクション張らないといけないはずですが
そのあたりのコードが一切見当たらない気がします

もしVC系統使われているのであればソケット通信の
サンプルプログラムがCDにあるのではないかと思いますが
（VC6にはあります）

Socket通信の作り的には全てイベント定義の形で
ソケット操作するはずです
ACCEPT/READ/WRITE/CLOSE 全てイベントが飛ぶので
無限ループなんか作る必要ないはずです