Java Socket实战之七 使用Socket通信传输文件
前面几篇文章介绍了使用Java的Socket编程和NIO包在Socket中的应用，这篇文章说说怎样利用Socket编程来实现简单的文件传输。
这里由于前面一片文章介绍了NIO在Socket中的应用，所以这里在读写文件的时候也继续使用NIO包，所以代码看起来会比直接使用流的方式稍微复杂一点点。
下面的示例演示了客户端向服务器端发送一个文件，服务器作为响应给客户端会发一个文件。这里准备两个文件E:/test/server_send.log和E:/test/client.send.log文件，在测试完毕后在客户端和服务器相同目录下会多出两个文件E:/test/server_receive.log和E:/test/client.receive.log文件。
下面首先来看看Server类，主要关注其中的sendFile和receiveFile方法。
[java] view plaincopyprint?
package com.googlecode.garbagecan.test.socket.nio;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.ClosedChannelException;
import java.nio.channels.FileChannel;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.Iterator;
import java.util.logging.Level;
import java.util.logging.Logger;
public class MyServer4 {
private final static Logger logger = Logger.getLogger(MyServer4.class.getName());
public static void main(String[] args) {
Selector selector = null;
ServerSocketChannel serverSocketChannel = null;
try {
// Selector for incoming time requests
selector = Selector.open();
// Create a new server socket and set to non blocking mode
serverSocketChannel = ServerSocketChannel.open();
serverSocketChannel.configureBlocking(false);
// Bind the server socket to the local host and port
serverSocketChannel.socket().setReuseAddress(true);
serverSocketChannel.socket().bind(new InetSocketAddress(10000));
// Register accepts on the server socket with the selector. This
// step tells the selector that the socket wants to be put on the
// ready list when accept operations occur, so allowing multiplexed
// non-blocking I/O to take place.
serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
// Here's where everything happens. The select method will
// return when any operations registered above have occurred, the
// thread has been interrupted, etc.
while (selector.select() > 0) {
// Someone is ready for I/O, get the ready keys
Iterator<SelectionKey> it = selector.selectedKeys().iterator();
// Walk through the ready keys collection and process date requests.
while (it.hasNext()) {
SelectionKey readyKey = it.next();
it.remove();
// The key indexes into the selector so you
// can retrieve the socket that's ready for I/O
doit((ServerSocketChannel) readyKey.channel());
}
}
} catch (ClosedChannelException ex) {
logger.log(Level.SEVERE, null, ex);
} catch (IOException ex) {
logger.log(Level.SEVERE, null, ex);
} finally {
try {
selector.close();
} catch(Exception ex) {}
try {
serverSocketChannel.close();
} catch(Exception ex) {}
}
}
private static void doit(final ServerSocketChannel serverSocketChannel) throws IOException {
SocketChannel socketChannel = null;
try {
socketChannel = serverSocketChannel.accept();
receiveFile(socketChannel, new File("E:/test/server_receive.log"));
sendFile(socketChannel, new File("E:/test/server_send.log"));
} finally {
try {
socketChannel.close();
} catch(Exception ex) {}
}
}
private static void receiveFile(SocketChannel socketChannel, File file) throws IOException {
FileOutputStream fos = null;
FileChannel channel = null;
try {
fos = new FileOutputStream(file);
channel = fos.getChannel();
ByteBuffer buffer = ByteBuffer.allocateDirect(1024);
int size = 0;
while ((size = socketChannel.read(buffer)) != -1) {
buffer.flip();
if (size > 0) {
buffer.limit(size);
channel.write(buffer);
buffer.clear();
}
}
} finally {
try {
channel.close();
} catch(Exception ex) {}
try {
fos.close();
} catch(Exception ex) {}
}
}
private static void sendFile(SocketChannel socketChannel, File file) throws IOException {
FileInputStream fis = null;
FileChannel channel = null;
try {
fis = new FileInputStream(file);
channel = fis.getChannel();
ByteBuffer buffer = ByteBuffer.allocateDirect(1024);
int size = 0;
while ((size = channel.read(buffer)) != -1) {
buffer.rewind();
buffer.limit(size);
socketChannel.write(buffer);
buffer.clear();
}
socketChannel.socket().shutdownOutput();
} finally {
try {
channel.close();
} catch(Exception ex) {}
try {
fis.close();
} catch(Exception ex) {}
}
}
}
下面是Client程序代码，也主要关注sendFile和receiveFile方法
[java] view plaincopyprint?
package com.googlecode.garbagecan.test.socket.nio;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;
import java.nio.channels.SocketChannel;
import java.util.logging.Level;
import java.util.logging.Logger;
public class MyClient4 {
private final static Logger logger = Logger.getLogger(MyClient4.class.getName());
public static void main(String[] args) throws Exception {
new Thread(new MyRunnable()).start();
}
private static final class MyRunnable implements Runnable {
public void run() {
SocketChannel socketChannel = null;
try {
socketChannel = SocketChannel.open();
SocketAddress socketAddress = new InetSocketAddress("localhost", 10000);
socketChannel.connect(socketAddress);
sendFile(socketChannel, new File("E:/test/client_send.log"));
receiveFile(socketChannel, new File("E:/test/client_receive.log"));
} catch (Exception ex) {
logger.log(Level.SEVERE, null, ex);
} finally {
try {
socketChannel.close();
} catch(Exception ex) {}
}
}
private void sendFile(SocketChannel socketChannel, File file) throws IOException {
FileInputStream fis = null;
FileChannel channel = null;
try {
fis = new FileInputStream(file);
channel = fis.getChannel();
ByteBuffer buffer = ByteBuffer.allocateDirect(1024);
int size = 0;
while ((size = channel.read(buffer)) != -1) {
buffer.rewind();
buffer.limit(size);
socketChannel.write(buffer);
buffer.clear();
}
socketChannel.socket().shutdownOutput();
} finally {
try {
channel.close();
} catch(Exception ex) {}
try {
fis.close();
} catch(Exception ex) {}
}
}
private void receiveFile(SocketChannel socketChannel, File file) throws IOException {
FileOutputStream fos = null;
FileChannel channel = null;
try {
fos = new FileOutputStream(file);
channel = fos.getChannel();
ByteBuffer buffer = ByteBuffer.allocateDirect(1024);
int size = 0;
while ((size = socketChannel.read(buffer)) != -1) {
buffer.flip();
if (size > 0) {
buffer.limit(size);
channel.write(buffer);
buffer.clear();
}
}
} finally {
try {
channel.close();
} catch(Exception ex) {}
try {
fos.close();
} catch(Exception ex) {}
}
}
}
}
首先运行MyServer4类启动监听，然后运行MyClient4类来向服务器发送文件以及接受服务器响应文件。运行完后，分别检查服务器和客户端接收到的文件。
http://blog.csdn.net/kongxx/article/details/7319410
分享到：
相关推荐
3. **字节流传输**：由于文件可能是任意字节的组合，因此文件传输通常使用字节流。Socket提供InputStream和OutputStream，它们都是基于字节的。客户端可以将FileInputStream中的字节流通过Socket的OutputStream传递...
Java Socket 大文件传输是网络编程中的一个关键领域，它涉及到高效的数据传输、包的分片与组装，以及网络协议的选择。在这个场景下，我们通常会用到TCP和UDP这两种传输层协议，以及Java的非阻塞I/O（NIO）技术。下面...
在这个"Java socket文件传输实例"中，我们将深入探讨如何使用Java的Socket类进行文件的发送和接收，这对于理解网络编程的基本原理以及在实际应用中构建文件共享系统至关重要。 首先，Java Socket是基于TCP/IP协议的...
在这个主题中，我们将深入探讨Java中的Socket文件传输编程以及多线程的应用。 首先，理解Socket的基本概念至关重要。Socket可以看作是网络上的端点，允许两个应用程序通过网络进行通信。在Java中，`java.net.Socket...
Java基于Socket文件传输示例Java基于Socket文件传输示例Java基于Socket文件传输示例
在这个“Java Socket聊天和文件传输工具”中，开发者结合了实时聊天和文件传输的功能，使得用户可以在进行文字交流的同时，无缝地进行文件的交换。这个工具在局域网环境中已经过初步测试，表明其稳定性和效率都达到...
总结，Java Socket提供了一种强大且灵活的方式来进行文件传输。通过理解Socket的基本概念，结合文件流操作，我们可以构建出高效、安全的文件传输系统。在实际应用中，还需要考虑网络环境、错误处理、安全性等多个...
总的来说，这个简单的文件传输程序利用了Java Socket API实现了客户端和服务器之间的文件交换，虽然它可能没有涵盖高级特性，如断点续传、错误恢复或性能优化，但对于理解和学习Socket编程基础是很有帮助的。...
Java基于Socket实现局域网文件传输，此文件包含了Eclipse项目源码和已经打包好了的.jar文件（文件发送端和文件接收端）。 处在同一局域网内的两台主机，一台运行sender.jar文件（发送端），另一台运行receiver.jar...
基于java nio socket 的文件传输例程
这个"Java基于Socket文件传输示例：服务器端和客户端"的文档很可能会详细讲解以上步骤，并提供实际的代码示例，帮助读者理解如何在Java中实现Socket文件传输。通过实践这样的示例，开发者可以深入理解网络编程的基本...
在这个"Java Socket聊天和文件传输工具"中，开发者利用Socket API创建了一个实用的工具，能够实现用户间的文本聊天功能以及文件的传输。虽然源代码未提供，但我们可以根据已知的信息探讨其背后的原理和技术要点。 1...
在这个示例中，我们将探讨如何使用Java的Socket实现文件传输，包括服务器端和客户端的实现细节。 首先，我们从服务器端开始。服务器端的核心是监听特定端口（在这个例子中是8821）上的连接请求，并在接收到连接后...
在本示例中，我们将深入探讨如何使用Java Socket进行图片的传输，这对于理解网络编程和数据交换至关重要。"Java Socket传输图片源代码"这个主题涵盖了以下几个关键知识点： 1. **Java Socket基础**： - Socket是...
- 在文件传输过程中，Java的I/O流是关键。文件输入流用于读取本地文件，而文件输出流则用于将数据写入目标文件。在Socket通信中，我们通常会将文件内容封装成字节流，然后通过Socket发送。 4. **套接字输入/输出流...
Java Socket技术在Android开发中广泛应用于网络通信，尤其是在文件传输方面。断点续传功能是文件传输中的一个重要特性，它允许在文件传输中断后从上次中断的位置继续传输，避免了因网络问题导致的文件传输失败而需...
在实际应用中，Java Socket文件传输可能涉及更复杂的逻辑，如多线程处理多个客户端连接，或者使用高级协议如FTP、HTTP进行更高效的文件传输。然而，基础的Socket通信机制是理解这些高级协议的关键。通过这个简单的...
Java Socket 文件传输小案例
总的来说，Java Socket文件传输是一种基础但实用的网络通信技术，通过它可以实现不同设备间的数据交换，为各种网络应用提供了可能，例如文件共享、在线聊天、远程控制等。理解和掌握这一技术对于Java开发者来说至关...