当前位置：文档之家 › Java Socket编程 文件传输(客户端从服务器下载一个文件)

Java Socket编程 文件传输(客户端从服务器下载一个文件)

  • 格式：docx
  • 大小：28.20 KB
  • 文档页数：7

用于客户端从服务器端下载文件服务器（Server）[java]view plain copy1.package com.socket.sample;2.3.import java.io.BufferedInputStream;4.import java.io.DataInputStream;5.import java.io.DataOutputStream;6.import java.io.File;7.import java.io.FileInputStream;8.import .ServerSocket;9.import .Socket;10.11.public class ServerTest {12.int port = 8821;13.14.void start() {15. Socket s = null;16.try {17. ServerSocket ss = new ServerSocket(port);18.while (true) {19.// 选择进行传输的文件20. String filePath = "D:\\lib.rar";21. File fi = new File(filePath);22.23. System.out.println("文件长度:" + (int) fi.length());24.25.// public Socket accept() throws26.// IOException侦听并接受到此套接字的连接。

此方法在进行连接之前一直阻塞。

27.28. s = ss.accept();29. System.out.println("建立socket链接");30. DataInputStream dis = new DataInputStream(31.new BufferedInputStream(s.getInputStream()));32. dis.readByte();33.34. DataInputStream fis = new DataInputStream(35.new BufferedInputStream(new FileInputStream(filePath)));36. DataOutputStream ps = new DataOutputStream(s.getOutputStream());37.// 将文件名及长度传给客户端。

这里要真正适用所有平台，例如中文名的处理，还需要加工，具体可以参见Think In Java38.// 4th里有现成的代码。

39. ps.writeUTF(fi.getName());40. ps.flush();41. ps.writeLong((long) fi.length());42. ps.flush();43.44.int bufferSize = 8192;45.byte[] buf = new byte[bufferSize];46.47.while (true) {48.int read = 0;49.if (fis != null) {50. read = fis.read(buf);51.// 从包含的输入流中读取一定数量的字节，并将它们存储到缓冲区数组 b52.// 中。

以整数形式返回实际读取的字节数。

在输入数据可用、检测到文件末尾 (end of file)53.// 或抛出异常之前，此方法将一直阻塞。

54. }55.56.if (read == -1) {57.break;58. }59. ps.write(buf, 0, read);60. }61. ps.flush();62.// 注意关闭socket链接哦，不然客户端会等待server的数据过来，63.// 直到socket超时，导致数据不完整。

64. fis.close();65. s.close();66. System.out.println("文件传输完成");67. }68.69. } catch (Exception e) {70. e.printStackTrace();71. }72. }73.74.public static void main(String arg[]) {75.new ServerTest().start();76. }77.}客户端工具（SocketTool）[java]view plain copy1.package com.socket.sample;2.3.import java.io.BufferedInputStream;4.import java.io.DataInputStream;5.import java.io.DataOutputStream;6.import .Socket;7.8.public class ClientSocket {9.private String ip;10.11.private int port;12.13.private Socket socket = null;14.15. DataOutputStream out = null;16.17. DataInputStream getMessageStream = null;18.19.public ClientSocket(String ip, int port) {20.this.ip = ip;21.this.port = port;22. }23.24./** */25./**26. * 创建socket连接27. *28. * @throws Exception29. * exception30. */31.public void CreateConnection() throws Exception {32.try {33. socket = new Socket(ip, port);34. } catch (Exception e) {35. e.printStackTrace();36.if (socket != null)37. socket.close();38.throw e;40. }41. }42.43.public void sendMessage(String sendMessage) throws Exception {44.try {45. out = new DataOutputStream(socket.getOutputStream());46.if (sendMessage.equals("Windows")) {47. out.writeByte(0x1);48. out.flush();49.return;50. }51.if (sendMessage.equals("Unix")) {52. out.writeByte(0x2);53. out.flush();54.return;55. }56.if (sendMessage.equals("Linux")) {57. out.writeByte(0x3);58. out.flush();59. } else {60. out.writeUTF(sendMessage);61. out.flush();62. }63. } catch (Exception e) {64. e.printStackTrace();65.if (out != null)66. out.close();67.throw e;68. } finally {69. }70. }71.72.public DataInputStream getMessageStream() throws Exception {73.try {74. getMessageStream = new DataInputStream(new BufferedInputStream(75. socket.getInputStream()));76.return getMessageStream;77. } catch (Exception e) {78. e.printStackTrace();79.if (getMessageStream != null)80. getMessageStream.close();81.throw e;83. }84. }85.86.public void shutDownConnection() {87.try {88.if (out != null)89. out.close();90.if (getMessageStream != null)91. getMessageStream.close();92.if (socket != null)93. socket.close();94. } catch (Exception e) {95.96. }97. }98.}客户端（Client）[java]view plain copy1.package com.socket.sample;2.3.import java.io.BufferedOutputStream;4.import java.io.DataInputStream;5.import java.io.DataOutputStream;6.import java.io.FileOutputStream;7.8.public class ClientTest {9.private ClientSocket cs = null;10.11.private String ip = "localhost";// 设置成服务器IP12.13.private int port = 8821;14.15.private String sendMessage = "Windows";16.17.public ClientTest() {18.try {19.if (createConnection()) {20. sendMessage();21. getMessage();22. }23.24. } catch (Exception ex) {25. ex.printStackTrace();26. }27. }28.29.private boolean createConnection() {30. cs = new ClientSocket(ip, port);31.try {32. cs.CreateConnection();33. System.out.print("连接服务器成功!" + "\n");34.return true;35. } catch (Exception e) {36. System.out.print("连接服务器失败!" + "\n");37.return false;38. }39.40. }41.42.private void sendMessage() {43.if (cs == null)44.return;45.try {46. cs.sendMessage(sendMessage);47. } catch (Exception e) {48. System.out.print("发送消息失败!" + "\n");49. }50. }51.52.private void getMessage() {53.if (cs == null)54.return;55. DataInputStream inputStream = null;56.try {57. inputStream = cs.getMessageStream();58. } catch (Exception e) {59. System.out.print("接收消息缓存错误\n");60.return;61. }62.63.try {64.// 本地保存路径，文件名会自动从服务器端继承而来。

合集下载

通过 Socket 发送和接收文件

通过 Socket 发送和接收文件

这是一个简单的包含发送端和接收端的例子。

发送端向接收端发送文件名和文件内容，接收端将收到的文件保存在磁盘上。

接收端可以同时接收多个发送端传来的文件，但没有处理文件同名的情况。

这个例子中设计了一个简单的协议。

发送的内容是这样的：文件名长度（4字节）—文件名—文件内容长度（4字节）—文件内容。

接收端也按照这个结构进行解析。

建议先看Client 类，再看Server 类。

view plaincopy to clipboardprint?import java.io.*;import .ServerSocket;import .Socket;/*** 简单的文件发送与接收示例*/public class FileTrasmission {//程序入口public static void main(String[] args) throws Exception {int port = 7788;new Server(port, "c:\\save\\").start();new Client().sendFile("127.0.0.1", port, "c:\\迷失在康熙末年.txt");}}/*** 接收端。

可同时接收多个发送端发来的文件。

但如果发来的文件是同名的话那就乱了。

*/class Server {private int listenPort;private String savePath;/*** 构造方法** @param listenPort 侦听端口* @param savePath 接收的文件要保存的路径** @throws IOException 如果创建保存路径失败Server(int listenPort, String savePath) throws IOException { this.listenPort = listenPort;this.savePath = savePath;File file = new File(savePath);if (!file.exists() && !file.mkdirs()) {throw new IOException("无法创建文件夹" + savePath);}}// 开始侦听public void start() {new ListenThread().start();}// 网上抄来的，将字节转成int。

用Socket编程实现FTP

用Socket编程实现FTP

6、多路复用——select() 功能：用来检测一个或多个套接字状态。
格式：int PASCAL FAR select(int nfds,fd_set FAR * readfds,fd_set FAR * writefds, fd_set FAR * exceptfds,const struct timeval FAR * timeout); 参数：readfds:指向要做读检测的指针 writefds:指向要做写检测的指针 exceptfds:指向要检测是否出错的指针 timeout:最大等待时间
连接管理：
数据连接有 3 大用途： （1） 从客户向服务器发送一个文件 （2） 从服务器向客户发送一个文件 （3） 从服务器向客户发送文件或目录列表。
每一个数据连接对传输一个文件或目录序列都要建立一个新的连接。 （1） 客户发出命令要求建立数据连接 （2） 客户在客户主机上未数据连接选择一个固定的端口号 （3） 客户使用 PORT 命令从控制连接上把端口号发给服务器。 （4） 服务器在控制连接上接收端口号，并向客户端主机上的端口发出主动打开，服务器的数据连接 使用端口 21。
服务器端程序则持续的监听网络。当接受到客户端的 Socket ，服务器程序提供相应的服务。网络通 信模块使用 POP3 控件来实现客户端与服务器的信息交流。
函数功能和流程如下：（1）首先创建一个 CFtpclient 的类的实例。 （2）用 LogOnToServer()函数登录到指定的 FTP 服务器，允许非匿名用户和匿名两种登录方式，默认 的端口为 21. （3）使用 MoveFile()函数来上传下载数据文件，其中第一个参数是本地地址，第二个参数是远程地 址，文件传输选用二进制模式。注意，文件传输使用同步模式。 （4）可以使用 Ftpcommand()函数来执行 FTP 指令，包括常用的“CWD/home/mydir”来改变远程服务 器上的地址，并处理服务器返回的应答。当这种方式不适用的时候，还可以使用 WriteStr()函数和 ReadStr() 函数向远程服务器发送指令，并自己解释返回的应答。 （5）当所有的文件传输完成之后，使用 LogOffServer 函数来断开与远程服务器的连接。
socket传输文件的原理

socket传输文件的原理

socket传输文件的原理
文件传输是计算机网络中的一项基本功能，它允许在网络上的不同计算机之间共享和传输文件。

Socket是实现文件传输的一种常用方式，其原理如下：
1. 建立连接：在进行文件传输之前，需要在发送方和接收方之间建立连接。

这通常通过TCP/IP 协议实现，使用Socket进行连接的建立。

一旦连接建立成功，发送方和接收方就可以通过该连接进行数据传输。

2. 文件分割：由于文件通常较大，不适合一次性传输，因此需要将文件分割成较小的数据块。

这些数据块可以按照一定的顺序进行编号，以便于接收方重新组合成完整的文件。

3. 发送数据：发送方通过Socket将分割好的数据块逐个发送给接收方。

在发送数据时，需要按照一定的协议进行数据的封装，例如添加文件名、数据块大小等信息。

4. 接收数据：接收方通过Socket接收到数据后，需要按照发送方的协议对数据进行解析和处理。

接收方会将收到的数据块进行缓存，以便后续重新组合成完整的文件。

5. 确认机制：为了确保文件传输的完整性和正确性，发送方和接收方之间需要建立一种确认机制。

例如，发送方可以发送一个数据包的编号给接收方，接收方在收到数据包后回复一个确认信号给发送方，表示该数据包已经成功接收。

如果发送方在一定时间内没有收到确认信号，则会重新发送数据包，以确保数据的可靠传输。

6. 关闭连接：当文件传输完成后，发送方和接收方之间的连接会被关闭。

这可以通过Socket 的关闭函数实现，释放网络资源。

通过以上步骤，使用Socket可以实现文件的传输。

在实际应用中，不同的文件传输协议可能会有一些差异，但基本原理是相同的。

Java文件上传与文件下载实现方法详解

Java文件上传与文件下载实现方法详解

Java⽂件上传与⽂件下载实现⽅法详解本⽂实例讲述了Java⽂件上传与⽂件下载实现⽅法。

分享给⼤家供⼤家参考，具体如下：Java⽂件上传数据上传是客户端向服务器端上传数据，客户端向服务器发送的所有请求都属于数据上传。

⽂件上传是数据上传的⼀种特例，指客户端向服务器上传⽂件。

即将保存在客户端的⽂件上传⼀个副本到服务器，并保存在服务器中。

1、上传表单要求⽂件上传要求客户端提交特殊的请求——multipart请求，即包含多部分数据的请求。

必须将<form/>标签的enctype属性值设为“multipart/form-data”,enctype表⽰encodingType，及编码类型由于客户端上传⽂件的⼤⼩是不确定的，所以http协议规定，⽂件上传的数据要存放于请求正⽂中，不能出现在URL地址栏内。

也就是说，想要上传⽂件必须提交POST请求。

表单中要有<input type="file" />标签注意：multipart/form-data请求与普通请求不同2、下载⽂件上传jar包并查看官⽅⽂档选择Commons中的FileUpload项⽬，并下载jar包和源⽂件查看FileUpload的⼯作⽅式查看FileUpload项⽬的API3、使⽤第三⽅jar包上传⽂件public class RegisterServlet extends HttpServlet {private static final long serialVersionUID = 1L;public RegisterServlet() {super();}protected void doGet(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {response.getWriter().append("Served at: ").append(request.getContextPath());}protected void doPost(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {//第⼀步、判断请求是否为multipart请求if(!ServletFileUpload.isMultipartContent(request)) {throw new RuntimeException("当前请求只⽀持⽂件上传");}try {//第⼆步、创建FileItem⼯⼚DiskFileItemFactory factory = new DiskFileItemFactory();//设置临时⽂件存储⽬录String path = this.getServletContext().getRealPath("/Temp");File temp = new File(path);factory.setRepository(temp);//单位：字节。