Socket的简单认识
Socket是一种面向连接的通信协议,Socket应用程序是一种C/S(Client端/Server端)结构的应用程序
Socket是两台机器间通信的端点。 Socket是连接运行在网络上的两个程序间的双向通讯端点。
Socket通信原理
- Server服务端的输入流相当于Client客户端的输出流
- Server服务端的输出流相当于Client客户端的输入流
注意
- 文件传输使用字节流(Steam)
- 使用
DataOutputStream
,DataOutputStream可以传java的基本类型和流
代码
Server.java
package csmode2;import java.io.IOException;import java.net.ServerSocket;import java.net.Socket;/** * @author StarsOne * @date Create in 2019-4-14 0014 10:53:58 * @description */class Server { public static void main(String[] args) { try (ServerSocket serverSocket = new ServerSocket(9090)){ System.out.println("服务器已启动..."); while (true) { System.out.println("等待接收文件"); //调用了accept方法之后,会一直处于等待接受文件的状态 Socket socket = serverSocket.accept();//接收客户端传来的数据 //交给后台线程处理 new AcceptThread(socket.getInputStream()).start(); } } catch (IOException e) { e.printStackTrace(); } }}
AcceptThread.java
package csmode2;import java.io.DataInputStream;import java.io.File;import java.io.FileOutputStream;import java.io.IOException;import java.io.InputStream;/** * @author StarsOne * @date Create in 2019/4/15 0015 14:17 * @description */class AcceptThread extends Thread { private InputStream inputStream; public AcceptThread(InputStream inputStream) { this.inputStream = inputStream; } @Override public void run() { try { //使用DataInputStream包装输入流 DataInputStream dataInputStream = new DataInputStream(inputStream); String fileName = dataInputStream.readUTF(); System.out.println(fileName);//在控制台显示文件名 //往某个位置写入文件 FileOutputStream fileOutputStream = new FileOutputStream("Q:\\MY" + File.separator + fileName); int c = -1; while ((c = dataInputStream.read()) != -1) { fileOutputStream.write(c); fileOutputStream.flush(); } System.out.println("文件上传成功!"); } catch (IOException e) { e.printStackTrace(); } }}
Client.java
package csmode2;import java.io.*;import java.net.Socket;/** * @author StarsOne * @date Create in 2019-4-14 0014 10:53:49 * @description */class Client { public static void main(String[] args) { // File[] files = new File("E:\\wan\\testfile").listFiles(); //如果是多个文件,只需要把文件放入一个list或者数组中,使用for循环把数组的文件全部上传到服务器 //上传的文件 File file = new File("R:\\动漫图片\\test.jpg"); try(Socket socket = new Socket("localhost", 9090)) { OutputStream outputStream = socket.getOutputStream(); //使用DataOutputStream DataOutputStream dataOutputStream = new DataOutputStream(outputStream); //向服务器端传文件名 dataOutputStream.writeUTF(file.getName()); dataOutputStream.flush();//刷新流,传输到服务端 //向服务器端传文件,通过字节流 //字节流先读取硬盘文件 BufferedInputStream bufferedInputStream = new BufferedInputStream(new FileInputStream(file)); int c = -1; while ((c=bufferedInputStream.read())!=-1) { //将读取的文件以字节方式写入DataOutputStream,之后传输到服务端 //这里也可以使用byte[]数据进行读取和写入 dataOutputStream.write(c); dataOutputStream.flush(); } } catch (IOException e) { e.printStackTrace(); } }}