java实现聊天室功能(包含全部代码,有界面)

1、.专业整理.服务器端代码：import .*;import java.io.*;import java.util.*;import java.util.concurrent.*;import javax.swing.*;public class Server private static final int PORT=6666;G_Menu gm=new G_Menu();private ServerSocket server;public ArrayList<PrintWriter> list;public static String user;public static Arr

2、ayList<User> list1=new ArrayList<User>();/定义用户集合public User uu;public Server(String user) this.user=user; public void getServer() list =new ArrayList<PrintWriter>(); tryserver=new ServerSocket(PORT);System.out.println("服务器启动，开始监听 ");while(true) Socket client=server.accept

3、();接收客户端线程PrintWriterwriter=newPrintWriter(client.getOutputStream(); list.add(writer); Thread t = new Thread(new Chat(client); t.start(); catch(Exception ex) ex.printStackTrace(); public static void main(String口 args) new Server(user).getServer();class Chat implements RunnableSocket socket;private B

4、ufferedReader br;private String msg;private String mssg=""public Chat(Socket socket)trythis.socket=socket;catch(Exception ex) ex.printStackTrace();public void run()BufferedReader(newtrybr=newInputStreamReader(socket.getInputStream();while(msg=br.readLine()!=null) if(msg.equals("100861

5、1")匹配字符串 显示好友列表 msg=br.readLine();隔开加到User对象中历用户集合String口 st=msg.split(":");/将用户信息跟消息分uu=new User(st0,st1,socket);将用户信息添list1.add(uu);/将对象添加到用户集合Iterator<User> it=Server.list1.iterator();/遍while(it.hasNext() User use=it.next(); msg=use.getName()+"("+use.getSex()+"

6、):" mssg+=msg;/将所有的用户信息连接成一个字符 串 sendMessage("1008611");显示好友列表匹配标识sendMessage(mssg);/ 群发消息 显示说话消息else if(msg.equals("10010")msg=br.readLine();System.out.println(msg);sendMessage("10010");显示说话信息匹配标识sendMessage(msg);else if(msg.equals("10086")/显示进入聊天室msg=br

7、.readLine();System.out.println(msg); sendMessage("10086");进入聊天室匹配标识sendMessage(msg);else if(msg.equals("841163574")/ 私聊 msg=br.readLine();String口 rt=msg.split("1072416535");/把传进来的用户信息跟说话内容分开System.out.println(rt1);/在服务器端显示说话内容String口 tg=rt0.split(":");因为是私聊，传过

8、来两个用户的用户信息，这句作用是再把两个用户信息分开Iterator<User>iu=Server.list1.iterator();遍历用户集合 while(iu.hasNext() User se=iu.next();if(tg1.equals(se.getName()+"("+se.getSex()+")")如果传进来的用户信息跟集合中的用户信息吻合 try PrintWriterpwriter=newPrintWriter(se.getSock().getOutputStream();建立用户自己的流pwriter.println(&

9、quot;841163574");/匹配标识pwriter.println(rt1);向单独用户发送消息pwriter.flush();System.out.println(rt1);catch(Exception ex) ex.printStackTrace();.学习帮手.else if(tg0.equals(se.getName()/进来的用户信息跟集合中的用户信息吻合如果传tryPrintWriterPrintWriter(se.getSock().getOutputStream();pwr=new建立用户自己的流pwr.println("841163574&quo

10、t;);匹配标识pwr.println(rt1);/向单独用户发送消息pwr.flush();System.out.println(rt1);catch(Exception ex) ex.printStackTrace();信息分隔开历用户集合else if(msg.equals("456987") msg=br.readLine();System.out.println(msg);/ sendMessage("456987");/下线在服务端显示信息 匹配字符串sendMessage(msg);/匹配完毕后群发消息String口 si=msg.spli

11、t(":");/将传过来的用户名跟Iterator<User> at=Server.list1.iterator();/while(at.hasNext()User sr=at.next();if(sr.getName().equals(si0)如果传过来的用户名跟用户集合里的用户吻合list1.remove(sr);/sr.getSock().close();将吻合的用户移除关闭此用户的socket break;else if(msg.equals("123654")刷新String mssge=""Iterator&l

12、t;User> iter=Server.list1.iterator();/遍历用户集合while(iter.hasNext() User uus=iter.next(); msg=uus.getName()+"("+uus.getSex()+"):" mssge+=msg;/将所有的用户信息连接成一个字符 串sendMessage("123654");/发送刷新匹配标识sendMessage(mssge);/ 群发消息 catch(IOException ex)ex.printStackTrace();public void

13、sendMessage(String message)/ 群发消息方法try for(PrintWriter pw:list)/输出流集合pw.println(message);pw.flush();catch(Exception ex) ex.printStackTrace();客户端代码：import .*;import java.io.*;import java.util.*;import java.util.concurrent.*;public class Socket_one客户端private static final int PORT=6666;/端口public static

14、 String user;public static Socket socket;public Socket_one(String user) this.user=user;trysocket=new Socket("127.0.0.1",PORT);/ 建立 socket 连接 System.out.println("【"+user+"欢迎来到聊天室！");Thread tt=new Thread(new Recove(socket,user);/ 建立客户端线 程tt.start(); 启动线程catch(Exception ex

15、) ex.printStackTrace(); public static void main(String口 args) throws Exception new Socket_one(user); class Recove implements Runnable public String user;private Socket socket;private BufferedReader keybord;public BufferedReader br;private PrintWriter pw;private String msg;G_Menu gm=new G_Menu();publ

16、ic Recove(Socket socket,String user) throws IOException trythis.socket=socket;this.user=user;catch(Exception ex) ex.printStackTrace();public void run() trybr=newBufferedReader(newInputStreamReader(socket.getInputStream();while(msg=br.readLine()!=null) String message=msg;if(message.equals("10086

17、11")/ 匹配字符串 显示好友列表 gm.listModel1.clear();/接收前清空好友列表gm.jcomb.removeAllItems();/ 清空 JCombox gm.jcomb.addItem("所有人"); message=br.readLine(); String口 str=message.split(":");/将接收到的所有用户信息分隔开 for(String ss:str) gm.listModel1.addElement(ss);/将所有用户信息添加到好友列表 gm.jcomb.addItem(ss); 将所有用

18、 户 信息添加 到 JCombox else if(message.equals("841163574")/ 私聊 message=br.readLine(); System.out.println(" 收到："+message);/ 在服务器端显 示私聊消息gm.jta2.append(message+"n");/ 在我的频道显示私聊信 息 else if(message.equals("10010")/显示说话消息 message=br.readLine(); System.out.println("

19、 收到："+message);/ 在服务器端显 示说话信息gm.jta1.append(message+"n");/在公共频道显示说话信息 gm.jta2.append(message+"n");/在我的频道显示说话信息显示进入聊天室在公共频道显示进入聊在我的频道显示进入聊else if(message.equals("10086")/message=br.readLine();天室信息天室信息gm.jta1.append(message+"n");gm.jta2.append(message+"

20、;n");else if(message.equals("123654")/ 刷新gm.listModel1.clear();/将好友列表清空gm.jcomb.removeAllItems();/ 将 JCombox 清空gm.jcomb.addItem("所有人");message=br.readLine();String口 sr=message.split(":");/将接收到的用户信息分隔开for(String sst:sr)将刷新后所有gm.listModel1.addElement(sst);/ 用户信息添加到好友

21、列表将刷新后所有用户信息添gm.jcomb.addItem(sst);/ 力口至U JCombox下线在公共频道显示用户下在我的频道显示用户下 else if(message.equals("456987")/ message=br.readLine();gm.jta1.append(message+"n"); 线信息gm.jta2.append(message+"n"); 线信息catch(IOException ex) ex.printStackTrace();登陆界面代码：import java.awt.*;import jav

22、a.awt.event.*;import javax.swing.*;import java.util.*;import javax.swing.border.*;class Landen extends Frame implements ActionListenerJFrame jf=new JFrame("聊天登陆)JPanel jp1=new JPanel();JPanel jp2=new JPanel();JPanel jp3=new JPanel();JPanel jp4=new JPanel();JLabel jl1=new JLabel(" 姓名："

23、);JLabel jl2=new JLabel(" 地址：")；JLabel jl3=new JLabel(" 端口：");JRadioButton jrb1=new JRadioButton("男生");JRadioButton jrb2=new JRadioButton("女生");JRadioButton jrb3=new JRadioButton("保密");public JTextField jtf1=new JTextField(10);public JTextField jtf2=

24、new JTextField(10);public JTextField jtf3=new JTextField(10);JButton jb1=new JButton("连接");JButton jb2=new JButton("断开")；TitledBorder tb=new TitledBorder("");ButtonGroup gb=new ButtonGroup();public void init()显示登录界面jb1.addActionListener(this);jb2.addActionListener(this)

25、;jpl.add(jll);jpl.add(jtfl);jpl.add(jrbl);jp1.add(jrb2);jp1.add(jrb3);jp2.add(jl2);jp2.add(jtf2);jp2.add(jl3);jp2.add(jtf3);jp3.add(jb1);jp3.add(jb2);jp4.setLayout(new GridLayout(3,1);jp4.add(jp1);jp4.add(jp2);jp4.add(jp3);jf.add(jp4);jtf2.setText("localhost");jtf3.setText("6666"

26、);gb.add(jrbl);gb.add(jrb2);gb.add(jrb3);jf.setLocation(200, 200);jf.setSize(350, 200);jf.setResizable(false);jf.setDefaultCloseOperation(JFrame.DISPOSE_ON_CLOSE);jf.setVisible(true);事件触发public void actionPerformed(ActionEvent event)/ jb1.setText("连接")； jb2.setText("断开")； String

27、s1=null;if(event.getActionCommand().equals(" 断开") System.exit(O); if(event.getActionCommand().equals(" 连接") if(jtf1.getText().equals("") JOptionPane.showMessageDialog(null,"请输入用户名!");")； else if(!jrb1.isSelected()&&!jrb2.isSelected()&&!jrb

28、3.isSelected() JOptionPane.showMessageDialog(null,"请选择性别！ else jf.setVisible(false); if(jrb1.isSelected() s1="boy" else if(jrb2.isSelected() s1="girl" else if(jrb3.isSelected() s1="secret" G_Menu gmu=new G_Menu(); gmu.getMenu(jtf1.getText(),s1); gmu.sock(); public

29、class Loginpublic static void main(String口 args) new Landen().init();主界面代码:import java.awt.*;import java.awt.event.*;import javax.swing.*;import javax.swing.border.*;import .*;import java.io.*;class G_Menu extends JFrame implements ActionListenerJFrame jf=new JFrame(" 聊天室"力public Socket_on

30、e soc;public PrintWriter pw;public JPanel jp1=new JPanel();public JPanel jp2=new JPanel();public JPanel jp3=new JPanel();public JPanel jp4=new JPanel();public JPanel jp5=new JPanel();public JPanel jp6=new JPanel();public JPanel jp7=new JPanel();public static JTextArea jta1=new JTextArea(12,42);publi

31、c static JTextArea jta2=new JTextArea(12,42);public JLabel jl1=new JLabel(" ");public static JComboBox jcomb=new JComboBox();public JCheckBox jcb=new JCheckBox(" 私聊)public JTextField jtf=new JTextField(36);public JButton jb1=new JButton(" 发送 >>");public JButton jb2=new

32、 JButton(" 刷新");public static DefaultListModel listModel1;public static JList lst1;public String na;public String se;public String message;public void getMenu(String name,String sex)/显示聊天界面jcomb.addItem(" 所有人");this.na=name;this.se=sex;jta1.setEditable(false);jta2.setEditable(fal

33、se);listModel1= new DefaultListModel。;lst1 = new JList(listModel1);lst1.setSelectionMode(ListSelectionModel.SINGLE_SELECTION);lst1.setVisibleRowCount(18);lst1.setFixedCellHeight(28);lst1.setFixedCellWidth(100);JScrollPane jsp1=new JScrollPane(jta1);JScrollPane jsp2=new JScrollPane(jta2);JScrollPane

34、jsp3=new JScrollPane(lst1);jsp3.setBorder(new TitledBorder("好友列表");jsp1.setBorder(new TitledBorder("主聊天频道")；jsp2.setBorder(new TitledBorder("我的频道");jp1.setLayout(new GridLayout(2,1);jpl.add(jspl);jp1.add(jsp2);jp2.setLayout(new FlowLayout(FlowLayout.LEFT);jp2.add(jl1);j

35、p2.add(jcomb);jp2.add(jcb);jp3.setLayout(new FlowLayout(FlowLayout.LEFT);jp3.add(jtf);jp3.add(jb1);jp4.setLayout(new GridLayout(2,1);jp4.add(jp2);jp4.add(jp3);jp5.setLayout(new BorderLayout();jp5.add(jp1,BorderLayout.NORTH);jp5.add(jp4,BorderLayout.SOUTH);jp6.setLayout(new BorderLayout();jp6.add(jsp

36、3,BorderLayout.NORTH);jp6.add(jb2,BorderLayout.SOUTH);jp7.setLayout(new FlowLayout(FlowLayout.LEFT);jp7.add(jp5);jp7.add(jp6);jf.add(jp7);jf.setLocation(200,200);jf.setSize(700,650);jf.setResizable(false);jf.setDefaultCloseOperation(JFrame.DO_NOTHING_ON_CLOSE);jf.setVisible(true);jb1.addActionListen

37、er(this);jb2.addActionListener(this);jtal.setLineWrap(true);jta2.setLineWrap(true);jsp1.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLL BAR_ALWAYS);jsp1.setHorizontalScrollBarPolicy(ScrollPaneConstants.HORIZONTAL_SC ROLLBAR_NEVER);jsp2.setVerticalScrollBarPolicy(ScrollPaneConstants.VE

38、RTICAL_SCROLL BAR_ALWAYS);jsp2.setHorizontalScrollBarPolicy(ScrollPaneConstants.HORIZONTAL_SC ROLLBAR_NEVER);jsp3.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLL BAR_ALWAYS);jsp3.setHorizontalScrollBarPolicy(ScrollPaneConstants.HORIZONTAL_SC ROLLBAR_NEVER);jf.pack();public void sock()

39、tryString user=na+"("+se+")"/ soc=new Socket_one(user);将用户信息保存成字符串形式 创建客户端对象创建输出流pw=new PrintWriter(soc.socket.getOutputStream();发送好友列表标识 发送用户信息发送进入聊天室标识"+"进入聊天室");/发送进入聊天室信息pw.println("1008611"); pw.println(na+":"+se);/ pw.flush();pw.println(&q

40、uot;10086"); pw.println(" "+na+" pw.flush();catch(Exception ex) ex.printStackTrace();public G_Menu() /设置窗口关闭事件，如果点击窗口右上角叉号关闭，执行下边程序jf.addWindowListener( new WindowAdapter()public void windowClosing(WindowEvent e) try pw=new PrintWriter(soc.socket.getOutputStream();pw.println("456987");发送下线标识pw.println(na+”:离开聊天室");/发送下线信息pw.flush(); jf.dispose();/关闭窗口catch(Exception ex) )； public void actionPerformed(ActionEvent event)/事件触发 jb1.setText("发送 >>"); jb2.setText(&