文章目录

• 一、服务器端 ServerSocket 开发
• • 1、创建服务器端套接字 ServerSocket
  • 2、等待客户端请求
  • 3、管理客户端连接
  • 4、接收客户端数据线程
  • 5、向客户端发送数据线程
• 二、服务器端 ServerSocket 完整代码示例

一、服务器端 ServerSocket 开发

---

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

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

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

2、等待客户端请求

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

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

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

public Socket accept() throws IOException

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

3、管理客户端连接

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

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

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

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

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())}}

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

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

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

命令行接收字符串数据 ,

def inputString = scanner.nextLine()

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

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

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

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

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

总结

以上是生活随笔为你收集整理的【Groovy】使用 Groovy 语言开发服务器 Server 和客户端 Client 套接字程序 ( 服务器端开发 )的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错，欢迎将生活随笔推荐给好友。