网络编程：TCP上传图片，多个的客户端给同一个服务端上传

本是古典何须时尚 2021-10-01 01:06 243阅读 0赞

【需求】：TCP上传图片，多个的客户端给同一个服务端上传

【代码】：

import java.io.*;
    import java.net.*;
    class  Client
    {
    	public static void main(String[] args) throws Exception
    	{
    		if(args.length!=1){
    			System.out.println("请选择一个jpg格式的图片");
    			return ;
    		}
    		File file=new File(args[0]);
    		if(!(file.exists()&&file.isFile())){
    			System.out.println("该文件不存在或不是文件");
    			return ;
    		}
    		if(!file.getName().endsWith(".jpg")){
    			System.out.println("图片格式有误，请重新选择");
    			return ;
    		}
    		if(file.length()>1024*1024*5){
    			System.out.println("图片过大，无法上传");
    			return ;
    		}
    		Socket s=new Socket("127.0.0.1",10007);
    		FileInputStream fis=new FileInputStream("D:\\WorkSpace\\测试.jpg");
    		OutputStream out=s.getOutputStream();
    		InputStream in=s.getInputStream();
    		byte[] buf=new byte[1024];
    		int len=0;
    		while((len=fis.read(buf))!=-1){
    			out.write(buf,0,len);
    		}
    		s.shutdownOutput();
    		byte[] bufIn=new byte[1024];
    		int num=in.read(bufIn);
    		System.out.println(new String(bufIn,0,num));
    		fis.close();
    		s.close();
    	}
    }
    class  Servers implements Runnable
    {
    	private Socket s;
    	Servers(Socket s){
    		this.s=s;
    	} 
    	public void run(){
    		String ip=s.getInetAddress().getHostAddress();
    		int count=1;
    		try{
    			System.out.println(ip+"...connected");
    			InputStream in=s.getInputStream();
    			File file=new File(ip+"("+(count)+")"+".jpg");
    			while(file.exists()){
    				file=new File(ip+"("+(count++)+")"+".jpg");;
    			}
    			OutputStream out=s.getOutputStream();
    			FileOutputStream fos=new FileOutputStream(file);
    			byte[] buf=new byte[1024];
    			int len=0;
    			while((len=in.read(buf))!=-1){
    				fos.write(buf,0,len);
    			}
    			out.write("上传成功".getBytes());
    			fos.close();
    			s.close();
    		}catch(Exception e){
    			throw new RuntimeException(ip+"上传失败");
    		}
    	}
    }
    class  Server
    {
    	public static void main(String[] args) throws Exception
    	{
    		ServerSocket ss=new ServerSocket(10007);
    		while(true){
    			Socket s=ss.accept();
    			new Thread(new Servers(s)).start();
    		}
    	}
    }

【输出】：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1RoZV9CZXN0X0hhY2tlcg_size_16_color_FFFFFF_t_70][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1RoZV9CZXN0X0hhY2tlcg_size_16_color_FFFFFF_t_70]: /images/20210811/244c753d6824467eb216fb28ae825372.png