Android TCP/UDP Demo

package com.windystory.battlefield.net; import android.util.Log; import java.io.BufferedReader; import java.io.DataInputStream; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.net.InetAddress; import java.net.Socket; public class TCPUtils { //端口号 public static final int PORT = 9090; //地址 public static final String HOST = "192.168.0.100"; private byte[] buffer = new byte[1024]; public static Socket socket; //Double CheckLock（DCL模式单例） private static TCPUtils utils = null; public static TCPUtils getInstance() { if (utils == null) { synchronized(TCPUtils.class){ if (utils == null) { utils = new TCPUtils(); } } } return utils; } /** * 构造函数，创建TCP客户端 */ private TCPUtils() { try { socket = new Socket(HOST, PORT); } catch (IOException e) { e.printStackTrace(); } } /** * 设置超时时间，该方法必须在bind方法之后使用. * * @param timeout 超时时间 * @throws Exception */ public void setSoTimeout(final int timeout) throws Exception { socket.setSoTimeout(timeout); } /** * 获得超时时间. * * @return 返回超时时间 * @throws Exception */ public int getSoTimeout() throws Exception { return socket.getSoTimeout(); } public final Socket getSocket() { return socket; } /** * 向指定的服务端发送数据信息. * * @param data 发送的数据信息 * @return 返回构造后俄数据报 * @throws IOException */ public final OutputStream send( String data) throws IOException { BufferedReader reader = new BufferedReader(new InputStreamReader(System.in)); OutputStream outputStream = socket.getOutputStream(); if (data != null) { outputStream.write(data.getBytes()); } return outputStream; } /** * 接收从指定的服务端发回的数据. * * @return 返回从指定的服务端发回的数据. * @throws Exception */ public final String receive() throws Exception { try { InputStream inputStream = socket.getInputStream(); DataInputStream input = new DataInputStream(inputStream); byte[] b = new byte[10000]; while (true) { int length = input.read(b); String Msg = new String(b, 0, length, "gb2312"); Log.v("data", Msg); return Msg; } } catch (Exception ex) { ex.printStackTrace(); } return ""; } /** * 关闭tcp连接. */ public void close() { try { socket.close(); } catch (Exception ex) { ex.printStackTrace(); } } }