文章目录
一、服务器端 ServerSocket 开发
1、创建服务器端套接字 ServerSocket
2、等待客户端请求
3、管理客户端连接
4、接收客户端数据线程
5、向客户端发送数据线程
二、服务器端 ServerSocket 完整代码示例
一、服务器端 ServerSocket 开发
1、创建服务器端套接字 ServerSocket
在服务器端 , 创建 ServerSocket , 绑定一个给定的端口号 8088 80888088 ,
// 服务器端 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()) } }
