【java基础：net】基于多线程的TCP图片上传客户端与服务端Demonstration

ゞ浴缸里的玫瑰 2022-06-05 09:10 209阅读 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.IOException;
    import java.net.ServerSocket;
    import java.net.Socket;
    /*
     * 需求：创建多线程的服务端处理程序，即：在每收到一个客户端的对象后，就开辟一个线程去执行相应的处理程序。
     */
    public class TcpPicMultiThreadServer {
    
    	public static void main(String[] args) throws IOException {
    	//1,创建服务端socket,获取客户端socket对象
    		@SuppressWarnings("resource")
    		ServerSocket ss=new ServerSocket(10007);
    		while(true) {
    			Socket s=ss.accept();//阻塞式，未接收到客户端socket对象会一直等待
    			//为每一个接收到的客户端socket对象开辟一个新的线程去处理
    			new Thread(new UploadTask(s)).start();
    		}
    	}
    
    }

### 第三部分：多线程服务端run( )程序 ###

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.Socket;
    /*
     * 需求：创建一个用于处理客户端SOCKET对象的线程。
     */
    public class UploadTask implements Runnable {
    	private Socket s;
    
    	public UploadTask(Socket s) {
    		super();
    		this.s = s;
    	}
    
    	@Override
    	public void run() {
    		//打印出链接进入服务器的ip信息
    		String ip = s.getInetAddress().getHostAddress();
    		System.out.println(ip + ".....已经连入");
    		//创建存储文件的文件名
    		File dir = new File("F:\\server");
    		if (!dir.exists())
    			dir.mkdirs();
    		File file = new File(dir, ip + ".jpg");
    		//下面的代码是为了避免文件名重复，若文件名重复，则在文件名后加(num),以作区分。
    		int num=0;
    		while(file.exists()) {
    			file=new File(dir,ip+"("+(++num)+")"+".jpg");
    		}
    		FileOutputStream fos = null;
    		try {
    		//接收从客户端发来的数据，并写入指定的文件中
    			InputStream in = s.getInputStream();
    			fos = new FileOutputStream(file);
    			byte[] bufin = new byte[1024];
    			int len = 0;
    			while ((len = in.read(bufin)) != -1) {
    				fos.write(bufin, 0, len);
    			}
    		//反馈给客户端信息，表示图片上传成功
    			OutputStream os = s.getOutputStream();
    			os.write("图片已上传成功！".getBytes());
    		} catch (IOException e) {
    			//此处未作处理
    		} finally {
    			// finally块用于关闭资源
    			try {
    				fos.close();
    			} catch (IOException e) {
    
    				e.printStackTrace();
    			}
    			try {
    				s.close();
    			} catch (IOException e) {
    
    				e.printStackTrace();
    			}
    		}
    
    	}
    
    }