用java设计并实现一个基于字符界面的C/S结构的文件传输程序

时间: 2023-12-18 12:03:01 浏览: 29
好的,我可以为您提供一份基本的Java代码实现: 1. 客户端界面设计 客户端界面采用字符界面,使用Java中的Console类来实现。客户端界面需要包括以下功能: - 连接服务器 - 上传文件 - 下载文件 - 查看服务器上的文件列表 - 断开连接 以下是客户端界面的代码实现: ``` import java.io.BufferedReader; import java.io.Console; import java.io.IOException; import java.io.InputStreamReader; import java.net.Socket; public class Client { private Socket socket; private BufferedReader reader; private Console console; public Client() { console = System.console(); } public void start() { while (true) { String command = console.readLine("请输入命令:"); if (command.equals("connect")) { connect(); } else if (command.equals("upload")) { upload(); } else if (command.equals("download")) { download(); } else if (command.equals("list")) { list(); } else if (command.equals("disconnect")) { disconnect(); break; } else { System.out.println("无效命令,请重新输入!"); } } } private void connect() { try { String host = console.readLine("请输入服务器地址:"); int port = Integer.parseInt(console.readLine("请输入服务器端口号:")); socket = new Socket(host, port); reader = new BufferedReader(new InputStreamReader(socket.getInputStream())); System.out.println("连接成功!"); } catch (IOException e) { System.out.println("连接失败!"); e.printStackTrace(); } } private void upload() { // TODO: 实现文件上传 } private void download() { // TODO: 实现文件下载 } private void list() { // TODO: 实现查看服务器上的文件列表 } private void disconnect() { try { socket.close(); reader.close(); System.out.println("已断开连接!"); } catch (IOException e) { e.printStackTrace(); } } public static void main(String[] args) { Client client = new Client(); client.start(); } } ``` 2. 服务器端实现 服务器端需要实现以下功能: - 监听客户端连接请求 - 接收客户端上传的文件并保存到指定目录 - 发送指定目录下的文件列表给客户端 - 接收客户端下载的文件并发送给客户端 以下是服务器端的代码实现: ``` import java.io.*; import java.net.ServerSocket; import java.net.Socket; import java.util.ArrayList; import java.util.List; public class Server { private ServerSocket serverSocket; private List<String> fileList; public Server(int port) { try { serverSocket = new ServerSocket(port); fileList = new ArrayList<>(); System.out.println("服务器已启动,等待客户端连接..."); } catch (IOException e) { e.printStackTrace(); } } public void start() { while (true) { try { Socket socket = serverSocket.accept(); System.out.println("客户端已连接:" + socket.getInetAddress()); new Thread(new ClientHandler(socket)).start(); } catch (IOException e) { e.printStackTrace(); } } } private synchronized void addFile(String filename) { fileList.add(filename); } private synchronized void removeFile(String filename) { fileList.remove(filename); } private synchronized List<String> getFileList() { return new ArrayList<>(fileList); } private class ClientHandler implements Runnable { private Socket socket; private BufferedReader reader; private PrintWriter writer; public ClientHandler(Socket socket) { try { this.socket = socket; reader = new BufferedReader(new InputStreamReader(socket.getInputStream())); writer = new PrintWriter(new OutputStreamWriter(socket.getOutputStream())); } catch (IOException e) { e.printStackTrace(); } } @Override public void run() { try { while (true) { String command = reader.readLine(); if (command == null) { break; } if (command.equals("upload")) { receiveFile(); } else if (command.equals("download")) { sendFile(); } else if (command.equals("list")) { sendFileList(); } else { writer.println("无效命令!"); writer.flush(); } } } catch (IOException e) { e.printStackTrace(); } finally { try { socket.close(); reader.close(); writer.close(); System.out.println("客户端已断开连接:" + socket.getInetAddress()); } catch (IOException e) { e.printStackTrace(); } } } private void receiveFile() throws IOException { String filename = reader.readLine(); addFile(filename); FileOutputStream fos = new FileOutputStream(filename); byte[] buffer = new byte[1024]; int len; while ((len = socket.getInputStream().read(buffer)) != -1) { fos.write(buffer, 0, len); } fos.close(); removeFile(filename); System.out.println("已接收文件:" + filename); } private void sendFile() throws IOException { String filename = reader.readLine(); File file = new File(filename); if (!file.exists() || !file.isFile()) { writer.println("文件不存在!"); writer.flush(); return; } FileInputStream fis = new FileInputStream(file); byte[] buffer = new byte[1024]; int len; while ((len = fis.read(buffer)) != -1) { socket.getOutputStream().write(buffer, 0, len); } fis.close(); System.out.println("已发送文件:" + filename); } private void sendFileList() throws IOException { List<String> fileList = getFileList(); for (String filename : fileList) { writer.println(filename); } writer.flush(); System.out.println("已发送文件列表!"); } } public static void main(String[] args) { Server server = new Server(8888); server.start(); } } ``` 以上是一个基本的Java代码实现,可以根据实际需求进行调整和优化。

相关推荐

最新推荐

recommend-type

java网络文件传输(c/s)

文档的功能在于实现文件的传输,是网络开发中的重点,无论是文本,还是图片都可传输……,很小,很实用
recommend-type

基于Java的Socket编写的C/S聊天程序实现

主要介绍了基于Java的Socket编写的C/S聊天程序实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
recommend-type

基于Java实现文件和base64字符串转换

主要介绍了基于Java实现文件和base64字符串转换,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
recommend-type

使用java自带des加密算法实现文件加密和字符串加密

主要介绍了使用java自带des加密算法实现文件加密和字符串加密的示例,需要的朋友可以参考下
recommend-type

Java实现字符串匹配(基于正则)

主要介绍了Java中使用正则表达式实现字符串匹配,字符串查找,匹配,替换,正则无不能做,特别是灵活的运用子串匹配,感兴趣的小伙伴们可以参考一下
recommend-type

zigbee-cluster-library-specification

最新的zigbee-cluster-library-specification说明文档。
recommend-type

管理建模和仿真的文件

管理Boualem Benatallah引用此版本:布阿利姆·贝纳塔拉。管理建模和仿真。约瑟夫-傅立叶大学-格勒诺布尔第一大学,1996年。法语。NNT:电话:00345357HAL ID:电话:00345357https://theses.hal.science/tel-003453572008年12月9日提交HAL是一个多学科的开放存取档案馆,用于存放和传播科学研究论文,无论它们是否被公开。论文可以来自法国或国外的教学和研究机构,也可以来自公共或私人研究中心。L’archive ouverte pluridisciplinaire
recommend-type

【实战演练】MATLAB用遗传算法改进粒子群GA-PSO算法

![MATLAB智能算法合集](https://static.fuxi.netease.com/fuxi-official/web/20221101/83f465753fd49c41536a5640367d4340.jpg) # 2.1 遗传算法的原理和实现 遗传算法(GA)是一种受生物进化过程启发的优化算法。它通过模拟自然选择和遗传机制来搜索最优解。 **2.1.1 遗传算法的编码和解码** 编码是将问题空间中的解表示为二进制字符串或其他数据结构的过程。解码是将编码的解转换为问题空间中的实际解的过程。常见的编码方法包括二进制编码、实数编码和树形编码。 **2.1.2 遗传算法的交叉和
recommend-type

openstack的20种接口有哪些

以下是OpenStack的20种API接口: 1. Identity (Keystone) API 2. Compute (Nova) API 3. Networking (Neutron) API 4. Block Storage (Cinder) API 5. Object Storage (Swift) API 6. Image (Glance) API 7. Telemetry (Ceilometer) API 8. Orchestration (Heat) API 9. Database (Trove) API 10. Bare Metal (Ironic) API 11. DNS
recommend-type

JSBSim Reference Manual

JSBSim参考手册,其中包含JSBSim简介,JSBSim配置文件xml的编写语法,编程手册以及一些应用实例等。其中有部分内容还没有写完,估计有生之年很难看到完整版了,但是内容还是很有参考价值的。