Java: Multithreading & UDP-Socket-Programmierung

Erste, was ist erste: Ihre Klassen beginnen mit einem Großbuchstaben pro die Java-Namenskonventionen:

Klassen-Namen sollten Substantive in gemischter groß - /Kleinschreibung mit dem ersten Buchstaben des
jedes internen Wortes großgeschrieben. Versuchen
halten Sie Ihre Klasse Namen einfach und
beschreibend. Verwenden Sie ganze Wörter-vermeiden
Akronyme und Abkürzungen (es sei denn, der
Abkürzung ist so weit verbreitet,
als die lange form, wie URL oder
HTML).

Zweite:
Versuchen, brechen Sie den code in kohärente Abschnitte, und ordnen Sie um einige gemeinsame Merkmal, dass Sie zu tun haben... vielleicht um die Funktionalität oder das Modell, das Sie Programmieren.

Der (Basis -) Modell für den server ist, dass die nur was es tut, ist, erhalten die socket-verbindungen... der server setzt auf einen handler zur Verarbeitung dieser verbindungen und das ist es. Wenn Sie versuchen, zu bauen, das Modell würde es wie folgt Aussehen:

class Server{
    private final ServerSocket serverSocket;
    private final ExecutorService pool;

    public Server(int port, int poolSize) throws IOException {
      serverSocket = new ServerSocket(port);
      pool = Executors.newFixedThreadPool(poolSize);
    }

    public void serve() {
      try {
        while(true) {
          pool.execute(new Handler(serverSocket.accept()));
        }
      } catch (IOException ex) {
        pool.shutdown();
      }
    }
  }

  class Handler implements Runnable {
    private final Socket socket;
    Handler(Socket socket) { this.socket = socket; }
    public void run() {
      //receive the datagram packets
    }
 }

Dritte: ich würde empfehlen, dass Sie einen Blick auf einige vorhandene Beispiele.

• Multi-threaded Client/Server-Anwendungen:
  
  http://www.ase.md/~aursu/ClientServerThreads.html
• Doug Lea:
  
  http://www.developer.com/java/ent/article.php/3645111/Java-5s-BlockingQueue.htm (Dank an John)
  
  http://gee.cs.oswego.edu/dl/cpj/index.html (immer noch nicht finden können, die genaue Beispiel, aber es ist da, irgendwo... wenn Sie mutig und sah über seine allcode.java - Datei).
• Concurrency in Practice-Beispiele:
  
  http://www.javaconcurrencyinpractice.com/listings.html
• Java-Concurrency-Tutorials:
  
  http://java.sun.com/docs/books/tutorial/essential/concurrency/

Pro aktualisiert Kommentare:

OK, Ravi, gibt es einige großen Probleme mit Ihrem code und einige minor Probleme mit ihm:

1. Ich gehe davon aus, dass die Receive Klasse ist dein client... Sie ziehen sollte, als ein separates Programm (mit seinen eigenen main-Klasse) und Ihre server und mehreren clients zur gleichen Zeit. Erzeugt einen neuen "client-thread", der auf Ihrem server für jeden neuen UDP-Paket, das Sie senden, ist eine verstörende Idee (großen Problem).

2. Werden, wenn Sie Ihre client-Anwendung, Sie sollten es machen, führen Sie den empfangen code in seinem eigenen while loop (minor - Ausgabe), z.B.:

   public class Client extends Thread
   {
       public Client(/*..*/)
       {
           //initialize your client
       }
   
       public void run()
       {
           while(true)
           {
               //receive UDP packets
               //process the UDP packets
           }
       }
   
       public static void main(String[] args) throws IOException
       {
           //start your client
           new Client().start();
       }
   }

3. Sollten Sie nur brauchen nur ein thread pro client und ein thread pro server (technisch noch nicht einmal einen separaten thread gibt, da main hat seinen eigenen thread), so könnten Sie nicht finden, die ExecutorService sehr nützlich ist.

Sonst dein Ansatz ist richtig... aber ich würde noch empfehlen, dass Sie überprüfen einige Beispiele.

InformationsquelleAutor

Es ist eine gute Sache, die Eclipse Geschichte funktioniert auch für einen Tag zurück 🙂 vielen Dank, dass ich in der Lage bin zu geben, sowohl Ravi als ein Beispiel und Lirik seine Antwort auf undichte stellen.

Lassen Sie mich ersten start indem Sie behaupten, dass ich keine Ahnung habe, was die Ursache für das Leck sein, aber wenn ich es lang genug ist, wird es nicht auf eine OutOfMemoryError.

Zweite, verließ ich den funktionierenden code auskommentiert Ravi für eine funktionierende basic-Beispiel von meinem UDP server. Das timeout war es, zu testen, wie lange meine firewall töten würde den Receiver Ende (30 Sekunden). Entfernen Sie einfach alles, was mit dem pool, und du bist gut zu gehen.

So, hier ist, ein arbeiten, aber die undichte version von meinem Beispiel Gewinde-UDP-server.

public class TestServer {

private static Integer TIMEOUT = 30;
private final static int MAX_BUFFER_SIZE = 8192;
private final static int MAX_LISTENER_THREADS = 5;
private final static SimpleDateFormat DateFormat = new SimpleDateFormat("yyyy-dd-MM HH:mm:ss.SSSZ");

private int mPort;
private DatagramSocket mSocket;

//You can remove this for a working version
private ExecutorService mPool;

public TestServer(int port) {
    mPort = port;
    try {
        mSocket = new DatagramSocket(mPort);
        mSocket.setReceiveBufferSize(MAX_BUFFER_SIZE);
        mSocket.setSendBufferSize(MAX_BUFFER_SIZE);
        mSocket.setSoTimeout(0);

        //You can uncomment this for a working version
        //for (int i = 0; i < MAX_LISTENER_THREADS; i++) {
        // new Thread(new Listener(mSocket)).start();
        //}

        //You can remove this for a working version
        mPool = Executors.newFixedThreadPool(MAX_LISTENER_THREADS);

    } catch (IOException e) {
        e.printStackTrace();
    }
}

//You can remove this for a working version
public void start() {
    try {
        try {
            while (true) {
                mPool.execute(new Listener(mSocket));
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    } finally {
        mPool.shutdown();
    }
}

private class Listener implements Runnable {

    private final DatagramSocket socket;

    public Listener(DatagramSocket serverSocket) {
        socket = serverSocket;
    }

    private String readLn(DatagramPacket packet) throws IOException {
        socket.receive(packet);
        return new BufferedReader(new InputStreamReader(new ByteArrayInputStream(packet.getData())), MAX_BUFFER_SIZE).readLine();
    }

    private void writeLn(DatagramPacket packet, String string) throws IOException {
        packet.setData(string.concat("\r\n").getBytes());
        socket.send(packet);
    }

    @Override
    public void run() {
        DatagramPacket packet = new DatagramPacket(new byte[MAX_BUFFER_SIZE], MAX_BUFFER_SIZE);
        String s;
        while (true) {
            try {
                packet = new DatagramPacket(new byte[MAX_BUFFER_SIZE], MAX_BUFFER_SIZE);
                s = readLn(packet);
                System.out.println(DateFormat.format(new Date()) + " Received: " + s);
                Thread.sleep(TIMEOUT * 1000);
                writeLn(packet, s);
                System.out.println(DateFormat.format(new Date()) + " Sent: " + s);
            } catch (IOException e) {
                e.printStackTrace();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

public static void main(String[] args) {
    if (args.length == 1) {
        try {
            TIMEOUT = Integer.parseInt(args[0]);
        } catch (Exception e) {
            TIMEOUT = 30;
        }
    }
    System.out.println(DateFormat.format(new Date()) + " Timeout: " + TIMEOUT);
    //new TestServer(4444);
    new TestServer(4444).start();
}
}

btw. @Lirik, erlebte ich dieses Verhalten zuerst in Eclipse, nach dem ich es getestet von der Befehlszeile aus. Und nochmal, ich habe KEINE Ahnung, was die Ursache dafür ist 😉 sorry...

InformationsquelleAutor djBo