Android和PC端通过局域网文件同步用代码怎么实现
局域网通常是分布在一个有限地理范围内的网络系统，一般所涉及的地理范围只有几公里。局域网专用性非常强，具有比较稳定和规范的拓扑结构。这篇文章主要为大家详细介绍了Android和PC端通过局域网文件同步的方法，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
具体实现代码如下
public class FileOptions {
public String name;
public String path;
public long size;
}
//Activity
public class MainActivity extends Activity {
private TextView tvMsg;
private EditText logShow, filePath;
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);
logShow = (EditText)findViewById(R.id. log_show);
handler = new Handler(){
@Override
public void handleMessage(Message msg) {
switch(msg. what){
case 0:
SimpleDateFormat format = new SimpleDateFormat("hh:mm:ss" );
logShow.append( "\n[" + format.format(new Date()) + "]" + msg.obj .toString());
break;
case 1:
tvMsg.setText( "请在PC端输入IP：" + GetIpAddress() + " 端口:" + msg.obj .toString());
break;
case 2:
Toast. makeText(getApplicationContext(), msg.obj.toString(), Toast. LENGTH_SHORT).show();
break;
}
}
};
socketManager = new SocketManager( handler);
}
@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 );
}
}
//socket管理
public class SocketManager {
private static final String FILE_PATH= "/glass";
private static final String TAG = "SocketManager";
private ServerSocket server;
private Handler handler = null;
private List fileList;
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() {
Socket socketPC= null;
try {
GetAllFiles();
socketPC = server.accept();
InetAddress netAddr = socketPC.getInetAddress();
String ipaddr = netAddr.getHostAddress();
Log. w( TAG, ipaddr);
OutputStream outputStream = socketPC.getOutputStream();
JSONArray jsonArr= new JSONArray();
for( int i=0;i< fileList.size();i++){
try {
JSONObject jsonObj= new JSONObject();
jsonObj.put( "name", fileList.get(i). name);
jsonObj.put( "path", fileList.get(i). path);
jsonObj.put( "size", fileList.get(i). size);
jsonArr.put(jsonObj);
} catch (JSONException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
String sendStr=jsonArr.toString();
byte[] sendBuf=sendStr.getBytes( "GB2312");
outputStream.write(sendBuf, 0, sendBuf. length);
outputStream.flush();
SendMessage(0, " 发送文件索引完成" );
outputStream.close();
socketPC.close();
for( int i=0;i< fileList.size();i++){
Socket fileSendSocket = server.accept();
File fsend= new File( fileList.get(i). path);
FileInputStream fis= new FileInputStream(fsend);
OutputStream fos = fileSendSocket.getOutputStream();
byte[] buf = new byte[1024];
while ( true) {
int read = 0;
if (fis != null) {
read = fis.read(buf);
}
if (read == -1) {
break;
}
fos.write(buf,0,read);
}
fos.flush();
SendMessage(0, fileList.get(i). name+ "--文件传输完成" );
fis.close();
fos.close();
fileSendSocket.close();
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void SendFile(ArrayList fileName, ArrayList 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());
}
}
//待优化
private void GetAllFiles(){
fileList= new ArrayList();
File rootPath= new File(Environment.getExternalStorageDirectory().getPath()+ FILE_PATH);
File[] files = rootPath.listFiles(); // 列出所有文件
for( int i=0;i
if(files[i].isFile()){
FileOptions fp= new FileOptions();
fp. name=files[i].getName();
fp. path=files[i].getPath();
fp. size=files[i].length();
fileList.add(fp);
}
}
}
}
PC端用VS2005写的。用了Json格式数据进行数据通信。主要用法为：在同一局域网内，打开PC端和Android端程序，按照Android端提示的IP地址及端口在PC端程序编辑框中正确输入，点击链接，即可将sd卡根目录下的相关文件夹下的文件同步到PC端。
//PC端主要源码
//数据传输线程
DWORD WINAPI RecvThread(LPVOID lpParameter)
{
SOCKET recvSocket = (SOCKET)lpParameter;
int ret = 0,strLen=0;
char recvBuffer[MAX_LEN],*pRecvAllData;
Json::Reader reader;
Json::Value jsonArr;
while ( true )
{
/*
*/
pRecvAllData=( char *)malloc(MAX_LEN);
while ((ret = recv(recvSocket, recvBuffer, MAX_LEN, 0))>0){
strLen+=ret;
pRecvAllData=( char *)realloc(pRecvAllData,strLen);
memcpy(pRecvAllData+strLen-ret,recvBuffer,ret);
};
if (!reader.parse(pRecvAllData, jsonArr)){
Sleep(1000);
continue ;
}
int jsonSize = jsonArr.size();
CString strItem;
fileList.RemoveAll();
for (int j = 0; j < jsonSize; ++j)
{
std::string name = jsonArr[j][ "name" ].asString();
std::string path = jsonArr[j][ "path" ].asString();
int size = jsonArr[j][ "size" ].asInt();
strItem.Format(TEXT( "%d" ), j+1);
pFileRecvDlg->m_fileListCtrl.InsertItem(j,strItem.GetBuffer(0));
pFileRecvDlg->m_fileListCtrl.SetItemText(j,0,strItem.GetBuffer(0));
strItem=name.c_str();
fileStr filest;
filest.name=name;
filest.size=size;
fileList.AddTail(filest);
pFileRecvDlg->m_fileListCtrl.SetItemText(j,1,strItem.GetBuffer(0));
}
free(pRecvAllData);
closesocket(recvSocket);
CRect rect;
pFileRecvDlg->GetClientRect(&rect);
pFileRecvDlg->ClientToScreen(rect);
if (!pProgressDlg->IsWindowVisible()){
pProgressDlg->ShowWindow(SW_SHOW);
}
pProgressDlg->SetWindowPos(NULL,rect.left+100,rect.top+100,0,0,SWP_NOSIZE);
pFileRecvDlg->GetDlgItem(IDC_BUTTON_CONNECT)->EnableWindow(FALSE);
// 发送文件名
for (int i=0;i
SOCKET nameSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
int ret = connect(nameSocket,( struct sockaddr*)&ServerAddr, sizeof (ServerAddr));
if ( ret == SOCKET_ERROR ){
AfxMessageBox(_T( "connect 失败 "));
} else {
}
FILE *fp;
int tempCount=0;
fileStr flst=fileList.GetAt(fileList.FindIndex(i));
fopen_s(&fp,flst.name.c_str(), "wb+" );
pProgressDlg->setFile(flst.name,flst.size);
while ((ret = recv(nameSocket, recvBuffer, MAX_LEN, 0))!=0){
fwrite(recvBuffer, sizeof (char ),ret,fp);
tempCount+=ret;
pProgressDlg->updateProgress(tempCount);
}
_fcloseall( );
closesocket(nameSocket);
}
pFileRecvDlg->GetDlgItem(IDC_BUTTON_CONNECT)->EnableWindow(TRUE);
pProgressDlg->ShowWindow(SW_HIDE);
}
return 0;
}
//连接按钮的响应函数
void CGlassFileRecvDlg::OnBnClickedButtonConnect()
{
// TODO: 在此添加控件通知处理程序代码
if (UpdateData()){
BYTE nField0,nField1,nField2,nField3;
m_IpAddrCtrl.GetAddress(nField0,nField1,nField2,nField3);
WSADATA Ws;
SOCKET CientSocket;
int Ret = 0;
int AddrLen = 0;
HANDLE hThread = NULL;
char SendBuffer[MAX_PATH];
//Init Windows Socket
if ( WSAStartup(MAKEWORD(2,2), &Ws) != 0 )
{
return ;
}
//Create Socket
CientSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
if ( CientSocket == INVALID_SOCKET )
{
MessageBox(_T( "socket 创建失败 " ));
return ;
}
char strAddr[50],tempStr[10];
memset(strAddr,0, sizeof (strAddr));
memset(tempStr,0, sizeof (tempStr));
itoa(nField0,tempStr,10);
strcat(strAddr,tempStr);
strcat(strAddr, "." );
itoa(nField1,tempStr,10);
strcat(strAddr,tempStr);
strcat(strAddr, "." );
itoa(nField2,tempStr,10);
strcat(strAddr,tempStr);
strcat(strAddr, "." );
itoa(nField3,tempStr,10);
strcat(strAddr,tempStr);
ServerAddr.sin_family = AF_INET;
ServerAddr.sin_addr.s_addr = inet_addr(strAddr);
ServerAddr.sin_port = htons(m_port);
memset(ServerAddr.sin_zero, 0x00, 8);
Ret = connect(CientSocket,( struct sockaddr*)&ServerAddr, sizeof (ServerAddr));
if ( Ret == SOCKET_ERROR ){
MessageBox(_T( "connect 失败 "));
return ;
} else {
HANDLE hThread = CreateThread(NULL, 0, RecvThread, (LPVOID)CientSocket, 0, NULL);
if ( hThread == NULL ){
MessageBox(_T( " 创建线程失败 "));
return ;
}
CloseHandle(hThread);
}
}
}
补充：局域网、校园网安全维护方法
校园网络分为内网和外网，就是说他们可以上学校的内网也可以同时上互联网，大学的学生平时要玩游戏购物，学校本身有自己的服务器需要维护;
在大环境下，首先在校园网之间及其互联网接入处，需要设置防火墙设备，防止外部攻击，并且要经常更新抵御外来攻击;
由于要保护校园网所有用户的安全，我们要安全加固，除了防火墙还要增加如ips，ids等防病毒入侵检测设备对外部数据进行分析检测，确保校园网的安全;
外面做好防护措施，内部同样要做好防护措施，因为有的学生电脑可能带回家或者在外面感染，所以内部核心交换机上要设置vlan隔离，旁挂安全设备对端口进行检测防护;
内网可能有ddos攻击或者arp病毒等传播，所以我们要对服务器或者电脑安装杀毒软件，特别是学校服务器系统等，安全正版安全软件，保护重要电脑的安全;
对服务器本身我们要安全server版系统，经常修复漏洞及更新安全软件，普通电脑一般都是拨号上网，如果有异常上层设备监测一般不影响其他电脑。做好安全防范措施，未雨绸缪。
Android和PC端通过局域网文件同步用代码怎么实现相关文章：