java--网络编程多人聊天

分手后的思念是犯贱 2022-06-02 03:07 194阅读 0赞

**ServerTest：**

package many;

import java.io.IOException;  
import java.net.ServerSocket;  
import java.net.Socket;  
import java.util.ArrayList;  
  
  
public class ServerTest \{  
static ArrayList<Socket> list = new ArrayList<Socket>();  
static int i = 10;  
  
public static void main(String\[\] args) \{  
try \{  
ServerSocket serverSocket = new ServerSocket(9999);  
while(true)\{  
Socket socket = serverSocket.accept();//连接多个客户端  
list.add(socket);//将连接成功的客户端保存到集合中  
ServerThread th = new ServerThread(socket);  
th.start();//开启子线程  
\}  
\} catch (IOException e) \{  
  
e.printStackTrace();  
\}  
  
\}

**ServerThread：**

package many;  
  
  
import java.io.BufferedReader;  
import java.io.BufferedWriter;  
import java.io.IOException;  
import java.io.InputStreamReader;  
import java.io.OutputStreamWriter;  
import java.net.Socket;  
  
  
public class ServerThread extends Thread\{  
private Socket socket;  
  
  
public ServerThread(Socket socket) \{  
super();  
this.socket = socket;  
\}  
  
@Override  
public void run() \{  
/\*  
\* 服务器为一个中转站，不参与聊天，只负责读取并转发  
\* 服务器的子线程负责读取多个客户端聊天的内容  
\* 然后将读取的内容转发给没聊天的其他客户端  
\*/  
try \{  
/\*  
\* socket:只当前聊天的客户端  
\* BufferedReader：读取当前正在聊天的一个客户端内容  
\*/  
BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));  
while(true)\{  
String message = br.readLine();  
System.out.println(message);  
/\*  
\* 遍历多个连接成功的客户端集合  
\* so:代表所有在线的客户端  
\*/  
for(Socket so:ServerTest.list)\{  
//判断不是当前正在聊天的客户端  
if(so!=socket)\{  
//转发 通过if判断以后 so 代表的是所有没有聊天的客户端  
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(so.getOutputStream()));  
bw.write(message);  
bw.newLine();  
bw.flush();  
\}  
\}  
\}  
\} catch (IOException e) \{  
// TODO Auto-generated catch block  
e.printStackTrace();  
\}  
\}  
  
  
\}

**ClientTest ：**

package many;  
  
  
import java.io.BufferedWriter;  
import java.io.IOException;  
import java.io.OutputStreamWriter;  
import java.net.Socket;  
import java.net.UnknownHostException;  
import java.util.Scanner;  
  
  
public class ClientTest \{  
  
  
public static void main(String\[\] args) \{  
try \{  
Socket socket = new Socket("127.0.0.1", 9999);  
ClientThread th = new ClientThread(socket);  
th.start();  
  
Scanner sc = new Scanner(System.in);  
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));  
while(true)\{  
String str = sc.nextLine();  
bw.write(str);  
bw.newLine();  
bw.flush();  
\}  
  
\} catch (UnknownHostException e) \{  
// TODO Auto-generated catch block  
e.printStackTrace();  
\} catch (IOException e) \{  
// TODO Auto-generated catch block  
e.printStackTrace();  
\}  
  
\}  
  
  
\}

**ClientThread ：**

package many;  
  
import java.io.BufferedReader;  
import java.io.IOException;  
import java.io.InputStreamReader;  
import java.net.Socket;  
  
  
public class ClientThread extends Thread\{  
private Socket socket;  
  
  
public ClientThread(Socket socket) \{  
super();  
this.socket = socket;  
\}  
@Override  
public void run() \{  
try \{  
BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));  
while(true)\{  
String str = br.readLine();  
System.out.println(str);  
\}  
\} catch (IOException e) \{  
// TODO Auto-generated catch block  
e.printStackTrace();  
\}  
  
\}  
  
  
\}