java编写的聊天室.docx

java编写的聊天室/服务器端package com.day92;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.PrintStream;import java.io.PrintWriter;import .ServerSocket;import .Socket;import java.util.ArrayList;import java.util.Iterator;import java.util.List;public class ChatServer extends Thread static ServerSocket server;PrintWriter out;Socket client;BufferedReader in;static List&ltSocket&gt allclient = new ArrayList&ltSocketpublic ChatServer(Socket client) this.client = client;public static void main(String args) throws IOException server = new ServerSocket(9999);System.out.println("服务端启动成功!");Socket socket;boolean boo = true;while (boo) socket = server.accept;System.out.println("得到客户端请求。");PrintWriter outP = new PrintWriter(socket.getOutputStream,true);outP.println("欢迎光临本聊天室!");outP.println("欢迎光临");allclient.add(socket);/服务器端每过来一个请求，就开一个线程,使得服务器能同时向每个客户端发送消息/随时读取本客户端发送过来的数据new ChatServer(socket).start;Override/同时运行的写到线程里面runpublic void run / TODO Auto-generated method stubtry boolean boo=true;while (boo) in = new BufferedReader(new InputStreamReader(client.getInputStream);/ 读取客户端写入的数据String str = in.readLine;if (!str.equals("") | str != null) /遍历整个集合，向每一个客户端写入Iterator&ltSocket&gt socketPer = allclient.iterator;while (socketPer.hasNext) Socket socketCurrent = (Socket) socketPer.next;out = new PrintWriter(socketCurrent.getOutputStream,true);out.println(str); catch (Exception e) /客户端package com.day92;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.PrintStream;import java.io.PrintWriter;import .InetAddress;import .Socket;import .UnknownHostException;/启动一个客户端public class ChatClient implements RunnableBufferedReader in;/需要读取服务器发送过来的消息PrintWriter out;/向服务器端写static Socket socket;public static void main(String args) throws UnknownHostException, IOException / TODO Auto-generated method stub/开一个客户端socket = new Socket("localhost", 9999);/BufferedReader in=new BufferedReader(new InputStreamReader(socket.getInputStream);/开一个客户端线程ChatClient chatClient=new ChatClient;new Thread(chatClient).start;chatClient.writerToServer;/向服务器发送信息的方法/把本客户端向服务器写入数据的功能单写到一个方法里面，/不能写到线程里面,因为向服务器写入数据的过程不能和其他的客户端同步public void writerToServer throws UnknownHostException, IOExceptiontry BufferedReader keyIn=new BufferedReader(new InputStreamReader(System.in);boolean boo=true;while(boo)String string=keyIn.readLine;out=new PrintWriter(socket.getOutputStream,true);out.println(InetAddress.getLocalHost.getHostName+"说："+string+"n");/string="" catch (UnknownHostException e1) / TODO Auto-generated catch blocke1.printStackTrace; catch (IOException e1) / TODO Auto-generated catch blocke1.printStackTrace;Override/开线程是为了，每个客户端都能同时得到服务器端发过来的数据/每个客户端需要同步接收到服务器发过来的信息public void run try boolean boo=true;in=new BufferedReader(new InputStreamReader(socket.getInputStream);while(boo)System.out.println(in.readLine); catch (IOException e) / TODO Auto-generated catch blocke.printStackTrace;