// import java.awt.*;import java.awt.event.*;import java.io.*;import java.net.*;import javax.swing.*;public class charroomserver {//----------------------------------------------------------****************定义变量//JFrameJFrame charFrame;JTextArea charText;JTextField charField2;JButton charButton2;ScrollPane sPanel;//JPanelJPanel jPanel1,jPanel2;//端口号and netpublic final static int DEFAULT_PORT=6666;//默认端口号ServerSocket serverSock;Socket clientSock;//index记录当前对象int index=0;//线程，对象ChatAcceptThread chatAcceptThread[]=new ChatAcceptThread[50];//对象数组 //_________________________________________________________________________________ //------------------------------------------------------------***************方法 //服务端图形 void gUi(){//new  charFrame=new JFrame("聊天室服务端"); jPanel2=new JPanel(); charButton2=new JButton("退出"); charText=new JTextArea(20,20); sPanel=new ScrollPane();  charField2=new JTextField(20); Container chartain=charFrame.getContentPane();//add    sPanel.add(charText);charText.setLineWrap(true);    jPanel2.add(charButton2);    jPanel2.add(charField2);// chartain.add(jPanel1,BorderLayout.NORTH); chartain.add(sPanel,BorderLayout.CENTER); chartain.add(jPanel2,BorderLayout.SOUTH);  charFrame.setBounds(200,200,500,400); charFrame.setVisible(true); charFrame.pack(); charFrame.show();//-------------------------------------------------------***************监听 //_________________________________________________________________________________}//监听void serverListen(){try{   serverSock=new ServerSocket(DEFAULT_PORT);   while(true){  clientSock=serverSock.accept();      chatAcceptThread[index]=new ChatAcceptThread(clientSock);//启动接受连接的线程  chatAcceptThread[index].start();  index++;  }  }catch(IOException e){  }  }//_________________________________________________________________________________ public  charroomserver(){ gUi(); serverListen();//服务器开始监听  }//----------------------------------------------------------************内部类//线程,多用户连接  class ChatAcceptThread extends Thread{  Socket clientSock2;  BufferedReader in;  PrintWriter out;public  ChatAcceptThread(Socket upSock){ clientSock2=upSock; }//runpublic void run(){  try{        in=new BufferedReader(new InputStreamReader(clientSock2.getInputStream()));     out=new PrintWriter(clientSock2.getOutputStream());   while(true){    String str=in.readLine();//    System.out.println(str);    charText.append(str+"\n");    for(int i=0;i<index;i++){       if(str.equals("end"))      break;           chatAcceptThread[i].out.println(str);    chatAcceptThread[i].out.flush(); }          }    }   catch(Exception e){   }}}//______________________________________________________________________________public static void main(String args[]){  new charroomserver(); }}// import java.net.*; import java.io.*; import javax.swing.*;import java.awt.*;import java.awt.event.*; public class charroom implements Runnable{ //----------------------------------------------------------****************定义变量//JFrameJFrame charFrame;JTextArea charText;JTextField charField1,charField2,charField3,charField4;JButton charButton1,charButton2,charButton3;ScrollPane sPanel;JLabel charLabel;//JPanelJPanel jPanel1,jPanel2;//Socket变量Socket server,socket;//文件,ioBufferedReader in;PrintWriter out;BufferedReader wt;//ThreadThread charThread=new Thread(this); //_________________________________________________________________________________ public  charroom(){ gUi(); } //------------------------------------------------------------***************方法//客服端图形 void gUi(){//new  charFrame=new JFrame("聊天室客户端"); jPanel1=new JPanel(); jPanel2=new JPanel(); charLabel=new JLabel("你对"); charButton1=new JButton("连接"); charButton2=new JButton("发送"); charButton3=new JButton("退出"); charText=new JTextArea(20,20); charText.setLineWrap(true); charText.setWrapStyleWord(true); sPanel=new ScrollPane();  charField1=new JTextField(20); charField2=new JTextField(20); charField3=new JTextField("昵称",10); charField4=new JTextField("大家",10); Container chartain=charFrame.getContentPane();//add    jPanel1.add(charField3);    jPanel1.add(charButton1);    jPanel1.add(charField1);    jPanel1.add(charButton3);    sPanel.add(charText);        jPanel2.add(charLabel);    jPanel2.add(charField4);    jPanel2.add(charField2);    jPanel2.add(charButton2); chartain.add(jPanel1,BorderLayout.NORTH); chartain.add(sPanel,BorderLayout.CENTER); chartain.add(jPanel2,BorderLayout.SOUTH);  charFrame.setBounds(200,200,500,400); charFrame.setVisible(true); charFrame.pack(); charFrame.show();//------------------------------------------------------------***********监听 //发送   charButton2.addActionListener(new ActionListener(){   public void actionPerformed(ActionEvent e){    send();   }  }); //连接 charButton1.addActionListener(new ActionListener(){   public void actionPerformed(ActionEvent e){    connect();   }  }); //退出 charButton1.addActionListener(new ActionListener(){  public void actionPerformed(ActionEvent e){   out();  }  }); //_________________________________________________________________________________   }//_________________ //Runpublic void run(){try{while(true){  String str=in.readLine();    charText.append(str+"\n");}     }catch(Exception e){}        }//联接connect()public void connect(){  try{   server=new Socket(InetAddress.getByName(charField1.getText()).getHostAddress(),6666);  if(server!=null){//connection successed    charText.setText(charField3.getText()+"连接成功!");   } //    server=new Socket(InetAddress.getLocalHost(),6666);  in=new BufferedReader(new InputStreamReader(server.getInputStream()));   out=new PrintWriter(server.getOutputStream());  wt=new BufferedReader(new InputStreamReader(System.in));    charThread.start();  }  catch(Exception e){  }     }//发送sendvoid send(){ out.println(charField3.getText()+"对大家说:"+charField2.getText()); out.flush(); charField2.setText("");}//退出方法void out(){ try  { server.close();    System.exit(0);}  catch(Exception event){     }} //_________________________________________________________________________________  public static void main(String args[]){  new charroom(); }}

评论