网络编程（Java）

package Demo08;import java.io.DataOutputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Scanner;public class ClientDemo01 {public static void main(String[] args) throws Exception {//实现tcp通信 多发多收 客户端开发//1、常见Socket管道对象Socket socket = new Socket("127.0.0.1", 9999);//2、从socket通信管道得到一个字节输出流OutputStream os = socket.getOutputStream();//3、特殊数据流DataOutputStream dos = new DataOutputStream(os);Scanner scanner = new Scanner(System.in);while (true) {System.out.println("请输入：");String msg = scanner.nextLine();if ("exit".equals(msg)) {System.out.println("退出成功！");dos.close();//4、释放资源socket.close();break;}dos.writeUTF(msg);dos.flush();}}
}

package Demo08;import java.io.DataInputStream;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;public class ServerDemo02 {public static void main(String[] args) throws Exception {//目标：实现TCP通信下 多发多收：服务器开发System.out.println("服务器端口启动了...");//1、实现tcp通信 多发多收 服务器开发ServerSocket ss = new ServerSocket(9999);//2、调用accept方法，等待客户端连接Socket socket = ss.accept();//3、从socket中获取输入流，读取客户端数据InputStream is = socket.getInputStream();//4、把字节输入流包装成特殊的数据属入流DataInputStream dis = new DataInputStream(is);//5、读取数据while (true) {String msg = dis.readUTF();System.out.println("收到的客户端msg：" + msg);//6、客户端的ip和端口（谁给我发的）System.out.println("客户端的ip：" + socket.getInetAddress().getHostAddress());System.out.println("客户端的端口：" + socket.getPort());System.out.println("----------------------------------------------------------------");}}
}

目前我们开发的服务端程序，是否可以支持同时与多个客户端通信 ？

package Demo06;import java.io.DataOutputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Scanner;public class ClientDemo01 {public static void main(String[] args) throws Exception {//实现tcp通信 多发多收 客户端开发//1、常见Socket管道对象Socket socket = new Socket("127.0.0.1", 9999);//2、从socket通信管道得到一个字节输出流OutputStream os = socket.getOutputStream();//3、特殊数据流DataOutputStream dos = new DataOutputStream(os);Scanner scanner = new Scanner(System.in);while (true) {System.out.println("请输入：");String msg = scanner.nextLine();if ("exit".equals(msg)) {System.out.println("退出成功！");dos.close();//4、释放资源socket.close();break;}dos.writeUTF(msg);dos.flush();}}
}

package Demo06;import java.io.DataInputStream;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;public class ServerDemo02 {public static void main(String[] args) throws Exception {//目标：实现TCP通信下 多发多收：服务器开发System.out.println("----------------------------------------------------------------");System.out.println("服务器端口启动了...");//1、实现tcp通信 多发多收 服务器开发ServerSocket ss = new ServerSocket(9999);while (true) {//2、调用accept方法，等待客户端连接Socket socket = ss.accept();System.out.println("一个客户端上线了~" + socket.getInetAddress().getHostAddress());//3、把这个客户端管道交给一个独立的子线程专门负责接收这个管道的消息new ServerReader(socket).start();}}
}

package Demo06;import java.io.DataInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;public class ServerReader extends Thread {private Socket socket;public ServerReader(Socket socket) {this.socket = socket;}@Overridepublic void run() {try {//读取管道的消息//3、获取字节输入流InputStream is = socket.getInputStream();//4、把字节输入流包装成特殊的数据属入流DataInputStream dis = new DataInputStream(is);//5、读取数据while (true) {String msg = dis.readUTF();System.out.println("收到的客户端msg：" + msg);//6、客户端的ip和端口（谁给我发的）System.out.println("客户端的ip：" + socket.getInetAddress().getHostAddress());System.out.println("客户端的端口：" + socket.getPort());System.out.println("----------------------------------------------------------------");}} catch (Exception e) {e.printStackTrace();System.out.println("客户端断开连接~" + socket.getInetAddress().getHostAddress());}}
}

package Demo07;import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.*;public class ServerDemo02 {public static void main(String[] args) throws Exception {//目标：实现TCP通信下 多发多收：服务器开发System.out.println("----------------------------------------------------------------");System.out.println("服务器端口启动了...");//1、实现tcp通信 多发多收 服务器开发ServerSocket ss = new ServerSocket(8080);ExecutorService pool = new ThreadPoolExecutor(3,10,10,TimeUnit.SECONDS,new ArrayBlockingQueue<Runnable>(100),Executors.defaultThreadFactory(),new ThreadPoolExecutor.AbortPolicy());while (true) {//2、调用accept方法，等待客户端连接Socket socket = ss.accept();System.out.println("一个客户端上线了~" + socket.getInetAddress().getHostAddress());//3、把这个客户端管道包装成一个任务给线程池处理pool.execute(new ServerReaderRunnable(socket));}}
}

package Demo07;import java.io.OutputStream;
import java.io.PrintStream;
import java.net.Socket;public class ServerReaderRunnable implements Runnable {private Socket socket;public ServerReaderRunnable(Socket socket) {this.socket = socket;}@Overridepublic void run() {try {//给当前对应的浏览器管道响应一个网页数据回去OutputStream os = socket.getOutputStream();//通过字节输出流包装写出数据给浏览器//把字节输出流包装给打印流PrintStream ps = new PrintStream(os);//写出响应的网页数据出去ps.println("HTTP/1.1 200 OK");ps.println("Content-Type:text/html;charset=utf-8");ps.println(); //换行ps.println("<!DOCTYPE html>\n" +"<html>\n" +"<head>\n" +"    <meta charset=\"utf-8\">\n" +"    <title>段落p标签</title>\n" +"</head>\n" +"<body>\n" +"<p>\n" +"    窗前明月光\n" +"    <br>\n" +"    疑是地上霜\n" +"    <br>\n" +"    举头望明月\n" +"    <br>\n" +"    低头思故乡\n" +"</p>\n" +"</body>\n" +"</html>");ps.close();socket.close();} catch (Exception e) {e.printStackTrace();System.out.println("客户端断开连接~" + socket.getInetAddress());}}
}