【Groovy】使用 Groovy 语言开发服务器 Server 和客户端 Client 套接字程序 ( 服务器客户端完整代码示例 | 运行服务器端与客户端效果及过程分析 )

// 服务器端
def serverSocket = new ServerSocket(8088)

// 存放客户端连接的集合
def sockets = []

// 服务器端是否关闭
def isQuit = false;

// 接收线程 , 接收客户端传递的数据
Thread.start {
    while (!isQuit) {
        // 等待接收客户端请求
        def socket = serverSocket.accept()

        /*
            上述 accept 操作还会抛出异常
            public Socket accept() throws IOException
            在 Java 中必须捕获处理该异常
            在 Groovy 中不强制要求处理异常
         */

        // 将客户端连接存储到 客户端连接的集合 sockets 集合中
        sockets << socket

        // 再次开启一个线程 , 读取客户端传输的内容
        Thread.start {
            // 读取数据的缓冲区
            def bytes = new byte[1024]
            // 没有关闭的情况下才开始读取
            while (!socket.isClosed()) {
                def len = socket.inputStream.read(bytes)
                if (len > 0) {
                    println "${socket.remoteSocketAddress} : ${new String(bytes, 0, len)}"
                }
                socket.outputStream.write("Hello Client, this is Server !".getBytes())
            }
        }

    }

    // 关闭服务器
    if (!serverSocket.isClosed()) {
        serverSocket.close();
    }
    sockets.each {
        it.close()
    }
}

// 读取命令行数据
def scanner = new Scanner(System.in)

// 发送线程 , 向客户端发送数据
Thread.start {
    while (!isQuit) {
        def inputString = scanner.nextLine()
        if (inputString == "quit") {
            isQuit = true
            // 关闭服务器
            if (!serverSocket.isClosed()) {
                serverSocket.close();
            }
            sockets.each {
                it.close()
            }
        }
        sockets*.outputStream*.write(inputString.getBytes())
    }
}

// 客户端套接字
def client = new Socket("127.0.0.1", 8088)

// 接收线程 , 读取服务器端传输的内容
Thread.start {
    // 读取数据的缓冲区
    def bytes = new byte[1024]
    // 没有关闭的情况下才开始读取
    while (!client.isClosed()) {
        def len = client.inputStream.read(bytes)
        if (len > 0) {
            println "${client.remoteSocketAddress} : ${new String(bytes, 0, len)}"
        }
    }
}

// 发送线程 , 向服务器端发送数据
Thread.start {
    client.outputStream.write("Hello Server , This is Client !".getBytes())
}

"Hello Server , This is Client !"

"Hello Client, this is Server !"