//与UDP数据接收线程通信更新UI线程中EditText控件中的内容receiveHandler=newHandler(){publicvoidhandleMessage(Messagemsg){point2.setText(receiveInfo);}};}//UDP数据接收线程pu...

// 与UDP数据接收线程通信更新UI线程中EditText控件中的内容

receiveHandler = new Handler() {

public void handleMessage(Message msg) {

point2.setText(receiveInfo);

}

};

}

// UDP数据接收线程

public class udpReceiveThread extends Thread {

@Override

public void run() {

try {

socket = new DatagramSocket(8081);

listenStatus = true;

while (listenStatus)

{

// byte[] inBuf= new byte[1024];

byte[] inBuf = new byte[1024];

DatagramPacket inPacket = new DatagramPacket(inBuf,

inBuf.length);

socket.receive(inPacket);

String str = new String(inPacket.getData());

receiveInfo = Change1(str, inPacket.getLength()).trim();

// receiveInfo = new String (inPacket.getData());

// receiveInfo= stringtopoint(inBuf,inPacket.getLength());

socket.close();

Message msg = new Message();

receiveHandler.sendMessage(msg);

try {Thread.sleep(100);

} catch (Exception e) {

// TODO: handle exception

}

}

} catch (Exception e) {

e.printStackTrace();

// TODO Auto-generated catch block

}

}

}

// 发送按钮单击事件

public void SendButtonClick(View source) {

new udpSendThread().start();

}

// 监听按钮点击事件

public void ListenButtonClick(View source) {

if (listenStatus == false) {

stop.setText("停止监听");

new udpReceiveThread().start();

} else {

stop.setText("开始监听");

socket.close();

listenStatus = false;

new udpReceiveThread().interrupt();

}

}

展开