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

定义用户new服务器端代码：import java .n et.*;import javax.swi ng.*;public class Serverprivate static final int PORT=6666;G_Me nu gm=new G_Me nu();private ServerSocket server;public ArrayList<Pri ntWriter> list;public static String user;public static ArrayList<User> list仁 new ArrayList<User>();集合public User uu;public Server(Stri ng user)this.user=user;public void getServer()list =new ArrayList<Pri ntWriter>();tryserver =new ServerSocket(PORT);(”服务器启动，开始监听 ");while(true)Socket clie nt=server.accept();接收客户端线程Prin tWriterwriter=Prin tWriter(clie nt.getOutputStream();list.add(writer);Thread t = new Thread( new Chat(clie nt);t.start();catch(Exceptio n ex)ex.pri ntStackTrace();public static void main(String args)new Server(user).getServer();class Chat impleme nts Runn ableSocket socket;private BufferedReader br;private String msg;private String mssg=""public Chat(Socket socket)try this.socket=socket;catch(Excepti on ex)ex.pri ntStackTrace();public void run()BufferedReader( newtrybr=newelse if(msg.equals("10010")In putStreamReader(socket.get In putStream(); while(msg=br.readLi ne()!=null) if(msg.equals("1008611")匹配字符串 显示好友列表msg=br.readL in e();Stri ng st=msg.split(":");/将用户信息跟消息分隔开uu=new User(st0,st1,socket);将用户信息添加到User对象中Iist1.add(uu);将对象添加到用户集合Iterator<User>it=Server.list1.iterator();/遍历用户集合while(it.hasNext()User use=it .n ext(); msg=use.getName()+"("+use.getSex()+"):"mssg+=msg;将所有的用户信息连接成一个字符串sen dMessage("1008611");显示好友列表匹配标识sendMessage(mssg);/ 群发消息显示说话消息msg=br.readL in e(); System.out.pri ntln( msg); se ndMessage("10010"); sen dMessage(msg);else if(msg.equals("10086")msg=br.readL in e(); System.out.pri ntln( msg); se ndMessage("10086"); sen dMessage(msg);显示说话信息匹配标识显示进入聊天室进入聊天室匹配标识else if(msg.equals("841163574")私聊msg=br.readL in e();Stri ng rt=msg.split("1072416535");把传进来的用户信息跟说话内容分开在服务器端显示说话内容Stri ng tg=rt0.split(":");/因为是私聊，传过来两个用户的用户信息，这句作用是再把两个用户信息分开遍历用户集合while(iu.hasNext()User se=i u.n ext();if(tg1.equals(se.getName()+"("+se.getSex()+")")如果传进来的用户信息跟集合中的用户信息吻合tryPrin tWriterpwriter= newPrin tWriter(se.getSock().getOutputStream();建立用户自己的流pwriter.pri ntln ("841163574");/匹配标识pwriter.pri ntl n(rt1);向单独用户发送消息pwriter.flush();catch(Excepti on ex)ex.pri ntStackTrace();else if(tgO.equals(se.getName()如果传进来的用户信息跟集合中的用户信息吻合tryPrin tWriterPrin tWriter(se.getSock().getOutputStream();pwr= new建立用户自己的流消息pwr.pri ntl n("841163574");匹配标识pwr.pri ntl n(rt1);向单独用户发送pwr.flush();System.out.pri ntl n(rt1);catch(Excepti on ex)ex.pri ntStackTrace();else if(msg.equals("456987")下线msg=br.readL in e();System.out.pri ntln( msg);/se ndMessage("456987");在服务端显示信息匹配字符串sen dMessage(msg);/匹配完毕后群发消息Stri ng si=msg.split(":");/将传过来的用户名跟信息分隔开历用户集合lterator<User> at=Server.list1.iterator();/while(at.hasNext()User sr=at. next();如果传过来if(sr.getName().equals(siO)的用户名跟用户集合里的用户吻合socketIist1.remove(sr); 将吻合的用户移除 sr.getSock().close();关闭 此用户 的break;else if(msg.equals("123654")刷新Stri ng mssge=""遍历用户集合while(iter.hasNext()User uus=iter. next(); msg=uus.getName()+"("+uus.getSex()+"):"mssge+=msg;将所有的用户信息连接成一个字符 串sen dMessage("123654");发送刷新匹配标识sen dMessage(mssge);/ 群发消息catch(IOExcepti on ex)ex.pri ntStackTrace(); public void sen dMessage(Stri ng message)/群发消息方法tryfor(Pri ntWriter pw:list)输出流集合pw.pri ntl n( message); pw.flush();catch(Excepti on ex)ex.pri ntStackTrace();客户端代码：import java .n et.*;public class Socket_ one/客户端private static final int PORT=6666;端口public static String user;public static Socket socket;public Socket_ on e(Stri ng user)this.user=user;try建立 socket 连接(”【"+user+"】欢迎来到聊天室！”)；Thread tt=new Thread(new Recove(socket,user);建立客户端线程tt.start();/ 启动线程catch(Exceptio n ex)ex.pri ntStackTrace();public static void main(String args) throws Exceptionnew Socket_ on e(user);class Recove impleme nts Runn ablepublic String user;private Socket socket;private BufferedReader keybord;public BufferedReader br;private Prin tWriter pw;private String msg;G_Me nu gm=new G_Me nu();public Recove(Socket socket,Stri ng user) throws IOExcepti ontrythis.socket=socket;this.user=user;catch(Exceptio n ex)ex.pri ntStackTrace();public void run()trybr=newBufferedReader( newIn putStreamReader(socket.get In putStream();while(msg=br.readLi ne()!=null)String message=msg;if(message.equals("1008611")匹配字符串 显示好友列表接收前清空好友列表清空 JCombox(” 所有人");message=br.readL in e();Stri ng str=message.split(":");/将接收到的所有用户信息分隔开for(Stri ng ss:str)将所有用户信息添加到好友列表将所有用 户信息添加 到 JComboxelse if(message.equals("841163574")私聊message=br.readL in e();(”收到："+message); 在服务器端显示私聊消息gm.jta2 .ap pe nd(message+"n");在我的频道显示私聊信息else if(message.equals("10010")显示说话消息message=br.readL in e();(”收到："+message);/ 在服务器端显示说话信息gm.jta1. appe nd(message+"n");在公共频道显示说话信息gm.jta2. appe nd(message+"n");在我的频道显示说话信息else if(message.equals("10086")message=br.readL in e();显示进入聊天室gm.jta1.appe nd(message+"n");在公共频道显示进入聊天至信息gm.jta2.appe nd(message+"n");在我的频道显示进入聊天至信息else if(message.equals("123654")gm.listModel1.clear();将好刷新F友列表清空gm.jcomb.removeAllltems();将JCombox清空gm.jcomb.addltem(” 所有人");message=br.readL in e();Stri ng sr=message.split(":");/将接收到的用户信息分隔开for(Stri ng sst:sr)将刷新后所有用户信息添加到好友列表gm.jcomb.addltem(sst);/将刷新后所有用户信息添加到 JCombox线信息线信息else if(message.equals("456987")message=br.readL in e();gm.jta1.appe nd(message+"n");gm.jta2.appe nd(message+"n");下线在公共频道显示用户下在我的频道显示用户下catch(IOExcepti on ex)ex.pri ntStackTrace(); 登陆界面代码：import javax.swi ng.*;class Landen exte nds Frame impleme nts Actio nListe ner JFrame jf=new JFrame(”聊天登陆");JPa nel jp 仁new JPan el(); JPanel jp2=new JPa nel();JPanel jp3=new JPanel();JPa nel jp4=new JPan el();JLabel jl1= new JLabel(" 姓名：");JLabel jl2=new JLabel("地址");JLabel jl3=new JLabel("端口：");JRadioButton jrb仁new JRadioButto n(”男生");JRadioButton jrb2=new JRadioButto n(”女生");JRadioButton jrb3=new JRadioButt on (” 保密");public JTextField jtf1= new JTextField(10); public JTextField jtf2=new JTextField(10); public JTextField jtf3=new JTextField(10);JButton jb 仁new JButto n(”连接");JButton jb2=new JButt on (”断开");TitledBorder tb=new TitledBorder("");Butt on Group gb=new Butt on Group(); public void in it()/显示登录界面jb1.addActi on Liste ner(this);jb2.addActi on Liste ner(this);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");gb.add(jrb1);gb.add(jrb2);gb.add(jrb3);jf.setLocatio n(200, 200);jf.setSize(350, 200);jf.setResizable(false);jf.setDefaultCloseOperatio n( JFrame.DISPOSE_ON_CLOSE); jf.setVisible(true);事件触发public void action Performed(Acti onEvent even t)/jbl.setText(”连接");jb2.setText(”断开");String s1= null;if(event.getActionCommand().equals(”断开")System.exit(O);if(event.getActionCommand().equals(”连接")if(jtf1.getText().equals("")请输入用户名!请选择性别！");JOpti onPan e.showMessageDialog( null,"");elseif(!jrb1.isSelected( )&& !jrb2.isSelected()&&!jrb3.isSelected()JOpti onPan e.showMessageDialog( null,"elsejf.setVisible(false);if(jrb1.isSelected()s仁"boy"else if(jrb2.isSelected()s1="girl"else if(jrb3.isSelected()s仁"secret"G_Me nu gmu=new G_Me nu();gmu.getMe nu(jtf1.getText(),s1);gmu.sock();public class Log inpublic static void main(String args) new Landen( ).i nit();主界面代码：import javax.swi ng.*;import java .n et.*;class G_Me nu exte nds JFrame impleme nts Actio nListe ner JFrame jf=new JFrame(” 聊天室");public Socket_ one soc;public Prin tWriter pw;public JPa nel jp1= new JPa nel();public JPa nel jp2=new JPa nel();public JPa nel jp3=new JPa nel();public JPa nel jp4=new JPa nel();public JPa nel jp5=new JPa nel();public JPa nel jp6=new JPa nel();public JPa nel jp7=new JPa nel();public static JTextArea jta仁new JTextArea(12,42);public 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 jb仁new JButton(”发送 >>");public JButton jb2=new JButton(”刷新");public static DefaultListModel listModel1;public static JList lst1;public String na;public String se;public String message;显示聊天界面public void getMe nu (Stri ng n ame,Stri ng sex)/jcomb.addltem(” 所有人");this .na=n ame;this.se=sex;jta1.setEditable(false);jta2.setEditable(false);listModel仁 new DefaultListModel。;lst1 = new JList(listModel1);lst1.setSelectio nM ode(ListSelectio nM odel.SINGLE_SELECTION); lst1.setVisibleRowCou nt(18);lst1.setFixedCellHeight(28); lst1.setFixedCellWidth(100);JScrollPane jsp1= new JScrollPane(jta1);JScrollPane jsp2=new JScrollPane(jta2);好友列表");JScrollPane 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);jp2.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(jsp3,BorderLayout.NORTH); jp6.add(jb2,BorderLayout.SOUTH);jp7.setLayout (new FlowLayout(FlowLayout.LEFT); jp7.add(jp5);jp7.add(jp6);jf.add(jp7);jf.setLocatio n(200,200);jf.setSize(700,650);jf.setResizable(false);jf.setDefaultCloseOperati on (JFrame.DO_NOTHING_ON_CLOSE); jf.setVisible(true);jb1.addActi on Liste ner(this);jb2.addActi on Liste ner(this);jtal.setL in eWrap(true);jta2.setL in eWrap(true);jsp1.setVerticalScrollBarPolicy(ScrollPa neCo nsta nts.VERTICAL_SCROLL BAR_ALWAYS);jsp1.setHorizo ntalScrollBarPolicy(ScrollPa neCo nsta nts.HORIZONTAL_SC ROLLBAR_NEVER);jsp2.setVerticalScrollBarPolicy(ScrollPa neCo nsta nts.VERTICAL_SCROLL BAR_ALWAYS);jsp2.setHorizo ntalScrollBarPolicy(ScrollPa neCo nsta nts.HORIZONTAL_SC ROLLBAR_NEVER);jsp3.setVerticalScrollBarPolicy(ScrollPa neCo nsta nts.VERTICAL_SCROLL BAR_ALWAYS);jsp3.setHorizo ntalScrollBarPolicy(ScrollPa neCo nsta nts.HORIZONTAL_SC ROLLBAR_NEVER);jf.pack();public void sock() tryString user= na+"("+se+")"将用户信息保存成字符串形式soc=new Socket_ on e(user);/仓 U建客户端对象创建输出流pw.pri ntln ("1008611");/ pw.pri ntln(n a+":"+se);/ pw.flush();pw.pri ntl n( "10086");/发送好友列表标识发送用户信息发送进入聊天室标识pw.println（”【"+na+" "+"进入聊天室"）;/发送进入聊天室信息pw.flush();catch(Exceptio n ex)ex.pri ntStackTrace();设置窗口关闭事件，如果点击窗口右上角叉号关闭，执public G_Menu() /行下边程序jf.addWi ndowListe ner( new Win dowAdapter()public void wi ndowClos in g(Wi ndowEve nt e) try pw.pri ntln( "456987");/发送下线标识pw.println(na+":离开聊天室");/发送下线信息pw.flush();jf.dispose();关闭窗口catch(Excepti on ex) );public void action Performed(Acti onEvent eve nt)事件触发jb1.setText("发送 >>");jb2.setText(”刷新");tryif(event.getActionCommand().equals(”发送 >>")/ 点击发送触发if(!jtf.getText().equals("")if(jcb.isSelected()String n ame1=(Stri ng)jcomb.getSelectedltem(); message="悄悄话"+na+"("+se+")"+"对"+name1+"说:"+jtf.getText();pw.pri ntln ("841163574");/发送私聊标识pw.pri ntln(n a+":"+name1+"1072416535"+message);发送私聊信息pw.flush();elsepw.pri ntln ("10010");/发送聊天标识pw.println(na+"说："+jtf.getText();/发送聊天信pw.flush();刷新")/点击刷新else if(eve nt.getAct ion Comma nd().equals(”触发pw.pri ntl n( "123654");/发送刷新标识pw.flush();catch(Exceptio n ex)ex.pri ntStackTrace();jtf.setText("");清空输入栏信息jtf.requestFocus(); 输入焦点实体类代码：class User用户姓名用户性别用户自己的socketprivate String n ame; private String sex;/ private Socket sock;/ public User(Stri ng n ame,Stri ng sex,Socket sock) setName( name); setSex(sex); setSock(sock); public String getName()return n ame;public void setName(Stri ng n ame)this .n ame=n ame;public String getSex()return sex;public void setSex(Stri ng sex)this.sex=sex;public Socket getSock()retur n sock;public void setSock(Socket sock) this.sock=sock;使用说明：1、先将所有的类都编译一下2、先运行服务器端代码3、再运行登录界面代码