在特定端口监听 UDP 消息

Posted 2023-02-17

【中文标题】在特定端口监听 UDP 消息

【英文标题】：Listening UDP messages in specific ports

【发布时间】：2019-09-24 08:19:22

【问题描述】：

我是使用 Java 进行 UDP 编程的新手。我编写了以下 UDP 服务器和客户端程序只是为了尝试这些概念。下面是客户端程序：

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketTimeoutException;

public class QuoteClient 

    public static void main(String[] args) 
        DatagramSocket socket = null;
        try 
             socket = new DatagramSocket();
             byte[] buf = new byte[256];
             String messg = "Hello UDP Server\n";

             while (true) 
                 buf = messg.getBytes();
                 InetAddress address = InetAddress.getByName ("127.0.0.1");
                 DatagramPacket packet = new DatagramPacket (buf, buf.length, address, 4000);
                 socket.send(packet);

                 Thread.sleep(10000);
             
         catch (SocketTimeoutException ex) 
            System.out.println("Timeout error: " + ex.getMessage());
            ex.printStackTrace();
         catch (IOException ex) 
            System.out.println("Client error: " + ex.getMessage());
            ex.printStackTrace();
         catch (InterruptedException ex) 
            ex.printStackTrace();
         finally 
            socket.close();
        
    

下面是服务器程序：

import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

public class QuoteServer 

    public static void main(String[] args) 
        DatagramSocket socket = null;
        DatagramPacket packet = null;
        byte[] buf = new byte[256];
        try 
            socket = new DatagramSocket(4000);
            InetAddress address = InetAddress.getByName ("127.0.0.1");
            while (true) 
                packet = new DatagramPacket(buf, buf.length, address, 5000);
                socket.receive(packet);
                String received = new String(packet.getData());
                System.out.println(received);
            
         catch (Exception e) 

        
    

我的想法是编写一个 UDP 客户端，它将数据包发送到端口 4000 的“本地主机”和一个服务器，它将在同一主机和端口上侦听数据包。但在这里我的服务器监听任何地址和任何端口。那么如何在服务器程序中指定地址和端口呢？此外，如果一条消息被分成几个数据包，是否有一种标准方法可以将这些数据包按顺序组合在一起？

【参考方案1】：

您的代码看起来正确 - 通过调用 DatagramSocket(4000)，您的服务器仅在端口 4000 上侦听，但在任何地址上。如果要监听特定的本地地址，请使用 DatagramSocket(4000, local_address)

另外，您不需要在接收者的 DatagramPacket 上指定地址和端口，即 5000 不是必需的。

我建议您使用 tcpdump 或 Wireshark 来查看您的网络流量是否通过。

没有将 UDP 数据报组合成更大消息的标准方法。您必须使用计数器或其他标识符自己实现。另请注意，UDP 不能保证传送，因此您需要处理未收到所有消息的情况。

【讨论】：

服务器是否会将数据包广播到所有端口，而客户端会从特定端口请求它？我基本上是在尝试收听来自纳斯达克的 UDP 消息（股票价格），它们广播到特定的频道。所以我们必须开发一个客户端来监听纳斯达克服务器和端口，对吗？如果 se 不需要在服务器程序中指定端口，消息将如何广播到该特定端口？

在这种情况下，纳斯达克将多播地址“多播”到给定端口。首先，您需要订阅多播地址，然后您的客户端可以在它们发送到的端口上侦听数据报。您之间的路由器必须支持多播订阅，某些防火墙可能会阻止它们。看看：docs.oracle.com/javase/7/docs/api/java/net/MulticastSocket.html