网络编程之多线程-7.docx

Server:package com.socket_thread;import java.io.IOException;import .ServerSocket;import .Socket;import java.util.ArrayList;import java.util.Collections;import java.util.List;public class Server / 定义保存所有Socket的ArrayList，并将其包装为线程安全的public static List socketList = Collections.synchronizedList(new ArrayList();public static void main(String args) try ServerSocket socket = new ServerSocket(3000);while (true) / 代码会阻塞，将一直等待别人的连接Socket s = socket.accept();socketList.add(s);new Thread(new ServerThread(s).start(); catch (IOException e) / TODO Auto-generated catch blocke.printStackTrace();serverThread:package com.socket_thread;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.PrintStream;import .Socket;public class ServerThread implements Runnable/定义当前线程所处理的SocketSocket s=null;BufferedReader br=null;public ServerThread(Socket s)this.s=s;/初始化该Socket对应的输出流try br=new BufferedReader(new InputStreamReader(s.getInputStream(); catch (IOException e) / TODO Auto-generated catch blocke.printStackTrace();Overridepublic void run() / TODO Auto-generated method stubString content=null;/采用循环不断从Socket中读取客户端发送过来的数据while (content=readFormClient()!=null) /遍历socketList中的每个Socket，将内容向每个Socket发送一次for(Socket s:Server.socketList)try PrintStream ps=new PrintStream(s.getOutputStream();ps.println(content); catch (IOException e) / TODO Auto-generated catch blocke.printStackTrace();/* * 定义读取客户端数据方法 * return */private String readFormClient()try return br.readLine();/如果捕获异常，则表明该Socket对应的客户端已经关闭 catch (IOException e) / 删除该SocketServer.socketList.remove(s);return null;Client:package com.socket_thread;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.PrintStream;import .Socket;import .UnknownHostException;public class Client public static void main(String args) / TODO Auto-generated method stubtry Socket socket = new Socket(, 3000);/ 客户端启动ClientThread线程不断的读取来自服务器的数据new Thread(new ClientThread(socket).start();PrintStream ps = new PrintStream(socket.getOutputStream();String line = null;/ 不断读取键盘输入BufferedReader br = new BufferedReader(new InputStreamReader(System.in);while (line = br.readLine() != null) / 将用户的键盘输入内容写入Socket对应的输出流ps.println(line); catch (UnknownHostException e) / TODO Auto-generated catch blocke.printStackTrace(); catch (IOException e) / TODO Auto-generated catch blocke.printStackTrace();ClientThread:package com.socket_thread;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import .Socket;public class ClientThread implements Runnable/该线程负责处理的Socketprivate Socket socket;BufferedReader br=null;public ClientThread(Socket socket)this.socket=socket;try br=new BufferedReader(new InputStreamReader(socket.getInputStream(); catch (IOException e) / TODO Auto-generated catch blocke.printStackTrace();Overridepublic void run() / TODO Auto-generated method stubString content=null;/不断读取Socket输入