Java实现多人聊天室(含界面) Java实现多人聊天室(含界面)

本文实例为大家分享了Java实现多人聊天室的具体代码，供大家参考，具体内容如下
先说，记录本人的学习过程，当笔记了
多人聊天室分为
1.服务器 ①.while循环 (guanbo) 每连接一个用户就记录一个用户的属性。
②.定义一个存储用户的类（ MySocket ）
③.接收信息（ ServerThread ）并发给每一位用户不需要再次发给自己
2.客户机 ①.线程（ Clithr ）接收数据添加到文本框。
②.Swing（kefuduang）做界面。
代码如下：
先客户机吧简单点

import javax.swing.*; import java.awt.*; import java.awt.event.ActionEvent; import java.io.*; import java.net.Socket; import java.time.DateTimeException; class CilThr extends Thread{Socket socket; JTextArea ta; public CilThr(Socket socket,JTextArea ta){//获取客户端的socket和文本区域this.socket=socket; this.ta=ta; }@Overridepublic void run() {while (true){//一直在接收中try {InputStream inputStream=socket.getInputStream(); //字节输入流DataInputStream din=new DataInputStream(inputStream); //数据输入流String text=din.readUTF(); //获取输入的数据ta.append(text); //添加到文本区域} catch (IOException e) {e.printStackTrace(); }}}}public class kefuduang {JFrame jf; JLabel jLabel; JTextField tf1,tf2; JButton start,send; JTextArea ta; Socket socket=new Socket("localhost",9000); //连接服务器需要的端口号9000public kefuduang() throws IOException {jf=new JFrame("客户端"); jLabel=new JLabel("用户名"); tf1=new JTextField(15); tf2=new JTextField(35); start=new JButton("连接"); send=new JButton("发送"); ta=new JTextArea(40,40); init(); //调用方法实现界面}public void init(){JPanel jp1=new JPanel(); JPanel jp2=new JPanel(); JPanel jp3=new JPanel(); ta.setEditable(false); //让文本框不能输入，只是显示出来send.setEnabled(false); //设置发送按钮，不能按，因为还没有连接上服务器jp1.add(jLabel); jp1.add(tf1); jp1.add(start); jp2.add(ta); jp2.add(new JScrollPane(ta,JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,JScrollPane.HORIZONTAL_SCROLLBAR_ALWAYS)); //设置文本区域的滚动条jp3.add(tf2); jp3.add(send); jf.add(jp1, BorderLayout.NORTH); //设置布局jf.add(jp2,BorderLayout.CENTER); jf.add(jp3,BorderLayout.SOUTH); jf.setVisible(true); jf.setLocationRelativeTo(null); jf.setSize(500,500); jf.setDefaultCloseOperation(JFrame.DISPOSE_ON_CLOSE); handler(); //添加按钮监听new CilThr(socket,ta).start(); //接收其他客户端发来的信息}private void handler() {start.addActionListener(new AbstractAction() {//连接@Overridepublic void actionPerformed(ActionEvent e) {//发起连接String user= tf1.getText(); //获取用户名System.out.println(user+"发起连接请求"); try {OutputStream outputStream=socket.getOutputStream(); //字节输出流DataOutputStream dout=new DataOutputStream(outputStream); //数据输出流dout.writeUTF(user+" 加入聊天"); //.writeUTF里的内容输出到文本里ta.append(user+" 加入聊天"+"\n"); //添加到显示的文本区域send.setEnabled(true); //再设置“发送”按钮可以被点击} catch (IOException ex) {ex.printStackTrace(); }//接收}}); send.addActionListener(new AbstractAction() {//“发送”按钮@Overridepublic void actionPerformed(ActionEvent e) {try {OutputStream outputStream=socket.getOutputStream(); //字节输出流DataOutputStream dout=new DataOutputStream(outputStream); //数据输出流String text=tf2.getText(); //获取待发送文本框的内容dout.writeUTF(text); //输出到文件ta.append("我说： "+text+"\n"); //添加到显示的文本区域tf2.setText(""); //设置下一次需要输入文本框的内容为空} catch (IOException ex) {ex.printStackTrace(); }}}); }public static void main(String[] args) throws IOException {new kefuduang(); //调用构造方法出界面}}

下面是服务器：

import java.io.*; import java.net.ServerSocket; import java.net.Socket; import java.util.ArrayList; import java.util.Date; class ServerThread extends Thread{Socket socket; ArrayList sockets; public ServerThread(Socket socket, ArrayList sockets) {//获取主函数传过来的值this.socket=socket; this.sockets=sockets; }@Overridepublic void run() {while(true){//接收一个用户的多次发送信息try {InputStream inputStream=socket.getInputStream(); //字节输入流DataInputStream din=new DataInputStream(inputStream); //数据输入流String text=din.readUTF(); //获取输入的信息String user=""; //设置当前用户名为空，以防下一次赋值for(int i=0; i sockets=new ArrayList(); //定义一个静态的集合里面的类型是class类 MySocketpublic static void main(String[] args) throws IOException {ServerSocket ss=new ServerSocket(9000); //服务器的端口号为9000System.out.println("服务器准备就绪"); while(true){//收集每一次客户端的连接Socket socket=ss.accept(); System.out.println("响应请求"); //每响应一个客户端就产生一个myscokcetInputStream inputStream=socket.getInputStream(); //字节输入流DataInputStream din=new DataInputStream(inputStream); //数据输入流String user=din.readUTF(); //获取客户端的名称 user=user.substring(0,user.length()-4); //把客户端的名字获取，删除“加入聊天”MySocket ms=new MySocket(socket,user); //把用户的名字和socket放到MyScket里sockets.add(ms); //再添加到集合里，这样就可以保存每一个客户端的名字和socketnew ServerThread(socket,sockets).start(); //启动线程把当前客户端的socket和加入到服务器的所有socket传到线程通过构造器，并开启线程run方法}}}

运行结果：