java实现聊天室功能

1、服务器端代码：.*;importjava.io.*;importjava.util.*;importjava.util.concurrent.*;importjavax.swing.*;publicclassServerprivatestaticfinalintPORT=6666;G_Menugm=newG_Menu();privateServerSocketserver;publicArrayList<PrintWriter>list;publicstaticStringuser;publicstaticArrayList<User>list1=newArrayLis

2、t<User>();/定义用户集合publicUseruu;publicServer(Stringuser)this.user=user;publicvoidgetServer()list=newArrayList<PrintWriter>();tryserver=newServerSocket(PORT);System.out.println("服务器启动,开始监听");while(true)Socketclient=server.accept();/接收客户端线程PrintWriterwriter=newPrintWriter(client.ge

3、tOutputStream();list.add(writer);Threadt=newThread(newChat(client);t.start();catch(Exceptionex)ex.printStackTrace();publicstaticvoidmain(Stringargs)newServer(user).getServer();classChatimplementsRunnableSocketsocket;privateBufferedReaderbr;privateStringmsg;privateStringmssg=""publicChat(So

4、cketsocket)trythis.socket=socket;catch(Exceptionex)ex.printStackTrace();publicvoidrun()trybr=newBufferedReader(newInputStreamReader(socket.getInputStream();while(msg=br.readLine()!=null)if(msg.equals("1008611")/匹配字符串显示好友列表(msg=br.readLine();Stringst=msg.split(":");/将用户信息跟消息分隔开uu=

5、newUser(st0,st1,socket);/将用户信息添加到User对象中list1.add(uu);/将对象添加到用户集合Iterator<User>it=Server.list1.iterator();/遍历用户集合while(it.hasNext()(Useruse=it.next();msg=use.getName()+"("+use.getSex()+"):"mssg+=msg;/将所有的用户信息连接成一个字符串sendMessage("1008611");/显示好友列表匹配标识sendMessage(ms

6、sg);/群发消息elseif(msg.equals("10010")/显示说话消息(msg=br.readLine();System.out.println(msg);sendMessage("10010");/显示说话信息匹配标识sendMessage(msg);elseif(msg.equals("10086")/显示进入聊天室msg=br.readLine();System.out.println(msg);sendMessage("10086");/进入聊天室匹配标识sendMessage(msg);el

7、seif(msg.equals("841163574")/私聊msg=br.readLine();Stringrt=msg.split("1072416535");/把传进来的用信信息跟说话内容分开System.out.println(rt1);/在服务器端显示说话内容Stringtg=rt0.split(":，/因为是私聊，传过来两个用户的用户信息，这句作用是再把两个用户信息分开Iterator<User>iu=Server.list1.iterator();/遍历用户集合while(iu.hasNext()(Userse=iu.

8、next();if(tg1.equals(se.getName()+"("+se.getSex()+")")/如果传进来的用户信息跟集合中的用户信息吻合(try(PrintWriterpwriter=newPrintWriter(se.getSock().getOutputStream();/建立用户自己的流pwriter.println("841163574");/匹配标识pwriter.println(rt1);/向单独用户发送消息pwriter.flush();System.out.println(rt1);catch(Exce

9、ptionex)(ex.printStackTrace();elseif(tg0.equals(se.getName()/如果传进来的用户信息跟集合中的用户信息吻合(tryPrintWriterpwr=newPrintWriter(se.getSock().getOutputStream();/建立用户自己的流pwr.println("841163574");/匹配标识pwr.println(rt1);/向单独用户发送消息pwr.flush();System.out.println(rt1);catch(Exceptionex)ex.printStackTrace();el

10、seif(msg.equals("456987")/下线msg=br.readLine();System.out.println(msg);/在服务端显示信息sendMessage("456987");/匹配字符串sendMessage(msg);/匹配完毕后群发消息Stringsi=msg.split(":，/将传过来的用户名跟信息分隔开Iterator<User>at=Server.list1.iterator();/遍历用户集合while(at.hasNext()(Usersr=at.next();if(sr.getName(

11、).equals(si0)/如果传过来的用户名跟用户集合里的用户吻合(list1.remove(sr);/将吻合的用户移除sr.getSock().close();/关闭此用户的socketbreak;elseif(msg.equals("123654")/刷新(Stringmssge=""Iterator<User>iter=Server.list1.iterator();/遍历用户集合while(iter.hasNext()(Useruus=iter.next();msg=uus.getName()+"("+uus.g

12、etSex()+"):"mssge+=msg;/将所有的用户信息连接成一个字符串sendMessage("123654");/发送刷新匹配标识sendMessage(mssge);/群发消息catch(IOExceptionex)ex.printStackTrace();publicvoidsendMessage(Stringmessage)/群发消息方法tryfor(PrintWriterpw:list)/输出流集合pw.println(message);pw.flush();catch(Exceptionex)(ex.printStackTrace(

13、);客户端代码：.*;importjava.io.*;importjava.util.*;importjava.util.concurrent.*;publicclassSocket_one/客户端(privatestaticfinalintPORT=6666;/端口publicstaticStringuser;publicstaticSocketsocket;publicSocket_one(Stringuser)(this.user=user;try(socket=newSocket("”,PORT);/建立socket连接System.out.println(

14、""+user+"】欢迎来到聊天室！”)；Threadtt=newThread(newRecove(socket,user);/建立客户端线程tt.start();/启动线程catch(Exceptionex)(ex.printStackTrace();publicstaticvoidmain(Stringargs)throwsException(newSocket_one(user);classRecoveimplementsRunnable(publicStringuser;privateSocketsocket;privateBufferedReaderke

15、ybord;publicBufferedReaderbr;privatePrintWriterpw;privateStringmsg;G_Menugm=newG_Menu();publicRecove(Socketsocket,Stringuser)throwsIOException(try(this.socket=socket;this.user=user;catch(Exceptionex)(ex.printStackTrace();publicvoidrun()(try(br=newBufferedReader(newInputStreamReader(socket.getInputSt

16、ream();while(msg=br.readLine()!=null)Stringmessage=msg;if(message.equals("1008611")/匹配字符串显示好友列表gm.listModel1.clear();/接收前清空好友列表gm.jcomb.removeAllItems();/清空JComboxgm.jcomb.addItem("所有人");message=br.readLine();Stringstr=message.split(":");/将接收到的所有用户信息分隔开for(Stringss:str)

17、gm.listModel1.addElement(ss);/将所有用户信息添加到好友列表gm.jcomb.addItem(ss);/将所有用户信息添加到JComboxelseif(message.equals("841163574")/私聊(message=br.readLine();System.out.println("收到："+message);/在服务器端显示私聊消息gm.jta2.append(message+"n");/在我的频道显示私聊信息elseif(message.equals("10010")/

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

19、显示进入聊天室信息gm.jta2.append(message+"n");/在我的频道显示进入聊天室信息elseif(message.equals("123654")/刷新(gm.listModel1.clear();/将好友列表清空gm.jcomb.removeAllItems();/彳务JCombox清空gm.jcomb.addItem("所有人");message=br.readLine();String口sr=message.split(":");/将接收到的用户信息分隔开for(Stringsst:sr)

20、(gm.listModel1.addElement(sst);/将刷新后所有用户信息添加到好友列表gm.jcomb.addItem(sst);/将刷新后所有用户信息添加到JComboxelseif(message.equals("456987")/下线(message=br.readLine();gm.jta1.append(message+"n");/在公共频道显示用户下线信息gm.jta2.append(message+"n");/在我的频道显示用户下线信息catch(IOExceptionex)(ex.printStackTra

21、ce();登陆界面代码：importjava.awt.*;importjava.awt.event.*;importjavax.swing.*;importjava.util.*;importjavax.swing.border.*;classLandenextendsFrameimplementsActionListener(JFramejf=newJFrame("聊天登陆，JPaneljp1=newJPanel();JPaneljp2=newJPanel();JPaneljp3=newJPanel();JPaneljp4=newJPanel();JLabeljl仁newJLabe

22、l("姓名：”)；JLabeljl2=newJLabel("地址：，JLabeljl3=newJLabel("端口:");JRadioButtonjrb1=newJRadioButton("男生");JRadioButtonjrb2=newJRadioButton("女生");JRadioButtonjrb3=newJRadioButton("保密");publicJTextFieldjtf1=newJTextField(10);publicJTextFieldjtf2=newJTextFiel

23、d(10);publicJTextFieldjtf3=newJTextField(10);JButtonjb1=newJButton("连接");JButtonjb2=newJButton("断开");TitledBordertb=newTitledBorder("");ButtonGroupgb=newButtonGroup();publicvoidinit()/显示登录界面jb1.addActionListener(this);jb2.addActionListener(this);jp1.add(jl1);jp1.add(jtf

24、1);jp1.add(jrb1);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(newGridLayout(3,1);jp4.add(jp1);jp4.add(jp2);jp4.add(jp3);jf.add(jp4);jtf2.setText("localhost");jtf3.setText("6666”);gb.add(jrbl);gb.add(jrb2);gb.

25、add(jrb3);jf.setLocation(200,200);jf.setSize(350,200);jf.setResizable(false);jf.setDefaultCloseOperation(JFrame.DISPOSE_ON_CLOSE);jf.setVisible(true);publicvoidactionPerformed(ActionEventevent)/事件触发jb1.setText("连接");jb2.setText("断开");Strings1=null;if(event.getActionCommand().equa

26、ls("断开")System.exit(0);if(event.getActionCommand().equals("连接")(if(jtf1.getText().equals("")(JOptionPane.showMessageDialog(null,”请输入用户名！");elseif(!jrb1.isSelected()&&!jrb2.isSelected()&&!jrb3.isSelected()(JOptionPane.showMessageDialog(null,”请选择性别！&q

27、uot;);else(jf.setVisible(false);if(jrb1.isSelected()(s1="boy"elseif(jrb2.isSelected()(s1="girl"elseif(jrb3.isSelected()(s1="secret"G_Menugmu=newG_Menu();gmu.getMenu(jtf1.getText(),s1);gmu.sock();publicclassLoginpublicstaticvoidmain(Stringargs)newLanden().init();主界面代码：im

28、portjava.awt.*;importjava.awt.event.*;importjavax.swing.*;importjavax.swing.border.*;.*;importjava.io.*;classG_MenuextendsJFrameimplementsActionListener(JFramejf=newJFrame("聊天室");publicSocket_onesoc;publicPrintWriterpw;publicJPaneljp1=newJPanel();publicJPaneljp2=newJPanel();publicJPaneljp3

29、=newJPanel();publicJPaneljp4=newJPanel();publicJPaneljp5=newJPanel();publicJPaneljp6=newJPanel();publicJPaneljp7=newJPanel();publicstaticJTextAreajta1=newJTextArea(12,42);publicstaticJTextAreajta2=newJTextArea(12,42);publicJLabeljl1=newJLabel("对");publicstaticJComboBoxjcomb=newJComboBox();

30、publicJCheckBoxjcb=newJCheckBox("私聊");publicJTextFieldjtf=newJTextField（36）;publicJButtonjb1=newJButton（"发送>>"）;publicJButtonjb2=newJButton（"刷新"）;publicstaticDefaultListModellistModel1;publicstaticJListlst1;publicStringna;publicStringse;publicStringmessage;publicv

31、oidgetMenu（Stringname,Stringsex）/显示聊天界面jcomb.addItem（"所有人"）;this.na=name;this.se=sex;jtal.setEditable(false);jta2.setEditable(false);listModel1=newDefaultListModel();lstl=newJList(listModel1);lst1.setSelectionMode(ListSelectionModel.SINGLE_SELECTION);lst1.setVisibleRowCount(18);lst1.setFix

32、edCellHeight(28);lst1.setFixedCellWidth(100);JScrollPanejsp1=newJScrollPane(jta1);JScrollPanejsp2=newJScrollPane(jta2);JScrollPanejsp3=newJScrollPane(lst1);jsp3.setBorder(newTitledBorder("好友列表");jsp1.setBorder(newTitledBorder("主聊天频道");jsp2.setBorder(newTitledBorder("我的频道&quo

33、t;);jp1.setLayout(newGridLayout(2,1);jp1.add(jsp1);jp1.add(jsp2);jp2.setLayout(newFlowLayout(FlowLayout.LEFT);jp2.add(jl1);jp2.add(jcomb);jp2.add(jcb);jp3.setLayout(newFlowLayout(FlowLayout.LEFT);jp3.add(jtf);jp3.add(jb1);jp4.setLayout(newGridLayout(2,1);jp4.add(jp2);jp4.add(jp3);jp5.setLayout(newBo

34、rderLayout();jp5.add(jp1,BorderLayout.NORTH);jp5.add(jp4,BorderLayout.SOUTH);jp6.setLayout(newBorderLayout();jp6.add(jsp3,BorderLayout.NORTH);jp6.add(jb2,BorderLayout.SOUTH);jp7.setLayout(newFlowLayout(FlowLayout.LEFT);jp7.add(jp5);jp7.add(jp6);jf.add(jp7);jf.setLocation(200,200);jf.setSize(700,650)

35、;jf.setResizable(false);jf.setDefaultCloseOperation(JFrame.DO_NOTHING_ON_CLOSE);jf.setVisible(true);jb1.addActionListener(this);jb2.addActionListener(this);jta1.setLineWrap(true);jta2.setLineWrap(true);jsp1.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLLBAR_ALWAYS);jsp1.setHorizontalS

36、crollBarPolicy(ScrollPaneConstants.HORIZONTAL_SCROLLBAR_NEVER);jsp2.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLLBAR_ALWAYS);jsp2.setHorizontalScrollBarPolicy(ScrollPaneConstants.HORIZONTAL_SCROLLBAR_NEVER);jsp3.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLLBAR_ALWAY

37、S);jsp3.setHorizontalScrollBarPolicy(ScrollPaneConstants.HORIZONTAL_SCROLLBAR_NEVER);jf.pack();publicvoidsock()tryStringuser=na+"("+se+")”;/将用户信息保存成字符串形式soc=newSocket_one(user);/创建客户端对象pw=newPrintWriter(soc.socket.getOutputStream();/创建输出流pw.println("1008611");/发送好友列表标识pw.pri

38、ntln(na+":"+se);/发送用户信息pw.flush();pw.println("10086");/发送进入聊天室标识pw.println(""+na+"】"+"进入聊天室");/发送进入聊天室信息pw.flush();catch(Exceptionex)ex.printStackTrace();publicG_Menu()/设置窗口关闭事件，如果点击窗口右上角叉号关闭，执行下边程序jf.addWindowListener(newWindowAdapter()publicvoidwindowClosing(WindowEvente)trypw=newPrintWriter(soc.socket.getOutputStream();pw.println("456987");/发送下线标识pw.println(na+":离开聊天室");/发送下线信息pw.flush();jf.dispose();/关闭窗口catch(Exceptionex);publicvoidactionPerformed(ActionEventevent)/事件触发(jb1.setText("发送>>");jb2.setText