【java基础：net】基于TCP的图片上传与反馈Demonstration

客官°小女子只卖身不卖艺 2022-06-05 08:42 174阅读 0赞

第一部分：客户端

package net.tcp.tcppicture;
    
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.net.Socket;
    
    /*
     * 需求：将客户端的图片上传至服务端。
     */
    public class TcpPicClient {
    
    	public static void main(String[] args) throws IOException {
    	//1,首先创建客户端socket
    		Socket s=new Socket("192.168.0.100",10007);
    	//2，创建字节输入流获取图片
    		File file=new File("F:\\client.jpg");
    		FileInputStream fis=new FileInputStream(file);
    	//3,通过socket对象创建向服务端的输出流,并且向输出流中传入数据
    		OutputStream os=s.getOutputStream();
    		byte[] buf=new byte[1024];
    		int len=0;
    		while((len=fis.read(buf))!=-1) {
    			os.write(buf,0,len);
    		}
    	//4,写完了之后告诉服务端已发送完毕
    		s.shutdownOutput();
    	//5,之后就是接收从服务端反馈回来的信息
    		InputStream is=s.getInputStream();
    		byte[] bufin=new byte[1024];
    		int lenin=is.read(bufin);//阻塞式，未收到信息会一直等待。
    		String str=new String(bufin,0,lenin);
    		System.out.println(str);
    	//6，关闭资源
    		fis.close();
    		s.close();
    	}
    
    }

第二部分：服务端

package net.tcp.tcppicture;
    
    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 TcpPicServer {
    
    	public static void main(String[] args) throws IOException {
    	//1,创建客户端socket,获取客户端socket对象
    		ServerSocket ss=new ServerSocket(10007);
    		Socket s=ss.accept();//阻塞式，为接收到客户端socket对象会一直等待
    		String ip=s.getInetAddress().getHostAddress();
    		System.out.println(ip+".....已经连入");
    	//2,接收从客户端发来的数据，并写入指定的文件中
    		InputStream in=s.getInputStream();
    		File dir=new File("F:\\server");
    		if(!dir.exists())
    			dir.mkdirs();
    		File file=new File(dir,ip+".jpg");
    		FileOutputStream fos=new FileOutputStream(file);
    		byte[] bufin=new byte[1024];
    		int len=0;
    		while((len=in.read(bufin))!=-1) {
    			fos.write(bufin, 0, len);
    		}
    	//3,反馈给客户端表示已收到
    		OutputStream os=s.getOutputStream();
    		os.write("图片已上传成功！".getBytes());
    	//4,关闭资源
    		fos.close();
    		s.close();
    		ss.close();
    		
    	}
    
    }