网站建设规划论文,wordpress 增加js,广州网站优化公司咨询,室内装修设计自学教材客户端 import java.io.*;
import java.net.Socket;/*** ### 作业3#xff1a;* 完成文件上传案例学习* - 案例需求* 客户端#xff1a;数据来自于本地文件#xff0c;接收服务器反馈* 服务器#xff1a;接收到的数据写入本地文件#xff0c;给出反馈* - 案例分析* - 创建…客户端 import java.io.*;
import java.net.Socket;/*** ### 作业3* 完成文件上传案例学习* - 案例需求* 客户端数据来自于本地文件接收服务器反馈* 服务器接收到的数据写入本地文件给出反馈* - 案例分析* - 创建客户端对象创建输入流对象指向文件每读一次数据就给服务器输出一次数据输出结束后使用shutdownOutput()方法告知服务端传输结束* - 创建服务器对象创建输出流对象指向文件每接受一次数据就使用输出流输出到文件中传输结束后。使用输出流给客户端反馈信息* - 客户端接受服务端的回馈信息*/
public class TcpSocket {public static void main(String[] args) throws IOException {Socket socket new Socket(127.0.0.1, 10086);BufferedInputStream buffInput new BufferedInputStream(new FileInputStream(C:\\Users\\Administrator\\Desktop\\Demo小案例\\共享文件夹\\IEDA背景图片\\img\\1.png));BufferedOutputStream buffOut new BufferedOutputStream(socket.getOutputStream());byte[] bytes new byte[1024];int length;while ((length buffInput.read(bytes)) ! -1) {buffOut.write(bytes, 0, length);buffOut.flush();}buffInput.close();socket.shutdownOutput();//读取反馈BufferedReader reader new BufferedReader(new InputStreamReader(socket.getInputStream()));String line;while ((line reader.readLine()) ! null) {System.out.println(line);}reader.close();socket.close();}
}
服务端 import java.io.*; import java.net.ServerSocket; import java.net.Socket; import java.util.UUID; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.Executors; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit;
/** author silence */ public class TcpServerSocket { public static void main(String[] args) throws IOException { //监听端口 ServerSocket socket new ServerSocket(10086); //创建线程池 ThreadPoolExecutor thread new ThreadPoolExecutor( 5, 10, 60, TimeUnit.SECONDS, new ArrayBlockingQueue(5), Executors.defaultThreadFactory(), new ThreadPoolExecutor.AbortPolicy() ); while (true) {//获得与客户端的连接对象Socket accept socket.accept();//将连接对象交给线程处理thread.submit(() - {ioFile(accept);});}} /** param accept 与客户端的连接对象 */ private static void success(Socket accept) { //字符输出 BufferedWriter writer null; try { //通过于客户端的连接获得网络连接对象获得字节输出流 OutputStream out accept.getOutputStream(); //通过转换流转换到字符输出流 writer new BufferedWriter(new OutputStreamWriter(out)); writer.write(“服务器接收文件成功”); writer.flush(); } catch (IOException e) { e.printStackTrace(); } finally { if (writer ! null) { try { writer.close(); } catch (IOException e) { e.printStackTrace(); } } try { accept.close(); } catch (IOException e) { e.printStackTrace(); } } } /** 读取客户端的文件信息写到本地param accept 与客户端的连接对象 */ private static void ioFile(Socket accept) { //字节输入流 BufferedInputStream input null; //字节输出流 BufferedOutputStream out null; try { //字节输入流 input new BufferedInputStream(accept.getInputStream()); //字节输出流 out new BufferedOutputStream(new FileOutputStream(“operate/src/operate424/operate/operate3/” UUID.randomUUID() “.png”)); //每次读取的字节数组 byte[] bytes new byte[1024]; //每次读取的字节个数 int length; while ((length input.read(bytes)) ! -1) { out.write(bytes, 0, length); } System.out.println(“服务器成功接收到一个文件”); //给客户端写成功信息 success(accept); } catch (IOException e) { e.printStackTrace(); } finally { if (out ! null) { try { out.close(); } catch (IOException e) { e.printStackTrace(); } } if (input ! null) { try { input.close(); } catch (IOException e) { e.printStackTrace(); } } } } }
