android手机端与PC端使用adb forword通信

PC端与Android手机端使用adb forword通信

服务器端代码如下：

import java.io.IOException;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;
public class Server {
 public static final String TAG = "server";
 public static int PC_LOCAL_PORT = 22222;
 public static int PHONE_PORT = 22222;
 public static String ADB_PATH = "adb.exe";
 /**
  * @param args
  */
 public static void main(String[] args) {
   // TODO Auto-generated method stub
   YingyonghuiHubServer.execAdb();
 }
 public static void execAdb() {
   // run the adb bridge
   try {
     Process p = Runtime.getRuntime().exec(
         ADB_PATH + " forward tcp:" + PC_LOCAL_PORT + " tcp:"
             + String.valueOf(PHONE_PORT));
     Scanner sc = new Scanner(p.getErrorStream());
     // If there is some output, it failed to start adb
     if (sc.hasNext()) {
       while (sc.hasNext())
         System.out.println(sc.next());
       System.err.println("Cannot start the Android debug bridge");
       return;
     }
     initializeConnection();
   } catch (Exception e) {
     System.err.println(e.toString());
   }
 }
 static Socket socket;
 public static void initializeConnection() {
   // Create socket connection
   try {
     socket = new Socket("localhost", PC_LOCAL_PORT);
     ObjectOutputStream oos = new ObjectOutputStream(
         socket.getOutputStream());
     oos.writeObject("lalala");
     oos.close();
     socket.close();
   } catch (UnknownHostException e) {
     System.err.println("Socket connection problem (Unknown host)"
         + e.getStackTrace());
     e.printStackTrace();
   } catch (IOException e) {
     System.err.println("Could not initialize I/O on socket");
     e.printStackTrace();
   }
 }
}

 客户端代码如下：

import java.io.IOException;
import java.io.ObjectInputStream;
import java.net.ServerSocket;
import java.net.Socket;
import android.app.Activity;
import android.content.Context;
import android.os.AsyncTask;
import android.os.Bundle;
import android.util.Log;
import android.widget.TextView;
import android.widget.Toast;
public class Client extends Activity {
 public static final String TAG = "client";
 public static int PHONE_PORT = 22222;
 Context mContext = null;
 TextView textView = null;
 ServerSocket server = null;
 @Override
 public void onCreate(Bundle savedInstanceState) {
   super.onCreate(savedInstanceState);
   setContentView(R.layout.main);
   this.mContext = this;
   this.textView = (TextView) this.findViewById(R.id.textView1);
   try {
     server = new ServerSocket(PHONE_PORT);
   } catch (IOException e) {
     e.printStackTrace();
     return;
   }
   new RepackTestTask().execute();
 }
 private class RepackTestTask extends AsyncTask {
   @Override
   protected Object doInBackground(Object... params) {
     Socket client = null;
     // initialize server socket
     while (true) {
       try {
         // attempt to accept a connection
         client = server.accept();
         Log.d(TAG, "Get a connection from "
             + client.getRemoteSocketAddress().toString());
         ObjectInputStream ois = new ObjectInputStream(
             client.getInputStream());
         String somewords = (String) ois.readObject();
         Log.d(TAG, "Get some words" + somewords);
         this.publishProgress(somewords);
         client.close();
       } catch (IOException e) {
         Log.e(TAG, "" + e);
       } catch (ClassNotFoundException e) {
         // TODO Auto-generated catch block
         e.printStackTrace();
       }
     }
   }
   @Override
   protected void onProgressUpdate(Object... values) {
     super.onProgressUpdate(values);
     Toast.makeText(mContext, values[0].toString(), Toast.LENGTH_LONG)
         .show();
   }
 }
}

感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！

来源：http://blog.csdn.net/paulluo0739/article/details/8175170