基本信息
源码名称：基于java socket的简单FTP功能实现
源码大小：0.01M
文件格式：.rar
开发语言：Java
更新时间：2019-04-19
友情提示：（无需注册或充值，赞助后即可获取资源下载链接）
嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：813200300
本次赞助数额为： 2 元×
微信扫码支付：2 元
×
请留下您的邮箱，我们将在2小时内将文件发到您的邮箱
源码介绍
实现FTP的一些功能，如上传文件，下载文件，显示目录，改变目录，退出等功能
实现FTP的一些功能，如上传文件，下载文件，显示目录，改变目录，退出等功能
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.net.*;
import java.util.ArrayList;
import java.io.File;
public class server {
ServerSocket ss = null;
String dir = "";//显示目录
String cmd = "";
DataOutputStream dos;
String direcFile = "";
File rootDirectory;
String shareFile;
DataInputStream dis ;
//ArrayList <File> fileArrayList = new ArrayList <File>();
ArrayList<File> fileArrayList = new ArrayList<File>();
private String shareFiledirectory;
public static void main(String[] args) {
//System.out.println("等待连接");
new server("D:\\Backup\\我的文档\\网络课程设计共享文件");
}
public server(String shareFiledirectory){
this.shareFiledirectory = shareFiledirectory;
//建立套接字
try {
ss = new ServerSocket(8888);//建立提供服务器的端口号为8888
} catch (IOException e1) {
e1.printStackTrace();
}
try{
while(true){
boolean flag = true;
while(flag){
Socket s = ss.accept();//阻塞式，等待客户端请求连接
System.out.println("已有客户端连接");
//接受对方的要求：
dis = new DataInputStream(new BufferedInputStream(s
.getInputStream()));//BufferedInputStream 利用缓冲区来提高读效率，
// 从此套接字读取字节的输入流
//BufferedInputStream(InputStream in) 参数in指定需要被装饰的输入流
cmd= dis.readUTF();//从dis输入流读取若干字节，把它转换为采用UTF-8字符编码的字符串,并将其放在cmd String变量里
//UTF-8对ASCII字符采用一个字节形式的编码，对非ASCII字符则采用两个或两个以上字节形式的编码
dis.close();//关闭输入流
s.close();//关闭socket
System.out.println("输出读入的字符串：" cmd);
// System.out.println(cmd=="get");
//接受后放在cmd里用于判断：
if(cmd.equals("get"))
get();
else if(cmd.equals("put"))
put();
else if(cmd.equals("cd"))
cd ();
else if(cmd.equals("dir"))
dir();
else if(cmd == "quit")
flag = false;
}
}
}catch (IOException e){
}
}
public void get(){
System.out.println("get" 1111);
Socket s = null;//连接为空
try{
s = ss.accept();
//接受对方的要求的文件名：
dis = new DataInputStream(new BufferedInputStream(s
.getInputStream()));//
String filePath = dis.readUTF();//
System.out.println(filePath);
//传输文件：
dos = new DataOutputStream(new BufferedOutputStream(s.getOutputStream()));
File file = new File(filePath);
dos.writeUTF(file.getName());
dos.flush();
dos.writeLong(file.length());
dos.flush();
dis = new DataInputStream(new BufferedInputStream(new FileInputStream(filePath)));
int BUFSIZE = 8192;
byte [] buf = new byte[BUFSIZE];
while(true){
int read = 0;
if(dis != null){
read = dis.read(buf);
}else{
System.out.println("no file founded!");
break;
}
if (read == -1){
break;
}
dos.write(buf, 0, read);
}
dos.flush();
}catch(IOException e){
System.out.println("asdfsssssssssss");
}finally{
try{
dos.close();
dis.close();
s.close();
}catch(IOException e){
}
}
}
public void put(){
System.out.println("put");
Socket s = null;
try{
s = ss.accept();
//下载文件
dis = new DataInputStream(new BufferedInputStream(s.getInputStream()));//从客户端接收存放上传文件路径的输出流
int bufferSize = 8192;
// 缓冲区
byte[] buf = new byte[bufferSize];
int passedlen = 0;
long len = 0;
String savePath = "E:/上传";
// 获取文件名称 保存上传 文件的路径名
savePath = savePath File.separator dis.readUTF();
//在本地路径建一个数据流
DataOutputStream fileOut = new DataOutputStream(
new BufferedOutputStream( new FileOutputStream(savePath)));
// 获取文件长度
len = dis.readLong(); //从输入流 中读取8个字节
System.out.println("文件的长度为:" len " KB");
System.out.println("开始接收文件!");
// 获取文件
while (true) {
int read = 0;
if (dis != null) {
read = dis.read(buf); //从输入流将数据读到缓冲区中，并将返回结果赋给read
}
passedlen = read;
if (read == -1) {
break;
}
System.out.println("文件接收了" (passedlen * 100 / len) "%");
fileOut.write(buf, 0, read);
}
System.out.println("接收完成，文件存为" savePath);
fileOut.close();
dis.close();
s.close();
}catch(IOException e ){
}
}
public void cd(){
System.out.println("cd");
Socket s = null;
try{
s = ss.accept();
//读取要到达的改变的目录：
dis = new DataInputStream(new BufferedInputStream(s
.getInputStream()));
shareFile = dis.readUTF();
System.out.println(shareFiledirectory);
dir();
}catch(IOException e){
}finally{
}
}
public void dir ( ) throws IOException{
rootDirectory = new File(shareFiledirectory);//shareFiledirectory表示共享文件的路径
fileArrayList.clear();
//String[] myList;//定义一个字符串数组
//myList = rootDirectory.listFiles();
//for(int i = 0;i<myList.length;i ){
// System.out.println(myList[i]);
//}
//catch(Exception e){
// e.printStackTrace();
//}
//}
/* File f=new File(shareFiledirectory);
File[] list=f.listFiles();
for(int i=0;i<list.length;i )
System.out.println(list[i].getAbsolutePath());//打印全路径*/
initFileArrayList();
for(int i =0;i<fileArrayList.size();i ){
System.out.println(fileArrayList.get(i).getAbsolutePath());
direcFile = direcFile fileArrayList.get(i).getAbsolutePath() '\n';
}
try{
Socket s = ss.accept();
dos = new DataOutputStream(
new BufferedOutputStream(s.getOutputStream()));
byte []buf = direcFile.getBytes();
dos.write(buf);
dos.flush();
dos.close();
s.close();
}catch(IOException e){
}
}
public void initFileArrayList() { // 将目录下所有文件放在一个数组列表里面fileArrayList
if (rootDirectory.isDirectory()) {
// 遍历目录下面的文件和子目录
File[] fileList = rootDirectory.listFiles();
System.out.println(fileList.length);
for (int i = 0; i < fileList.length; i ) {
// 如果是文件,添加到文件列表中
if (fileList[i].isFile()) {
fileArrayList.add(new File(fileList[i].getAbsolutePath()));
System.out.println(fileList[i].getAbsolutePath());
System.out.println("添加了" fileList[i].getName());
}
// 否则递归遍历子目录
else if (fileList[i].isDirectory()) {
System.out.println("文件");
fileList[i].mkdir();//
rootDirectory = fileList[i];
initFileArrayList();
}
}
}
}
}