一个Java实现的简单的多个客户端聊天程序
客户端
import java.awt.*; import java.awt.event.*; import java.io.*; import java.lang.*; import java.net.*; public class HeartClient extends Frame { /* * 成员方法出场... */ private TextField tfText; private TextArea taContent; private Socket s; private DataOutputStream dos; private DataInputStream dis; /** * 注意，入口... ^^ * @param args */ public static void main(String[] args) { new HeartClient().launchFrame(); } /** * Loading GU */ public void launchFrame(){ tfText = new TextField(); taContent = new TextArea(); this.setSize(300,300); this.setLocation(300,300); this.tfText.addActionListener(new TFListener()); this.add(tfText,BorderLayout.SOUTH); this.add(taContent,BorderLayout.NORTH); this.addWindowListener(new WindowAdapter(){ @Override public void windowClosing(WindowEvent e) { System.exit(0); }}); this.pack(); this.connect(); this.setVisible(true); } /** * 我在努力地连接服务器中... */ public void connect() { try { s = new Socket("127.0.0.1",1720); dos = new DataOutputStream(s.getOutputStream()); dis = new DataInputStream(s.getInputStream()); new Thread(new SendThread()).start(); // dos.writeUTF("Hello,i find u!"); } catch (UnknownHostException e) { System.out.println("UnknownHostException"); e.printStackTrace(); } catch (IOException e) { System.out.println("IOException"); e.printStackTrace(); }finally{ //关闭啥尼... } } /** * 额不会傻等着tfText(TextField tfText的监听器类) */ class TFListener implements ActionListener{ private String str; @Override public void actionPerformed(ActionEvent e) { str = tfText.getText().trim(); tfText.setText(""); try { dos.writeUTF(str); } catch (IOException e1) { System.out.println("IOException"); e1.printStackTrace(); } } } /** * 客户端接收消息的线程呦... * */ class SendThread implements Runnable{ private String str; private boolean iConnect = false; public void run(){ iConnect = true; recMsg(); } /** * 消息，看招，哪里跑...（客户端接收消息的实现） * @throws IOException */ public void recMsg() { try { while(iConnect){ str = dis.readUTF(); taContent.setText(str); } } catch (IOException e) { e.printStackTrace(); } } } } 服务器端
import java.io.*; import java.net.*; import java.util.*; public class HeartServer { /* * 成员变量闪亮登场 */ List<ClientThread> clients = new ArrayList<ClientThread>(); /** * 这系入口啊，向这里看齐... * @param args */ 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<clients.size(); i++){ System.out.println("转发消息中..."+i); ClientThread c = clients.get(i); c.sendMsg(str); } } } catch (IOException e) { e.printStackTrace(); } } /** * 转发消息，我做主... * 将送至服务器的消息发送给每个连接到的客户端 */ public void sendMsg(String str){ try { System.out.println("创建输出管道！"); dos = new DataOutputStream(this.s.getOutputStream()); System.out.println("正在向客户端写消息！"); dos.writeUTF(str); System.out.println("正在向客户端写消息成功！"); } catch (IOException e) { e.printStackTrace(); } } } }