UDPのOnMessage（）機能

Question

DatagramPacketを使用するUDPメッセージにOnMessage（）タイプの機能があるかどうか疑問に思っていましたか？私はすべてのメッセージが届くようにしたいので、タイマーでランダムにリソースを浪費することはありません。

OnMessage私はWebSocketClientで行われたものを指しています。あるいは、.netの "Available"に類似した機能です。

While (rxUdpClient.Available > 0) 

いくつかのポートを監視しているので、各ポートに対してrun（）を実行するスレッドが呼び出されます。問題は、私は40 +/secという大きな速度でメッセージが入っているようです。

これは私が現在持っているものです。

public void run() 
{ 
    DatagramSocket sock = null;  
     sock = new DatagramSocket(port); 
    byte[] buffer = new byte[DataAdapterFB1.HEADER_SIZE + DataAdapterFB1.MAX_DATA_BYTES]; 
    DatagramPacket incoming = new DatagramPacket(buffer, buffer.length); 

    while (true){   
     sock.receive(incoming);   
     byte[] data = incoming.getData(); 
     String s = new String(data, 0, incoming.getLength()); 
     //This is the processing code, but it isn't its own thread... 
     ScadaMsg newMessage = new ScadaMsg(data); 
    } 
} 

Answer 1

のDatagramPacketは、（受信）の動作はそうあなたが正常に行いますがただで入ってくるデータグラムをリッスンします別のスレッドを起動され、ブロックしていますループを作成し、さらに処理するためにそれらをディスパッチします。

void run() { 
    socket = new DatagramSocket(4445); 

    while(true) { 
     byte[] buf = new byte[256]; 
     DatagramPacket packet = new DatagramPacket(buf, buf.length); 
     socket.receive(packet); //JVM will wait here, until there is an incoming packet 
     onMessage(packet.getData()) 
    } 
} 

public abstract void onMessage(final byte[] pkt);