（转）C#与Android通过adb实现usb通讯

Runtime.getRuntime().exec("adb forward tcp:12580 tcp:10086");   
Thread.sleep(3000);  

import java.io.IOException;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;


public class TcpConnect implements Runnable{
    private final  int SERVER_PORT = 10086;
    private ServerSocket mServerSocket;
    private Socket mClient;
    private String mDeviceId;
    private String mDeviceType;
    public TcpConnect(String aDeviceId, String aDeviceType){
        this.mDeviceId= aDeviceId;
        this.mDeviceType = aDeviceType;
        try {             
            String ip = InetAddress.getLocalHost().getHostAddress();  
            System.out.println("ip地址是: " + ip);
            //System.out.println(aDeviceId + "   型号: " + aDeviceType);
            mServerSocket = new ServerSocket(SERVER_PORT);
            System.out.println("TcpConnect" + "建立Socket");
        　　// listen();
            
        } catch (IOException e) {
            // TODO Auto-generated catch block
            //e.printStackTrace();
            System.out.println("TcpConnect" + e.getMessage());
        }        
    }
    
    public void listen(){
        while(true){            
            try {
            　　mClient = mServerSocket.accept();    
    　　　　　　 // Log.e("TcpConnect", "在积极的监听");
        　　} catch (IOException e) {
            　　// TODO Auto-generated catch block
            　　//e1.printStackTrace();
            　　System.out.println("TcpConnect" + e.getMessage());
        　　}
        }
        
    }
    

    @Override
    public void run() {
        // TODO Auto-generated method stub    
    　　// if(mClient.isConnected()){
        BufferedOutputStream out = null;    
        System.out.println("TcpConnect" + "开始监听");
        while(true){
        try{                    
        　　// Log.e("TcpConnect", "开始监听");
            mClient = mServerSocket.accept();    
        　　// if(mClient.isConnected()){
            System.out.println("TcpConnect" + "检测到有连接");
            out = new BufferedOutputStream(mClient.getOutputStream());        
            String recordStr = mDeviceId + "|" + mDeviceType;
            out.write(recordStr.getBytes("utf-8"));
    　　　　 // int length = recordStr.getBytes().length;        
    　　　　 // byte[] b = recordStr.getBytes();    
    　　　　 // out.writeInt(length);        
    　　　　 // out.write(b);    
            out.flush();
            // Log.e("TcpConnect", recordStr);
　　　　　　  // out.flush();            
    　　　　 // }
        } catch(Exception e){
　　　　　　System.out.println("TcpConnect" + e.getMessage());
        
        }finally{
            if(out != null){
                try {
                    out.close();
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    System.out.println("TcpConnect" + e.getMessage());
                }
                
            }
            if(mServerSocket != null){
                try {
                    mServerSocket.close();
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    System.out.println("TcpConnect" + e.getMessage());
                }
            }
    //    }
        }
        
        
        }    
    }
    
      public static void main(String[] args){
          new Thread(new TcpConnect("2366578546946", "T959")).start();
      }
    

    }

 Process p = new Process(); //实例一个Process类，启动一个独立进程
                p.StartInfo.FileName = "cmd.exe"; //设定程序名
                p.StartInfo.UseShellExecute = false; //关闭Shell的使用
                p.StartInfo.RedirectStandardInput = true; //重定向标准输入
                p.StartInfo.RedirectStandardOutput = true; //重定向标准输出
                p.StartInfo.RedirectStandardError = true; //重定向错误输出
                p.StartInfo.CreateNoWindow = true; // 设置不显示窗口
                p.StartInfo.ErrorDialog = false;
                p.StartInfo.WindowStyle = ProcessWindowStyle.Hidden;
                p.Start();
                p.StandardInput.WriteLine(@"adb forward tcp:12580 tcp:10086");


                //         Thread.Sleep(3000);   
                SocketClient client = new SocketClient();
                MessageBox.Show("收到的数据为: " + client.listen());

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net;
using System.Net.Sockets;


namespace PreInstaller.IO
{
    class SocketClient
    {
  

        public string listen()
        {          
            Socket client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            IPAddress myIP = IPAddress.Parse("127.0.0.1");
            IPEndPoint EPhost = new IPEndPoint(myIP, int.Parse("12580"));
            client.Connect(EPhost);          
            byte[] t_data = new byte[1024];
            string data = null;
            int i = 0;
             while ((i = client.Receive(t_data)) != 0)
             {
                 data = Encoding.UTF8.GetString(t_data, 0, i);                      

             }
             client.Close();
             return data;             
        }
    }
}