上傳文件，我用了兩種方式實現(xiàn)，首先是用對象序列化，即把要上傳的數(shù)據(jù)打包成要上傳的對象，然后上傳。

需要注意的是：序列化的那兩個類一定要相同，包括包名。（其實就是客戶端和服務(wù)器端的javabean類，不過加上Serializable）

本人由于沒有處理好服務(wù)器端和客戶端的包名而使程序不能執(zhí)行。

同時： 在客戶端進(jìn)行序列化，在服務(wù)器端就進(jìn)行反序列化。

好了，上代碼：

首先是序列化的類：

public class UploadFile  implements Serializable  {
 private String title;
 private byte[] contentdata;
 private String mimetype;
 private  String type;
 private long length;
 public String getTitle() {
  return title;
 }
 public void setTitle(String title) {
  this.title = title;
 }
 public byte[] getContentdata() {
  return contentdata;
 }
 public void setContentdata(byte[] contentdata) {
  this.contentdata = contentdata;
 }
 public String getMimetype() {
  return mimetype;
 }
 public void setMimetype(String mimetype) {
  this.mimetype = mimetype;
 }
 public String getType() {
  return type;
 }
 public void setType(String type) {
  this.type = type;
 }
 public long getLength() {
  return length;
 }
 public void setLength(long length) {
  this.length = length;
 }
  
}

public class MainSocket extends Activity {
private Button butchose=null;
private Button up=null;
private   TextView text=null;
private static String filePath=null;

 
 @Override
 protected void onCreate(Bundle savedInstanceState) {
  super.onCreate(savedInstanceState);
  super.setContentView(R.layout.mainsocket);
  butchose=(Button)super.findViewById(R.id.socketchose);
  text=(TextView)super.findViewById(R.id.socketshow);
  up=(Button)super.findViewById(R.id.socketup);
  butchose.setOnClickListener(new MyButton());
  up.setOnClickListener(new MyButton());
  
 }
 //button按鈕的不同實現(xiàn)
 class MyButton implements OnClickListener{

 @Override
 public void onClick(View v) {
  switch (v.getId()) {
 case R.id.socketup://發(fā)送文件按鈕
 try {
  if(text.getText().toString()==null)
  { Toast.makeText(MainSocket.this, "請選擇上傳文件", 3).show();}
  sendup();
 } catch (Exception e) {
  e.printStackTrace();
 }
 break;

default:
 break;
}
  
 }

 
 
}
 
 //發(fā)送文件函數(shù)
 public void sendup() throws Exception{
  final Socket socket=new Socket("服務(wù)器ip",8897); //建立socket連接
  BufferedReader buffer=new BufferedReader(new InputStreamReader(socket.getInputStream()));//構(gòu)建一個緩沖區(qū)，用于存放服務(wù)器返回的數(shù)據(jù)
  new Thread(new Runnable(){//開啟一個新線程，用于發(fā)送數(shù)據(jù)
  @Override
  public void run() {
   try {
    ObjectOutputStream obj=new ObjectOutputStream(socket.getOutputStream());//對象序列化的應(yīng)用
    UploadFile file=MainSocket.this.upfile();//從下面那個函數(shù)中得到序列化的對象
    obj.writeObject(file);//把對象發(fā)送出去
   } catch (IOException e) {
   
    e.printStackTrace();
   }
   
  }}).start();
  String s=buffer.readLine().toString();//得到服務(wù)器返回的數(shù)據(jù)
  System.out.println("-------------------返回的數(shù)據(jù)是"+s);
  if(s.equals("true")){
   text.setText("操作成功！");
  }
  else{
   text.setText("操作失敗");
  }
  socket.close();
 
 }
 //構(gòu)造序列化對象
 public UploadFile upfile(){
  UploadFile upfile=new UploadFile();
  upfile.setTitle("自行設(shè)置");
  upfile.setMimetype("自行設(shè)置");
  try {
  File file=new File(filePath);//得到發(fā)送的文件
  InputStream in=new FileInputStream(file) ;//打開文件的輸出流（前臺的輸入流）
  ByteArrayOutputStream ous=new ByteArrayOutputStream();//聲明一個字節(jié)流
  byte[] data=new byte[1024];//緩存數(shù)組
  int len=0;
 while((len=in.read(data))!=-1){//把前面輸入流的數(shù)據(jù)送到字節(jié)流中
  ous.write(data,0,len);
 }
 upfile.setContentdata(ous.toByteArray());//把字節(jié)流的數(shù)據(jù)送到j(luò)avabean中，即序列化對象中
 upfile.setLength(file.length());//設(shè)置長度
 upfile.setType(filePath.substring(filePath.lastIndexOf(".")+1));
 } catch (Exception e) {
   
  e.printStackTrace();
 }
 return upfile;
 }
 
 
 
}
服務(wù)器端：

package lxf.com;

import java.io.IOException;
import java.net.ServerSocket;

public class server {

 public static void main(String[] args) {
 try {
  ServerSocket socket=new ServerSocket(8897);
  while(true){
  new Thread(new ServerThread(socket.accept())).start(); 
  }
 } catch (IOException e) {
  
  e.printStackTrace();
 }

 }

}

服務(wù)器端實現(xiàn)類：

package lxf.com;

import java.io.File;
import java.io.FileOutputStream;
import java.io.ObjectInputStream;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.Socket;
import java.util.UUID;

import lxf.socket.UploadFile;

 

 

public class ServerThread implements Runnable {
private String PATH="d:"+File.separator+"lxf"+File.separator;
private UploadFile uploadfile=null;
private Socket socket;
public ServerThread(Socket socekt1){
 this.socket=socekt1;
 System.out.println("建立新的連接");
}
 @Override
 public void run() {
   try {
   
   
   ObjectInputStream input=new ObjectInputStream(socket.getInputStream());//進(jìn)行反序列化
   uploadfile=new UploadFile();
    this.uploadfile=(UploadFile)input.readObject();//把流數(shù)據(jù)轉(zhuǎn)換成序列化對象
    System.out.println("文件長短是："+uploadfile.getLength());
    System.out.println("文件格式："+uploadfile.getType());
    PrintStream out=new PrintStream(socket.getOutputStream());//建立socket輸出流
    save();
    out.println("true");//給客戶端應(yīng)答
  } catch (Exception e) {
   
   e.printStackTrace();
  }
  finally{
 
   
   
  }

 }
 public boolean save() throws  Exception{
  File file=new File(PATH+UUID.randomUUID()+"."+uploadfile.getType());//建立一個文件夾
  if(!file.getParentFile().exists())//父文件不存在建立父文件
  {
   file.getParentFile().mkdir();
  }
  OutputStream output=new FileOutputStream(file);//打開控制臺輸出流
  output.write(uploadfile.getContentdata());//把數(shù)據(jù)寫入文件
  output.close();
  return true ;
 }

}

由于本人每一步寫的很細(xì)，標(biāo)的也很細(xì)。大家應(yīng)該可以看懂。

ObjectInputStream與ObjectOutputStream類所讀寫的對象必須實現(xiàn)了Seralizable接口。對象中的transient和static類型的成員變量不會被讀取和寫入。

另外，客戶端的布局大家可以自行設(shè)置。在這里，還有第二種方法：實現(xiàn)多線程多用戶斷點續(xù)傳功能，也是用數(shù)據(jù)流的方式上傳。

標(biāo)簽： 代碼 服務(wù)器 服務(wù)器端

版權(quán)申明：本站文章部分自網(wǎng)絡(luò)，如有侵權(quán)，請聯(lián)系：west999com@outlook.com
特別注意：本站所有轉(zhuǎn)載文章言論不代表本站觀點！
本站所提供的圖片等素材，版權(quán)歸原作者所有，如需使用，請與原作者聯(lián)系。