Java Socket PC端 服务器 TCP

功能：

    监听端口：30000；

    通过客户端IP地址判断该客户端是否已经连接，若已经连接就删除掉原来的Socket，重新建立连接；

    有客户端连接后自动发送一送一条"已连接 "给该客户端；

    对收到消息判断是否为空格组成或其他制表符等的无意义字段，对含有有意义字符的广播给所有客户端；

[MySocketServer.java]:

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;

@SuppressWarnings("resource")
public class MySocketServer {
    // 定义保存所有Socket的ArrayList
    public static ArrayList<Socket> socketList = new ArrayList<Socket>();
    public static ArrayList<String> ipList = new ArrayList<String>();

    public static void main(String args[]) throws IOException {
        ServerSocket ss = new ServerSocket(30000);
        while (true) {
            // 此行代码会阻塞，一直等待别人的连接
            Socket s = ss.accept();

            String ip = s.getInetAddress().toString();
            ip = s.getInetAddress().toString();
            if (ipList.size() == 0) {
                System.out.println("提醒：" + ip + " 用户连接到服务器！");
            }
            for (int i = 0; i < ipList.size(); i++) {
                if (ip.equals(ipList.get(i))) {
                    ipList.remove(i);
                    socketList.remove((i));
                    System.out.println("提醒：" + ip + " 用户已重新连接到服务器！");
                } else {
                    System.out.println("提醒：" + ip + " 用户连接到服务器！");
                }
            }

            ipList.add(ip);
            socketList.add((s));
            // 每当一个客户端连接后，启动一个ServerThread线程为该客户端服务
            new Thread(new ServerThread(s)).start();
        }
    }
}

[ServerThread.java]:

import java.io.BufferedReader;
import java.io.IOException;
import java.net.SocketException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;

// 负责处理每个线程通信的线程类
public class ServerThread implements Runnable {
    // 定义当前线程要处理的Socket
    Socket s = null;
    // 该线程处理的Socket对应的输入输出流
    BufferedReader br = null;
    int n = 0;

    public ServerThread(Socket s) throws IOException {
        this.s = s;
        // 初始化该Socket对应的输入输出流
        br = new BufferedReader(new InputStreamReader(s.getInputStream(),
                "utf-8"));
    }

    public void run() {
        try {
            if (n == 0) {
                OutputStream osGuangBo = s.getOutputStream();
                osGuangBo.write(("已连接
").getBytes("utf-8"));
            }
            String content = null;
            // 采用循环不断从Socket中读取客户端发送过来的数据
            while ((content = br.readLine()) != null) {
                /*
                 * 当收到的字符串不是空或无意义的空格、TAB制表符的时候
                 * 才进行处理；String.trim().isEmpty()去掉前导空白和后 导空白，再判断是否为空;
                 */
                if (!content.trim().isEmpty()) {
                    System.out.println("收到：" + content);

                    // 告知客户端已收到消息
                    // OutputStream os = s.getOutputStream();
                    // os.write("SUCESS".getBytes("utf-8"));

                    // 遍历socketList中的每个Socket，将内容向每个Socket发送一次
                    for (Socket s : MySocketServer.socketList) {
                        // 不能声明在for循环外部，否则输出流就只是主线程传进来的那一个，导致广播的消息都给了那一个socket
                        OutputStream osGuangBo = s.getOutputStream();
                        osGuangBo.write(("广播：" + content + "
")
                                .getBytes("utf-8"));
                    }
                }
            }
        } catch (SocketException e) {
            System.out.println("Socket Reset!");
            // 删除该Socket
            MySocketServer.socketList.remove(s);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}