Java聊天系统实训报告

Java聊天系统实训报告一、实训目的：1、理解C/S模式的软件系统结构，掌握网络编程的基本概念；

2、了解Java的多线程机制，掌握Java多线程技术的应用；

3、熟练掌握基于TCP协议的Socket编程；

4、熟练掌握基于UDP协议的Socket编程；

5、了解Socket编程的协议约定以及信息交互方法；二、实训要求：使用JBuilder提供的组件及网络包，开发一个实用的C/S模式聊天室系统。功能要求

要求该系统由客户端及服务器端两部分组成。系统界面要求：要求系统具有友好的用户界面，界面简洁、操作方便；本程序客户端主要完成了：

1.客户端发送信息可以广播客户。

2.广播客户，则将信息转发到所有客户端。

服务器主要完成了：客户-服务器之间信息的交互。例如hello发送信息到服务器，服务器将信息转发到所有与之连接的客户（hello、boy），通过这种形式，就可以实现客户之间的信息广播。

本程序可以实现发送信息广播，只要进入客户端都可以看到消息，本程序采用了流的概念，java多线程，Socket应用程序中用到的代码如下客户端代码：importjava.awt.*;importjava.awt.event.*;importjava.io.*;import.*;publicclassLoginimplementsActionListener{privatestaticfinalActionListenerWindowAdapter=null; privateFramef;privateTextFieldtf;privateLabell;privateStringtfContent="";publicLogin(){ f=newFrame("欢迎登陆本程序...按enter键直接登录");l=newLabel("请输入你的名字");tf=newTextField(20);f.setLayout(newFlowLayout());f.add(l);f.add(tf);f.pack();f.show();tf.addActionListener(this);f.addWindowListener(newWindowAdapter(){publicvoidwindowClosing(WindowEvente){System.exit(0);}});} publicvoidactionPerformed(ActionEvente){System.out.println("ftclicked");tfContent=tf.getText();ClientFramecf=newClientFrame(tfContent);f.dispose();}publicstaticvoidmain(String[]args){newLogin();}}classClientFrameextendsThreadimplementsActionListener{privateFramef;privateTextFieldtf;privateButtonbtn;TextAreata;privatePanelpup;Stringdata;BufferedReaderInputS;PrintStreamOutputS;Stringname;ClientFrame(Stringstr){name=str; Socketclient;try{client=newSocket("localhost",6000);InputS=newBufferedReader(newInputStreamReader(client.getInputStream()));OutputS=newPrintStream(client.getOutputStream(),true);}catch(Exceptionex){ex.printStackTrace();} OutputS.println("欢迎"+name+"光临");f=newFrame("客户端");tf=newTextField(30);tf.addActionListener(this);btn=newButton("发送");ta=newTextArea();pup=newPanel();f.setLayout(newBorderLayout());f.add(pup,BorderLayout.NORTH);pup.add(tf);pup.add(btn);f.add(ta);f.pack();f.setSize(400,300);f.addWindowListener(newWindowAdapter(){publicvoidwindowClosing(WindowEvente){OutputS.println(name+"已经离开");System.exit(0);}});btn.addActionListener(this);f.show();this.start(); } publicvoidrun(){ try{ while(true){ System.out.println("正在监听端口..."); OutputS.println("\u0001"); ta.setText(InputS.readLine().replaceAll("\u0001","\n")); Thread.sleep(1000); } } catch(Exceptionex){ ex.printStackTrace(); } }publicvoidactionPerformed(ActionEvente){Stringcmd=e.getActionCommand();if(cmd.equals("发送")){System.out.println("发送clicked");data=tf.getText();try{OutputS.println(name+"说:"+data);ta.setText(InputS.readLine().replaceAll("\u0001","\n"));}catch(Exceptionex){ex.printStackTrace();}tf.setText("");}else{ System.out.println("发送clicked");data=tf.getText();try{OutputS.println(name+"说:"+data);ta.setText(InputS.readLine().replaceAll("\u0001","\n"));}catch(Exceptionex){ex.printStackTrace();}tf.setText("");}}}运行结果如下图：服务器代码如下:importjava.io.*;importjava.awt.*;importjava.awt.event.*;import.*;importjava.util.ArrayList;publicclassServerFrameimplementsActionListener{privateFramef;privateTextAreata;privateMenuBarmb;privateMenuItemstart;privateMenum;booleanisStop;staticArrayListclients;ServerFrame(){f=newFrame("java聊天系统服务器");ta=newTextArea();mb=newMenuBar();m=newMenu("服务器管理");start=newMenuItem("启动服务器");mb.add(m);m.add(start);start.addActionListener(this);f.setMenuBar(mb);f.add(ta);f.setSize(260,60);f.addWindowListener(newWindowAdapter(){publicvoidwindowClosing(WindowEvente){System.exit(0);}});f.show();}publicvoidactionPerformed(ActionEvente)//该方法用来对发生在按钮上的事件进行处理{Stringcmd=e.getActionCommand();if(cmd.equals("启动服务器")){System.out.println("初始化中...");try{System.out.println("服务器已经启动");ServerSocketserver=newServerSocket(6000);while(!isStop){SocketClient=server.accept();Servicess=newService(Client);}}catch(Exceptionex){ex.printStackTrace();}}}publicstaticvoidmain(String[]args){newServerFrame();}}classServiceextendsThread{Stringdata;BufferedReaderInputS;PrintStreamOutputS;SocketClient;staticStringContent="";publicService(SocketClientSocket)throwsException{Client=ClientSocket;try{InputS=newBufferedReader(newInputStreamReader(Client.getInputStream()));OutputS=newPrintStream(Client.getOutputStream(),true);}catch(Exceptionex){System.out.println("不能连接客户端!");return;}this.start();}publicvoidrun(){System.out.println(this);try{while(true){data=InputS.readLine();if(data.equals("\u0001")){ OutputS.println(Content);}else{ Content=data+"\u0001"+Content;System.out.println(Content);if(Content==null)break;else{OutputS.println(Content);System.out.println("FromClient:"+Content);}}}Client.close();