FileDocCategorySizeDatePackage
MultiJabberClient.javaAPI DocExample4600Mon Apr 06 18:10:22 BST 1998None

JabberClientThread

public class JabberClientThread extends Thread

Fields Summary
private Socket
socket
private BufferedReader
in
private PrintWriter
out
private static int
counter
private int
id
private static int
threadcount
Constructors Summary
public JabberClientThread(InetAddress addr)

    System.out.println("Making client " + id);
    threadcount++;
    try {
      socket = 
        new Socket(addr, MultiJabberServer.PORT);
    } catch(IOException e) {
      // If the creation of the socket fails, 
      // nothing needs to be cleaned up.
    }
    try {    
      in = 
        new BufferedReader(
          new InputStreamReader(
            socket.getInputStream()));
      // Enable auto-flush:
      out = 
        new PrintWriter(
          new BufferedWriter(
            new OutputStreamWriter(
              socket.getOutputStream())), true);
      start();
    } catch(IOException e) {
      // The socket should be closed on any 
      // failures other than the socket 
      // constructor:
      try {
        socket.close();
      } catch(IOException e2) {}
    }
    // Otherwise the socket will be closed by
    // the run() method of the thread.
Methods Summary
public voidrun()

    try {
      for(int i = 0; i < 25; i++) {
        out.println("Client " + id + ": " + i);
        String str = in.readLine();
        System.out.println(str);
      }
      out.println("END");
    } catch(IOException e) {
    } finally {
      // Always close it:
      try {
        socket.close();
      } catch(IOException e) {}
      threadcount--; // Ending this thread
    }
public static intthreadCount()

       
    return threadcount;