利用JAVA实现简单聊天室

1、利用JAVA实现简单聊天室1.设计思路Java是一种简单的，面向对象的，分布式的，解释的，键壮的，安全的，结构中立的，可移植的，性能很优异的，多线程的，动态的语言。而且，Java很小，整个解释器只需215K的RAM。因此运用JAVA程序编写聊天室，实现简单聊天功能。程序实现了聊天室的基本功能，其中有：（1）启动服务器：实现网络的连接，为注册进入聊天室做准备。（2）注册登陆界面：填写基本信息如姓名等，可以供多人进入实现多人聊天功能。（3）发送信息：为用户发送信息提供平台。（4）离开界面：使用户退出聊天室。（5）关闭服务器：断开与网络的连接，彻底退出聊天室。2.设计方法 在设计简单聊天室时，需要编

2、写5个Java源文件：Server.java、Objecting.java、LogIn.java、ClientUser.java、Client.java。3 程序功能图及程序相关说明(1)主功能框图启动服务器注册界面发送信息（用户A）发送信息（用户B）发送信息（用户C）关闭服务器(2) 聊天室基本功能表序号文件名主要功能1ServerHost被服务器调用2Client显示聊天室3ClientUser被客户端调用4LogIn注册登陆5Objecting连接服务器6Server启动服务器4.程序代码是说明程序中引入的包：package Chat;import .*;import j

3、ava.awt.*;import java.awt.event.*;import javax.swing.*;import java.util.*;import java.io.*;（1）服务器端代码中用户自定义类：类名：Server作用：服务器启动继承的接口名：ActionListenerpublic class Server implements ActionListener定义的对象：count /记录点机关闭按钮次数2次关闭soconly /只有SOCKET,用于群发sockets /所有客户的SOCKETsocket_thread /Socket所在的线乘，用于退出；frame /

4、定义主窗体panel /定义面板start，stop /启动和停止按钮主要成员方法：public void center /定义小程序查看器的位置public void actionPerformed /定义处理异常机制定义子类：serverRun,Details继承的父类名：Threadclass serverRun extends Thread /启线乘用于接收连入的Socketclass Details extends Thread /具体处理消息的线乘,只管发送消息创建一个ServerSocket 对象，用于接受指定端口客户端的信息ServerSocket server = new S

5、erverSocket(1234);接受请求时候，通过accept()方法，得到一个socket对象。Socket socket = server.accept();通过socket创建流（输入，输出）。BufferedReaderbr=newBufferedReader(newInputStreamReader(socket.getInputStream()DataInputStream dis = new DataInputStream(socket.getInputStream();PrintWriter out = new PrintWriter(socket.getOutputStr

6、eam();通过流，来和客户交互。(2)用户注册代码中相关类： 类名：LogIn作用：用户注册登录继承的接口名：ActionListener public class LogIn implements ActionListener定义的对象：Title /定义标题Name /提示输入姓名，添加注册信息Send /提示点击“进入”，进入聊天室构造方法：public LogIn()（3）客户端： 创建一个socket对象，用于连接服务器。 用socket创建流。 通过流和服务器进行交互。 交互完毕，将流和socket关闭。（4）聊天室：类名：Client作用：实现发送即时信息。继承的接口名：Act

7、ionListenerpublic class Client implements ActionListener构造方法：public Client(String name2)异常处理：public void actionPerformed(ActionEvent e)public void connect()public void actionPerformed(ActionEvent e) 定义的子类：ClientSocket 继承的父类：Thread class ClientSocket extends Thread ()5.设计结果与分析5个Java源文件：Server.java、Ob

8、jecting.java、LogIn.java、ClientUser.java、Client.java。分别编译这5个Java源文件，或运行“javac *.java”命令，编译全部的源文件，然后运行连接服务器的主类，即运行Server类。连接完毕后在运行注册的主函数类，即运行LogIn类。 首先运行启动服务器的文件Server.java,运行结果如下：图1服务器启动成功结果分析：在进入聊天室之前必须先启动服务器，实现服务器端的连接为用户的登录打开“窗口”。其次运行用户注册登录文件LogIn.java,运行结果如下：图2用户登陆界面结果分析：添加用户信息，输入用户姓名，为用户进入聊天室提供关口

9、。并且利用以下语句实现如图3的界面 JLabel title=new JLabel(免注册版);JLabel name=new JLabel(输入姓名);JButton send=new JButton(进入);添加注册信息后点击“进入”按钮，结果如图3图3显示用户已登录结果分析：当服务器启动用户完成信息注册时，在服务期端的界面中会显示当前在线的人员，并且提示客户已连接到服务器，可以进行聊天行为。图4显示聊天内容结果分析：多个用户进入聊天室之后，用户可以在发送信息的文本框里填写自己的内容，点击“发送信息”按钮，信息会出现在上方的区域内，在界面的右方还可以显示在线人员的姓名，另在线用户可以知道有

10、谁在聊天室内。聊天结束点击“离开”按钮，结果如图5所示：图5离开聊天室点击服务器中的“停止”按钮，结果如图6.图7.所示：图6 点击“停止”按钮图7终止与服务器端连接结果分析：用户聊天结束点击“离开”按钮之后会在服务器端的界面上自动显示该用户已离开，提时、示服务器执行相关行为。离开界面：使用户退出聊天室；关闭服务器：断开与网络的连接，彻底退出聊天室。6语句实现（1）Server.javapackage Chat;import .*;import java.awt.*;import java.awt.event.*;import javax.swing.*;import java

11、.util.*;import java.io.*;public class Server implements ActionListenerint count=0;Vector soconly=new Vector();HashMap sockets=new HashMap(); HashMap socket_thread=new HashMap(); ServerSocket serversocket; JFrame frame; JTextArea area=new JTextArea(); JPanel panel=new JPanel(); JButton start=new JBut

12、ton(启动); JButton stop=new JButton(停止); public Server() panel.add(start); panel.add(stop); frame.add(panel,BorderLayout.NORTH); frame.add(area,BorderLayout.CENTER); frame.pack(); center(); frame.setDefaultCloseOperation(WindowConstants.DO_NOTHING_ON_CLOSE); frame.setVisible(true); start.addActionList

13、ener(this); stop.addActionListener(this); System.out.println(new); public void center() Toolkit toolkit=Toolkit.getDefaultToolkit(); Dimension e=toolkit.getScreenSize(); int x=e.width/2-(int)(frame.getSize().getWidth()/2); int y=e.height/2-(int)(frame.getSize().getHeight()/2); frame.setLocation(x,y)

14、; public void actionPerformed(ActionEvent e) JButton btn=(JButton)e.getSource(); if(btn=start) serverRun serverrun=new serverRun(); System.out.println(gogo); serverrun.start(); if(btn=stop) try Iterator i = soconly.iterator(); while (i.hasNext() Socket s = (Socket) i.next(); ObjectOutputStream out =

15、 new ObjectOutputStream(s. getOutputStream(); Objecting bj=new Objecting(); out.writeObject(系统消息-服务器马上关闭！请马上关闭客户端); count+; if(count=2) System.exit(0); JOptionPane.showMessageDialog(frame,已通知客户端，请再次点击关闭按钮关闭); catch(Exception ex)ex.printStackTrace(); class serverRun extends Thread public void run() t

16、ry System.out.println(开始SERVERRUN); serversocket=new ServerSocket(55555); area.append(服务器启动n); start.setEnabled(false); while(true) Socket socket=serversocket.accept(); System.out.println(连接成功); BufferedReader br=new BufferedReader(new InputStreamReader(socket.getInputStream(); String name=br.readLi

17、ne(); area.append(服务器接收用户+name+的连接n); soconly.add(socket); Iterator i=soconly.iterator(); while(i.hasNext() Socket s=(Socket)i.next();/获得其他SOCKET的通信口 ObjectOutputStream out=new ObjectOutputStream(s.getOutputStream(); out.writeObject(系统消息-+name+用户进入+-); Vector v=getList(); Iterator j=soconly.iterator

18、(); while(j.hasNext() Socket s = (Socket) j.next(); ObjectOutputStream out = new ObjectOutputStream(s.getOutputStream(); out.writeObject(v); System.out.println(服务器发送用户列表进入); Details d=new Details(socket); socket_thread.put(name,d); d.start(); catch(Exception e)e.printStackTrace(); class Details exte

19、nds Thread boolean alive=true; ObjectInputStream in; ObjectOutputStream out; Socket socket; Details(Socket socket) this.socket=socket; public void run() while(alive) try in = new ObjectInputStream(socket.getInputStream(); Objecting objecting=(Objecting)in.readObject(); String name=objecting.getKey()

20、; String content=objecting.getValue(); if(name.equalsIgnoreCase(all) Iterator i=soconly.iterator(); while(i.hasNext() Socket s=(Socket)i.next(); out=new ObjectOutputStream(s.getOutputStream(); out.writeObject(content); System.out.println(Send); if(name.equalsIgnoreCase(exit) Details thread=(Details)

21、socket_thread.get(content); thread.alive=false; area.append(content+离开n); socket.close(); soconly.remove(socket); sockets.remove(content); Iterator i=soconly.iterator(); while(i.hasNext() Socket s=(Socket)i.next(); out=new ObjectOutputStream(s.getOutputStream(); out.writeObject(系统消息-+content+用户离开+-)

22、; Vector v=getList(); Iterator j=soconly.iterator(); while(j.hasNext() Socket s = (Socket) j.next(); ObjectOutputStream out = new ObjectOutputStream(s.getOutputStream(); out.writeObject(v); System.out.println(服务器发送用户列表离开); if(!name.equalsIgnoreCase(all)&!name.equalsIgnoreCase(exit) area.append(处理私聊信

23、息); Socket s=(Socket)sockets.get(name); out=new ObjectOutputStream(s.getOutputStream(); out.writeObject(content); catch(Exception e)e.printStackTrace(); public Vector getList() Vector v=new Vector(); Set set=sockets.keySet(); Iterator i=set.iterator(); while(i.hasNext() v.add(i.next(); return v; pub

24、lic static void main(String args) new Server(); （2）Objecting.javapackage Chat;import java.io.Serializable;public class Objecting implements Serializable String key; String value; public Objecting() public Objecting(String key,String value) this.key =key; this.value=value; public void setKey(String k

25、ey) this.key = key; public void setValue(String value) this.value = value; public String getKey() return key; public String getValue() return value; （3）LogIn.javapackage Chat;import javax.swing.*;import java.awt.*;import java.awt.event.*;public class LogIn implements ActionListener JFrame frame; JLa

26、bel title=new JLabel(免注册版); JPanel banner=new JPanel();JTextField text=new JTextField(10); JPanel body=new JPanel(); JPanel buttom=new JPanel(); JLabel name=new JLabel(输入姓名); JButton send=new JButton(进入); public LogIn() frame=new JFrame(注册); frame.setDefaultCloseOperation(WindowConstants.DISPOSE_ON_

27、CLOSE); banner.add(title); body.add(name); body.add(text); buttom.add(send); frame.add(banner,BorderLayout.NORTH); frame.add(body,BorderLayout.CENTER); frame.add(buttom,BorderLayout.SOUTH); frame.pack(); center(); frame.setVisible(true); send.addActionListener(this); public void center() Toolkit too

28、lkit=Toolkit.getDefaultToolkit(); Dimension e=toolkit.getScreenSize(); int x=e.width/2-(int)(frame.getSize().getWidth()/2); int y=e.height/2-(int)(frame.getSize().getHeight()/2); frame.setLocation(x,y); public void actionPerformed(ActionEvent e) if(text.getText().equals() JOptionPane.showMessageDial

29、og(frame,姓名不能为空); return; else new Client(text.getText(); frame.dispose(); public static void main(String args) new LogIn(); （4）ClientUser.javapackage Chat;import java.awt.*;import java.awt.event.*;import javax.swing.*;import .*;import java.io.*;public class ClientUser extends WindowAdapter

30、implements ActionListener,Runnablepublic JFrame jf; public JTextField jt; public JTextField name; public JButton connect; public JScrollPane jsp; public JTextArea jta; public JButton jb; public JLabel l; Socket soc; InputStream soc_in; OutputStream soc_out; BufferedReader Bsoc_in; PrintWriter Psoc_o

31、ut;public ClientUser() jf=new JFrame(Client Chat Room); jta=new JTextArea(10,30); jta.setEditable(false); jsp=new JScrollPane(jta,JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,JScrollPane.HORIZONTAL_SCROLLBAR_AS_NEEDED); jt=new JTextField(30); name=new JTextField(5); l=new JLabel(Please in put your name); c

32、onnect=new JButton(Connect); connect.addActionListener(this); jt.addActionListener(this); jb=new JButton(Send The Message); jb.addActionListener(this); JPanel jp=new JPanel(); JPanel jp2=new JPanel(); jp.setLayout(new FlowLayout(); jp.add(jt); jp.add(jb); jp2.add(l); jp2.add(name); jp2.add(connect);

33、 Container c=jf.getContentPane(); c.setLayout(new GridBagLayout(); GridBagConstraints gbc=new GridBagConstraints(); gbc.gridx=0; gbc.gridy=0; c.add(jp2,gbc);gbc.gridx=0; gbc.gridy=1; c.add(jsp,gbc); gbc.gridy=2; c.add(jp,gbc); jf.pack(); jf.setVisible(true); public static void main(String args) Clie

34、ntUser cuser=new ClientUser(); public void windowClosing(WindowEvent e) System.exit(0);public void actionPerformed(ActionEvent e) if (e.getSource()=connect) if(name.getText().equals() new JOptionPane().showMessageDialog(null,Please in Put your name First!); else try soc=new Socket(localhost,55555);

35、Psoc_out=new PrintWriter(soc.getOutputStream(),true); Bsoc_in=new BufferedReader(new InputStreamReader(soc.getInputStream(); Psoc_out.println(name.getText(); catch(Exception e1)e1.printStackTrace(); name.setEditable(false); new Thread (this).start(); if(e.getSource()=jt|e.getSource()=jb) jta.append(

36、name.getText()+:+jt.getText()+n); Psoc_out.println(name.getText()+:+jt.getText(); jt.setText(); public void run() Stringtext; while(true) try text=Bsoc_in.readLine(); jta.append(text+n); catch(Exception e)e.printStackTrace(); （5）Client.javapackage Chat;import javax.swing.*;import java.awt.*;import j

37、ava.awt.event.*;import .*;import java.io.*;import java.util.Vector;public class Client implements ActionListener ClientSocket cs; String name; Socket socket; JFrame frame; JTextArea area=new JTextArea(30,30); JTextField text=new JTextField(30); JButton send=new JButton(发送消息); JButton exit=ne

38、w JButton(离开); JPanel banner=new JPanel(); JPanel panel=new JPanel(); List list=new List(35); JPanel right=new JPanel(); JLabel welcome=new JLabel(); public Client(String name2) =name2; welcome.setText(name+-欢迎来到聊天室); area.setEditable(false); frame=new JFrame(聊天室); frame.setDefaultCloseOper

39、ation(WindowConstants.DO_NOTHING_ON_CLOSE); frame.setResizable(false); banner.add(welcome); frame.add(banner,BorderLayout.NORTH); panel.add(text); panel.add(send); panel.add(exit); frame.add(panel,BorderLayout.SOUTH); frame.add(area,BorderLayout.CENTER); right.add(new JScrollPane(list); frame.add(ri

40、ght,BorderLayout.EAST); frame.pack(); center(); frame.setVisible(true); connect(); send.addActionListener(this); exit.addActionListener(this); list.addActionListener(new ActionListener() public void actionPerformed(ActionEvent e) String to=list.getSelectedItem(); String content=JOptionPane.showInput

41、Dialog(frame,输入向+name+发送的私聊信息,私聊,JOptionPane.INFORMATION_MESSAGE); if(content=null) return; else Objecting o=new Objecting(to,-私聊信息-+name+:+content); try ObjectOutputStream out = new ObjectOutputStream(socket.getOutputStream(); out.writeObject(o); JOptionPane.showMessageDialog(frame,to+收到消息); catch(Exception e2)e2.printStackTrace(); ); text.addActionListener(new Acti