android經過socket上傳文件
思想：
1.直接將全部數據安裝字節數組發送
2.對象序列化方式
兩種方式：java
1、thread方式
Client1 :android
主界面
package org.lxh.demo;
import java.io.BufferedReader;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.ObjectOutputStream;
import java.net.Socket;
import org.lxh.util.UploadFile;
import android.app.Activity;
import android.os.Bundle;
import android.os.Environment;
import android.view.View;
import android.view.View.OnClickListener;
import android.widget.Button;
import android.widget.TextView;
public class MyClientDemo extends Activity {
private Button send = null;
private TextView info = null;
@Override
public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
super.setContentView(R.layout.main);
this.send = (Button) super.findViewById(R.id.send);
this.info = (TextView) super.findViewById(R.id.info);
this.send.setOnClickListener(new SendOnClickListener());
}
private class SendOnClickListener implements OnClickListener {
@Override
public void onClick(View v) {
try {
final Socket client = new Socket("192.168.1.114", 8888);
BufferedReader buf = new BufferedReader(new InputStreamReader(
client.getInputStream())); // 讀取返回的數據
new Thread(new Runnable() {
@Override
public void run() {
try {
ObjectOutputStream oos = new ObjectOutputStream(
client.getOutputStream());
UploadFile myFile = SendOnClickListener.this.getUploadFile();
oos.writeObject(myFile);//寫文件對象
oos.close();
} catch (Exception e) {
}
}
}).start();
String result = buf.readLine(); // 接收返回信息
System.out.println("**************** " + result);
if ("true".equals(result)) {
MyClientDemo.this.info.setText("操做成功！");
} else {
MyClientDemo.this.info.setText("操做失敗！");
}
buf.close();
client.close();
} catch (Exception e) {
e.printStackTrace();
}
} private UploadFile getUploadFile() throws Exception { // 包裝了傳送數據
UploadFile myFile = new UploadFile();
myFile.setTitle("DISNEY公園"); // 設置標題
myFile.setMimeType("image/jpeg"); // 圖片的類型
File file = new File(Environment.getExternalStorageDirectory()
.toString() + File.separator + "disney.jpg");
InputStream input = null;
try {
input = new FileInputStream(file); // 從文件中讀取
ByteArrayOutputStream bos = new ByteArrayOutputStream();
byte data[] = new byte[1024];
int len = 0;
while ((len = input.read(data)) != -1) {
bos.write(data, 0, len);
}
myFile.setContentData(bos.toByteArray());
myFile.setContentLength(file.length());
myFile.setExt("jpg");
} catch (Exception e) {
throw e;
} finally {
input.close();
}
return myFile;
}
}
}
2.序列化文件對象
package org.lxh.util;
import java.io.Serializable;
@SuppressWarnings("serial")
public class UploadFile implements Serializable {
private String title ;
private byte [] contentData ;
private String mimeType ;
private long contentLength ;
private String ext ;
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 long getContentLength() {
return contentLength;
}
public void setContentLength(long contentLength) {
this.contentLength = contentLength;
}
public String getExt() {
return ext;
}
public void setExt(String ext) {
this.ext = ext;
}
}
2、handler方式
Client:
1.主界面
public class MyClientDemo extends Activity {
private Button send = null;
private TextView info = null;
private static final int FINISH = 0 ;
private Handler myHandler = new Handler(){
@Override
public void handleMessage(Message msg) {
switch(msg.what) {
case FINISH:
String result = msg.obj.toString() ; // 取出數據
if ("true".equals(result)) {
MyClientDemo.this.info.setText("操做成功！");
} else {
MyClientDemo.this.info.setText("操做失敗！");
} break ;
}
}
} ;
@Override
public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
super.setContentView(R.layout.main);
this.send = (Button) super.findViewById(R.id.send);
this.info = (TextView) super.findViewById(R.id.info);
this.send.setOnClickListener(new SendOnClickListener());
}
private class SendOnClickListener implements OnClickListener {
@Override
public void onClick(View v) {
try {
final Socket client = new Socket("192.168.1.114", 8888);
final BufferedReader buf = new BufferedReader(new InputStreamReader(
client.getInputStream())); // 讀取返回的數據
new Thread(new Runnable() {
@Override
public void run() {
try {
ObjectOutputStream oos = new ObjectOutputStream(
client.getOutputStream());
UploadFile myFile = SendOnClickListener.this.getUploadFile();
oos.writeObject(myFile);
String str = buf.readLine() ; // 讀取數據
oos.close();
Message msg = MyClientDemo.this.myHandler.obtainMessage(FINISH, str);
MyClientDemo.this.myHandler.sendMessage(msg) ;
buf.close();
client.close();
} catch (Exception e) {
e.printStackTrace() ;
}
}
}).start();
} catch (Exception e) {
e.printStackTrace();
}
}
2.序列化文件對象
private UploadFile getUploadFile() throws Exception { // 包裝了傳送數據
UploadFile myFile = new UploadFile();
myFile.setTitle("DISNEY公園"); // 設置標題
myFile.setMimeType("image/jpeg"); // 圖片的類型
File file = new File(Environment.getExternalStorageDirectory()
.toString() + File.separator + "disney.jpg");
InputStream input = null;
try {
input = new FileInputStream(file); // 從文件中讀取
ByteArrayOutputStream bos = new ByteArrayOutputStream();
byte data[] = new byte[1024];
int len = 0;
while ((len = input.read(data)) != -1) {
bos.write(data, 0, len);
}
myFile.setContentData(bos.toByteArray());
myFile.setContentLength(file.length());
myFile.setExt("jpg");
} catch (Exception e) {
throw e;
} finally {
input.close();
}
return myFile;
}
}
}
server端
package org.lxh.server;
import java.net.ServerSocket;
public class MyServer {
public static void main(String[] args) throws Exception {
ServerSocket server = new ServerSocket(8888); // 服務器端端口
boolean flag = true; // 定義標記，能夠一直死循環
while (flag) { // 經過標記判斷循環
new Thread(new ServerThreadUtil(server.accept())).start(); // 啓動線程
}
server.close(); // 關閉服務器
}
}
package org.lxh.server;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.Socket;
import java.util.UUID;
import org.lxh.util.UploadFile;
public class ServerThreadUtil implements Runnable {
private static final String DIRPATH = "D:" + File.separator + "mldnfile"
+ File.separator; // 目錄路徑
private Socket client = null;
private UploadFile upload = null;
public ServerThreadUtil(Socket client) {
this.client = client;
System.out.println("新的客戶端鏈接...");
}
@Override
public void run() {
try {
PrintStream out = new PrintStream(this.client.getOutputStream());
ObjectInputStream ois = new ObjectInputStream(
client.getInputStream()); // 反序列化
this.upload = (UploadFile) ois.readObject(); // 讀取對象
System.out.println("文件標題：" + this.upload.getTitle());
System.out.println("文件類型：" + this.upload.getMimeType());
System.out.println("文件大小：" + this.upload.getContentLength());
out.print(this.saveFile()) ;
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
this.client.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
private boolean saveFile() throws Exception { // 負責文件內容的保存
File file = new File(DIRPATH + UUID.randomUUID() + "."
+ this.upload.getExt());
if (!file.getParentFile().exists()) {
file.getParentFile().mkdir();
}
OutputStream output = null;
try {
output = new FileOutputStream(file) ;
output.write(this.upload.getContentData()) ;
return true ;
} catch (Exception e) {
throw e;
} finally {
output.close();
}
}
}
相關文章
- 1. android中利用socket上傳文件
- 2. Android中Socket大文件斷點上傳
- 3. socket 文件上傳下載
- 4. Go經過ssh上傳文件或遍歷上傳文件夾
- 5. 經過socket發送文件
- 6. FormData經過ajax上傳文件
- 7. java 經過 HttpURLConnection 上傳文件
- 8. 經過數據流上傳文件
- 9. php經過ftp協議上傳文件
- 10. Windows 機器經過 FTP 上傳文件
- 更多相關文章...
- • PHP 文件上傳 - PHP教程
- • R XML 文件 - R 語言教程
- • Flink 數據傳輸及反壓詳解
- • Docker容器實戰(七) - 容器眼光下的文件系統
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
最新文章
- 1. 在windows下的虛擬機中,安裝華爲電腦的deepin操作系統
- 2. 強烈推薦款下載不限速解析神器
- 3. 【區塊鏈技術】孫宇晨：區塊鏈技術帶來金融服務的信任變革
- 4. 搜索引起的鏈接分析-計算網頁的重要性
- 5. TiDB x 微衆銀行 | 耗時降低 58%，分佈式架構助力實現普惠金融
- 6. 《數字孿生體技術白皮書》重磅發佈（附完整版下載）
- 7. 雙十一「避坑」指南：區塊鏈電子合同爲電商交易保駕護航！
- 8. 區塊鏈產業，怎樣「鏈」住未來？
- 9. OpenglRipper使用教程
- 10. springcloud請求一次好用一次不好用zuul Name or service not known
歡迎關注本站公眾號,獲取更多信息
