如何将基础Web聊天室代码升级，实现长尾词自动回复功能？

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

多线程聊天工具javaimport java.io.*; import java.net.*; import java.util.*;

public class HeartServer { List clients=new ArrayList();

public static void main(String[] args) { new HeartServer().start(); }

public void start() { try { ServerSocket serverSocket=new ServerSocket(1234); System.out.println(服务器启动，等待连接...);

while (true) { Socket clientSocket=serverSocket.accept(); clients.add(clientSocket); new Thread(new ClientHandler(clientSocket)).start(); } } catch (IOException e) { e.printStackTrace(); } }

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())); String message;

while ((message=in.readLine()) !=null) { System.out.println(客户端： + message); broadcast(message); }

clients.remove(clientSocket); } catch (IOException e) { e.printStackTrace(); } finally { try { clientSocket.close(); } catch (IOException e) { e.printStackTrace(); } } }

private void broadcast(String message) throws IOException { for (Socket socket : clients) { try { PrintWriter out=new PrintWriter(socket.getOutputStream(), true); out.println(服务器： + message); } catch (IOException e) { clients.remove(socket); socket.close(); } } } } }

多线程聊天

import java.io.*; import java.net.*; import java.util.*; public class HeartServer { List clients = new ArrayList (); public static void main(String[] args) { new HeartServer().start(); } public void start(){ try { boolean iConnect = false; ServerSocket ss = new ServerSocket(1720); iConnect = true; while(iConnect){ System.out.println("绑定服务器端口成功！"); Socket s = ss.accept(); ClientThread currentClient = new ClientThread(s);//创建线程引用 System.out.println("发现客户端！"); clients.add(currentClient);//把当前客户端加入集合 new Thread(currentClient).start(); System.out.println("客户端进程已经启动！"); } } catch (IOException e) { System.out.println("IOException"); e.printStackTrace(); } } class ClientThread implements Runnable { private Socket s; private DataInputStream dis; private DataOutputStream dos; private String str; private boolean iConnect = false; ClientThread(Socket s){ this.s = s; iConnect = true; } public void run(){ System.out.println("run方法启动了！"); try { while(iConnect){ System.out.println("RUN方法中的while循环启动，正在等待客户端的发送消息..."); dis = new DataInputStream(s.getInputStream()); str = dis.readUTF(); System.out.println(str); for(int i=0; i