用java写一个云端资源共享小程序
程序员文章站
2022-07-09 13:30:28
云端共享小程序:首先介绍一些程序功能:多用户共享资源,创建一个共享服务器,服务器存储器可以存放资源,用户可以向服务器上传文件,也可以从服务器下载文件,实现了多用户分享资源的功能。技术栈:1.集合框架(map集合)2.IO流(对象序列化,文件传输等)3.多线程 4.网络编程(TCP/IP协议) 5.简单的GUI界面()来看下界面效果(本人喜欢粉色,用户可以自定义颜色…):点击下载后具体不再详述,看程序:服务端:package com.softeem....
云端共享小程序:
首先介绍一些程序功能:多用户共享资源,创建一个共享服务器,服务器存储器可以存放资源,用户可以向服务器上传文件,也可以从服务器下载文件,实现了多用户分享资源的功能。
技术栈
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<String, File> map = new HashMap<String, File>();
/** 服务器暂存文件的文件夹(这里我用电脑作为服务器) */
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 <T>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<String, File> 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<String, File>) 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<String, File> 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();
}
}
});
}
}
总结:
这个小程序综合性比较强,所以代码量较多,可以一直下载或者上传,多线程之间互不影响,每次点击下载或者上传都会创建一个线程进行下载或上传,各个任务之间互不影响,上面程序还可以继续扩展和优化,比如加入进度显示,大厅通知所有人某个用户上传了什么,下载了什么,这里不再叙述。
本文地址:https://blog.csdn.net/m0_47547434/article/details/107595204