public class UDPClient {

     private static final int SERVER_PORT = 6000;

     private DatagramSocket dSocket = null;

     private String msg;

     private String ip;

     public UDPClient(String msg, String ip) {

         super();

         this.msg = msg;

         this.ip = ip;

     }

     public void send() {

         try {

             dSocket = new DatagramSocket();

             byte[] bys = msg.getBytes();

             int len = bys.length;

             DatagramPacket dp = new DatagramPacket(bys, len, InetAddress.getByName(ip), SERVER_PORT);

             dSocket.send(dp);

             // }

         } catch (Exception e) {

             // TODO Auto-generated catch block

             e.printStackTrace();

         } finally {

             dSocket.close();

         }

     }

 }

public class UDPServer implements Runnable {

	private static final int PORT = 6000;

	private byte[] msg = new byte[2048];

	Context context;

	public UDPServer(Context context) {

		this.context = context;

	}

	@Override

	public void run() {

		DatagramSocket s;

		try {

			s = new DatagramSocket(PORT);

			while (true) {

				int len = msg.length;

				DatagramPacket dp = new DatagramPacket(msg, len);

				s.receive(dp);

				byte[] byc = dp.getData();

				int len2 = dp.getLength();

				String ss = new String(byc, 0, len2);

				Message msg = Message.obtain();

				msg.what = 0x789;

				msg.obj = ss;

				MainActivity.handler.sendMessage(msg);

			}

		} catch (Exception e) {

			e.printStackTrace();

		}

	}

}