`
panxq0809
  • 浏览: 296822 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论

Socket 发送和接收文件例子

    博客分类:
  • java
阅读更多

这是一个简单的包含发送端和接收端的例子。发送端向接收端发送文件名和文件内容,接收端将收到的文件保存在磁盘上。接收端可以同时接收多个发送端传来的文件,但没有处理文件同名的情况。

  这个例子中设计了一个简单的协议。发送的内容是这样的:

  文件名长度(4字节)—文件名—文件内容长度(4字节)—文件内容。

  接收端也按照这个结构进行解析。建议先看 Client 类,再看 Server 类。

 

import java.io.*;
import java.net.ServerSocket;   
import java.net.Socket;       
/**  
 * 简单的文件发送与接收示例  
 */  
public class FileTrasmission {
    //程序入口 
    public static void main(String[] args) throws Exception { 
        int port = 5678;   
        new Server(port, "c:\save\").start();   
        new Client().sendFile("127.0.0.1", port, "c:\test.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。b 长度不得小于 4,且只会取前 4 位。   
    public static int b2i(byte[] b) {   
        int value = 0;   
        for (int i = 0; i < 4; i++) {   
            int shift = (4 - 1 - i) * 8;   
            value += (b[i] & 0x000000FF) << shift;   
        }   
        return value;   
    }   

    /**  
     * 侦听线程  
    */  
    private class ListenThread extends Thread {   
   @Override  
        public void run() {   
            try {   
                ServerSocket server = new ServerSocket(listenPort);   
               // 开始循环   
                while (true) {   
                    Socket socket = server.accept();   
                    new HandleThread(socket).start();   
                }   
            } catch (IOException e) {   
                e.printStackTrace();   
            }   
        }   
    }   

    /**  
     * 读取流并保存文件的线程  
     */  
    private class HandleThread extends Thread {      
       private Socket socket;   
        private HandleThread(Socket socket) {   
            this.socket = socket;   
        }   
        @Override  
        public void run() {   
            try {   
                InputStream is = socket.getInputStream();   
                readAndSave(is);   
            } catch (IOException e) {   
                e.printStackTrace();   
            } finally {   
                try {   
                   socket.close();   
                } catch (IOException e) {   
                    // nothing to do   
                }   
            }   
        }   

        // 从流中读取内容并保存   
        private void readAndSave(InputStream is) throws IOException {   
            String filename = getFileName(is);   
            int file_len = readInteger(is);   
            System.out.println("接收文件:" + filename + ",长度:" + file_len);   
            readAndSave0(is, savePath + filename, file_len);   
            System.out.println("文件保存成功(" + file_len + "字节)。");   
        }   
        private void readAndSave0(InputStream is, String path, int file_len) throws IOException {   
            FileOutputStream os = getFileOS(path);   
            readAndWrite(is, os, file_len);   
            os.close();   
        }   
        // 边读边写,直到读取 size 个字节   
        private void readAndWrite(InputStream is, FileOutputStream os, int size) throws IOException {   
            byte[] buffer = new byte[4096];   
            int count = 0;   
            while (count < size) {   
                int n = is.read(buffer);   
                // 这里没有考虑 n = -1 的情况   
                os.write(buffer, 0, n);   
                count += n;   
           }   
        }   
        // 读取文件名   
        private String getFileName(InputStream is) throws IOException {   
            int name_len = readInteger(is);   
            byte[] result = new byte[name_len];   
            is.read(result);   
            return new String(result);   
        }   
        // 读取一个数字   
        private int readInteger(InputStream is) throws IOException {   
            byte[] bytes = new byte[4];   
            is.read(bytes);   
            return b2i(bytes);   
        }

  
        // 创建文件并返回输出流   
        private FileOutputStream getFileOS(String path) throws IOException {   
            File file = new File(path);   
            if (!file.exists()) {   
                file.createNewFile();   
            }   
            return new FileOutputStream(file);   
        }   
    }   
}  

  

/**  
 * 发送端  
 */  
class Client {   

    // 网上抄来的,将 int 转成字节   
    public static byte[] i2b(int i) {   
        return new byte[]{   
                (byte) ((i >> 24) & 0xFF),   
                (byte) ((i >> 16) & 0xFF),   
                (byte) ((i >> 8) & 0xFF),   
                (byte) (i & 0xFF)   
        };   
    }      

    /**  
     * 发送文件。文件大小不能大于 {@link Integer#MAX_VALUE}  
     *  
     * @param hostname 接收端主机名或 IP 地址  
      * @param port     接收端端口号  
     * @param filepath 文件路径  
     *  
     * @throws IOException 如果读取文件或发送失败  
     */  
    public void sendFile(String hostname, int port, String filepath) throws IOException {   
        File file = new File(filepath);   
        FileInputStream is = new FileInputStream(filepath);   
        Socket socket = new Socket(hostname, port);           OutputStream os = socket.getOutputStream();   
        try {   
            int length = (int) file.length();   
            System.out.println("发送文件:" + file.getName() + ",长度:" + length);   

            // 发送文件名和文件内容   
            writeFileName(file, os);   
           writeFileContent(is, os, length);   
        } finally {   
            os.close();   
            is.close();   
        }   
    }   

    // 输出文件内容   
    private void writeFileContent(InputStream is, OutputStream os, int length) throws IOException {   
        // 输出文件长度   
        os.write(i2b(length));   
        // 输出文件内容   
        byte[] buffer = new byte[4096];   
        int size;   
        while ((size = is.read(buffer)) != -1) {   
            os.write(buffer, 0, size);   
        }   
    }   

    // 输出文件名   
    private void writeFileName(File file, OutputStream os) throws IOException {   
        byte[] fn_bytes = file.getName().getBytes();   
        os.write(i2b(fn_bytes.length));         // 输出文件名长度   
        os.write(fn_bytes);    // 输出文件名   
    }   
}

 

分享到:
评论

相关推荐

    VB使用Socket控件发送接收文件的例子

    在VB(Visual Basic)编程中,Socket控件是...这个例子就是一个基础的演示,帮助开发者理解如何利用Socket控件在VB中实现文件发送和接收功能。在实际应用中,可能还需要考虑错误处理、多线程、断点续传等更复杂的场景。

    C#Socket文件传输简单例子(将文件名和文件同时传输)

    本示例主要探讨如何使用C#的Socket类进行文件的传输,包括文件名和文件内容的同步发送与接收。这里我们将详细讲解实现这一功能的关键步骤和相关知识点。 首先,了解Socket的工作原理。Socket是TCP/IP协议栈的一部分...

    利用socket连续发送与连续接收数据

    在IT领域,网络编程是不可或缺的一部分,而Socket编程则是实现网络...连续发送和接收数据的场景在许多应用中都很常见,比如文件传输、在线聊天等。通过理解和掌握Socket编程,开发者可以构建出高效且可靠的网络应用。

    关于C语言 socket数据 文件传输的例子

    在IT领域,网络编程是不可或缺的一...这个例子提供了从发送端到接收端的文件传输实现,对于理解C语言socket编程和网络文件传输的原理非常有帮助。通过实践和调试这样的代码,可以深入理解和掌握网络编程的核心技术。

    VC Socket发送与接收通讯小程序

    总之,"VC Socket发送与接收通讯小程序"是一个基础但实用的网络通信工具,它展示了如何在VC环境下利用MFC的CSocket类进行TCP通信,是学习网络编程和Socket技术的好例子。通过深入理解这个程序,开发者可以更好地掌握...

    C#语言Socket传文件例子

    这个“C#语言Socket传文件例子”提供了学习Socket通信和文件传输的实践平台。通过理解和实践这个例子,开发者可以掌握Socket编程的基本技巧,为进一步开发复杂的网络应用打下基础。在实际项目中,还可以考虑增加断点...

    delphi使用socket通讯例子-文件传输

    Delphi是一款强大的Object Pascal编程环境,它提供了丰富的工具和库来实现网络通信,其中之一就是通过Socket接口。本文将深入探讨如何在Delphi中使用Socket进行文件传输。 首先,Socket是一种在不同计算机之间建立...

    通过Socket传送文件的例子

    本文将基于给定的标题“通过Socket传送文件的例子”和描述来深入探讨Socket编程以及如何利用它进行文件传输。 首先,Socket是网络编程中的一个接口,它允许应用程序通过网络发送和接收数据。在Java中,Socket类提供...

    CSocket发送接受长文件的例子

    在`www.pudn.com.txt`和"CSocket发送接受长文件的例子"这两个文件中,可能包含了详细的代码实现和步骤解释。阅读这些文件将有助于你更好地理解和实现这个过程。 需要注意的是,在实际应用中,还需要考虑错误处理、...

    C#使用Socket发送和接收TCP数据

    - 一旦连接建立,就可以通过Socket的Send和Receive方法发送和接收数据。 以下是简单的C#代码示例: **服务器端(Listen.cs)** ```csharp using System; using System.Net; using System.Net.Sockets; class ...

    C# Socket 通信接收和发送例子

    本篇文章将详细讲解C#中Socket通信的基本概念、使用方法,以及如何通过示例实现数据的接收和发送。 首先,Socket在计算机网络中扮演着客户端与服务器端之间数据传输的桥梁角色。它基于TCP/IP协议,为应用程序提供...

    socket传输文件例子demo

    总之,这个"socket传输文件例子demo"是一个实践性的学习资源,可以帮助开发者深入理解如何在VC++环境中利用Socket进行文件传输,同时也可以作为开发自己网络通信软件的基础。通过阅读和分析源代码,我们可以学习到...

    一个使用socket实现文件传输的例子

    然后,我们将文件内容分割成多个数据块,每个块通过Socket发送到服务器。服务器接收到数据块后,将其写入目标文件,直到接收完整个文件。这个过程需要确保数据的完整性和正确性,通常可以通过校验和或序列号进行验证...

    socket通信允许发送文字、图片、文件,可指定用户

    我们可以先读取文件到字节数组,然后根据文件大小分块,每一块使用Socket发送。在接收端,接收每一块数据并写入到临时文件,直到所有数据接收完毕,再将临时文件合并为原始文件。 4. **指定用户通信**: 在Socket...

    VC socket传送文件的例子(转载)

    标题"VC socket传送文件的例子(转载)"揭示了我们将讨论如何使用Visual C++(简称VC)通过Socket接口来实现文件的发送与接收。 首先,Socket是网络编程的基本组件,它提供了进程间通信(IPC)的接口,使得运行在...

    Socket编程例子

    客户端和服务器都使用`socket()`创建Socket,然后通过`sendto()`和`recvfrom()`函数直接发送和接收数据。由于UDP是无连接的,所以无需`connect()`、`bind()`和`listen()`操作。 四、TestSocket示例分析 在提供的...

    Java基于Socket文件传输示例:服务器端和客户端

    ` 将文件名和长度以特定格式发送给客户端,以便客户端知道要接收什么文件以及预期的大小。 6. **传输文件内容**:通过循环读取文件内容,然后写入到`DataOutputStream`,如`ps.write(buf, 0, read);`,每次读取一定...

    springboot实现websocket发送和接收消息

    本篇文章将深入探讨如何使用Spring Boot来实现WebSocket的发送和接收消息功能。 首先,我们需要在Spring Boot项目中添加WebSocket相关的依赖。Spring Boot本身并不直接包含WebSocket的支持,但可以通过添加`spring-...

Global site tag (gtag.js) - Google Analytics