logo资料库

java聊天系统【完整版】.doc

第1页 / 共10页
第2页 / 共10页
第3页 / 共10页
第4页 / 共10页
第5页 / 共10页
第6页 / 共10页
第7页 / 共10页
第8页 / 共10页
资料共10页,剩余部分请下载后查看
第一部分:代码
第二部分:运行显示
{完毕}
聊天系统(java)
聊天系统(java 版) 2012 年 8 月 12 日 第一部分:代码 一、 聊天窗口 ChatClient.java 代码: import java.awt.*; import java.awt.event.*; import java.io.*; import java.net.*; public class ChatClient extends Frame { Socket s = null; DataOutputStream dos = null; DataInputStream dis = null; private boolean bConnected = false; TextField tfTxt = new TextField(); TextArea taContent = new TextArea(); Thread tRecv = new Thread(new RecvThread()); public static void main(String[] args){ new ChatClient().launchFrame(); } public void launchFrame(){ setLocation(400,300); this.setSize(300,300); add(tfTxt,BorderLayout.SOUTH); add(taContent,BorderLayout.NORTH); pack(); this.addWindowListener(new WindowAdapter(){ @Override public void windowClosing(WindowEvent e) { disconnect(); System.exit(0); /*} public void disconnect(){ try { dos.close(); s.close(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); }*/ } }); tfTxt.addActionListener(new TFListener()); QQ583734331
聊天系统(java 版) 2012 年 8 月 12 日 setVisible(true); connect(); tRecv.start(); } public void connect(){ try { s = new Socket("127.0.0.1",8888); dos = new DataOutputStream(s.getOutputStream()); dis = new DataInputStream(s.getInputStream()); System.out.println("connected!"); bConnected = true; } catch (UnknownHostException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public void disconnect(){ try { dos.close(); dis.close(); s.close(); } catch (IOException e) { e.printStackTrace(); } /* try { bConnected = false; tRecv.join(); }catch (InterruptedException e) { e.printStackTrace(); }finally{ try { dos.close(); dis.close(); s.close(); } catch (IOException e) { e.printStackTrace(); } QQ583734331
聊天系统(java 版) 2012 年 8 月 12 日 } */ } private class TFListener implements ActionListener{ @Override public void actionPerformed(ActionEvent e) { // TODO Auto-generated method stub String str =tfTxt.getText().trim(); //taContent.setText(str); tfTxt.setText(""); try { //DataOutputStream dos = new DataOutputStream(s.getOutputStream()); dos.writeUTF(str); dos.flush(); //dos.close(); } catch (IOException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } } }private class RecvThread implements Runnable{ public void run() { try { while(bConnected){ String str = dis.readUTF(); taContent.setText(taContent.getText()+str+'\n'); } } catch (SocketException e) { System.out.println("轻轻地我走了,正如我悄悄地来。"); } catch (EOFException e) { System.out.println("亲,退出了,886!"); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } } 二、聊天系统服务器 ChatServer.java 代码: QQ583734331
聊天系统(java 版) 2012 年 8 月 12 日 import java.io.*; import java.net.*; import java.util.*; public class ChatServer { boolean started = false; ServerSocket ss = null; List clients = new ArrayList(); public static void main(String[] args){ new ChatServer().start(); // DataInputStream dis = null; } public void start(){ try { ss = new ServerSocket(8888); started = true; } catch(BindException e){ System.out.println("端口使用中。。。。"); System.out.println("请关掉相关程序并重新运行服务器!"); System.exit(0); } catch(IOException e){ e.printStackTrace(); } try{ while(started){ //boolean bConnected = false; Socket s = ss.accept(); Client c = new Client(s); System.out.println("a client connected!"); new Thread(c).start(); clients.add(c); //dis.close(); } //} catch (EOFException e){ // System.out.println("Client closed!"); } catch (IOException e) { e.printStackTrace(); } finally { try { ss.close(); QQ583734331
聊天系统(java 版) 2012 年 8 月 12 日 } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } /*try { if(dis != null) dis.close(); if(s != null) s.close(); } catch (IOException e1) { // TODO Auto-generated catch block e1.printStackTrace(); }*/ } } class Client implements Runnable{ private Socket s; private DataInputStream dis = null; private DataOutputStream dos = null; private boolean bConnected = false; public Client(Socket s){ this.s = s; try { dis = new DataInputStream(s.getInputStream()); dos = new DataOutputStream(s.getOutputStream()); bConnected = true; } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public void send(String str) { try { dos.writeUTF(str); } catch (IOException e) { clients.remove(this); System.out.println("对方推出了!我从List里面去掉了!"); //e.printStackTrace(); } } public void run(){ //Client c = null; QQ583734331
聊天系统(java 版) 2012 年 8 月 12 日 //bConnected = true; // dis = new DataInputStream(s.getInputStream()); try{ while(bConnected){ String str = dis.readUTF(); System.out.println(str); for(int i=0;i
聊天系统(java 版) 2012 年 8 月 12 日 亲!注意:应该先运行服务器,稍等三秒,然后再运行聊天窗口哦!【刚巴黎!!! (日语:中文是:加油!!!)】 二、ChatClient.java 运行显示: 聊天是两个人的事,所以要运行两次 ChatClient.java 哦,亲! 三、聊天阶段显示: QQ583734331
分享到:
收藏