TCP 上传图片到服务端

客户端

package itecat.zpf.tcp;

import java.io.File;

import java.io.FileInputStream;

import java.io.IOException;

import java.io.InputStream;

import java.io.OutputStream;

import java.net.Socket;

import java.net.UnknownHostException;

public class TcpUpClient {
public static void main(String[] args) throws IOException {

// 创建socket
Socket s = new Socket("192.168.81.105", 10007);
// 读取源图片
File picfile = new File("zpf\\as.jpg");
FileInputStream fis = new FileInputStream(picfile);
// 目的是socket
OutputStream out = s.getOutputStream();

byte[] buff = new byte[1024];
int len = 0;

while ((len = fis.read(buff)) != -1) {
out.write(buff, 0, len);
}

s.shutdownOutput();

InputStream in = s.getInputStream();
byte[] buffin = new byte[1024];
int lenin = in.read(buffin);
System.out.println(new String(buffin, 0, lenin));
fis.close();
s.close();

}

}

服务端

package itecat.zpf.tcp;

import java.io.File;

import java.io.FileOutputStream;

import java.io.IOException;

import java.io.InputStream;

import java.io.OutputStream;

import java.net.ServerSocket;

import java.net.Socket;

public class TcpUPServer {

  public static void main(String[] args) throws IOException {
ServerSocket ss=new ServerSocket(10007);

while(true){

Socket s = ss.accept();  
InputStream in = s.getInputStream();
 
  File picfile=new File("zpf\\as.jpg");
  FileOutputStream fos=new FileOutputStream(picfile);
  byte[] buff=new byte[1024];
  int len=0;
  while((len=in.read(buff))!=-1){
  fos.write(buff, 0, len);
  }
 
  //个客户端回馈信息
  OutputStream out=s.getOutputStream();
  out.write("上传成功".getBytes());
  fos.close();
  s.close();
}
 

}

}