Android UDP

      package com.chy.socket;
      import java.io.IOException;
      import java.net.DatagramPacket;
      import java.net.DatagramSocket;
      import java.net.SocketException;
      import com.chy.global.GlobalValue;
      public class UdpClient {
     	private boolean isStop = false;
     	private DatagramSocket datagramSocket = null;
     	private onReceiveListener onReceiveListener = null;
     	private ReadThread readThread = null;
     	public interface onReceiveListener {
     		public void onReceive(DatagramPacket packet);
      	}
     	class ReadThread extends Thread {
     		@Override
     		public void run() {
     			byte[] buffer = new byte[GlobalValue.READ_BLOCK_SIZE];
     			DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
     			while (!isStop && !isInterrupted()) {
     				try {
      					datagramSocket.receive(packet);
     					if (onReceiveListener != null) {
      						onReceiveListener.onReceive(packet);
      					}
      				} catch (IOException ex) {
      					ex.printStackTrace();
      				}
      			}
      		}
      	}
     	public UdpClient(int port, onReceiveListener onReceiveListener) {
     		try {
      			datagramSocket = new DatagramSocket(port);
      		} catch (SocketException ex) {
      			ex.printStackTrace();
      		}
     		if (datagramSocket == null) {
     			return;
      		}
     		this.onReceiveListener = onReceiveListener;
      		readThread = new ReadThread();
      		readThread.start();
      	}
     	public synchronized boolean send(byte[] buffer) {
     		boolean result = false;
     		if(datagramSocket != null) {
     			DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
     			try {
      				datagramSocket.send(packet);
      				result = true;
      			} catch (IOException ex) {
      				ex.printStackTrace();
      			}
      		}
     		return result;
      	}
     	public void close() {
      		isStop = true;
     		if(readThread != null && !readThread.isInterrupted()) {
      			readThread.interrupt();
      			readThread = null;
      		}
     		if (datagramSocket != null) {
      			datagramSocket.close();
      		}
      	}
      }
  
 

文章来源: blog.csdn.net，作者：福州-司马懿，版权归原作者所有，如需转载，请联系作者。

原文链接：blog.csdn.net/chy555chy/article/details/51560186