public class ChatSocket extends Thread {Socket socket;public ChatSocket(Socket s) {socket = s;}public void out(String out) {try {socket.getOutputStream().write(out.getBytes("UTF-8"));} catch (Exception e) {e.printStackTrace();}}@Overridepublic void run() {int count = 0;while (true) {count++;out("loop : " + count + ", \t");try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}}}

public class ServerListener extends Thread {@Overridepublic void run() {ServerSocket serverSocket;try {serverSocket = new ServerSocket(12345);while (true) {// 监听 12345端口Socket socket = serverSocket.accept();// 建立连接JOptionPane.showMessageDialog(null,"There is an client access 12345 port");new ChatSocket(socket).start();}} catch (IOException e) {e.printStackTrace();}}
}

public class MyServerSocket {public static void main(String[] args) {new ServerListener().start();}}

public class MainActivity extends Activity {EditText etIP, etComposing;TextView tvContent;@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);etIP = (EditText) findViewById(R.id.etIP);etComposing = (EditText) findViewById(R.id.etComposing);tvContent = (TextView) findViewById(R.id.tvContent);findViewById(R.id.btnConn).setOnClickListener(new OnClickListener() {@Overridepublic void onClick(View v) {// TODO Auto-generated method stub
                connect();}});findViewById(R.id.btnSend).setOnClickListener(new OnClickListener() {@Overridepublic void onClick(View v) {// TODO Auto-generated method stub
                send();}});}Socket socket = null;BufferedWriter bw;BufferedReader br;public void connect() {AsyncTask<Void, String, Void> read = new AsyncTask<Void, String, Void>() {@Overrideprotected Void doInBackground(Void... params) {try {socket = new Socket(etIP.getText().toString(), 12345);bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));br = new BufferedReader(new InputStreamReader(socket.getInputStream()));publishProgress("@success");try {String line;while ((line = br.readLine()) != null) {publishProgress(line);}} catch (IOException e) {// TODO Auto-generated catch block
                        e.printStackTrace();}} catch (UnknownHostException e) {// TODO Auto-generated catch blockpublishProgress("@fail");e.printStackTrace();} catch (IOException e) {publishProgress("@fail");e.printStackTrace();}return null;}@Overrideprotected void onProgressUpdate(String... values) {if (values[0].equals("@success")) {tvContent.append("Success connect to Server\n");} else if(values[0].equals("@fail")) {tvContent.append("Connect to Server Fail\n");} else{Log.d("CARLOZ", "Other: " + values[0]);tvContent.append("Other: " + values[0] + "\n");}super.onProgressUpdate(values);}};read.execute();}public void send() {try {tvContent.append("Me: " + etComposing.getText().toString() + "\n");bw.write(etComposing.getText().toString() + "\n");bw.flush();etComposing.setText("");// clear} catch (IOException e) {// TODO Auto-generated catch block
            e.printStackTrace();}}
}