Android手机间使用socket进行文件互传实例

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

这是一个Android手机间文件传输的例子，两个手机同时装上此app，然后输入接收端的ip，选择文件，可以多选，点确定，就发送到另一个手机，一个简单快捷文件快传实例。可以直接运用到项目中。

下面是文件选择器：

代码

首先加入文件选择库

compile 'com.nononsenseapps:filepicker:2.5.2'

这个库的地址和用法在：https://github.com/spacecowboy/NoNonsense-FilePicker

activity_main.xml

MainActivity.class

public class MainActivity extends AppCompatActivity {
private static final int FILE_CODE = ;
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 :
SimpleDateFormat format = new SimpleDateFormat("hh:mm:ss");
txtEt.append("\n[" + format.format(new Date()) + "]" + msg.obj.toString());
break;
case :
tvMsg.setText("本机IP：" + GetIpAddress() + " 监听端口:" + msg.obj.toString());
break;
case :
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 = ; i < clip.getItemCount(); i++) {
Uri uri = clip.getItemAt(i).getUri();
paths.add(uri.getPath());
fileNames.add(uri.getLastPathSegment());
}
Message.obtain(handler, , "正在发送至" + 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, , "正在发送至" + 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();
}
public String GetIpAddress() {
WifiManager wifiManager = (WifiManager) getSystemService(WIFI_SERVICE);
WifiInfo wifiInfo = wifiManager.getConnectionInfo();
int i = wifiInfo.getIpAddress();
return (i & 0xFF) + "." +
((i >> ) & 0xFF) + "." +
((i >> ) & 0xFF)+ "." +
((i >> ) & 0xFF );
}
}

SocketManager.class

public class SocketManager {
private ServerSocket server;
private Handler handler = null;
public SocketManager(Handler handler){
this.handler = handler;
int port = ;
while(port > ){
try {
server = new ServerSocket(port);
break;
} catch (Exception e) {
port--;
}
}
SendMessage(, 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(, "正在接收:" + 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[];
int size = -;
while ((size = dataStream.read(buffer)) != -){
file.write(buffer, ,size);
}
file.close();
dataStream.close();
data.close();
SendMessage(, fileName + "接收完成");
}catch(Exception e){
SendMessage(, "接收错误:\n" + e.getMessage());
}
}
public void SendFile(ArrayList<String> fileName, ArrayList<String> path, String ipAddress, int port){
try {
for (int i = ; 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(, "正在发送" + fileName.get(i)); Socket data = new Socket(ipAddress, port);
OutputStream outputData = data.getOutputStream();
FileInputStream fileInput = new FileInputStream(path.get(i));
int size = -;
byte[] buffer = new byte[];
while((size = fileInput.read(buffer, , )) != -){
outputData.write(buffer, , size);
}
outputData.close();
fileInput.close();
data.close();
SendMessage(, fileName.get(i) + " 发送完成");
}
SendMessage(, "所有文件发送完成");
} catch (Exception e) {
SendMessage(, "发送错误:\n" + e.getMessage());
}
}
}