Java实现文件上传服务器和客户端

Java实现文件上传服务器和客户端

本文实例为大家分享了java实现文件上传服务器和客户端的具体代码，供大家参考，具体内容如下http://

文件上传服务器端：

/**

* 使用TCP协议实现上传功能的服务器端

* 思路：

* 新建ServerSocket

* 等待客户端连接

* 连接上后开启子线程，把连接获取的Socket传给子线程

* 循环进行

* @author yajun

*

*/

public class UploadServer {

public static void main(String[] args) {

UploadServer server=new UploadServer();

UploadThread command=new UploadThread();

server.start(command);

}

/**

* 功能：接受连接，开启子线程，循环

* @param command 用于下载的子线程对象，该对象实现了Runnable接口

*/

private void start(UploadThread command){

//局部变量

ServerSocket serverSocket = null;

Socket transSocjFrRCket;

//业务逻辑

try {

serverSocket=new ServerSocket(55555);

while(true){

System.out.println("等待连接……");

transSocket=serverSocket.accept();

int i=0;

i++;

System.out.println("第"+i+"个连接");

//用不用在下载完后关闭线程呢？？？

command.setSocket(transSocket);

Executors.newFixedThreadPool(5).execute(command);

}

//异常捕获

} catch (IOException e) {

e.printStackTrace();

//关闭资源

} finally{

try {

serverSocket.close();

} catch (IOException e) {

e.printStackTrace();

}

}//End of try

}//End of connect

@Test

public void testConnect() {

//测试任务：先运行服务器端，然后多次运行客户端，服务器段可以不断创建子线程，则测试成功

//测试准备：构造一个线程，用于模拟下载线程

UploadThread command=new UploadThread();

start(command);

}

@Test

public void testDown() throws IOException {

byte[] buf;

ByteArrayInputStream bis;

String str="canglaoshi.avi\ncontent,content,content";

buf=str.getBytes();

bis=new ByteArrayInputStream(buf);

UploadThread ut=new UploadThread();

ut.down(bis);

}

}

//完成各个传输任务的子线程

class UploadThread implements Runnable{

Socket socket;

public UploadThread(){}

public UploadThread(Socket socket){

this.socket=socket;

}

@Override

public void run() {

InputStream in;

try {

in = socket.getInputStream();

down(in);

//异常处理

} catch (IOException e) {

e.printStackTrace();

} finally{

try {

socket.close();

} catch (IOException e) {

e.printStackTrace();

}

}

//测试代码

/*try {

Thread.sleep(5000);

System.out.println(Thread.currentThread().getName()+",复制完毕");

} catch (InterruptedException e) {

e.printStackTrace();

}*/

}//End of run

public void setSocket(Socket socket){

this.socket=socket;

}

//下载方法

/**

* 目标：把InputStream中的数据写入到本地

* 思路：

* 1.获取输入流,最好传入输入流，而不是直接从Socket获取，传入有利用单元测试

* 2.从输入流中读到文件名

* 3.新建文件和文件输出流

* 4.从输入流中读到文件内容到文件输出流

* 5.

* @throws IOException

*/

public void down(InputStream in) throws IOException{

//局部变量

char ch;

char[] nameArr=new char[256];

byte[] buf=new byte[1024];

String name="";

OutputStream out = null;

//业务逻辑

try {

//第一步：获取文件名，构造文件输出流

int i=0;

while((ch=(char) in.read())!='\n'){

nameArr[i++]= ch;

}

//name=nameArr.toString();//这句话无法将字符数组转换为字符串，需用下面的语句

name=new String(nameArr);

System.out.println("要下载的文件为："+name);

out=new FileOutputStream("src\\down\\"+name);

//第二步：将输入流中的其他内容写入到文件

int len;

while((len=in.read(buf))!=-1){

out.write(buf,0,len);

}

out.flush();

//异常捕获

} catch (IOException e) {

e.printStackTrace();

//关闭资源

}finally{

//疑问：两个捕获可不可以放到一块呢，怎样处理关闭流时的异常最好呢？

in.close();

out.close();

}

//调试

System.out.println(name);

}

}//End of UploadThread

文件上传客户端：

/**

* 使用TCP协议实现上传功能的客户端

* @author yajun

*/

public class UploadClient {

public static void main(String[] args) {

UploadClient client=new UploadClient();

client.upload("src\\thursday\\AsListTest.java");

}

/**

* 作用：上传文件到服务器

* 1.建立到服务器的连接

* 2.获取输出流

* 3.将文件内容写入到输出流

* 4.获取服务器的响应

*/

private void upload(String name){

Socket socket=null;

OutputStream out;

try {

socket=new Socket("127.0.0.1", 55555);

out=socket.getOutputStream();

write2OutputStream(name, out);

//异常捕获

} catch (UnknownHostExcjFrRCeption e) {

e.printStackTrace();

} catch (IjFrRCOException e) {

e.printStackTrace();

}

}

@Test

public void testUpload() {

upload("src\\status.xml");

}

/**

* 作用：传入文件名和输出流，将文件写入到输出流

* @param path

* @throws IOException

*/

private void write2OutputStream(String path,OutputStream out) throws IOException{

FileInputStream fis = null;

byte[] buf=new byte[1024];

String fileName="";

//业务逻辑

try {

//1.写入文件名

fileName=path.substring(path.lastIndexOf('\\')+1);

System.out.println("您要上传的文件名为："+fileName);

out.write(fileName.getBytes());

out.write('\n');

//2.写入文件内容

fis=new FileInputStream(path);

int len;

while((len=fis.read(buf))!=-1){

out.write(buf, 0, len);

}

out.flush();

//异常处理

} catch (IOException e) {

e.printStackTrace();

//关闭资源

} finally{

fis.close();

out.close();

}

}//End of upload

@Test

public void testWrite2OutputStream() throws IOException {

ByteArrayOutputStream out = null;

try {

out=new ByteArrayOutputStream();

write2OutputStream("src\\status.xml", out);

System.out.println(out.toString("utf-8"));

} catch (IOException e) {

e.printStackTrace();

} finally{

out.close();

}

}

}

本文已被整理到了《Java上传操作技巧汇总》，欢迎大家学习阅读。

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。