(5）优化TCP编写 客服端上传图片，服务端给客服端提示接收状态

(5）优化TCP编写 客服端上传图片，服务端给客服端提示接收状态

模拟QQ上传文件时，提示文件上传成功，首先要先启动服务端，否则报错，因为TCP是可靠协议,所以没有对应的服务端时会报错，发送数据为图片

一.编写TCP协议服务端

package demo.soket.tcp;
  ​
  import java.io.BufferedInputStream;
  import java.io.BufferedOutputStream;
  import java.io.FileOutputStream;
  import java.io.IOException;
  import java.io.OutputStream;
  import java.net.ServerSocket;
  import java.net.Socket;
  ​
  //TCP协议服务端
  public class Server {
      public static void main(String[] args) {
          /**
           * 1.创建服务端ServerSocket对象
           * 2.监听socket连接
           * 3.通过返回的socket对象来获取io流里面的数据
           * 4.打印数据
           */
          //1.
          ServerSocket server=null;
          Socket client=null;
          BufferedOutputStream os=null;
          try {
              server=new ServerSocket(12345);
              //2.
              client=server.accept();
              //3.
              //字节缓冲输入流，效率高
              BufferedInputStream bis=new BufferedInputStream(client.getInputStream());
              
              //接收客服端胡消息
              os=new BufferedOutputStream(new FileOutputStream("客户端发过来的图片.jpg"));
              byte[] b=new byte[1024];
              int len=0;
              while((len=bis.read(b))!=-1) {
                  os.write(b, 0, len);
                  os.flush();//刷出缓冲流中的数据，关闭连接前一定要刷，否则会数据缺失
              }
              System.out.println("-----------------");
              System.out.println("通知客服端我已经接收了你的图片");
              //给客服端发消息
              OutputStream out=client.getOutputStream();
              out.write("图片上传成功".getBytes());
          } catch (IOException e) {
              e.printStackTrace();
          }finally {
              if(client!=null) {
                  try {
                      client.close();
                  } catch (IOException e) {
                      e.printStackTrace();
                  }
              }
              if(os!=null) {
                  try {
                      os.close();
                  } catch (IOException e) {
                      e.printStackTrace();
                  }
              }
          }
      }
  ​
  }
  ​

二.编写TCP协议客服端

 package demo.soket.tcp;
  ​
  import java.io.BufferedInputStream;
  import java.io.BufferedOutputStream;
  import java.io.FileInputStream;
  import java.io.IOException;
  import java.io.InputStream;
  import java.net.Socket;
  import java.net.UnknownHostException;
  ​
  /**
   * TCP特点:
   * 1.建立连接，形成传输数据的通道
   * 2.在链接中进行大量数据传输
   * 3.通过三次握完成连接，是可靠协议,所以没有对应的服务端时会报错
   * 4.必建立连接，效率会稍低些
   * @author Administrator
   *
   */
  public class Client {
      public static void main(String[] args) {
          /**
           * 1.创建一个客服端的socket对象
           * 2.建立连接
           * 3.通过io流在管道里面传输数据
           * 写数据：输出流 getOutputStream() 
           * 接收数据：输入流 getInputStream() 
           * 4.关闭socket
           */
          //1.|2.
          Socket client=null;
          try {
              client=new Socket("192.168.95.2",12345);
              //3.
              BufferedOutputStream os=new BufferedOutputStream(client.getOutputStream());
              String path="C:\Users\Administrator\Pictures\微信图片_20200629170031.jpg";
              BufferedInputStream buf=new BufferedInputStream(new FileInputStream(path));
              byte[] b=new byte[1024];
              int len=0;
              while((len=buf.read(b))!=-1) {
                  os.write(b, 0, len);
                  os.flush();//关闭连接前一定要刷，否则会数据缺失
              }
              System.out.println("-----------------");
              /**
               * 关闭连接以进行写入，而不关闭通道。
               * 这句代码一定要加:否则服务器端不知道你图片什么时候传完，while中会一直连接通道，就不会走下一步
               */
              client.shutdownOutput();
              //获取服务端发过来的消息
              InputStream in=client.getInputStream();
              byte[] bi=new byte[1024];
              int leng=0;
              while((leng=in.read(bi))!=-1) {
                  System.out.println("收到服务器通知:"+new String(bi,0,leng));
              }
              //关闭读文件操作
              buf.close();
              os.close();
          } catch (UnknownHostException e) {
              e.printStackTrace();
          } catch (IOException e) {
              e.printStackTrace();
          }finally {
              //4.
              if(client!=null) {
                  try {
                      client.close();
                  } catch (IOException e) {
                      e.printStackTrace();
                  }
              }
          }
      }
  }
  ​

三 .demo运行

刷新项目后会多一张上传的图片,以及可以看到服务器发送的通知：