这是一个简单的包含发送端和接收端的例子。发送端向接收端发送文件名和文件内容,接收端将收到的文件保存在磁盘上。接收端可以同时接收多个发送端传来的文件,但没有处理文件同名的情况。
这个例子中设计了一个简单的协议。发送的内容是这样的:
文件名长度(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(Visual Basic)编程中,Socket控件是...这个例子就是一个基础的演示,帮助开发者理解如何利用Socket控件在VB中实现文件发送和接收功能。在实际应用中,可能还需要考虑错误处理、多线程、断点续传等更复杂的场景。
本示例主要探讨如何使用C#的Socket类进行文件的传输,包括文件名和文件内容的同步发送与接收。这里我们将详细讲解实现这一功能的关键步骤和相关知识点。 首先,了解Socket的工作原理。Socket是TCP/IP协议栈的一部分...
在IT领域,网络编程是不可或缺的一部分,而Socket编程则是实现网络...连续发送和接收数据的场景在许多应用中都很常见,比如文件传输、在线聊天等。通过理解和掌握Socket编程,开发者可以构建出高效且可靠的网络应用。
在IT领域,网络编程是不可或缺的一...这个例子提供了从发送端到接收端的文件传输实现,对于理解C语言socket编程和网络文件传输的原理非常有帮助。通过实践和调试这样的代码,可以深入理解和掌握网络编程的核心技术。
总之,"VC Socket发送与接收通讯小程序"是一个基础但实用的网络通信工具,它展示了如何在VC环境下利用MFC的CSocket类进行TCP通信,是学习网络编程和Socket技术的好例子。通过深入理解这个程序,开发者可以更好地掌握...
这个“C#语言Socket传文件例子”提供了学习Socket通信和文件传输的实践平台。通过理解和实践这个例子,开发者可以掌握Socket编程的基本技巧,为进一步开发复杂的网络应用打下基础。在实际项目中,还可以考虑增加断点...
Delphi是一款强大的Object Pascal编程环境,它提供了丰富的工具和库来实现网络通信,其中之一就是通过Socket接口。本文将深入探讨如何在Delphi中使用Socket进行文件传输。 首先,Socket是一种在不同计算机之间建立...
本文将基于给定的标题“通过Socket传送文件的例子”和描述来深入探讨Socket编程以及如何利用它进行文件传输。 首先,Socket是网络编程中的一个接口,它允许应用程序通过网络发送和接收数据。在Java中,Socket类提供...
在`www.pudn.com.txt`和"CSocket发送接受长文件的例子"这两个文件中,可能包含了详细的代码实现和步骤解释。阅读这些文件将有助于你更好地理解和实现这个过程。 需要注意的是,在实际应用中,还需要考虑错误处理、...
- 一旦连接建立,就可以通过Socket的Send和Receive方法发送和接收数据。 以下是简单的C#代码示例: **服务器端(Listen.cs)** ```csharp using System; using System.Net; using System.Net.Sockets; class ...
本篇文章将详细讲解C#中Socket通信的基本概念、使用方法,以及如何通过示例实现数据的接收和发送。 首先,Socket在计算机网络中扮演着客户端与服务器端之间数据传输的桥梁角色。它基于TCP/IP协议,为应用程序提供...
总之,这个"socket传输文件例子demo"是一个实践性的学习资源,可以帮助开发者深入理解如何在VC++环境中利用Socket进行文件传输,同时也可以作为开发自己网络通信软件的基础。通过阅读和分析源代码,我们可以学习到...
然后,我们将文件内容分割成多个数据块,每个块通过Socket发送到服务器。服务器接收到数据块后,将其写入目标文件,直到接收完整个文件。这个过程需要确保数据的完整性和正确性,通常可以通过校验和或序列号进行验证...
我们可以先读取文件到字节数组,然后根据文件大小分块,每一块使用Socket发送。在接收端,接收每一块数据并写入到临时文件,直到所有数据接收完毕,再将临时文件合并为原始文件。 4. **指定用户通信**: 在Socket...
标题"VC socket传送文件的例子(转载)"揭示了我们将讨论如何使用Visual C++(简称VC)通过Socket接口来实现文件的发送与接收。 首先,Socket是网络编程的基本组件,它提供了进程间通信(IPC)的接口,使得运行在...
客户端和服务器都使用`socket()`创建Socket,然后通过`sendto()`和`recvfrom()`函数直接发送和接收数据。由于UDP是无连接的,所以无需`connect()`、`bind()`和`listen()`操作。 四、TestSocket示例分析 在提供的...
` 将文件名和长度以特定格式发送给客户端,以便客户端知道要接收什么文件以及预期的大小。 6. **传输文件内容**:通过循环读取文件内容,然后写入到`DataOutputStream`,如`ps.write(buf, 0, read);`,每次读取一定...
本篇文章将深入探讨如何使用Spring Boot来实现WebSocket的发送和接收消息功能。 首先,我们需要在Spring Boot项目中添加WebSocket相关的依赖。Spring Boot本身并不直接包含WebSocket的支持,但可以通过添加`spring-...