目前我们开发的服务端程序，是否可以支持与多个客户端同时通信？
- 不可以的。
- 因为服务端现在只有一个主线程，只能处理一个客户端的消息。
代码演示如下：
客户端：
public class Client {public static void main(String[] args) throws Exception{System.out.println("客户端开启！");//1.创建Socket对象，并同时请求与服务端程序的连接。Socket socket = new Socket("127.0.0.1",8888);//2.从socket通信管道中得到一个字节输出流。用来发数据给服务端程序OutputStream os = socket.getOutputStream();//3.把低级的字节输出流包装成数据输出流DataOutputStream dos = new DataOutputStream(os);Scanner sc = new Scanner(System.in);while (true) {System.out.println("请输入：");String msg = sc.nextLine();//一旦用户输入了exit，就退出客户端程序if ("exit".equals(msg)){System.out.println("退出成功！");dos.close();socket.close();break;}//4.开始写数据出去了dos.writeUTF(msg);dos.flush();}}
}
服务端：
public class Server {public static void main(String[] args) throws Exception{System.out.println("服务端开启！");//1.创建ServerSocket的对象，同时为服务端注册端口。ServerSocket serverSocket = new ServerSocket(8888);while (true) {//2.使用serverSocket对象，调用一个accept方法，等待客户端的连接请求Socket socket = serverSocket.accept();System.out.println("有人上线了：" + socket.getRemoteSocketAddress());//3.把这个客户端对应的socket通信管道，交给一个对立的线程负责处理new ServerReaderThread(socket).start();}}
}
线程类：
public class ServerReaderThread extends Thread{private Socket socket;public ServerReaderThread(Socket socket){this.socket = socket;}@Overridepublic void run(){try {InputStream is = socket.getInputStream();DataInputStream dis = new DataInputStream(is);while (true) {try {String msg = dis.readUTF();System.out.println(msg);} catch (IOException e) {System.out.println("有人下线了："+ socket.getRemoteSocketAddress());dis.close();socket.close();break;}}} catch (IOException e) {e.printStackTrace();}}
} 本文链接：https://my.lmcjl.com/post/1531.html
展开阅读全文
4 评论