阅读量:3
要使用Java Socket传输大文件,可以使用以下步骤:
创建一个ServerSocket对象来监听某个端口号,等待客户端连接。
客户端使用Socket对象连接到服务器的IP地址和端口号。
服务器端接受客户端的连接请求,使用
accept()
方法返回一个Socket对象,用于与客户端通信。客户端通过Socket对象获取InputStream和OutputStream,用于读取和发送数据。
服务器端也通过Socket对象获取InputStream和OutputStream,用于读取和发送数据。
服务器端从InputStream中读取文件内容,并将内容写入OutputStream发送给客户端。
客户端从InputStream中读取服务器发送的文件内容,并将内容写入文件。
反复进行步骤6和7,直到文件传输完成。
关闭所有的流和Socket连接。
以下是一个简单的示例代码:
服务器端代码:
import java.io.*; import java.net.*; public class Server { public static void main(String[] args) throws IOException { ServerSocket serverSocket = new ServerSocket(8888); System.out.println("等待客户端连接..."); Socket socket = serverSocket.accept(); System.out.println("客户端已连接"); InputStream inputStream = socket.getInputStream(); OutputStream outputStream = new FileOutputStream("output.txt"); byte[] buffer = new byte[1024]; int length; while ((length = inputStream.read(buffer)) > 0) { outputStream.write(buffer, 0, length); } System.out.println("文件传输完成"); outputStream.close(); inputStream.close(); socket.close(); serverSocket.close(); } }
客户端代码:
import java.io.*; import java.net.*; public class Client { public static void main(String[] args) throws IOException { Socket socket = new Socket("localhost", 8888); OutputStream outputStream = socket.getOutputStream(); InputStream inputStream = new FileInputStream("input.txt"); byte[] buffer = new byte[1024]; int length; while ((length = inputStream.read(buffer)) > 0) { outputStream.write(buffer, 0, length); } System.out.println("文件传输完成"); inputStream.close(); outputStream.close(); socket.close(); } }
在这个示例中,服务器端将客户端发送的文件内容写入到名为"output.txt"的文件中。客户端从名为"input.txt"的文件中读取文件内容,并发送给服务器端。
注意:这个示例代码只能用于传输小文件,如果要传输大文件,可以考虑使用多线程或者断点续传等技术来优化。