如何在.NET Core中從Socket接收數據？

我目前正在將一個硬件庫移植到.NET Core上。通信在TCP上工作。我有'Socket.BeginReceive'方法的問題。 MSDN 如何在.NET Core中從Socket接收數據？

看來在.NET Core中沒有等價的方法。我怎樣才能從TCP套接字接收數據？

private void InternalDataReceived(IAsyncResult ar) 

{ 
    int dataCount = 0; 
    byte[] buffer; 

    try 
    { 
     if (_client != null && _client.Client != null) 
     { 
      dataCount = _client.Client.EndReceive(ar); 
     } 

     if (dataCount > 0) 
     { 
      try 
      { 
       buffer = new byte[dataCount]; 
       Array.Copy(_inBuffer, buffer, dataCount); 

       if (DataReceived != null) 
       { 
        DataReceived(buffer); 
       } 
      } 
      catch (Exception exc) 
      { 
       if (exc is System.Net.Sockets.SocketException) 
       { 
        Disconnect(); 
        return; 
       } 
      } 
      _client.Client.BeginReceive(_inBuffer, 0, _inBuffer.Length, SocketFlags.None, InternalDataReceived, null); 
     } 
    } 
    catch 
    { 
     Disconnect(); 
    } 
}

來源

2016-12-20 Mat

有[同步]（https://docs.microsoft.com/en-us/dotnet/core/api/system.net.sockets。 Socket＃System_Net_Sockets_Socket_Receive_System_Byte ___）和[異步]（https://docs.microsoft.com/en-us/dotnet/core/api/system.net.sockets.socket#System_Net_Sockets_Socket_ReceiveAsync_System_Net_Sockets_SocketAsyncEventArgs_）版本的.NET Core中的接收。 –

我找到了另一種方法來做到這一點。希望這可以幫助別人。

基本上我剛結束了使用NetworkStream類。您可以致電TcpClient.GetStream()獲取實例。如果您使用GetStream的using塊，則連接將在using後關閉。這就是爲什麼我沒有在我的例子中使用它，因爲我需要連接來保持活着。

MSDN NetworkStream.Read

我的示例代碼：

static void Main(string[] args) 
{ 
    TcpClient client = new TcpClient(); 

    client.Client.Connect(IPAddress.Parse("192.168.100.5"), 8000); 

    //Task.Run(() => ReadData(client)); 

    Task.Run(() => ReadDataLoop(client)); 

    client.Client.Send(Encoding.ASCII.GetBytes("{\"TID\":1111,\"blabla\":{}}")); 


    while (true) 
    { 

    } 
} 

private static void ReadDataLoop(TcpClient client) 
{ 
    while (true) 
    { 
     if (!client.Connected) 
      break; 

     string xxx = ""; 
     xxx = ReadData(client); 
     Console.WriteLine(xxx); 
    } 
} 

private static string ReadData(TcpClient client) 
{ 
    string retVal; 
    byte[] data = new byte[1024]; 

    NetworkStream stream = client.GetStream(); 


    byte[] myReadBuffer = new byte[1024]; 
    StringBuilder myCompleteMessage = new StringBuilder(); 
    int numberOfBytesRead = 0; 


    do 
    { 
     numberOfBytesRead = stream.Read(myReadBuffer, 0, myReadBuffer.Length); 

     myCompleteMessage.AppendFormat("{0}", Encoding.ASCII.GetString(myReadBuffer, 0, numberOfBytesRead)); 

    } 
    while (stream.DataAvailable); 



    retVal = myCompleteMessage.ToString(); 


    return retVal; 
}

來源

2016-12-21 15:12:07 Mat

如何在.NET Core中從Socket接收數據？

回答

相關問題