Android Socket网络通信

核心提示：import java.io.OutputStreamWriter;import java.io.PrintWriter;import java.net.ServerSocket;import java.net.Socket;import java.util.ArrayList;import java.util.Lis

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.ServerSocket;

import java.net.Socket;

import java.util.ArrayList;

import java.util.List;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

/**

* com Server

*

* @author Aina.huang E-mail: 674023920@qq.com

* @version 创建时间：2010 Jul 14, 2010 10:45:35 AM 类说明

*/

public class Main {

private static final int PORT = 9999;// 端口监听

private List mList = new ArrayList();// 存放客户端socket

private ServerSocket server = null;

private ExecutorService mExecutorService = null;// 线程池

/**

* @param args

*/

public static void main(String[] args) {

// TODO Auto-generated method stub

new Main();

}

public Main() {

try {

server = new ServerSocket(PORT);

mExecutorService = Executors.newCachedThreadPool();// 创建一个线程池

System.out.println("Server Start...");

Socket client = null;

while (true) {

client = server.accept();

mList.add(client);

mExecutorService.execute(new Service(client));// 开启一个客户端线程.

}

} catch (Exception ex) {

ex.printStackTrace();

}

}

public class Service implements Runnable {

private Socket socket;

private BufferedReader in = null;

private String msg = "";

public Service(Socket socket) {

this.socket = socket;

try {

in = new BufferedReader(new InputStreamReader(socket

.getInputStream()));

msg = "user:" + this.socket.getInetAddress() + " come total:"