Drive_F.zip

package com.hisign.android2pc; import android.os.Bundle; import android.support.v7.app.AppCompatActivity; import android.text.TextUtils; import android.util.Log; import android.widget.Toast; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.net.ServerSocket; import java.net.Socket; /** * @author lixm * * 这里没有处理多客户端连接，可以开子线程，处理每一个socket */ public class MainActivity extends AppCompatActivity { ServerThread serverThread; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); serverThread = new ServerThread(); serverThread.start(); } @Override protected void onDestroy() { super.onDestroy(); serverThread.setIsLoop(false); } /** * socket线程 */ class ServerThread extends Thread { private static final String TAG = "lixm"; DataInputStream inputStream = null; DataOutputStream outputStream = null; boolean isLoop = true; private Socket socket = null; private boolean isStartSend = false; public void setIsLoop(boolean isLoop) { this.isLoop = isLoop; } @Override public void run() { ServerSocket serverSocket = null; try { serverSocket = new ServerSocket(8888); socket = serverSocket.accept(); // 这里开始阻塞，如果有人连上，则开始发送信息 inputStream = new DataInputStream(socket.getInputStream()); outputStream = new DataOutputStream(socket.getOutputStream()); receiveData(); } catch (Exception e) { e.printStackTrace(); Log.d(TAG, "Exception ",e); } finally { if (serverSocket != null) { try { serverSocket.close(); } catch (Exception e) { e.printStackTrace(); } } } } /** * 接收PC端过来的数据 */ private void receiveData(){ new Thread(){ // 接收数据的线程 public void run(){ byte[] buffer = new byte[1024]; while (isLoop){ if(inputStream != null){ try { Log.d("lixm","here will blocking"); int len = inputStream.read(buffer); String receiveData = new String(buffer,0,len,"UTF-8"); Log.d("lixm","Server,receiveData = " + receiveData); if(!TextUtils.isEmpty(receiveData) && receiveData.toLowerCase().equals("start")){ isStartSend = true; sendData2Pc(); }else if(!TextUtils.isEmpty(receiveData) && receiveData.toLowerCase().equals("stop")){ isStartSend = false; isLoop = false; socket.close(); runOnUiThread(new Runnable() { @Override public void run() { Toast.makeText(MainActivity.this,"服务端关闭",Toast.LENGTH_SHORT).show(); } }); } } catch (IOException e) { Log.d("lixm","IOException : ",e); } } } } }.start(); } private void sendData2Pc(){ // 发送数据的线程 new Thread(){ public void run(){ int times = 1; while(isStartSend){ String echo = " send data: " + times + ", 这里是android端发出的信息。"; try { outputStream.write(echo.getBytes("UTF-8")); outputStream.flush(); Log.d(TAG, echo); times ++; Thread.sleep(1000); } catch (IOException e) { e.printStackTrace(); } catch (InterruptedException e) { e.printStackTrace(); } } } }.start(); } } }