从同一套接字发送和接收数据的简单 UDP 示例

Question

由于某种原因，我很难从同一套接字发送和接收数据。无论如何，这是我的客户端代码：

var client = new UdpClient();
IPEndPoint ep = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 11000); // endpoint where server is listening (testing localy)
client.Connect(ep); 

// send data
client.Send(new byte[] { 1, 2, 3, 4, 5 }, 5);

// then receive data
var receivedData = client.Receive(ref ep);  // Exception: An existing connection was forcibly closed by the remote host

基本上，我想创建一个协议，我发送一个udp包，然后我期待一个响应。就像HTTP协议一样，每个请求都有一个响应。如果服务器在不同的计算机上，此代码可以工作。但是，可能会出现服务器和客户端在同一台计算机上的情况。

以下是服务器:

UdpClient udpServer = new UdpClient(UDP_LISTEN_PORT);

while (true)
{
    var groupEP = new IPEndPoint(IPAddress.Any, 11000); // listen on any port
    var data = udpServer.Receive(ref groupEP);
    udpServer.Send(new byte[] { 1 }, 1); // if data is received reply letting the client know that we got his data          
}

我不能使用tcp的原因是因为有时客户端在NAT（路由器）后面，并且做UDP打孔比TCP更简单。

感谢markmnl回答以下是我的代码:

服务器：

UdpClient udpServer = new UdpClient(11000);

while (true)
{
    var remoteEP = new IPEndPoint(IPAddress.Any, 11000); 
    var data = udpServer.Receive(ref remoteEP); // listen on port 11000
    Console.Write("receive data from " + remoteEP.ToString());
    udpServer.Send(new byte[] { 1 }, 1, remoteEP); // reply back
}

客户端代码：

var client = new UdpClient();
IPEndPoint ep = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 11000); // endpoint where server is listening
client.Connect(ep);

// send data
client.Send(new byte[] { 1, 2, 3, 4, 5 }, 5);

// then receive data
var receivedData = client.Receive(ref ep);

Console.Write("receive data from " + ep.ToString());

Console.Read();

Answer 1

这是我定义远程和本地端口，然后将接收到的数据写出到文件中的解决方案，将它们全部放入您选择的一类中，并进行正确的导入

    static UdpClient sendClient = new UdpClient();
    static int localPort = 49999;
    static int remotePort = 49000;
    static IPEndPoint localEP = new IPEndPoint(IPAddress.Any, localPort);
    static IPEndPoint remoteEP = new IPEndPoint(IPAddress.Parse("127.0.0.1"), remotePort);
    static string logPath = System.AppDomain.CurrentDomain.BaseDirectory + "/recvd.txt";
    static System.IO.StreamWriter fw = new System.IO.StreamWriter(logPath, true);


    private static void initStuff()
    {
      
        fw.AutoFlush = true;
        sendClient.ExclusiveAddressUse = false;
        sendClient.Client.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
        sendClient.Client.Bind(localEP);
        sendClient.BeginReceive(DataReceived, sendClient);
    }

    private static void DataReceived(IAsyncResult ar)
    {
        UdpClient c = (UdpClient)ar.AsyncState;
        IPEndPoint receivedIpEndPoint = new IPEndPoint(IPAddress.Any, 0);
        Byte[] receivedBytes = c.EndReceive(ar, ref receivedIpEndPoint);
        fw.WriteLine(DateTime.Now.ToString("HH:mm:ss.ff tt") +  " (" + receivedBytes.Length + " bytes)");

        c.BeginReceive(DataReceived, ar.AsyncState);
    }


    static void Main(string[] args)
    {
        initStuff();
        byte[] emptyByte = {};
        sendClient.Send(emptyByte, emptyByte.Length, remoteEP);
    }

Answer 2

我会尽量保持简短，几个月前我已经为一个我正在尝试构建的游戏这样做了，它做了一个UDP“客户端-服务器”连接，就像TCP一样，你可以使用它发送(消息)(消息对象)。我已经用它做了一些测试，它工作得很好，如果需要的话可以随意修改。

Answer 3

（我想你知道使用UDP（用户数据报协议）并不能保证交付，检查重复和拥塞控制，只会回答你的问题）。

在您的服务器中，这一行:

var data = udpServer.Receive(ref groupEP);

将group pEP从您拥有的内容重新分配给您收到内容的地址。

这一行:

udpServer.Send(new byte[] { 1 }, 1); 

将不起作用，因为您尚未指定将数据发送给谁。（它适用于您的客户端，因为您调用了连接，这意味着发送将始终发送到您连接到的endpoint，当然我们不希望在服务器上这样做，因为我们可能有很多客户端）。我会：

UdpClient udpServer = new UdpClient(UDP_LISTEN_PORT);

while (true)
{
    var remoteEP = new IPEndPoint(IPAddress.Any, 11000);
    var data = udpServer.Receive(ref remoteEP);
    udpServer.Send(new byte[] { 1 }, 1, remoteEP); // if data is received reply letting the client know that we got his data          
}

此外，如果您在同一台机器上有服务器和客户端，则应该将它们放在不同的端口上。