1 　　try {
2 　　ServerSocket serverSocket = new ServerSocket(50000);    //创建一个ServerSocket，用于监听客户端Socket的连接请求
3 　　    while(true) {
4 　　        Socket socket = serverSocket.accept();    　　　　//每当接收到客户端的Socket请求，服务器端也相应的创建一个Socket
5 　　　　　　//todo开始进行Socket通信
6 　　    }
7 　　}catch (IOException e) {
8 　　    e.printStackTrace();
9 　　}

1 　　try {
2 　　    socket = new Socket("192.168.1.101", 50000);    //192.168.1.101是服务器的IP地址，50000是端口号
3 　　　　//todo开始进行Socket通信
4 　　} catch (IOException e) {
5 　　    e.printStackTrace();
6 }

 1 　　/*
 2 　　 * Class    :   MyServer类，用于监听客户端Socket连接请求
 3 　　 * Author   :   博客园-依旧淡然
 4 　　 */
 5 　　public class MyServer {
 6 　　
 7 　　    //定义ServerSocket的端口号
 8 　　    private static final int SOCKET_PORT = 50000;
 9 　　    //使用ArrayList存储所有的Socket
10 　　    public static ArrayList<Socket> socketList = new ArrayList<Socket>();
11 　　
12 　　    public void initMyServer() {
13 　　        try {
14 　　　　　　　　//创建一个ServerSocket，用于监听客户端Socket的连接请求
15 　　            ServerSocket serverSocket = new ServerSocket(SOCKET_PORT);
16 　　            while(true) {
17 　　                //每当接收到客户端的Socket请求，服务器端也相应的创建一个Socket
18 　　                Socket socket = serverSocket.accept();
19 　　                socketList.add(socket);
20 　　                //每连接一个客户端，启动一个ServerThread线程为该客户端服务
21 　　                new Thread(new ServerThread(socket)).start();
22 　　            }
23 　　        }catch (IOException e) {
24 　　            e.printStackTrace();
25 　　        }
26 　　    }
27 　　
28 　　    public static void main(String[] args) {
29 　　        MyServer myServer = new MyServer();
30 　　        myServer.initMyServer();
31 　　    }
32 　　}

 1 　　public class ServerThread implements Runnable {
 2 　　
 3 　　    //定义当前线程所处理的Socket
 4 　　    private Socket socket = null;
 5 　　    //该线程所处理的Socket对应的输入流
 6 　　    private BufferedReader bufferedReader = null;
 7 　　
 8 　　    /*
 9 　　     * Function  :    ServerThread的构造方法
10 　　     * Author    :    博客园-依旧淡然
11 　　     */
12 　　    public ServerThread(Socket socket) throws IOException {
13 　　        this.socket = socket;
14 　　        //获取该socket对应的输入流
15 　　        bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
16 　　    }
17 　　
18 　　    /*
19 　　     * Function  :    实现run()方法，将读到的客户端内容进行广播
20 　　     * Author    :    博客园-依旧淡然
21 　　     */
22 　　    public void run() {
23 　　        try {
24 　　            String content = null;
25 　　            //采用循环不断地从Socket中读取客户端发送过来的数据
26 　　            while((content = bufferedReader.readLine()) != null) {
27 　　                //将读到的内容向每个Socket发送一次
28 　　                for(Socket socket : MyServer.socketList) {
29 　　                    //获取该socket对应的输出流
30 　　                    PrintStream printStream = new PrintStream(socket.getOutputStream());
31 　　                    //向该输出流中写入要广播的内容
32 　　                    printStream.println(packMessage(content));
33 　　
34 　　                }
35 　　            }
36 　　        } catch(IOException e) {
37 　　            e.printStackTrace();
38 　　        }
39 　　    }
40 　　
41 　　    /*
42 　　     * Function  :    对要广播的数据进行包装
43 　　     * Author    :    博客园-依旧淡然
44 　　     */
45 　　    private String packMessage(String content) {
46 　　        String result = null;
47 　　        SimpleDateFormat df = new SimpleDateFormat("HH:mm:ss");    //设置日期格式
48 　　        if(content.startsWith("USER_ONE")) {
49 　　            String message = content.substring(8);        //获取用户发送的真实的信息
50 　　            result = "\n" + "往事如风  " + df.format(new Date()) + "\n" + message;
51 　　        }
52 　　        if(content.startsWith("USER_TWO")) {
53 　　            String message = content.substring(8);        //获取用户发送的真实的信息
54 　　            result = "\n" + "依旧淡然  " + df.format(new Date()) + "\n" + message;
55 　　        }
56 　　        return result;
57 　　    }
58 　　
59 　　}

 1     /*
 2      * Function   :   初始化Socket
 3      * Author     :   博客园-依旧淡然
 4      */
 5     private void initSocket() {
 6         try {
 7             socketUser1 = new Socket(URL_PATH, SOCKET_PORT);            //用户1的客户端Socket
 8             socketUser2 = new Socket(URL_PATH, SOCKET_PORT);            //用户2的客户端Socket
 9             clientThread = new ClientThread();        //客户端启动ClientThread线程，读取来自服务器的数据
10             clientThread.start();
11         } catch (IOException e) {
12             e.printStackTrace();
13         }
14     }

 1     /*
 2      * Function   :   run()方法，用于读取来自服务器的数据
 3      * Author     :   博客园-依旧淡然
 4      */
 5 　　public void run() {
 6 　　try {
 7 　　        String content = null;
 8 　　        while((content = bufferedReader .readLine()) != null) {
 9 　　            Bundle bundle = new Bundle();
10 　　            bundle.putString(KEY_CONTENT, content);
11 　　            Message msg = new Message();
12 　　            msg.setData(bundle);            //将数据封装到Message对象中
13 　　            myHandler.sendMessage(msg);
14 　　        }
15 　　    } catch (Exception e) {
16 　　        e.printStackTrace();
17 　　    }
18 　　}

 1     /*
 2      * Class      :   内部类MyHandler，用于接收消息并处理
 3      * Author     :   博客园-依旧淡然
 4      */
 5     private class MyHandler extends Handler {
 6         public void handleMessage(Message msg) {
 7             Bundle bundle = msg.getData();            //获取Message中发送过来的数据
 8             String content = bundle.getString(KEY_CONTENT);
 9             MyContent.setContent(content);            //保存聊天记录
10             mTextView.setText(MyContent.getContent());
11         }
12     }