网络编程3

TCP通信-多发多收

客户端Client

package 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退出程序

服务端Serve

package 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(); } } }

服务端使用死循环不停的接收这个客户端发来的信息，同时补充异常捕捉功能，监测到客户端退出后，退出循环释放资源