使用线程处理套接字客户端

import java.io.*;

import java.net.*;

public class Client {

     public static void main(String[] args) {//nowjava.com - 时  代  Java 提 供

          try {

               Socket sock = new Socket("localhost",444);

               SendThread sendThread = new SendThread(sock);

               Thread thread = new Thread(sendThread);thread.start();

               RecieveThread recieveThread = new RecieveThread(sock);

               Thread thread2 =new Thread(recieveThread);thread2.start();

          } catch (Exception e) {

            System.out.println(e.getMessage());

        }
        /*
        来 自*
         n o w j a v a . c o m - 时  代  Java
        */

     }

}


class RecieveThread implements Runnable {

     Socket sock=null;

     BufferedReader recieve=null;


     public RecieveThread(Socket sock) {

          this.sock = sock;

     }//end constructor


     public void run() {


          try {

              recieve = new BufferedReader(new InputStreamReader(this.sock.getInputStream()));//get inputstream

              String msgRecieved = null;

              while((msgRecieved = recieve.readLine())!= null) {

                   System.out.println("From Server: " + msgRecieved);

                   System.out.println("Please enter something to send to server..");

              }

          } catch(Exception e) {

            System.out.println(e.getMessage());

        }

     }//end run

}//end class recievethread


class SendThread implements Runnable {

     Socket sock=null;

     PrintWriter print=null;

     BufferedReader brinput=null;


     public SendThread(Socket sock) {

          this.sock = sock;

     }//end constructor

     public void run() {

          try {

              if( sock.isConnected() ) {


                   System.out.println("Client connected to "+sock.getInetAddress() + " on port "+sock.getPort());

                   this.print = new PrintWriter(sock.getOutputStream(), true);


                while(true) {

                       System.out.println("Type your message to send to server..type 'EXIT' to exit");

                       brinput = new BufferedReader(new InputStreamReader(System.in));

                       String msgtoServerString=null;

                       msgtoServerString = brinput.readLine();