Android UDP broadcast Example

package com.udp; import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.net.SocketException; import java.net.UnknownHostException; import java.util.ArrayList; import java.util.HashMap; import java.util.Map; import android.app.Activity; import android.net.DhcpInfo; import android.net.wifi.WifiManager; import android.os.Bundle; import android.os.Handler; import android.os.Message; import android.util.Log; import android.view.View; import android.view.View.OnClickListener; import android.widget.Button; import android.widget.ListView; import android.widget.SimpleAdapter; import android.widget.Toast; public class UpdnetActivity extends Activity { public final int PORT = 34567; private Button serverButton; private Button clientButton; private Button CloseButton; private ListView listView2; private ArrayList<Map<String, Object>> arraylist; private SimpleAdapter mSimpleAdapter; private final int MESSAGE_LIST_UPDATE = 0; private Button refreshButton; private int ServerTag = 0; private int ClientTag = 0; Thread ServerThread; Thread ClientThread; DatagramSocket sr; private String IpString; private String DeviceName; private HashMap<String, Object> map; public String sysinfo(){ return android.os.Build.MODEL; } /** Called when the activity is first created. */ @Override public void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.main); serverButton = (Button) findViewById(R.id.button1); clientButton = (Button) findViewById(R.id.button2); CloseButton = (Button) findViewById(R.id.button3); refreshButton = (Button) findViewById(R.id.button4); serverButton.setOnClickListener(new OnClickListener() { @Override public void onClick(View v) { // TODO Auto-generated method stub ServerTag = 0; ServerThread =new Thread(new SendUdpBroadcast()); ServerThread.start(); } }); clientButton.setOnClickListener(new OnClickListener() { @Override public void onClick(View v) { ClientTag = 0; // TODO Auto-generated method stub ClientThread =new Thread(new Clientthread()); ClientThread.start(); } }); CloseButton.setOnClickListener(new OnClickListener() { @Override public void onClick(View v) { // TODO Auto-generated method stub ServerTag = 1; ClientTag = 1; if(ServerThread != null){ ServerThread.interrupt(); ServerThread = null; } if(ClientThread != null){ ClientThread.interrupt(); ClientThread = null; sr.disconnect(); } } }); arraylist = new ArrayList<Map<String, Object>>(); mSimpleAdapter = new SimpleAdapter(this, arraylist, R.layout.controldevice_name, new String[] { "devicename", "ipaddress" }, new int[] { R.id.name, R.id.state }); listView2 = (ListView) findViewById(R.id.listview2); listView2.setAdapter(mSimpleAdapter); refreshButton.setOnClickListener(new OnClickListener() { public void onClick(View v) { // TODO Auto-generated method stub Refresh(); } }); } private void Refresh(){ arraylist.clear(); mSimpleAdapter.notifyDataSetChanged(); } public class SendUdpBroadcast extends Thread{ public void run() { // TODO Auto-generated method stub super.run(); DatagramSocket socket; try{ Log.e("SendUdpBroadcast","SendUdpBroadcast"); socket = new DatagramSocket(); InetAddress serverAddress = InetAddress.getByName(getServerName()); String str = sysinfo(); byte data [] = str.getBytes(); DatagramPacket packet = new DatagramPacket(data,data.length,serverAddress,PORT); while (ServerTag == 0) { try { Log.d("Udpnet", "serverAddress"+serverAddress); socket.send(packet); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } try { Thread.sleep(2000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }catch (Exception e) { // TODO: handle exception } } } private String intToIp(int i) { return ( i & 0xFF) + "." + ((i >> 8 ) & 0xFF) + "." + ((i >> 16 ) & 0xFF) + "." + ((i >> 24 ) & 0x00 ) ; } private String getServerName(){ WifiManager mWifiManager = (WifiManager) getSystemService(WIFI_SERVICE); DhcpInfo info = mWifiManager.getDhcpInfo(); return intToIp(info.gateway); } // public class Serverthread extends Thread { // DatagramSocket ss; // // public void run() { // // TODO Auto-generated method stub // try { // ss = new DatagramSocket(); // } catch (SocketException e) { // e.printStackTrace(); // } // try { // ss.setBroadcast(true); // } catch (SocketException e) { // e.printStackTrace(); // } // byte[] b = new byte[100]; // DatagramPacket p = new DatagramPacket(b, b.length); // try { // p.setAddress(InetAddress.getByAddress(new byte[] { (byte) 192, // (byte) 168, (byte) 1, (byte) 0 })); // } catch (UnknownHostException e) { // e.printStackTrace(); // } // p.setPort(PORT); // int i = 0; // while (true) { // // String s = new Integer(i++).toString(); // b = s.getBytes(); // p.setData(b); // try { // Log.e("Udpnet", "Send data"); // ss.send(p); // } catch (IOException e) { // // TODO Auto-generated catch block // e.printStackTrace(); // } // try { // Thread.sleep(2000); // } catch (InterruptedException e) { // // TODO Auto-generated catch block // e.printStackTrace(); // } // } // } // } public class Clientthread extends Thread { DatagramSocket sr; public void run() { // TODO Auto-generated method stub super.run(); try { sr = new DatagramSocket(PORT); } catch (SocketException e) { // TODO Auto-generated catch block Log.e("Clientthread","SocketException"); e.printStackTrace(); } if(sr == null){ Log.e("Clientthread","sr == null"); } while (ClientTag == 0) { byte[] buf = new byte[256]; DatagramPacket pct = new DatagramPacket(buf, buf.length); try { Log.e("UdpClient", "receiver"); sr.receive(pct); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } String s = new String(buf); Log.e("UpdClient", s.replaceAll("\0", "") + " " + pct.getAddress().toString()); IpString = pct.getAddress().toString(); IpString = IpString.substring(1, IpString.length()); DeviceName = new String(pct.getData(),pct.getOffset(),pct.getLength()); Log.e("UpdClient", "IpString" + IpString); Message msg = new Message(); msg.what = MESSAGE_LIST_UPDATE; mHandler.sendMessage(msg); } } } public Handler mHandler = new Handler() { @Override public void handleMessage(Message msg) { // TODO Auto-generated method stub super.handleMessage(msg); switch (msg.what) { case MESSAGE_LIST_UPDATE: updateArraylist(); break; } } }; private void updateArraylist(){ map = new HashMap<String, Object>(); map.put("devicename", DeviceName); map.put("ipaddress", IpString); arraylist.add(map); mSimpleAdapter.notifyDataSetChanged(); } }