总结于尚硅谷学习视频
一、代码
TCPTest1类
package com.day0320_1; import org.junit.jupiter.api.Test; import java.io.*; import java.net.InetAddress; import java.net.ServerSocket; import java.net.Socket; /** * 实现TCP的网络编程 * 例子1：客户端发送信息给服务端，服务端将数据显示在控制台上 * * */ public class TCPTest1 { //客户端 @Test public void client() { Socket socket = null; OutputStream os = null; try { //1.创建Socket对象，指明了服务器的IP和端口号 InetAddress inet =InetAddress.getByName("127.0.0.1"); socket = new Socket(inet,8899); //2.获取一个输出流，用于输入数据 os = socket.getOutputStream(); //3.写出数据的操作 os.write("你好，我是客户端mm".getBytes()); } catch (IOException e) { e.printStackTrace(); } finally { //4.资源关闭 if(os!=null) try { os.close(); } catch (IOException e) { e.printStackTrace(); } if(socket!=null) try { socket.close(); } catch (IOException e) { e.printStackTrace(); } } } //服务端 @Test public void server(){ ServerSocket ss = null; Socket socket = null; InputStream is= null; ByteArrayOutputStream baos= null; try { //1.创建服务器端的ServerSocket，指明自己的端口号 ss = new ServerSocket(8899); //2.调用accept()来表示接受来自于客户端的socket socket = ss.accept(); //3.获取输入流 is = socket.getInputStream(); //不建议这样写，可能会有乱码 // byte[] buffer =new byte[1024]; // int len; // while((len=is.read())!=-1){ // String str= new String(buffer,0,len); // System.out.println(str); // } //4.读取输入流当中的数据 baos = new ByteArrayOutputStream(); byte[] buffer=new byte[5]; int len; while((len=is.read(buffer))!=-1){ baos.write(buffer,0,len); } System.out.println(baos.toString()); System.out.println("收到了来自于："+socket.getInetAddress().getHostAddress()+"的数据"); } catch (IOException e) { e.printStackTrace(); } finally { //5. // 关闭资源 if(baos!=null) { try { baos.close(); } catch (IOException e) { e.printStackTrace(); } } if(is!=null){ try { is.close(); } catch (IOException e) { e.printStackTrace(); } } if(socket!=null){ try { socket.close(); } catch (IOException e) { e.printStackTrace(); } } if(ss!=null){ try { ss.close(); } catch (IOException e) { e.printStackTrace(); } } } } }
TCPTest2类
package com.day0320_1; import org.junit.jupiter.api.Test; import java.io.*; import java.net.InetAddress; import java.net.ServerSocket; import java.net.Socket; import java.net.UnknownHostException; /** * 实现TCP的网络编程 * 例子2：客户端发送文件给服务端，服务端将文件保存在本地 * * */ public class TCPTest2 { /* 这里涉及到的异常，应该使用try-catch-finally处理 */ @Test public void client()throws IOException { //1. Socket socket=new Socket(InetAddress.getByName("127.0.0.1"),9090); //2. OutputStream os=socket.getOutputStream(); //3. FileInputStream fis=new FileInputStream(new File("图片.png")); //4. byte[] buffer =new byte[1024]; int len; while ((len=fis.read(buffer))!=-1){ os.write(buffer,0,len); } //5. fis.close(); os.close(); socket.close(); } /* 这里涉及到的异常，应该使用try-catch-finally处理 */ @Test public void server()throws IOException{ //1. ServerSocket ss = new ServerSocket(9090); //2. Socket socket=ss.accept(); //3. InputStream is = socket.getInputStream(); //4. FileOutputStream fos=new FileOutputStream(new File("新图片.png")); //5. byte[] buffer=new byte[1024]; int len; while ((len=is.read(buffer))!=-1){ fos.write(buffer,0,len); } //6. fos.close(); is.close(); socket.close(); ss.close(); } }
TCPTest3类
package com.day0320_1; import org.junit.jupiter.api.Test; import java.io.*; import java.net.InetAddress; import java.net.ServerSocket; import java.net.Socket; /** * 实现TCP的网络编程 * 例子3：客户端发送文件给服务端，服务端将文件保存在本地，并返回“发送成功”给客户端， * 并关闭相应的连接 * * */ public class TCPTest3 { /* 这里涉及到的异常，应该使用try-catch-finally处理 */ @Test public void client()throws IOException { //1. Socket socket=new Socket(InetAddress.getByName("127.0.0.1"),9090); //2. OutputStream os=socket.getOutputStream(); //3. FileInputStream fis=new FileInputStream(new File("图片.png")); //4. byte[] buffer =new byte[1024]; int len; while ((len=fis.read(buffer))!=-1){ os.write(buffer,0,len); } //关闭数据的输出 socket.shutdownOutput(); //5.接受来自于服务器端的反馈，并显示在控制台上 InputStream is = socket.getInputStream(); ByteArrayOutputStream baos=new ByteArrayOutputStream(); byte[] buffer1= new byte[1024]; int len1; while ((len1= is.read(buffer1))!=-1){ baos.write(buffer1,0,len1); } System.out.println(baos.toString()); //6. fis.close(); os.close(); socket.close(); baos.close(); } /* 这里涉及到的异常，应该使用try-catch-finally处理 */ @Test public void server()throws IOException{ //1. ServerSocket ss = new ServerSocket(9090); //2. Socket socket=ss.accept(); //3. InputStream is = socket.getInputStream(); //4. FileOutputStream fos=new FileOutputStream(new File("新图片1.png")); //5. byte[] buffer=new byte[1024]; int len; while ((len=is.read(buffer))!=-1){ fos.write(buffer,0,len); } System.out.println("图片传输完成"); //6.服务器端给予客户端反馈 OutputStream os = socket.getOutputStream(); os.write("你好，美女，照片我已收到，非常漂亮".getBytes()); //7. fos.close(); is.close(); socket.close(); ss.close(); os.close(); } }
二、图片
