一、服务器端 ServerSocket 开发

1、创建服务器端套接字 ServerSocket

在服务器端 , 创建 ServerSocket , 绑定一个给定的端口号 $8088$ ,

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

  

 

  
1
  
2
 

2、等待客户端请求

然后调用 ServerSocket 服务器套接字 的 accept 方法 , 阻塞当前线程 , 等待客户端连接 ,

        // 等待接收客户端请求
        def socket = serverSocket.accept()

  

 

  
1
  
2
 

注意 , 上述 accept 操作还会抛出异常 ,

public Socket accept() throws IOException

  

 

  
1
 

在 Java 中必须捕获并处理该异常 , 在 Groovy 中不强制要求处理异常 , 建议进行捕获处理 ;

3、管理客户端连接

声明一个集合 , 用于存放客户端连接 , 集合类型是 ArrayList 类型 ;

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

  

 

  
1
  
2
 

当 ServerSocket 服务器套接字 accept 到客户端请求 , 会得到 客户端的 Socket 套接字 , 将客户端连接存储到 客户端连接的集合 sockets 集合中 ;

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

  

 

  
1
  
2
 

4、接收客户端数据线程

获取到 客户端套接字 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())
            }
        }

  

 

  
1
  
2
  
3
  
4
  
5
  
6
  
7
  
8
  
9
  
10
  
11
  
12
  
13
 

5、向客户端发送数据线程

使用 Scanner 从命令行中读取数据 ,

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

  

 

  
1
  
2
 

命令行接收字符串数据 ,

def inputString = scanner.nextLine()

  

 

  
1
 

将命令行输入的字符串 , 发送给所有的客户端进程 ;

sockets*.outputStream*.write(inputString.getBytes())

  

 

  
1
 

服务器向客户端发送数据的线程 :

// 读取命令行数据
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())
    }
}

  

 

  
1
  
2
  
3
  
4
  
5
  
6
  
7
  
8
  
9
  
10
  
11
  
12
  
13
  
14
  
15
  
16
  
17
  
18
  
19
  
20
 

二、服务器端 ServerSocket 完整代码示例

// 服务器端
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())
    }
}


  

 

  
1
  
2
  
3
  
4
  
5
  
6
  
7
  
8
  
9
  
10
  
11
  
12
  
13
  
14
  
15
  
16
  
17
  
18
  
19
  
20
  
21
  
22
  
23
  
24
  
25
  
26
  
27
  
28
  
29
  
30
  
31
  
32
  
33
  
34
  
35
  
36
  
37
  
38
  
39
  
40
  
41
  
42
  
43
  
44
  
45
  
46
  
47
  
48
  
49
  
50
  
51
  
52
  
53
  
54
  
55
  
56
  
57
  
58
  
59
  
60
  
61
  
62
  
63
  
64
  
65
  
66
  
67
  
68
  
69
  
70
  
71
  
72
 

文章来源: hanshuliang.blog.csdn.net，作者：韩曙亮，版权归原作者所有，如需转载，请联系作者。

原文链接：hanshuliang.blog.csdn.net/article/details/122386967