(高效開發)Android手機間使用socket進行檔案互傳例項
阿新 • • 發佈：2019-01-31
說明
這是一個Android手機間檔案傳輸的例子，兩個手機同時裝上此app，然後輸入接收端的ip，選擇檔案，可以多選，點確定，就傳送到另一個手機，一個簡單快捷檔案快傳例項。可以直接運用到專案中。
下面是檔案選擇器：
程式碼
首先加入檔案選擇庫
compile 'com.nononsenseapps:filepicker:2.5.2'activity_main.xml
<RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android"
xmlns:tools="http://schemas.android.com/tools" MainActivity.class
public class MainActivity extends AppCompatActivity {
private static final int FILE_CODE = 0;
private TextView tvMsg;
private EditText txtIP, txtPort, txtEt;
private Button btnSend;
private Handler handler;
private SocketManager socketManager;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
tvMsg = (TextView)findViewById(R.id.tvMsg);
txtIP = (EditText)findViewById(R.id.txtIP);
txtPort = (EditText)findViewById(R.id.txtPort);
txtEt = (EditText)findViewById(R.id.et);
btnSend = (Button)findViewById(R.id.btnSend);
btnSend.setOnClickListener(new View.OnClickListener(){
@Override
public void onClick(View v) {
Intent i = new Intent(MainActivity.this, FilePickerActivity.class);
i.putExtra(FilePickerActivity.EXTRA_ALLOW_MULTIPLE, true);
i.putExtra(FilePickerActivity.EXTRA_ALLOW_CREATE_DIR, false);
i.putExtra(FilePickerActivity.EXTRA_MODE, FilePickerActivity.MODE_FILE);
i.putExtra(FilePickerActivity.EXTRA_START_PATH, Environment.getExternalStorageDirectory().getPath());
startActivityForResult(i, FILE_CODE);
}
});
handler = new Handler(){
@Override
public void handleMessage(Message msg) {
switch(msg.what){
case 0:
SimpleDateFormat format = new SimpleDateFormat("hh:mm:ss");
txtEt.append("\n[" + format.format(new Date()) + "]" + msg.obj.toString());
break;
case 1:
tvMsg.setText("本機IP：" + GetIpAddress() + " 監聽埠:" + msg.obj.toString());
break;
case 2:
Toast.makeText(getApplicationContext(), msg.obj.toString(), Toast.LENGTH_SHORT).show();
break;
}
}
};
socketManager = new SocketManager(handler);
}
@TargetApi(Build.VERSION_CODES.JELLY_BEAN)
@Override
protected void onActivityResult(int requestCode, int resultCode, Intent data) {
if (requestCode == FILE_CODE && resultCode == Activity.RESULT_OK) {
final String ipAddress = txtIP.getText().toString();
final int port = Integer.parseInt(txtPort.getText().toString());
if (data.getBooleanExtra(FilePickerActivity.EXTRA_ALLOW_MULTIPLE, true)) {
// For JellyBean and above
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.JELLY_BEAN) {
ClipData clip = data.getClipData();
final ArrayList<String> fileNames = new ArrayList<>();
final ArrayList<String> paths = new ArrayList<>();
if (clip != null) {
for (int i = 0; i < clip.getItemCount(); i++) {
Uri uri = clip.getItemAt(i).getUri();
paths.add(uri.getPath());
fileNames.add(uri.getLastPathSegment());
}
Message.obtain(handler, 0, "正在傳送至" + ipAddress + ":" + port).sendToTarget();
Thread sendThread = new Thread(new Runnable(){
@Override
public void run() {
socketManager.SendFile(fileNames, paths, ipAddress, port);
}
});
sendThread.start();
}
} else {
final ArrayList<String> paths = data.getStringArrayListExtra
(FilePickerActivity.EXTRA_PATHS);
final ArrayList<String> fileNames = new ArrayList<>();
if (paths != null) {
for (String path: paths) {
Uri uri = Uri.parse(path);
paths.add(uri.getPath());
fileNames.add(uri.getLastPathSegment());
socketManager.SendFile(fileNames, paths, ipAddress, port);
}
Message.obtain(handler, 0, "正在傳送至" + ipAddress + ":" + port).sendToTarget();
Thread sendThread = new Thread(new Runnable(){
@Override
public void run() {
socketManager.SendFile(fileNames, paths, ipAddress, port);
}
});
sendThread.start();
}
}
}
}
}
@Override
protected void onDestroy() {
super.onDestroy();
System.exit(0);
}
public String GetIpAddress() {
WifiManager wifiManager = (WifiManager) getSystemService(WIFI_SERVICE);
WifiInfo wifiInfo = wifiManager.getConnectionInfo();
int i = wifiInfo.getIpAddress();
return (i & 0xFF) + "." +
((i >> 8 ) & 0xFF) + "." +
((i >> 16 ) & 0xFF)+ "." +
((i >> 24 ) & 0xFF );
}
}SocketManager.class
public class SocketManager {
private ServerSocket server;
private Handler handler = null;
public SocketManager(Handler handler){
this.handler = handler;
int port = 9999;
while(port > 9000){
try {
server = new ServerSocket(port);
break;
} catch (Exception e) {
port--;
}
}
SendMessage(1, port);
Thread receiveFileThread = new Thread(new Runnable(){
@Override
public void run() {
while(true){
ReceiveFile();
}
}
});
receiveFileThread.start();
}
void SendMessage(int what, Object obj){
if (handler != null){
Message.obtain(handler, what, obj).sendToTarget();
}
}
void ReceiveFile(){
try{
Socket name = server.accept();
InputStream nameStream = name.getInputStream();
InputStreamReader streamReader = new InputStreamReader(nameStream);
BufferedReader br = new BufferedReader(streamReader);
String fileName = br.readLine();
br.close();
streamReader.close();
nameStream.close();
name.close();
SendMessage(0, "正在接收:" + fileName);
Socket data = server.accept();
InputStream dataStream = data.getInputStream();
String savePath = Environment.getExternalStorageDirectory().getPath() + "/" + fileName;
FileOutputStream file = new FileOutputStream(savePath, false);
byte[] buffer = new byte[1024];
int size = -1;
while ((size = dataStream.read(buffer)) != -1){
file.write(buffer, 0 ,size);
}
file.close();
dataStream.close();
data.close();
SendMessage(0, fileName + "接收完成");
}catch(Exception e){
SendMessage(0, "接收錯誤:\n" + e.getMessage());
}
}
public void SendFile(ArrayList<String> fileName, ArrayList<String> path, String ipAddress, int port){
try {
for (int i = 0; i < fileName.size(); i++){
Socket name = new Socket(ipAddress, port);
OutputStream outputName = name.getOutputStream();
OutputStreamWriter outputWriter = new OutputStreamWriter(outputName);
BufferedWriter bwName = new BufferedWriter(outputWriter);
bwName.write(fileName.get(i));
bwName.close();
outputWriter.close();
outputName.close();
name.close();
SendMessage(0, "正在傳送" + fileName.get(i));
Socket data = new Socket(ipAddress, port);
OutputStream outputData = data.getOutputStream();
FileInputStream fileInput = new FileInputStream(path.get(i));
int size = -1;
byte[] buffer = new byte[1024];
while((size = fileInput.read(buffer, 0, 1024)) != -1){
outputData.write(buffer, 0, size);
}
outputData.close();
fileInput.close();
data.close();
SendMessage(0, fileName.get(i) + " 傳送完成");
}
SendMessage(0, "所有檔案傳送完成");
} catch (Exception e) {
SendMessage(0, "傳送錯誤:\n" + e.getMessage());
}
}
}以上就是全部程式碼。
下載地址：點這裡。