基于Java的socket的聊天窗口

package com.lt.server; import com.lt.util.SwingTester; import javax.swing.*; import java.awt.*; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.awt.event.WindowAdapter; import java.awt.event.WindowEvent; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.net.ServerSocket; import java.net.Socket; import java.net.SocketException; import java.util.ArrayList; import java.util.Iterator; public class ServerChat extends JFrame { private static final int PORT = 7608; private JTextArea serverTa = new JTextArea(); private JScrollPane sp = new JScrollPane(serverTa); private JPanel btntool = new JPanel(); // private JButton startBtn = new JButton("启动"); private JButton stopbtn = new JButton("停止"); private ArrayList<ClientConn> ccList = new ArrayList<>(); private ServerSocket ss = null; private boolean isStart = false; public ServerChat() { this.setTitle("服务器端"); this.add(sp, BorderLayout.CENTER); // this.btntool.add(startBtn); ImageIcon arrowIcon = null; java.net.URL imgURL = SwingTester.class.getResource("chat.jpg"); System.out.println(imgURL); arrowIcon = new ImageIcon(imgURL); this.setIconImage(arrowIcon.getImage()); this.btntool.add(stopbtn); this.add(btntool, BorderLayout.SOUTH); this.setBounds(0, 0, 500, 500); stopbtn.addActionListener(new ActionListener() { @Override public void actionPerformed(ActionEvent e) { isStart = false; try { if (ss != null) { ss.close(); } System.out.println("服务器停止!\n"); serverTa.append("服务器断开!\n"); System.exit(0); } catch (IOException ioException) { ioException.printStackTrace(); } } }); this.addWindowListener(new WindowAdapter() { @Override public void windowClosing(WindowEvent e) { isStart = false; try { if (ss != null) { ss.close(); } System.out.println("服务器停止!\n"); serverTa.append("服务器断开!\n"); System.exit(0); } catch (IOException ioException) { ioException.printStackTrace(); } } }); serverTa.setEditable(false); this.setVisible(true); startServer(); } //服务器启动 public void startServer(){ try { try { ss = new ServerSocket(PORT); isStart = true; } catch (IOException e) { e.printStackTrace(); } //可以接受多个客户端的连接 while (isStart) { Socket s = ss.accept(); ccList.add(new ClientConn(s)); System.out.println("一个客户端连接服务区：" + s.getInetAddress() + "/" + s.getPort()); serverTa.append("一个客户端连接服务区：" + s.getInetAddress() + "/" + s.getPort() + "\n"); } } catch (IOException e) { e.printStackTrace(); } // receiveStr(); serverTa.append("服务器启动成功！\n"); } /** * //服务器接受数据 public void receiveStr() { try { dis = new DataInputStream(s.getInputStream()); String str = dis.readUTF(); System.out.println(str); serverTa.append(str); } catch (IOException e) { e.printStackTrace(); } } */ //这个对象是属于服务器端的一个连接对象 class ClientConn implements Runnable{ Socket s = null; public ClientConn(Socket s) { this.s = s; (new Thread(this)).start(); } //同时接收多个客户端的信息 -- 多线程接收数据 @Override public void run() { try { DataInputStream dis = new DataInputStream(s.getInputStream()); while (isStart) { String str = dis.readUTF(); System.out.println(s.getInetAddress() + "/" + s.getPort() +"说: " + str); serverTa.append(s.getInetAddress() + "/" + s.getPort() +"说: " + str + "\n"); String strSend = s.getInetAddress() + "/" + s.getPort() +"说: " + str + "\n"; //遍历ccList，调用send方法 Iterator<ClientConn> it = ccList.iterator(); while (it.hasNext()) { ClientConn o = it.next(); o.send(strSend); } } } catch (SocketException e) { System.out.println("一个客户端下线了：" + s.getInetAddress() + "/" + s.getPort()); serverTa.append("一个客户端下线了：" + s.getInetAddress() + "/" + s.getPort() + "\n"); } catch (IOException e) { System.out.println("服务器中断了!"); e.printStackTrace(); } } //给每个连接对象发送数据 public void send(String str) { try { DataOutputStream dos = new DataOutputStream(this.s.getOutputStream()); dos.writeUTF(str); } catch (IOException e) { e.printStackTrace(); } } } public static void main(String[] args) { ServerChat sc = new ServerChat(); } }