网络编程3

TCP通信-多发多收客户端Clientpackage TCP2; import java.io.DataOutputStream; import java.io.OutputStream; import java.net.Socket; import java.util.Scanner; 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); 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(); } } }客户端使用死循环不停的发送数据知道输入exit退出程序服务端Servepackage TCP2; import java.io.DataInputStream; import java.io.IOException; import java.io.InputStream; import java.net.ServerSocket; import java.net.Socket; public class Server{ public static void main(String[] args) throws Exception{ System.out.println(...服务端启动成功...); //1.创建ServerSocket的对象同时为服务端注册端口 ServerSocket serverSocket new ServerSocket(8888); //2.使用serverSocket对象调用一个accept方法等待客户端连接请求 Socket socket serverSocket.accept(); //3.从socket通信管理中得到一个字节输入流 InputStream is socket.getInputStream(); //4.把原始的字节输入流包装成数据输入流 DataInputStream dis new DataInputStream(is); while (true) { try { //5.使用数据输入流读取客户端发送过来的消息 String rs dis.readUTF(); System.out.println(rs); } catch (IOException e) { dis.close(); socket.close(); System.out.println(socket.getRemoteSocketAddress()已经退出); break; } // dis.close(); // socket.close(); } } }服务端使用死循环不停的接收这个客户端发来的信息同时补充异常捕捉功能监测到客户端退出后退出循环释放资源