import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;public class tListen extends Thread{public static ServerSocket ssct_server;public static Socket sct_server;public static InetAddress ip_server;public static Integer pt_server;// 线程变量public static tReceive t_receive;// 本机IP和PORTpublic tListen(InetAddress ip, int port){this.ip_server = ip;this.pt_server = port;}public void run(){// 开始监听try{fMain.l_status.setText("状态:正在监听客户端......");ssct_server = new ServerSocket(pt_server,2,ip_server);sct_server = ssct_server.accept();fMain.l_status.setText("状态:已经连接上客户端!");fMain.set_btn(0, 1);// 启动接收线程t_receive = new tReceive(sct_server); t_receive.start();}catch (Exception e0){fMain.l_status.setText("错误:" + e0);if (ssct_server != null)try{ssct_server.close();}catch (Exception e1){fMain.l_status.setText("错误:" + e1);}}      }}

package com.hzhi.mouse_mb;import java.net.Socket;import android.os.Bundle;
import android.os.Message;
import android.widget.Toast;public class ConnectThread extends Thread{public static Socket socket_client;public static String ip_server;public static int port_server;// 消息变量private Message msg;private Bundle bdl;public ConnectThread(String ip, int pt){this.ip_server = ip;this.port_server = pt;}public void run(){try{socket_client = new Socket(ip_server, port_server);send_message(MainActivity.msg_con_stop, "");           }catch(Exception e){send_message(MainActivity.msg_error, e.getMessage());}}// 发送消息(用于更新UI)public void send_message(int x, String s){msg = new Message();bdl = new Bundle();   bdl.putString("1",s);msg.what = x;msg.setData(bdl);  MainActivity.main_handler.sendMessage(msg);}}