java中的多线程客户端-服务器聊天应用

Question

ClientDemo.java

import java.io.*;
import java.net.Socket;

/*
* To change this template, choose Tools | Templates
* and open the template in the editor.
*/

/**
*
* @author zain-mughal
*/
public class ClientDemo extends javax.swing.JFrame {
DataInputStream input;
PrintWriter output;
public void Connect(){
    try {
        Socket s = new Socket("127.0.0.1", 2111);
        input=new DataInputStream(s.getInputStream());
        output=new PrintWriter(s.getOutputStream());
        boolean more_data=true;
        while(more_data){
            String in=input.readLine();
            if(in==null){
                more_data=false;
            }
            else{
                System.out.println(in);
            }
        }
        s.close();
        input.close();
        output.close();
    } catch (Exception ex) {
       ex.printStackTrace();
    }
}
public static void main(String args[]){
   ClientDemo obj=new ClientDemo();
   obj.Connect();

}

}

HServer.java

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.logging.Level;
import java.util.logging.Logger;

/*
* To change this template, choose Tools | Templates
* and open the template in the editor.
*/

/**
*
* @author zain-mughal
*/
public class HServer extends Thread {
Socket AcceptReQ;
public HServer(Socket reqAccept) {
    this.AcceptReQ=reqAccept;
}
@Override
public void run(){
    try {
        DataInputStream input = new DataInputStream(AcceptReQ.getInputStream());
        PrintWriter output = new PrintWriter(AcceptReQ.getOutputStream());
        String in=null;
        while((in=input.readLine())!=null){
                System.out.println(in);
        }

        AcceptReQ.close();
        input.close();
        output.close();
    } catch (Exception ex) {
        ex.printStackTrace();
    }
  }
 public static void main(String args[]){
    try {
        ServerSocket req = new ServerSocket(2111);

        while(true){
            Socket reqAccept=req.accept();
            Thread t=new HServer(reqAccept);
            t.start();
        }
    } catch (Exception ex) {
        Logger.getLogger(HServer.class.getName()).log(Level.SEVERE, null, ex);
    }
}
}

Answer 1

试试这个：

构建健壮的Java服务器

构建基本Echo服务器和ChatServer