服务器

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;

import com.sun.xml.internal.bind.v2.runtime.unmarshaller.XsiNilLoader.Array;

public class Myset {

    public static void main(String[] args) {

        // 定义一个集合
        final ArrayList<Socket> ss = new ArrayList<Socket>();
        try {
            // 设置服务器的端口号
            ServerSocket s = new ServerSocket(8888);

            while (true) {
                System.out.println("等待接收一个新用户的请求");
                // 定义socket接收
                final Socket socket = s.accept();
                // 把接收到的放到结合中去
                ss.add(socket);
                // 开启线程
                new Thread() {

                    public void run() {
                        try {
                            // 读取发送过来的东西
                            BufferedReader b = new BufferedReader(
                                    new InputStreamReader(
                                            socket.getInputStream(), "utf-8"));
                            // 利用循环多次接受
                            while (true) {
                                // 把读到的值付给data
                                String data = b.readLine();
                                // 新建一个socket 比对集合中你接收到的客户端
                                for (Socket sk : ss) {

                                    // 这个判断是不给自己发
                                    // if (sk != socket) {
                                    // 创建输出流
                                    PrintWriter pw = new PrintWriter(
                                            sk.getOutputStream());

                                    // 把date的值发送出去
                                    pw.println(data + "123");
                                    System.out.println(data + "123");
                                    // 刷新
                                    pw.flush();

                                    // }
                                }
                            }

                        } catch (Exception e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }

                    };
                }.start();
            }

        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

    }

}