使用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;


public class CloudServer extends Thread {
	
	private Socket s;
	
	Map map = new HashMap();
	
	File file = new File("C:\Users\14252\Desktop\keepFiles");

	
	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 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();
		}

	}

	
	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();
	}

	
	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;

public class Tools {
	
	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;
	}
	
	public static void tips(String s) {
		System.out.println(s);
	}

	
	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();

	}

	
	public static void sendMsg(OutputStream os, String msg) {
		PrintWriter pw = new PrintWriter(os);
		pw.println(msg);
		pw.flush();
	}
 
	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();
	}
	
	public static void transObject(T t,OutputStream os) throws IOException{
		ObjectOutputStream oos=new ObjectOutputStream(os);
	 oos.writeObject(t);
	}
	
	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;


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);
		
		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);
		
		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;


public class CilentSharing {
	
	private Socket s;
	
	File file1;
	
	String ss;
	
	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() {

	}

	
	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();
				}
			}
		});
	}

	
	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;


public class DownlownServer extends Thread {
	
	Socket s;
	
	File file;
	
	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;


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 云端资源共享小程序内容请搜索考高分网以前的文章或继续浏览下面的相关文章希望大家以后多多支持考高分网！