Socket编程模仿上传本地图片,并且响应客户端

短命女 2022-01-06 20:09 176阅读 0赞

服务端:

package com.huan.yu1;
    
    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 ServerSokcetDemo1 implements Runnable {
    
    	private Socket s;
    
    	public ServerSokcetDemo1(Socket s) {
    		super();
    		this.s = s;
    	}
    
    	/**
    	 * 定义一个线程
    	 */
    
    	@Override
    	public void run() {
    		// 读取客户端的数据进行上传
    		int count = 1;
    		String ip = s.getInetAddress().getHostAddress();
    		System.err.println(ip + "---connect");
    		// 读取客户端发过来得数据
    		try {
    			InputStream is = s.getInputStream();
    			// 定义目的地
    			byte[] b = new byte[1024 * 4];
    			File file = new File("F://ppp");
    			if (!file.exists()) {
    				file.mkdir();
    			}
    			// 重新定义上传文件的路径和名称
    			File child = new File(file, ip + "00" + count + ".jpg");
    			// 如果存在就重新创建
    			while (child.exists()) {
    				child = new File(file, ip + "00" + count + ".jpg");
    			}
    			FileOutputStream fos = new FileOutputStream(child);
    			int len = 0;
    			while ((len = is.read(b)) != -1) {
    				fos.write(b);
    			}
    
    			OutputStream out = s.getOutputStream();
    
    			out.write("上传成功".getBytes());
    			fos.close();
    			s.close();
    			
    
    		} catch (IOException e) {
    			e.printStackTrace();
    		}
    
    	}
    
    	
    	/**
    	 * 客户端上传数据
    	 * 
    	 * @throws IOException
    	 */
    	@SuppressWarnings("resource")
    	public static void main(String[] args) throws IOException {
    		ServerSocket ss = new ServerSocket(10666);
    		while (true) {
    			Socket s = ss.accept();
    			new Thread(new ServerSokcetDemo1(s)).start();;
    
    		}
    
    	}
    
    }

客户端:

package com.huan.yu1;
    
    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 ClientSocket {
    
    	/**
    	 * 客户端
    	 * 
    	 * @throws IOException
    	 * @throws UnknownHostException
    	 */
    	@SuppressWarnings("resource")
    	public static void main(String[] args) throws UnknownHostException, IOException {
    		// 请求服务,并且要将数据上传上去
    		//本地ip
    		Socket s = new Socket("192.168.86.1", 10666);
    		FileInputStream fis = new FileInputStream("F://picture//1920.png");
    		OutputStream os = s.getOutputStream();
    		byte[] b = new byte[1024 * 4];
    
    		int len = 0;
    		while ((len = fis.read(b)) != -1) {
    			os.write(b);
    		}
    		// 告诉服务器读取完毕
    		s.shutdownOutput();
    		// 读取服务器的数据
    		InputStream is = s.getInputStream();
    		byte[] b1 = new byte[1024 ];
    		int len1=is.read(b1);
    		String str=new String(b1,0,len1);
    		System.err.println(str);
    		
    		fis.close();
    		s.close();
    		is.close();
    		
    		
    	}
    
    }

转载于:https://www.cnblogs.com/liushisaonian/p/8595285.html