/*** 测试服务器* */
public class TestServer {public static void main(String[] args) throws IOException {ServerSocket ss = new ServerSocket(5417);Socket client = null;while (true) {System.out.println("waiting for...");client = ss.accept();BufferedReader br = new BufferedReader(new InputStreamReader(client.getInputStream()));System.out.println(br.readLine());}}
}

/*** SocketManager，简单的封装了一下* @author Kross(krossford@foxmail.com)* @date 2014-3-24 21:39:48* */
public class SocketManager {private Socket client = null;//服务器的IP地址private String ip = "113.251.172.30";//监听的端口号private int port = 5417;/*** 获取一个实例* */public static SocketManager newInstance() throws UnknownHostException, IOException {return new SocketManager();}private SocketManager() throws UnknownHostException, IOException {client = new Socket(ip, port);}/*** 发送一条消息* @param msg 消息内容* */public void sendMessage(String msg) throws IOException {PrintWriter printWriter = new PrintWriter(client.getOutputStream());printWriter.print(msg);printWriter.flush();printWriter.close();    //一定要关闭输出流，要不然消息无法送达到服务器
    }
}

/*** 发起请求的线程* @author Kross(krossford@foxmail.com)* @date 2014-3-24 21:40:21* */
public class SocketThread implements Runnable {private String message;public SocketThread(String msg) {message = msg;}@Overridepublic void run() {try {SocketManager.newInstance().sendMessage(message);} catch (UnknownHostException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}}
}

public class MainActivity extends Activity {private EditText etInput = null;private Button bSend = null;@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);Log.i("MainActivity", Thread.currentThread().getName());etInput = (EditText)findViewById(R.id.et_input);bSend = (Button)findViewById(R.id.b_send);bSend.setOnClickListener(new SendButtonListener());}class SendButtonListener implements OnClickListener {@Overridepublic void onClick(View v) {String msg = etInput.getEditableText().toString().trim();new Thread(new SocketThread(msg)).start();etInput.setText("");}}
}