2016-01-12 126 views
0

我正尝试使用套接字连接到应用程序。无法从服务器接收消息的套接字

应用程序使用端口6100进行通信。 我能够将消息发送到应用程序,但无法接收任何消息。

这是我的代码,请让我知道如果我做错了什么。

public void Connect2(string host, int port, string cmd) 
{ 
    byte[] bytes = new byte[10024]; 
    IPAddress[] IPs = Dns.GetHostAddresses(host); 

    Socket s = new Socket(AddressFamily.InterNetwork, 
    SocketType.Stream, 
    ProtocolType.Tcp); 
    s.SendTimeout = 100; 
Console.WriteLine("Establishing Connection to {0}", 
    host); 
    try 
    { 
     s.Connect(IPs[0], port); 
    } 

    catch (Exception e) 
    { 

     MessageBox.Show(e.Message); 
    } 



    byte[] sendBites = System.Text.Encoding.ASCII.GetBytes(cmd); 
    int bytesSent = s.Send(sendBites); 
    int bytesRec = s.Receive(bytes); 
    s.ReceiveFrom(bytes, ref tmpRemote); 
    MessageBox.Show(s.ReceiveBufferSize.ToString()); 
    MessageBox.Show(Encoding.ASCII.GetString(bytes, 0, bytesRec)); 
    s.Shutdown(SocketShutdown.Both); 
    s.Close(); 

} 

回答

0

这段代码工作正常

 public string SocketSendReceive(string server, int port, string cmd) 
    { 
     byte[] recvBuffer = new byte[1024]; 
     string host = "127.0.0.1"; 
     TcpClient tcpClient = new TcpClient(); 
     try 
     { 
      tcpClient.Connect(host, 6100); 
     } 
     catch (SocketException /*e*/) 
     { 
      tcpClient = null; 
     } 


     if (tcpClient != null && tcpClient.Connected) 
     { 

      tcpClient.Client.Send(Encoding.UTF8.GetBytes(cmd)); 
      tcpClient.Client.Receive(recvBuffer); 
      // port = Convert.ToInt16(Encoding.UTF8.GetString(recvBuffer).Substring(2)); 
      tcpClient.Close(); 

     } 

     return Encoding.ASCII.GetString(recvBuffer, 0, recvBuffer.Length); 
    } 
+0

此代码已损坏。它无法检查来自'Receive'的返回值,它告诉你有多少个字节已经放入缓冲区。 TCP是字节流。如果你想要“消息传递”,你可以自己在TCP之上实现消息组帧,或者移动到已经提供消息的更高层抽象。 –

0

首先,当连接失败时,您仍然尝试发送/接收数据。将发送和接收置于try/catch中。


我可以看到你打电话收到两次:

int bytesRec = s.Receive(bytes); 
s.ReceiveFrom(bytes, ref tmpRemote); 

什么可能发生的情况是:

  • 您发送命令
  • 您正在等待响应“int bytesRec = s.Receive(bytes);
  • 然后再次等待更多数据。“s.ReceiveFrom(bytes,ref tmpRemote);

不过,也许服务器不会发送额外的数据,让你在等待‘永远’

再次尝试取出s.ReceiveFrom(bytes, ref tmpRemote);


Socket.ReceiveFrom()通常用于接收UDP广播

+0

我已经更改了代码,但仍然是我的应用程序挂起,我没有收到任何错误消息。 –

+0

尝试 s.Connect(IPs [0],port); byte [] sendBites = System.Text.Encoding.ASCII.GetBytes(cmd); int bytesSent = s.Send(sendBites); int bytesRec = 0; do bytesRec = s.Receive(bytes,bytes.Length,0); } while(bytesRec> 0); } 赶上(例外五) { MessageBox.Show(e.Message); } –

相关问题