ソケットを介してメッセージを受信する

Question

lan-messengerをシミュレートするときに、現在のコードをテストするためにループバックアドレスを使用しています。送信している最初のメッセージを受信できるようになっています。その後、メッセージはありません

private void accepted(IAsyncResult iar) 
    { 
     Socket server = (Socket)iar.AsyncState; 
     Socket client = server.EndAccept(iar); 
     if (client.Connected) 
     { 
      try 
      { 
       client.BeginReceive(receive, 0, receive.Length, System.Net.Sockets.SocketFlags.None, new AsyncCallback(rec), client); 
      } 
      catch (ArgumentException) 
      { 
       MessageBox.Show("arguments incorrect in begin-receive call", "Error", MessageBoxButtons.OK); 
      } 
      catch (SocketException) 
      { 
       MessageBox.Show("error in accessing socket while receiving", "Error", MessageBoxButtons.OK); 
      } 
      catch (ObjectDisposedException) 
      { 
       MessageBox.Show("socket closed while receiving", "Error", MessageBoxButtons.OK); 
      } 
      catch (Exception) 
      { 
       MessageBox.Show("error while receiving", "Error", MessageBoxButtons.OK); 
      } 

     } 

これは始まり、受け取るメソッドが実行されるコールバック関数は次のとおりです。？接続が行われるコールバック関数は これを助けがソケットバッファのクリアを行うには何もsocket.Isをされるしなさい到達します：

void rec(IAsyncResult ar) 
    { 

     StringBuilder receivedData; 
     //String oldvalue; 
     Socket remote = (Socket)ar.AsyncState; 
     int recv = remote.EndReceive(ar); 
     receivedData = new StringBuilder(Encoding.ASCII.GetString(receive, 0, recv)); 
     //MessageBox.Show(receivedData.ToString(), "received", MessageBoxButtons.OK); 
     StringBuilder sb = new StringBuilder(this.textBox1.Text); 
     sb.AppendLine(receivedData.ToString()); 
     if (textBox1.InvokeRequired) 
     { 
      this.Invoke((MethodInvoker)delegate { this.textBox1.Text = sb.ToString(); }); 

     } 
     remote.Close(5); 
     return; 
    } 

受け取ったデータを変数に代入するために、stringbuilderやstringのデータ型と何か関係がありますか？ここで

Answer 1

は間違っている何

http://www.devarticles.com/c/a/C-Sharp/Socket-Programming-in-C-Part-I/1/

http://www.devarticles.com/c/a/C-Sharp/Socket-Programming-in-C-sharp-Part-II/

...ソースコードとC＃のソケットプログラミング上の2部構成のチュートリアル、あるデザインに完全に依存。ポーリングですか？または、イベントを待っていますか？

ソースは、このページに添付download.zipファイルです：これを見てみましょう http://www.developerfusion.com/article/3918/socket-programming-in-c-part-1/

Answer 2

。 WaitForDataがそれ自身をどのように呼び出すかに注目してください。これにより、2番目以降のメッセージを受信できます。

これ以上のデータを待つことはありません。

private void OnClientConnect(IAsyncResult asyn) 
    { 
     m_Client = m_Listener.EndAccept(asyn); 
     WaitForData(); 
    } 
    private void WaitForData() 
    { 
     buffer = new byte[1024]; 
     m_Client.BeginReceive(buffer, 0, buffer.Length, SocketFlags.None, new AsyncCallback(OnDataReceived), null); 
    } 
    private void OnDataReceived(IAsyncResult asyn) 
    { 
     int iRx = 0; 
     iRx = m_Client.EndReceive(asyn); 

     if (iRx > 0) 
     { 
      PacketReceiver.BytesReceived(buffer); 
     } 

     if (m_Client.Connected == true) 
      WaitForData(); 
    } 

Answer 3

あなたのREC方法でBeginReceiveを呼び出すために忘れてしまった：ここ

はあなたのコードがどうあるべきかです：もちろん

void rec(IAsyncResult ar) 
{ 
    StringBuilder receivedData; 
    //String oldvalue; 
    Socket remote = (Socket)ar.AsyncState; 
    int recv = remote.EndReceive(ar); 
    receivedData = new StringBuilder(Encoding.ASCII.GetString(receive, 0, recv)); 
    //MessageBox.Show(receivedData.ToString(), "received", MessageBoxButtons.OK); 
    StringBuilder sb = new StringBuilder(this.textBox1.Text); 
    sb.AppendLine(receivedData.ToString()); 
    if (textBox1.InvokeRequired) 
    { 
    this.Invoke((MethodInvoker)delegate { this.textBox1.Text = sb.ToString(); }); 

    } 
    remote.BeginReceive(receive, 0, receive.Length, System.Net.Sockets.SocketFlags.None, new AsyncCallback(rec), remote); 
    //remote.Close(5); 
    return; 
} 

このコードではなくソケットを閉じませんが、よりをお待ちしていますデータ。あなたのsendメソッドで、各メッセージに異なるソケットを作成している場合、BeginReceiveではなくBeginAcceptを呼び出す必要があります。

希望します。