各位大哥，帮小女子看看！先谢了。在线等待。

Question

为什么服务器与客户端不能通讯。
服务器：
import java.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;
//
public class ChatRoomServer  extends Frame implements Runnable//
{ Panel panel,panel2;
 ScrollPane sPanel;
 TextArea textArea;
 Button button1;
 TextField textField2;
 Label label1;
 Button button2;
 PrintWriter out; ServerSocket serverSock;
 Thread chatAcceptThread;//启动接受连接的线程
 BroadcastThread broadcastThread;//广播thread; run when server is listening 
 java.util.Vector clients;//记录连接的线程
 java.util.Vector clientsInfor;//记录连接线程的信息
 public static int index=0;
 
 public ChatRoomServer()
{
  try
  {
  jbInit(); //
  }
  catch(Exception e)
  {
   e.printStackTrace();
  }
  //serverListen();//服务器开始监听
}
 /**/
 //初始化界面
 public void jbInit()
{
  panel=new Panel();
  panel2=new Panel();
  sPanel=new ScrollPane();
  textArea=new TextArea("server information:\n");
  button1=new Button("退出");
  button2=new Button("发送");
  textField2=new TextField("input Message here and send to server");
  label1=new Label("消息:");
  
  sPanel.add(textArea);
 button2.addActionListener(new java.awt.event.ActionListener()
 {
   public void actionPerformed(ActionEvent e)
   {
    button2_actionPerformed(e);
   }
  });
  //textField2:for input message;be registered to KeyListener.
  //press key:Enter to send message
  textField2.addKeyListener(new textField2_KeyAdapter(this));
  panel2.add(label1);
  panel2.add(textField2);
  panel2.add(button2);
  //退出按钮注册
  button1.addActionListener(new java.awt.event.ActionListener()
  {
   public void actionPerformed(ActionEvent e)
   {
    button1_actionPerformed(e);
   }
  });
  panel.add(button1);
  
  this.addWindowListener(new ChatFrame_WindowAdapter(this));//注册到继承了窗口适配器的类
  this.setSize(500,400);
  this.setLayout(new BorderLayout());
  this.add(sPanel,BorderLayout.CENTER);
  this.add(panel,BorderLayout.NORTH);
  this.add(panel2,BorderLayout.SOUTH);
  this.show();
 }
 public void sendInformation()
 {
  out.println(textField2.getText());
  out.flush();
  
 }  private void button2_actionPerformed(ActionEvent e)  //发送按钮
 {//
 //startConnect();
     serverListen();
     sendInformation();
 } 
 public void button1_actionPerformed(ActionEvent e)
 {
  exit();
 }
 
 public void processMsg(String str)
 {//
  textArea.append(str);
 }
 
 public void serverListen()
 {
  try
  {
   serverSock=new ServerSocket(1001);
  }
  catch(IOException e)
  {
   processMsg(e.toString());
   processMsg("server failed!\n");
  }
  processMsg("server listening on port:"+1001);
  clients=new java.util.Vector();
  clientsInfor=new java.util.Vector();
  
  chatAcceptThread=new Thread(this);//启动接受连接的线程
  chatAcceptThread.start();
  
  broadcastThread=new BroadcastThread(this);//广播线程
  broadcastThread.start();
  
  //还有一个回收无用连接thread 的线程
 }  //接受连接并记录线程信息
 public void run()
 {
  int i=0;
  try{
   while(true)
  {
    
    Socket clientSock=serverSock.accept();
    CommunicateThread ct=new CommunicateThread(clientSock,this,index);//创建线程保持连接
    clients.add(ct);//record Communicate Thread;
    i++;
    index++;//version2
    clientsInfor.add("Thread-"+i);
    processMsg("Thread-"+i+"join in\n");
 
    
   }
  }catch(IOException e){
   processMsg(e.toString());
  } 
 }
 
 public void exit(){
  broadcastThread.broadcast("Server exit!");
  try{
   serverSock.close();
  }catch(IOException ioe){}
  finally{
   System.exit(0);
  }
 }
/* */
 public static void main(String[] args){
  ChatRoomServer chat=new ChatRoomServer();
 }
}//保持连接线程
class CommunicateThread extends Thread
{
 protected Socket clientSock;
 protected BufferedReader in=null;
 protected PrintWriter out;
 ChatRoomServer chatFrame;
 boolean isTrue=true;//run()
 java.util.Vector inforStack;
 int index2;//
 
 public CommunicateThread(Socket Sock,ChatRoomServer cFrame,int index)
{
  clientSock=Sock;
  chatFrame=cFrame;
  index2=index;
  inforStack=new java.util.Vector();
  try
  {
   String line;
   in=new BufferedReader(new InputStreamReader(clientSock.getInputStream()));
   out=new PrintWriter(clientSock.getOutputStream());
   line=in.readLine();
   chatFrame.processMsg("Client:"+line);
   
  }
  catch(IOException ei)
  {
   try{
    clientSock.close();
  }catch(IOException ei2){ }
   chatFrame.processMsg(ei.toString());
   return;
  }
  this.start();
 }
 
 public void run(){
  String infor;
  try
  {
     //System.out.println("Client:"+in.readLine());
   while(isTrue){
    infor=in.readLine();
    if(infor.equals("Client exit!")){
     writeInformation(infor);//把信息写到信息栈，以倍广播出去
     stopRun();
    }else if(infor!=null){
     writeInformation(infor);
    }//else break;
    try{
     Thread.sleep(100);//version2
    }catch(InterruptedException ex){}
   }
  }catch(IOException e){ ;}
  finally{
   try{
    in.close();
    out.close();
    clientSock.close();
    chatFrame.clients.remove(index2);//在clients中清除本线程序
    ChatRoomServer.index--;//
   }catch(IOException ei){;}
  }
  
 }
 
 public void writeInformation(String infor)
{//写信息栈
  inforStack.add(infor);
 }
 
 private void stopRun(){//终止线程
  isTrue=false;
 }
 
 public void sendInformation(String str){//发送信息
  try{
   out.println(str);
   out.flush();
  }catch(Exception e){;} 
 }  
}class BroadcastThread extends Thread{//广播线程
 ChatRoomServer chatFrame2;
 java.util.Vector chatClients;//连接线程信息
 java.util.Vector msgStack;//信息栈
 java.util.Vector clientMsg;//记录客户发送的信息
 CommunicateThread comThread1;
 CommunicateThread comThread2;
 String string;//information in inforStack
 String clientName;//client thread name
 String broadcastInfor;//broadcast information=clientName+string;
 
 public BroadcastThread(ChatRoomServer cFrame){
  chatFrame2=cFrame;
  chatClients=chatFrame2.clients;
  clientMsg=chatFrame2.clientsInfor;
  //this.start();
 }
 
 public void broadcast(String str){//广播  
  for(int k=0;k<chatClients.size();k++){//send to everyone分别调用每个连接线程，发送信息 
   comThread2=(CommunicateThread)chatClients.get(k);
   comThread2.sendInformation(str);
  }
 }
 
 public void run(){
  try{
   while(true){
    for(int i=0;i<chatClients.size();i++){
     comThread1=(CommunicateThread)chatClients.get(i);
     msgStack=comThread1.inforStack;//得到每个连接的信息栈
     clientName=(String)clientMsg.get(i);//客户名 
     //读取每个连接线程的信息栈并把信息发送出去
     for(int j=0;j<msgStack.size();j++){
      string=(String)msgStack.get(j);
      broadcastInfor=clientName+"->"+string;
      broadcast(broadcastInfor);
     }
     //clear the inforStack
     msgStack.removeAllElements();//清除以发送的信息
     
    }
    try{
     Thread.sleep(100);//version2
    }catch(InterruptedException ex){}
   }
  }catch(Exception e){}
 }
 
}
class textField2_KeyAdapter extends java.awt.event.KeyAdapter
{
 ChatRoomServer chatFrame;
 
 public textField2_KeyAdapter(ChatRoomServer chatFrame)
 {
  this.chatFrame=chatFrame;
 }
 
 public void keyPressed(KeyEvent e)  //键击Enter键，发送信息！
 {
  int j=e.getKeyCode();
  if(j==e.VK_ENTER)
  {
  chatFrame.serverListen();
      chatFrame.sendInformation();
  }
 }
}//处理窗口关闭事件的适配器
class ChatFrame_WindowAdapter extends java.awt.event.WindowAdapter{
 ChatRoomServer chatFrame;
 public ChatFrame_WindowAdapter(ChatRoomServer chatFrame){
  this.chatFrame=chatFrame;
 }
 public void windowClosing(WindowEvent e){//exit program
  chatFrame.exit();//reference to the method exit() in ChatRoomServer.
 }
}

Answer 1

客户端：
import java.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;
import java.util.*;//yzq edited
public class ChatRoomClient extends Frame implements Runnable
{

 Panel panel1,panel2;
 Button button2;//button1,
 TextField textField2;//textField1,
 Label label1;
 TextArea textArea;
 ScrollPane sPanel;
 PrintWriter out;
 BufferedReader in=null;
 Socket sock;
 OutputStream os;
 
 //create Thread to Read information from Server
 Thread readThread1;
// Thread readThread2;
 boolean isTrue=true;//thread can go on runing ??
 
 public ChatRoomClient()
{
  try
  {
   jbInit();
  }
  catch(Exception e)
  {
   e.printStackTrace();
  }
 }
 
  public void processMsg(String msg)  //客户端处理消息
 {
  textArea.append(msg);
  textArea.append("\n");
 }
 public static void main(String[] args) //main method
{
  ChatRoomClient c=new ChatRoomClient();
  c.show();
 }
 //should set size,position and Font of every component
 private void jbInit()
{
  button2=new Button("发送");
  textField2=new TextField("input Message here and send to server");
  label1=new Label("消息:");
  panel2=new Panel();
  sPanel=new ScrollPane();
  textArea=new TextArea();
  
  //panel2
  //press button2: 发送 to send message
  sPanel.add(textArea);
  button2.addActionListener(new java.awt.event.ActionListener()
  {
   public void actionPerformed(ActionEvent e)
   {
    button2_actionPerformed(e);
   }
  });
  //textField2:for input message;be registered to KeyListener.
  //press key:Enter to send message
  textField2.addKeyListener(new textField2_KeyAdapter(this));
  panel2.add(label1);
  panel2.add(textField2);
  panel2.add(button2);
  
  //frame
  this.addWindowListener(new ChatFrame_WindowAdapter(this));//frame is registered to WindowListener
  this.setLayout(new BorderLayout());
  this.setSize(500,400);
  this.add(sPanel,BorderLayout.CENTER);  //this.add(panel1,BorderLayout.NORTH);  this.add(panel2,BorderLayout.SOUTH);
  //this.show()
    
 }
 //public void endConnect(){//close IOstream 
 
 public void sendInformation()
 {
  out.println(textField2.getText());
  out.flush();
  
 }
 private void button2_actionPerformed(ActionEvent e)  //发送按钮
 {//
 startConnect();
     sendInformation();
 }
   
 public void stopRun()  //to stop the running thread
 {
  isTrue=false;
 }  public void exit()  //窗口关闭；如果有连接则关闭连接和相关的"流"
 {
  try  //send "Client exit!" to Server!
  {
   out.println("Client exit!");
   out.flush();
  }
  catch(Exception exc){}
  //endConnect();
  try  //close IOstream
  { 
   sock.close();
   in.close();
   out.close();
  }
  catch(IOException ioe){}
  finally
  { 
   System.exit(0);
  }
 }  public void startConnect() 
{  try
  {
   Socket sock=new Socket("127.0.0.1",1001);
                     //yzq modified
   if(sock!=null) //connection successed
   {
    processMsg("Connect successfully!");
   } 
    Client c=new Client(sock);
 }
  catch(IOException ex)
  {
   processMsg(ex.toString());
   processMsg("Connect failed!");
  }
  
  readThread1=new Thread(this);
  readThread1.start();   //readThread2运行服务器端
 } class Client extends Thread                              //实现 Client线程类
{
    Socket socket;                                       //用来存储一个连接客户的socket信息
public void send(StringBuffer msg)                   //实现想客户端发送信息的方法
    {
   out.println(msg);                                  //用打印流发送信息
   out.flush();
} public  Client(Socket s)                             //Client线程类的构造器
{
   socket=s;                                           
   try
   {
           
   out=new PrintWriter(s.getOutputStream());      //存储特定客户socket的输出流发送服务器
   in=new BufferedReader(new InputStreamReader(s.getInputStream()));
   String info=in.readLine();                   //读取接受来的信息
   }
    catch(IOException e)
{
       System.out.println("Error:"+e);
     }
}//end of Client constrator
}
public void run()
{
  String msg;
  isTrue=true;
  while(isTrue)
  {
   try
   {
    msg=in.readLine();
    if(msg.equals("Server exit!"))  //server exit
{
     processMsg(msg);
     stopRun();//终止线程
    }
else if(msg!=null)
{
     processMsg(msg);
    }
    Thread.sleep(1000);    
   }
   catch(IOException e)
   {
    processMsg(e.toString());
   }
   catch(InterruptedException ei)
   {
    processMsg(ei.toString());
   }
  }
  //endConnect();
  try  //服务器退出关闭连接和相关的"流"
  {
   sock.close();
   in.close();
   out.close();
  }catch(IOException ioe){} 
 }
}
//文本筐textField2的键击事件适配器class textField2_KeyAdapter extends java.awt.event.KeyAdapter
{
 ChatRoomClient chatFrame;
 
 public textField2_KeyAdapter(ChatRoomClient chatFrame)
 {
  this.chatFrame=chatFrame;
 }
 
 public void keyPressed(KeyEvent e)  //键击Enter键，发送信息！
 {
  int j=e.getKeyCode();
  if(j==e.VK_ENTER)
  {
  chatFrame.startConnect();
      chatFrame.sendInformation();
  }
 }
}//窗口关闭事件适配器
class ChatFrame_WindowAdapter extends java.awt.event.WindowAdapter
{
 ChatRoomClient chatFrame;
 public ChatFrame_WindowAdapter(ChatRoomClient chatFrame)
 {
  this.chatFrame=chatFrame;
 }
 public void windowClosing(WindowEvent e)  //exit program
 {
  chatFrame.exit();//reference to the method exit() in ChatRoomClient.
 }
}

Answer 2

呵呵，楼的代码是从书上copy过来的吧。

Answer 3

好明显的错误public static void main(String[] args){
    ChatRoomServer chat = new ChatRoomServer();    //ServerSocket should be created
    chat.serverListen();
}不过代码还有好多其他小Bug哦................