如何用Java编写简易版QQ聊天软件？

本文共计1280个文字，预计阅读时间需要6分钟。

Java实现简单的类似QQ聊天工具，供大家参考，具体内容如下：使用到的知识点：- Java Socket编程及TCP协议- Java Swing- 简单的Java多线程- 运行截图：

服务器端实现：javapackage tcp_server;import java.net.ServerSocket;import java.net.Socket;import java.io.BufferedReader;import java.io.InputStreamReader;import java.io.PrintWriter;import java.io.IOException;

public class Server { public static void main(String[] args) { int port=12345; try (ServerSocket serverSocket=new ServerSocket(port)) { System.out.println(Server is running on port + port); while (true) { Socket clientSocket=serverSocket.accept(); new Thread(new ClientHandler(clientSocket)).start(); } } catch (IOException e) { e.printStackTrace(); } }

private static class ClientHandler implements Runnable { private Socket clientSocket;

public ClientHandler(Socket socket) { this.clientSocket=socket; }

@Override public void run() { try (BufferedReader in=new BufferedReader(new InputStreamReader(clientSocket.getInputStream())); PrintWriter out=new PrintWriter(clientSocket.getOutputStream(), true)) { String inputLine; while ((inputLine=in.readLine()) !=null) { System.out.println(Received: + inputLine); out.println(Echo: + inputLine); } } catch (IOException e) { e.printStackTrace(); } } }}

Java实现简单的类似QQ聊天工具，供大家参考，具体内容如下

所使用到的知识点：

• java socket编程之TCP协议
• java Swing
• 简单的java多线程

运行截图：

服务器端实现：

package tcp_server; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; import java.util.Iterator; import java.util.Map; import java.util.Set; /**  * @author 乔澳  * @version 1.0  * @title: ServerThread  * @projectName 20200222TCPServer  * @description:  * @date 2020/2/27   8:58  */ public class ServerThread extends Thread{     private User user;     public ServerThread(User user){         this.user = user;     }     @Override     public void run() {         Map<String, User> userMap = Server.userMap;         Set<String> keys = userMap.keySet();         try {             BufferedReader reader = new BufferedReader(new InputStreamReader(user.getSocket().getInputStream()));             while (true) {                 String value = reader.readLine();// 客户端发来的一句话                 String[] valueAndUser = value.split("@");                 //群聊                 if (valueAndUser.length == 1) {                     Iterator<String> it = keys.iterator();                     while (it.hasNext()) {                         String key = it.next();                         User u = userMap.get(key);                         PrintWriter pw = new PrintWriter(u.getSocket().getOutputStream());                         pw.println(user.getUsername() + "：" + value + "(来自群消息)");                         pw.flush();                     }                 } else {                     //单聊                     for (int i = 1; i < valueAndUser.length; i++) {                         String username = valueAndUser[i];                         User u = userMap.get(username);                         PrintWriter pw = new PrintWriter(u.getSocket().getOutputStream());                         pw.println(user.getUsername() + "：" + valueAndUser[0] + "(来自私聊)");                         pw.flush();                     }                 }             }         } catch (IOException e) {             System.out.println(user.getUsername()+"下线了");         }     } }

package tcp_server; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.ServerSocket; import java.net.Socket; import java.util.HashMap; import java.util.Map; /**  * @author 乔澳  * @version 1.0  * @title: Server  * @projectName 20200222TCPServer  * @description:  * @date 2020/2/25   9:12  */ public class Server {     static Map<String,User> userMap = new HashMap<String, User>();     public static void main(String[] args) {         try {             System.out.println("===server start===");             ServerSocket server = new ServerSocket(9999);             while(true) {                 Socket socket = server.accept();                 BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));                 String username = br.readLine();                 User user = new User(username,socket);                 System.out.println(user.getUsername()+"上线啦");                 userMap.put(username,user);                 ServerThread thread = new ServerThread(user);                 thread.start();             }         } catch (IOException e) {             // TODO Auto-generated catch block             e.printStackTrace();         }     } }

package tcp_server; import java.net.Socket; /**  * @author 乔澳  * @version 1.0  * @title: User  * @projectName 20200222TCPServer  * @description:  * @date 2020/2/27   8:23  */ public class User {     public User(String username, Socket socket) {         this.username = username;         this.socket = socket;     }     private String username;     private Socket socket;     public User() {     }     public String getUsername() {         return username;     }     public Socket getSocket() {         return socket;     }     public void setUsername(String username) {         this.username = username;     }     public void setSocket(Socket socket) {         this.socket = socket;     } }

客户端实现：

package tcp_client; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.net.Socket; /**  * @author 乔澳  * @version 1.0  * @title: ClientReader  * @projectName 20200222TCPClient  * @description:  * @date 2020/2/26   16:11  */ public class ClientReader extends Thread {     private Socket socket;     public ClientReader(Socket socket){         this.socket = socket;     }     public void run(){         try {             InputStream is = socket.getInputStream();             InputStreamReader isr = new InputStreamReader(is);             BufferedReader reader = new BufferedReader(isr);             for(;;){                 String value = reader.readLine();                 System.out.println(value);             }         } catch (IOException e) {             System.out.println("对不起，服务器崩溃了");         }     } }

package tcp_client; import java.io.IOException; import java.io.OutputStream; import java.io.PrintWriter; import java.net.Socket; import java.util.Scanner; /**  * @author 乔澳  * @version 1.0  * @title: ClientWriter  * @projectName 20200222TCPClient  * @description:  * @date 2020/2/26   16:11  */ public class ClientWriter extends Thread{     private Socket socket;     public ClientWriter(Socket socket){         this.socket = socket;     }     public void run(){         try {             Scanner input = new Scanner(System.in);             OutputStream os = socket.getOutputStream();             PrintWriter pw = new PrintWriter(os);             while(true) {                 System.out.println("说点什么吧：");                 String msg = input.nextLine();                 pw.println(msg);                 pw.flush();             }         } catch (IOException e) {             e.printStackTrace();         }     } }

package tcp_client; import javax.swing.*; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.io.*; import java.net.Socket; /**  * @author 乔澳  * @version 1.0  * @title: QQFrame  * @projectName 20200222TCPClient  * @description:  * @date 2020/2/28   9:46  */ public class QQFrame extends JFrame{     private String name;     private JPanel panel = new JPanel();     private JTextArea mesgArea = new JTextArea();     private JScrollPane mesgPane = new JScrollPane(mesgArea);     private JTextArea speakArea = new JTextArea();     private JScrollPane speakPane = new JScrollPane(speakArea);     private JButton sendBtn = new JButton("发送");     private JButton resetBtn = new JButton("取消");     private Socket socket;     public QQFrame(String name){         super(name);         this.name = name;         this.initOther();         this.initElement();         this.initSelf();         this.connectServer();         this.startReader();         this.initListener();     }     private void connectServer(){         System.out.println("===client start===");         try {             socket = new Socket("127.0.0.1",9999);             PrintWriter pw = new PrintWriter(socket.getOutputStream());             pw.println(name);             pw.flush();         } catch (IOException e) {             JOptionPane.showMessageDialog(this,"服务器连接失败");             //e.printStackTrace();         }     }     private void startReader(){         //启动"读"线程         ClientReader reader = new ClientReader();         reader.start();     }     private void initListener(){         ActionListener listener = new ActionListener() {             @Override             public void actionPerformed(ActionEvent e) {                 try {                     OutputStream os = socket.getOutputStream();                     PrintWriter pw = new PrintWriter(os);                     String msg = speakArea.getText();                     if(msg.isEmpty())                         return;                     pw.println(msg);                     pw.flush();                     speakArea.setText("");                 } catch (IOException ee) {                     ee.printStackTrace();                 }             }         };         sendBtn.addActionListener(listener);         resetBtn.addActionListener(new ActionListener() {             @Override             public void actionPerformed(ActionEvent e) {                 speakArea.setText("");             }         });     }     private void initOther(){         panel.setLayout(null);         mesgArea.setEditable(false);         mesgPane.setBounds(10,10,305,220);         speakPane.setBounds(10,240,305,140);         sendBtn.setBounds(180,390,60,30);         resetBtn.setBounds(260,390,60,30);     }     private void initElement(){         panel.add(mesgPane);         panel.add(speakPane);         panel.add(sendBtn);         panel.add(resetBtn);         this.add(panel);     }     private void initSelf(){         this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);         this.setBounds(1400,220,350,500);         this.setVisible(true);     }     public static void main(String[] args) {         new QQFrame("乔乔");         new QQFrame("小红");         new QQFrame("小明");     }     //内部类     public class ClientReader extends Thread {         StringBuffer sb = new StringBuffer();         public void run(){             try {                 if(socket!=null) {                     InputStream is = socket.getInputStream();                     InputStreamReader isr = new InputStreamReader(is);                     BufferedReader reader = new BufferedReader(isr);                     for (; ; ) {                         String value = reader.readLine();                         sb.append(value + "\n");                         mesgArea.setText(sb.toString());                     }                 }             } catch (IOException e) {                 e.printStackTrace();             }         }     } }

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持自由互联。