您的位置:首页 > 理论基础 > 计算机网络

基于TCP协议的Socket编程,实现文件的上传

2016-03-18 19:59 686 查看
说明:

数据的上传读取都涉及数据I/O流,I/O流失相对Java程序而言,若是文件数据要流入Java程序,则为输入流,若流出Java程序,则为输出流!

客户端:文件先转化为输入流到程序,然后从Socket的实例化对象中获取输出流,把输入流读取并写入到输出流。

客户端:MainActivity.java
public void onclick(View V){
Thread thread = new Thread(new Runnable(){
@Override
public void run() {
//获取文件的路径:此时图片文件是存储在SD卡上的
File file = new File("sdcard/hou.jpg");
try {
//创建Socket对象,指定IP地址和端口号(IP地址请修改为自己电脑IP)
Socket socket = new Socket("192.168.1.101",54321);
//把文件放到输入流里面
InputStream is = new FileInputStream(file);
//从socket中获取OutputStream
OutputStream outputStream =socket.getOutputStream();
//定义一个存储输入流的字节数组buffer
byte []buffer = new byte[4*1024];
int temp = 0;
//把InputStream读取并循环写入到OutputStream中
while((temp = is.read(buffer))!=-1){
outputStream.write(buffer,0,temp);
}
outputStream.flush();
//关闭流和socket套接字;
is.close();
outputStream.close();
socket.close();
} catch (Exception e) {
e.printStackTrace();
}

}
});
thread.start();

}
服务器端代码:
package ay.lipengfei.socket;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.DataInputStream;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;

public class Socket implements Runnable {

/**
* @param args
*/
public static void main(String[] args) {
Thread desktopServerThread = new Thread(new Socket());
desktopServerThread.start();

}
public void run(){
try {
ServerSocket serverSocket = new ServerSocket(54321);

while(true){
System.out.println("等待用户连接");
//接受用户请求;
java.net.Socket client =serverSocket.accept();
System.out.println("有新用户连接服务器");
//接收传来的流数据放入输入流;
InputStream is = client.getInputStream();
//新new一个FileOutputStream对象,并把输入流输读写到这个输出流中生成新文件,读写操作同客户端。
FileOutputStream fos = new FileOutputStream("D:/hou1.jpg");
byte[] buffer = new byte[1024];
while(true){

int temp = is.read(buffer,0,buffer.length);
if(temp==-1)
break;
fos.write(buffer,0,temp);
}
fos.close();
System.out.println("读写完成!");
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}

}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: