当前位置: 开发笔记 > 运维 > 正文

使用java实现云端资源共享小程序的代码

作者：云中之锦书 | 来源：互联网 | 2021-09-02 18:59

这篇文章主要介绍了用java写一个云端资源共享小程序,本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下

云端共享小程序：

首先介绍一些程序功能：多用户共享资源，创建一个共享服务器，服务器存储器可以存放资源，用户可以向服务器上传文件，也可以从服务器下载文件，实现了多用户分享资源的功能。
技术栈
1.集合框架（Map集合）
2.IO流（对象序列化，文件传输等）
3.多线程
4.网络编程（TCP/IP协议）
5.简单的GUI界面
来看下界面效果（本人喜欢粉色，用户可以自定义颜色…）：

在这里插入图片描述

点击下载后：

在这里插入图片描述

具体不再详述，看程序：服务端：

package com.softeem.clound.server;

import java.io.File;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.HashMap;
import java.util.Map;

import com.softeem.clound.ToolsAndUI.Tools;

/***
 * 云端共享服务器：
 * 实现多用户云端共享资源
 * @author gq
 *
 */
public class CloudServer extends Thread {
	/** 套接字 */
	private Socket s;
	/** 文件Map集合 */
	Map map = new HashMap();
	/** 服务器暂存文件的文件夹（这里我用电脑作为服务器） */
	File file = new File("C:\\Users\\14252\\Desktop\\keepFiles");

	/**
	 * 定义构造器初始化套接字
	 * 
	 * @param s
	 */
	public CloudServer(Socket s) {
		this.s = s;
	}

	@Override
	public void run() {
		File files[] = file.listFiles();
		// 先将服务器文件加入到结合中去
		for (File file : files) {
			map.put(file.getName(), file);
		}
		// 先询问用户下载还是上传
		try {
			/*
			 * // 将选择发送给用户 String msg = "欢迎进入云端共享(先选择您的操作)";
			 * Tools.sendMsg(s.getOutputStream(), msg);
			 */
			// 接收到用户的回复
			String s1 = Tools.getMsg(s.getInputStream());
			// 得到用户请求进行操作
			if (s1.equals("1")) {
				Tools.tips("用户选择了下载操作！");
				downLoad();
			} else if ("2".equals(s1)) {
				Tools.tips("用户选择了上传操作！");
				upLoad();
			}
		} catch (IOException e) {
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}

	}

	/**
	 * 下载文件
	 * 
	 * @throws IOException
	 */
	private void downLoad() throws IOException {
		/**
		 * 将文件集合序列化传给用户
		 */
		Tools.transObject(map, s.getOutputStream());
		// 得到用户下载文件的名字(用户发来的名字可能有空格，去除空格)
		String name = Tools.getMsg(s.getInputStream()).trim();
		// 通过对面传过来的文件名找到文件
		File file = map.get(name);
		// 将文件传输给用户
		Tools.transFile(s.getOutputStream(), file);
		// 将传输成功的信息打印到控制台
		Tools.tips(file.getName() + ":传输完成");
		// 通过半关闭将输出流关闭，解决服务端阻塞问题
		s.shutdownOutput();
	}

	/**
	 * 用户上传文件
	 * 
	 * @throws IOException
	 * @throws ClassNotFoundException
	 */
	private void upLoad() throws ClassNotFoundException, IOException {
		// 通过对象序列化得到文件对象
		Object obj = Tools.getObject(s.getInputStream());
		File f = (File) obj;
		// 设置好文件路径
		file = new File(file, f.getName());
		// 传输信息解决阻塞问题
		Tools.sendMsg(s.getOutputStream(), "");
		// 获取文件
		Tools.getFile(s.getInputStream(), file);
		// 服务器控制台显示用户下载成功
		Tools.tips(file.getName() + " 文件上传成功");
	}

	public static void main(String[] args) throws IOException {
		// 设置一个端口为5555的服务器
		ServerSocket server = new ServerSocket(5555);
		// 不断循环接收多个用户请求
		while (true) {
			// 监听用户请求
			Socket s = server.accept();
			// 当监听到用户请求时，创建线程执行任务
			new CloudServer(s).start();
			// 将每个客户进入到服务器的信息打印到控制台
			Tools.tips("客户端访问了服务器：" + s.getInetAddress().getHostAddress());
		}
	}

}

工具类：

package com.softeem.clound.ToolsAndUI;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
/**
 * 工具类
 * @author 14252
 */
public class Tools {
	/**
	 * * 将套接字输出流包装成打印流并且打印信息
	 * @param os
	 * @param msg
	 * @throws IOException
	 */
	public static void Println(OutputStream os, String msg) throws IOException {

	}

	public static String getMsg(InputStream in) throws IOException {
		InputStreamReader isr = new InputStreamReader(in);
		BufferedReader br = new BufferedReader(isr);
		String s1 = null;
		s1 = br.readLine();
		return s1;
	}
	/**
	 * 简化输出语句
	 * 
	 * @param s
	 */
	public static void tips(String s) {
		System.out.println(s);
	}

	/**
	 * 传输（发送）文件
	 * @param os
	 * @param file
	 * @throws IOException
	 */
	public static void transFile(OutputStream os, File file) throws IOException {
		BufferedOutputStream fos = new BufferedOutputStream(os);
		byte b[] = new byte[1024];
		FileInputStream fis = new FileInputStream(file);
		int len = 0;
		while ((len = fis.read(b)) != -1) {
			fos.write(b, 0, len);
		}
		fos.flush();

	}

	/**
	 * 发送消息
	 * @param os
	 * @param msg
	 */
	public static void sendMsg(OutputStream os, String msg) {
		PrintWriter pw = new PrintWriter(os);
		pw.println(msg);
		pw.flush();
	}
 /**
 * 接收文件
 * @param in
 * @param file
 * @throws IOException
 */
	public static void getFile(InputStream in, File file) throws IOException {
		BufferedInputStream bu = new BufferedInputStream(in);
		int len = 0;
		byte b[] = new byte[1024];
		// System.out.println("下载完成！");
		FileOutputStream fos = new FileOutputStream(file);
		while ((len = bu.read(b)) != -1) {
			fos.write(b, 0, len);
		}
		fos.flush();
	}
	/**
	 * 定义泛型方法传输序列化对象
	 * @param t
	 * @param os
	 * @throws IOException
	 */
	public static void transObject(T t,OutputStream os) throws IOException{
		ObjectOutputStream oos=new ObjectOutputStream(os);
	 oos.writeObject(t);
	}
	/**
	 * 定义泛型方法反序列化序列化对象
	 * @param in
	 * @return
	 * @throws ClassNotFoundException
	 * @throws IOException
	 */
	public static Object getObject(InputStream in) throws ClassNotFoundException, IOException{
		ObjectInputStream ois = new ObjectInputStream(in);
		Object o= ois.readObject();
		return o;
	}
	
}

界面

package com.softeem.clound.ToolsAndUI;

import java.awt.Color;
import java.awt.Container;
import java.awt.Font;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;

/**
 * JFrame界面
 * 
 * @author 14252
 *
 */
public class MyJFrame extends JFrame {

	private static final long serialVersiOnUID= -82252562835060372L;
	// 确认按钮
	public static JButton jb1 = new JButton("确认");
	public static JButton jb2 = new JButton("确认");
	public static JButton jbDown = new JButton("下载");
	public static JButton jbUp = new JButton("上传");
	// 文本框
	public static JTextArea jt2 = new JTextArea();
	public static JTextArea jt = new JTextArea();
	public static JTextArea jt1 = new JTextArea();
	public static JScrollPane js = new JScrollPane();
	// 标签
	public static JLabel j1 = new JLabel("输入您要下载的文件名");
	public static JLabel j2 = new JLabel("输入上传文件路径");

	/**
	 * 显示窗口
	 */
	public static void showJFrame() {
		JFrame jf = new JFrame();
		/** 设置窗口 */
		jf.setTitle("云端文件共享mini版");
		jf.setSize(520, 700);
		jf.setLayout(null);
		jf.setVisible(true);
		jf.setResizable(false);
		// 设置容器
		Container c = jf.getContentPane();
		/** 设置滚动条以及文本框 */
		js.setBounds(50, 50, 400, 200);
		c.add(js);
		jt.setFont(new Font("", 20, 16));
		jt.setBounds(50, 50, 400, 200);
		js.setViewportView(jt);
		c.add(jt);
		/** 设置上传下载按钮 */
		jbDown.setBounds(50, 280, 100, 40);
		jbUp.setBounds(350, 280, 100, 40);
		c.add(jbUp);
		c.add(jbDown);
		/** 设置按钮1以及文本框1以及标签1 */
		jb1.setBounds(350, 350, 100, 40);
		c.add(jb1);
		j1.setBounds(50, 360, 300, 100);
		j1.setFont(new Font("", 20, 20));
		j1.setForeground(Color.RED);
		c.add(j1);
		jt1.setBounds(50, 350, 240, 40);
		jt1.setFont(new Font("", 18, 18));
		js.setViewportView(jt);
		c.add(jt1);
		/** 设置按钮2以及文本框2以及标签2 */
		jb2.setBounds(350, 500, 100, 40);
		c.add(jb2);
		jt2.setBounds(50, 500, 240, 40);
		c.add(jt2);
		j2.setBounds(50, 510, 300, 100);
		j2.setFont(new Font("", 20, 20));
		j2.setForeground(Color.RED);
		c.add(j2);
		jt2.setFont(new Font("", 17, 17));
		/** 设置背景颜色 */
		c.setBackground(Color.PINK);

	}
}

服务端：

package com.softeem.clound.cilent;

import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.File;
import java.io.IOException;
import java.net.Socket;
import com.softeem.clound.ToolsAndUI.MyJFrame;
import com.softeem.clound.ToolsAndUI.Tools;

/**
 * 客户端
 * 
 * @author gq
 */
public class CilentSharing {
	/** 套接字 */
	private Socket s;
	/** 下载到的路径 */
	File file1;
	/** 定义一个状态（1 下载 2 上传） */
	String ss;
	/** 服务器ip地址 */
	private String ip;
	/** 服务器端口号 */
	private int port;

	public CilentSharing(File file1, String ip, int port) {
		this.file1 = file1;
		this.ip = ip;
		this.port = port;
	}

	public CilentSharing() {

	}

	/**
	 * 选择进行的操作
	 * 
	 * @throws IOException
	 * @throws ClassNotFoundException
	 */
	private void choose() throws IOException, ClassNotFoundException {
		// 下载
		downLoad();
		// 上传
		upLoad();
	}

	/**
	 * 下载功能(点击下载按钮启动)
	 */
	private void downLoad() {
		// 点击下载按钮开始下载
		MyJFrame.jbDown.addActionListener(new ActionListener() {
			@Override
			public void actionPerformed(ActionEvent e) {
				try {
					s = new Socket(ip, port);
				} catch (IOException e2) {
					e2.printStackTrace();
				}
				// 将你的选择发送给服务端（1,2）
				try {
					ss = "1";
					Tools.sendMsg(s.getOutputStream(), ss);
					// 启动下载线程
					new DownlownServer(s, file1).start();
					return;
				} catch (IOException e1) {
					e1.printStackTrace();
				}
			}
		});
	}

	/**
	 * 上传文件功能(点击上传按钮启动)
	 */
	private void upLoad() {
		MyJFrame.jbUp.addActionListener(new ActionListener() {
			@Override
			public void actionPerformed(ActionEvent e) {
				try {
					MyJFrame.jt.setText("请输入您要上传文件所在路径！");
					s = new Socket(ip, port);
					// 将选择发给服务端
					ss = "2";
					Tools.sendMsg(s.getOutputStream(), ss);
					// 开启上传线程
					new UpServer(s).start();
				} catch (IOException e1) {
					e1.printStackTrace();
				}
			}
		});
	}

	/**
	 * 开始任务
	 * 
	 * @throws ClassNotFoundException
	 * @throws IOException
	 */
	public static void main(String[] args) throws ClassNotFoundException, IOException {
		// 启动界面
		MyJFrame.showJFrame();
		// 说明
		MyJFrame.jt.setText("欢迎使用云端共享！！！" + "\n" + "注意：" + "\n" + "在上传文件填写路径前或选择下载文件时" + ",先选择您的" + "\n" + "操作（上传/下载）");
		// 文件下载的路径(这里写自己的保存路径)
		File f = new File("C:\\Users\\14252\\Desktop\\新建文件夹 (4)");
		// 端口号
		int port = 5555;
		// ip地址
		String ip = "192.168.0.102";
		// 调用选择进行操作的方法
		new CilentSharing(f, ip, port).choose();

	}

}

客户端下载服务线程：

package com.softeem.clound.cilent;

import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.File;
import java.io.IOException;
import java.net.Socket;
import java.util.HashMap;
import java.util.Map;

import com.softeem.clound.ToolsAndUI.MyJFrame;
import com.softeem.clound.ToolsAndUI.Tools;

/**
 * 创建线程回应下载点击事件
 * 
 * @author gq
 *
 */
public class DownlownServer extends Thread {
	/** socket套接字 */
	Socket s;
	/** 用户的下载路径 */
	File file;
	/** 接收传过来的map集合 */
	Map map;
	/** 接收文本框内容 */
	String msg;
	/** 接受所有文件信息 */
	String show="";

	public DownlownServer(Socket s, File file) {
		this.s = s;
		this.file = file;
	}

	@Override
	public void run() {
		// 创建线程执行下载任务
		// 反对象序列化（得到map集合）
		Object obj = null;
		try {
			obj = Tools.getObject(s.getInputStream());
		} catch (ClassNotFoundException | IOException e2) {
			// TODO 自动生成的 catch 块
			e2.printStackTrace();
		}
		// 得到Map集合
		map = (HashMap) obj;
		// 将服务器文件信息显示到这里
		map.forEach((k, v) -> {
			show = show + "文件名： " + k + "\n";
		});
		// 将可以下载的文件列出来
		MyJFrame.jt.setText(show);
		// 按钮点击事件下载文件
		MyJFrame.jb1.addActionListener(new ActionListener() {
			@Override
			public void actionPerformed(ActionEvent e) {
				// 将选择的文件名字传给服务端
				try {
					msg = MyJFrame.jt1.getText().trim();
					// 将下载文件名字传给服务器
					Tools.sendMsg(s.getOutputStream(), msg);
					// 将服务端文件下载下来
					File f = new File("");
					// 接收原路径
					f = file;
					file = new File(file, msg);
					// 接收文件
					Tools.getFile(s.getInputStream(), file);
					MyJFrame.j1.setText("下载成功！！！");
					// 恢复原路径可以多次下载
					file = f;
					//关闭套接字
					s.close;
				} catch (IOException e1) {
					e1.printStackTrace();
				}

			}
		});
	}

}

客户端上传线程：

package com.softeem.clound.cilent;

import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.File;
import java.io.IOException;
import java.net.Socket;
import java.util.Map;

import com.softeem.clound.ToolsAndUI.MyJFrame;
import com.softeem.clound.ToolsAndUI.Tools;

/***
 * 上传线程
 * @author 14252
 *
 */
public class UpServer extends Thread{
	/***/
	Socket s;
	File file;
	Map map;
	String show;
	public UpServer(Socket s) {
		this.s = s;
	}
	@Override
	public void run() {
		MyJFrame.jb2.addActionListener(new ActionListener() {
			
			@Override
			public void actionPerformed(ActionEvent e) {
				//得到输入的文件路径
				String cOntent=MyJFrame.jt2.getText();
				file=new File(content);
				try {
					//将文件信息通过对象序列化传过去
					Tools.transObject(file, s.getOutputStream());
					//得到服务端响应避免阻塞
					Tools.getMsg(s.getInputStream());
					//开始传输文件
					Tools.transFile(s.getOutputStream(), file);
					//在界面显示显示上传成功
					MyJFrame.j2.setText("上传成功");
					MyJFrame.jt.setText(file.getName()+"上传成功！");
					// 通过半关闭将输出流关闭，解决服务端阻塞问题
					s.shutdownOutput();
				} catch (IOException e1) {
					e1.printStackTrace();
				} 
			}
		});
	}

}

总结：

这个小程序综合性比较强，所以代码量较多，可以一直下载或者上传，多线程之间互不影响，每次点击下载或者上传都会创建一个线程进行下载或上传，各个任务之间互不影响，上面程序还可以继续扩展和优化，比如加入进度显示，大厅通知所有人某个用户上传了什么，下载了什么，这里不再叙述。

到此这篇关于用java写一个云端资源共享小程序的文章就介绍到这了,更多相关java 云端资源共享小程序内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持！

推荐阅读

tomcat
Web学习历程记录（七）——Tomcat基本概念和配置

本文介绍了Web学习历程记录中关于Tomcat的基本概念和配置。首先解释了Web静态Web资源和动态Web资源的概念，以及C/S架构和B/S架构的区别。然后介绍了常见的Web服务器，包括Weblogic、WebSphere和Tomcat。接着详细讲解了Tomcat的虚拟主机、web应用和虚拟路径映射的概念和配置过程。最后简要介绍了http协议的作用。本文内容详实，适合初学者了解Tomcat的基础知识。 ... [详细]

蜡笔小新 2023-12-13 17:08:24
容器
阿里云物联网 .NET Core 客户端 | CZGL.AliIoTClient：4. 设备上报属性

阿,里,云,物,联网,net,core,客户端,czgl,aliiotclient, ... [详细]

蜡笔小新 2023-12-14 12:40:20
容器
Hyperledger Fabric外部链码构建与运行的开发笔记

本文介绍了Hyperledger Fabric外部链码构建与运行的相关知识，包括在Hyperledger Fabric 2.0版本之前链码构建和运行的困难性，外部构建模式的实现原理以及外部构建和运行API的使用方法。通过本文的介绍，读者可以了解到如何利用外部构建和运行的方式来实现链码的构建和运行，并且不再受限于特定的语言和部署环境。 ... [详细]

蜡笔小新 2023-12-13 21:47:39
tomcat
Oracle优化新常态的五大禁止及其性能隐患

本文介绍了Oracle优化新常态中的五大禁止措施，包括禁止外键、禁止视图、禁止触发器、禁止存储过程和禁止JOB，并分析了这些禁止措施可能带来的性能隐患。文章还讨论了这些禁止措施在C/S架构和B/S架构中的不同应用情况，并提出了解决方案。 ... [详细]

蜡笔小新 2023-12-12 12:55:55
tomcat
Servlet多用户登录时HttpSession会话信息覆盖问题的解决方案

本文讨论了在Servlet多用户登录时可能出现的HttpSession会话信息覆盖问题，并提供了解决方案。通过分析JSESSIONID的作用机制和编码方式，我们可以得出每个HttpSession对象都是通过客户端发送的唯一JSESSIONID来识别的，因此无需担心会话信息被覆盖的问题。需要注意的是，本文讨论的是多个客户端级别上的多用户登录，而非同一个浏览器级别上的多用户登录。 ... [详细]

蜡笔小新 2023-12-10 12:00:40
容器
Java容器中的compareto方法排序原理解析

本文从源码解析Java容器中的compareto方法的排序原理，讲解了在使用数组存储数据时的限制以及存储效率的问题。同时提到了Redis的五大数据结构和list、set等知识点，回忆了作者大学时代的Java学习经历。文章以作者做的思维导图作为目录，展示了整个讲解过程。 ... [详细]

蜡笔小新 2023-12-14 13:53:31
容器
Spring特性实现接口多类的动态调用详解

本文详细介绍了如何使用Spring特性实现接口多类的动态调用。通过对Spring IoC容器的基础类BeanFactory和ApplicationContext的介绍，以及getBeansOfType方法的应用，解决了在实际工作中遇到的接口及多个实现类的问题。同时，文章还提到了SPI使用的不便之处，并介绍了借助ApplicationContext实现需求的方法。阅读本文，你将了解到Spring特性的实现原理和实际应用方式。 ... [详细]

蜡笔小新 2023-12-14 03:24:19
容器
docker增加restart=always, docker重启后自动启动容器的方法

本文介绍了在运行docker容器时如何添加参数来保证每次docker服务重启后容器也自动重启的方法，以及如何使用命令来更新已启动的容器。 ... [详细]

蜡笔小新 2023-12-14 03:04:27
容器
图解redis的持久化存储机制RDB和AOF的原理和优缺点

本文通过图解的方式介绍了redis的持久化存储机制RDB和AOF的原理和优缺点。RDB是将redis内存中的数据保存为快照文件，恢复速度较快但不支持拉链式快照。AOF是将操作日志保存到磁盘，实时存储数据但恢复速度较慢。文章详细分析了两种机制的优缺点，帮助读者更好地理解redis的持久化存储策略。 ... [详细]

蜡笔小新 2023-12-13 20:24:11
port
页面请求方法参数最长_关于 HTTP GET/POST 请求参数长度最大值的一个理解误区

http:my.oschina.netleejun2005blog136820刚看到群里又有同学在说HTTP协议下的Get请求参数长度是有大小限制的，最大不能超过XX ... [详细]

蜡笔小新 2023-12-13 19:20:03
容器
处理docker容器时间和宿主机时间不一致问题的方法

本文介绍了处理docker容器时间和宿主机时间不一致问题的方法，包括复制主机的localtime到容器、处理报错情况以及重启容器的步骤。通过这些方法，可以解决docker容器时间和宿主机时间不一致的问题。 ... [详细]

蜡笔小新 2023-12-13 18:55:18
容器
解决全栈跨域问题的方法及步骤详解

本文详细介绍了解决全栈跨域问题的方法及步骤，包括添加权限、设置Access-Control-Allow-Origin、白名单等。通过这些操作，可以实现在不同服务器上的数据访问，并解决后台报错问题。同时，还提供了解决second页面访问数据的方法。 ... [详细]

蜡笔小新 2023-12-13 18:07:28
路由器
计算机网络初识及通信流程分析

本文介绍了计算机网络的定义和通信流程，包括客户端编译文件、二进制转换、三层路由设备等。同时，还介绍了计算机网络中常用的关键词，如MAC地址和IP地址。 ... [详细]

蜡笔小新 2023-12-13 16:50:29
port
ABAP开发发送邮件程序的配置和代码整理

本文介绍了通过ABAP开发往外网发邮件的需求，并提供了配置和代码整理的资料。其中包括了配置SAP邮件服务器的步骤和ABAP写发送邮件代码的过程。通过RZ10配置参数和icm/server_port_1的设定，可以实现向Sap User和外部邮件发送邮件的功能。希望对需要的开发人员有帮助。摘要长度：184字。 ... [详细]

蜡笔小新 2023-12-13 15:50:17
port
在重复造轮子的情况下用ProxyServlet反向代理来减少工作量

像不少公司内部不同团队都会自己研发自己工具产品，当各个产品逐渐成熟，到达了一定的发展瓶颈，同时每个产品都有着自己的入口，用户 ... [详细]

蜡笔小新 2023-12-13 15:19:01

云中之锦书

这个家伙很懒，什么也没留下！

Tags | 热门标签

RankList | 热门文章