1 IO流相关知识
1.1 File
表示文件或者文件夹，被表示的文件或者文件夹不一定存在,主要就是代表路劲
构造方法:new File("路径")
1.2 IO:读写文件中的数据
把自己当成内存，看硬盘的方向,硬盘一般是读和写,那么硬盘中的数据到内存就是输入就是读，内存到硬盘中就是输出就是写
使用场景:涉及到纯文本文件用字符流，剩下的全部用字节流
转换流：读对象 就是读字节出为字符 写对象就是将字符流写出为字节流
2 多线程相关知识
2.1 多线程实现的三种方式
继承Thread，实现Runnable，实现Callable
2.2 创建线程池的各种方式
Executors的newCachedThreadPool缓存线程池,newFixedThreadPool固定长度线程池，newScheduleThreadPool计时任务线程池，单一线程池等等，也可以直接创建线程池底层实现ThreadPoolExecutor更加具体的实现一个线程池的创建
3 网络编程相关知识
3.1 TCP传输
客户端:Socket创建对象传入host和端口，之后对象获得输出流继续输出，写出相关数据，关闭资源
接收端：通过ServerSocket创建对象传入接受数据端口号，之后对象调用接受方法accept返回Socket对象，之后就是就收数据，关闭资源
如果交换数据就要不断的重复三次握手，就是不断获得输出流，等到输出流的过程。
4 文件上传的服务器端代码
1.服务器创建,传入端口
2.创建线程池等待用来控制线程数
3.服务器接收客户端请求,死循环因为要一直接收
4.通过线程池提交运行代码
5.创建输入输出流进行交互
6.释放资源
import java.io.*; import java.net.ServerSocket; import java.net.Socket; import java.util.UUID; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class Server { public static void main(String[] args)throws Exception { ServerSocket serverSocket = new ServerSocket(8888); ExecutorService executorService = Executors.newFixedThreadPool(10); while (true) { Socket socket = serverSocket.accept(); executorService.submit(() -> { try { System.out.println(socket.getInetAddress().getHostAddress()+"开始上传"); /*3.创建输入流，指向客户端*/ InputStream is = socket.getInputStream(); /*4.创建输出流，指向文件*/ FileOutputStream fos = new FileOutputStream("socket/"+ UUID.randomUUID()); byte[] data = new byte[1024]; int len; while((len=is.read(data)) != -1){ fos.write(data,0,len); } System.out.println(socket.getInetAddress().getHostAddress()+"上传完毕"); /*5.创建输出流，写"上传成功" 给客户端*/ BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())); writer.write("上传成功"); writer.newLine(); writer.flush(); fos.close(); socket.close(); } catch (Exception e) { e.printStackTrace(); } }); } } }
5 文件上传的客户端代码
这里是一个客户端,如果多个客户端可以看出效果,满足多线程.
1.创建客户端Socket对象进行建立连接
2.之后创建输入输出流进行服务器交互
3.释放资源
import java.io.BufferedReader; import java.io.FileInputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.net.Socket; public class Client { public static void main(String[] args) throws Exception{ Socket socket = new Socket("localhost", 8888); /*1.创建输入流，读取本地文件*/ FileInputStream fis = new FileInputStream("socket/socket.iml"); /*2.创建输出流，指向的是服务器*/ OutputStream os = socket.getOutputStream(); byte[] data = new byte[1024];//用于存储读取到的数据 int len;//用于记录读取了几个数据 while((len=fis.read(data)) != -1){ os.write(data,0,len); } //写入结束符 socket.shutdownOutput(); /*6.创建输入流，读取服务器端返回的消息*/ BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream())); String message = reader.readLine(); System.out.println(message); fis.close(); socket.close(); } }
6 运行效果
