第十七节：第五部分：网络通信：TCP通信-支持与多个客户端同时通信

TCP通信-支持与多个客户端同时通信

代码：

Server类（服务端）

package com.itheima.day5_TCP3;import java.io.DataInputStream;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;/*
* 目标:完成TCP通信快速入门-服务端开发:实现多发多收。
* */
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();}}
}

ServerReaderThread类（线程方法）

package com.itheima.day5_TCP3;import java.io.DataInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;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 (Exception e) {System.out.println("有人下线了："+socket.getRemoteSocketAddress());dis.close();socket.close();break;}}} catch (Exception e) {e.printStackTrace();}}
}

Client类（客户端）

package com.itheima.day5_TCP3;import java.io.DataOutputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Scanner;/** 目标:完成TCP通信快速入门-客户端开发:实现客户端可以反复的发消息出去* */
public class Client {public static void main(String[] args) throws Exception {// 1、创建Socket对象，并同时请求与服务端程序的连接。Socket socket = new Socket("127.0.0.1", 8888);// 2、从socket通信管道中得到一个字节输出流，用来发数据给服务端程序。OutputStream os = socket.getOutputStream();//3、把低级的字节输出流包装成数据输出流DataOutputStream dos = new DataOutputStream(os);//4、开始写数据出去了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;}dos.writeUTF(msg);dos.flush();}}
}