免费网站制作平台建站之星网站

当前位置： 首页 > news >正文

免费网站制作平台,建站之星网站,常州网站建设企业网站制作,能进网站的浏览器文章目录 目录 文章目录 前言 一、Socket通信 1.1 BIO 1.2 NIO 1.3 AIO 二、WebSocket协议 总结 前言 一、Socket通信 Socket是一种用于网络通信的编程接口#xff08;API#xff09;#xff0c;它提供了一种机制#xff0c;使不同主机之间可以通过网络进行数据传输和通信… 文章目录 目录 文章目录 前言 一、Socket通信 1.1 BIO 1.2 NIO 1.3 AIO 二、WebSocket协议 总结 前言 一、Socket通信 Socket是一种用于网络通信的编程接口API它提供了一种机制使不同主机之间可以通过网络进行数据传输和通信。Socket是支持TCP/IP协议栈的应用层与传输层之间的接口。 在Socket编程中有两种常见的角色客户端和服务器端。客户端负责发起连接请求服务器端负责接收并处理连接请求。 Socket通信的基本流程如下 服务器端创建一个ServerSocket对象并指定一个端口号。该对象会监听该端口上的连接请求。客户端创建一个Socket对象并指定要连接的服务器的IP地址和端口号。客户端使用Socket对象发起连接请求向服务器发送连接请求。服务器监听到连接请求后通过accept()方法接受客户端的连接创建一个Socket对象与客户端建立连接。客户端和服务器端通过各自的Socket对象进行数据的读取和写入实现双向的数据交换。数据交换完成后可以关闭连接。客户端和服务器端都可以使用close()方法关闭自己的Socket对象。 通过Socket编程可以实现不同设备之间的网络通信。例如可以使用Socket编程来开发基于TCP/IP的客户端-服务器应用、聊天程序、文件传输程序等。 需要注意的是Socket编程只提供了底层的网络通信接口对于数据的格式、协议、解析等需要自行定义和处理。在Java中可以使用Java标准库中的java.net.Socket和java.net.ServerSocket来实现Socket编程。 socket编程步骤 服务器监听服务器启动后它会有一个线程一直启动等待着客户端端连接。它会定义好自己的端口号。客户端请求客户端端套接字提出连接请求要连接的目标是服务端的套接字。客户端必须要指明服务端套接字的地址和端口号。连接确认当服务端收到客户端的连接请求就会响应客户端套接字的请求建立一个新的线程处理客户端的请求。 1.1 BIO BIOBlocking I/O是Java中的一种阻塞式I/O模型也称为传统的I/O模型。在BIO中每个I/O操作都会阻塞当前线程直到数据准备好或者操作完成。 BIO的工作原理如下 服务器端创建一个ServerSocket对象并监听指定的端口。服务器通过accept()方法等待客户端发起连接请求。当有客户端连接请求到达时服务器通过accept()方法接受客户端的连接并返回一个新的Socket对象。服务器使用新的Socket对象与客户端进行数据的读取和写入。客户端使用Socket对象与服务器进行通信发送请求并接收响应。服务器端和客户端通过读写操作进行数据的交互但是这些操作都是阻塞的直到数据完全发送或接收完毕。 BIO的特点 阻塞BIO的I/O操作是阻塞的当没有数据可读或写时线程会一直阻塞在相应的读写操作上无法去处理其他任务。线程池限制由于每个连接都需要独占一个线程进行处理当并发连接数很大时线程资源会被耗尽导致性能下降。可靠性由于阻塞的特性BIO在网络不稳定或出现异常时可能会导致程序挂起或阻塞。 虽然BIO具有易于理解和使用的优点但其在高并发应用场景下的性能较差。随着网络应用的发展为了提高性能和扩展性非阻塞I/O模型如NIONew I/O和异步I/O模型如AIOAsynchronous I/O逐渐成为主流。 需要注意的是BIO仍然适用于某些特定的应用场景特别是在连接数较少且对实时性要求不高的情况下。 服务器端 package com.rcg.testtwo;import java.io.; import java.net.ServerSocket; import java.net.Socket;/** author 1452863884qq.com rcg* date Created in 2023/8/24 14:47* description服务端* modified By* version:/ public class BioServer {public static void main(String[] args) {//定义端口号int port 9999;//定义服务器套接字ServerSocket serverSocket null;try {//创建服务器套接字serverSocket new ServerSocket(port);//一直监听是否有客户端请求过来while (true) {//每次都会新建一个线程来处理接收到到请求Socket socket serverSocket.accept();//每次都会新建一个线程来处理接收到到请求new Thread(new SocketHandler(socket)).start();}} catch (Exception e) {e.printStackTrace();} finally {//如果服务器套接字不为空则关闭if (serverSocket! null) {try {serverSocket.close();} catch (IOException e) {e.printStackTrace();}serverSocket null;}}}static class SocketHandler implements Runnable {//定义socketSocket socket null;public SocketHandler(Socket socket) {this.socket socket;}//处理读取的数据Overridepublic void run() {BufferedReader reader null;PrintWriter writer null;try {//读取数据,BIO 是面向流到所以定义流 BufferedReader 来读取数据reader new BufferedReader(new InputStreamReader(socket.getInputStream(), UTF-8));//将收到的数据返回给客户端writer new PrintWriter(new OutputStreamWriter(socket.getOutputStream(), UTF-8));String readMessage null;//循环读取数据while (true) {if ((readMessage reader.readLine()) null) {break;}System.out.println(server reading…….. readMessage);//将数据返回给客户端writer.println(server recive : readMessage);writer.flush();}} catch (IOException e) {e.printStackTrace();} finally {if (socket! null) {try {socket.close();} catch (IOException e) {e.printStackTrace();}socket null;}if (reader! null) {try {reader.close();} catch (IOException e) {e.printStackTrace();}reader null;}if (writer! null) {writer.close();writer null;}}}} }客户端 package com.rcg;import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.Socket; import java.util.Scanner;/** author 1452863884qq.com rcg* date Created in 2023/8/24 14:54* description客户端* modified By* version:/ public class BioClient {public static void main(String[] args) {//服务端到 ip 地址String host 127.0.0.1;//和服务端到端口号一致int port 9999;Socket socket null;BufferedReader reader null;PrintWriter writer null;//接收键盘输入数据Scanner scanner new Scanner(System.in);try {//创建 socket 对象socket new Socket(host, port);//创建 BufferedReader 对象String message null;reader new BufferedReader(new InputStreamReader(socket.getInputStream(), UTF-8));writer new PrintWriter(socket.getOutputStream(), true);//循环接收数据while (true) {message scanner.nextLine();//如果接收到 exit 则退出if (message.equals(exit)) {break;}//数据发送服务端writer.println(客户端输入 message);writer.flush();//接收服务端的响应System.out.println(reader.readLine());}} catch (IOException e) {e.printStackTrace();} finally {//关闭 socket 对象if (socket! null) {try {socket.close();} catch (IOException e) {e.printStackTrace();}socket null;}//关闭 BufferedReader 对象if (reader! null) {try {reader.close();} catch (IOException e) {e.printStackTrace();}reader null;}//关闭 PrintWriter 对象if (writer! null) {writer.close();writer null;}}} } 效果  1.2 NIO NIONew I/O是Java中提供的一种非阻塞式I/O模型与传统的阻塞式I/OBIO相比NIO能更高效地处理I/O操作和并发连接。 NIO的关键组件包括通道Channel缓冲区Buffer、选择器Selector和非阻塞模式。下面对每个组件进行简要介绍 通道Channel通道是数据源和目标之间的连接可以用于读取和写入数据。在NIO中所有I/O操作都是通过通道进行的。不同类型的通道如文件通道、套接字通道等适用于不同的I/O场景。 缓冲区Buffer缓冲区是一个连续的内存块用于存储数据。它使得读取和写入数据更加高效。在NIO中所有数据的读取和写入都是通过缓冲区进行的。 选择器Selector选择器是用于检测通道上的事件的对象。通过选择器可以实现单个线程管理多个通道从而高效地处理并发连接。选择器可以监控通道上的事件类型如接受连接、读取数据、写入数据等并根据事件的发生情况来执行相应的操作。 非阻塞模式NIO使用非阻塞模式进行通信。在非阻塞模式下当一个通道没有数据可读取时线程不会被阻塞而是可以继续处理其他任务。这样可以避免每个连接都需要独占一个线程的资源浪费问题实现更高效的并发连接处理。
NIO的工作原理如下 服务器创建一个选择器并将其注册到一个或多个通道上。当有事件发生如连接、读取、写入等选择器会通过轮询的方式检测到事件的发生。当事件发生时选择器会返回一个包含已就绪事件的键集合程序可以通过这些键来获取感兴趣的事件和相应的通道。程序根据事件类型执行相应的操作如接受连接、读取数据、写入数据等。 NIO相比于BIO具有以下优点 高并发性NIO使用选择器和非阻塞模式能够高效地处理并发连接减少线程的使用提高系统的并发性能。可扩展性NIO支持单线程管理多个通道适用于需要管理大量连接的场景提供了更好的可扩展性。非阻塞式NIO采用非阻塞模式不会因为一个通道的读写操作导致阻塞可以同时处理多个通道的操作提高了系统的响应速度。 需要注意的是NIO的实现相对复杂需要合理地使用和管理缓冲区、处理事件等。在Java中可以使用java.nio包下的类来进行NIO编程如SelectableChannel、ByteBuffer、Selector等。 总的来说NIO是一种更高效和灵活的I/O模型适用于需要处理大量并发连接的场景如网络服务器、聊天程序、游戏服务器等。 服务器端 package com.rcg.testtwo;/** author 1452863884qq.com rcg* date Created in 2023/8/24 15:49* description* modified By* version:/import java.io.IOException; import java.net.InetSocketAddress; import java.nio.ByteBuffer; import java.nio.channels.SelectionKey; import java.nio.channels.Selector; import java.nio.channels.ServerSocketChannel; import java.nio.channels.SocketChannel; import java.util.Iterator;public class NioServer {private static ByteBuffer readBuf ByteBuffer.allocate(1024);private static ByteBuffer writeBuf ByteBuffer.allocate(1024);public static void main(String[] args) {int port 9999;Selector selector;try {//打开多路复用器selector Selector.open();//定义一个 ChannelServerSocketChannel channel ServerSocketChannel.open();//非阻塞模型channel.configureBlocking(false);//绑定端口号channel.bind(new InetSocketAddress(port));//channel 注册到 Selector 上面channel.register(selector, SelectionKey.OP_ACCEPT);System.out.println(服务已经启动了……);while (true) {//复用器开始监听selector.select();IteratorSelectionKey seletionKeys selector.selectedKeys().iterator();while (seletionKeys.hasNext()) {SelectionKey key seletionKeys.next();if (key.isValid()) {//监听客户端第一次端连接信息if (key.isAcceptable()) {ServerSocketChannel ssc (ServerSocketChannel) key.channel();SocketChannel sc ssc.accept();sc.configureBlocking(false);sc.register(selector, SelectionKey.OP_READ);System.out.println(accept a client : sc.socket().getInetAddress().getHostName());} else {read(key);}}seletionKeys.remove();}}} catch (IOException e) {e.printStackTrace();}}private static void read(SelectionKey key) {try {//清空缓冲区readBuf.clear();//获取注册在通道里面的 key 对象SocketChannel sc (SocketChannel) key.channel();//读取数据int count sc.read(readBuf);//如果没有数据则关闭连接if (count -1) {key.channel().close();key.cancel();return;}//有数据则进行读取 读取之前需要进行复位方法(把position 和limit进行复位)readBuf.flip();//6 根据缓冲区的数据长度创建相应大小的byte数组接收缓冲区的数据byte[] bytes new byte[readBuf.remaining()];//7 接收缓冲区数据readBuf.get(bytes);String body new String(bytes).trim();System.out.println(服务端接受到客户端请求的数据: body);//9 告诉客户端已收到数据writeBuf.put((你好,客户端,我已收到数据: body).getBytes());//对缓冲区进行复位writeBuf.flip();//写出数据到服务端sc.write(writeBuf);//清空缓冲区数据writeBuf.clear();} catch (Exception e) {e.printStackTrace();}} } 客户端 package com.rcg;/** author 1452863884qq.com rcg* date Created in 2023/8/24 15:53* description* modified By* version:/ import java.io.IOException; import java.net.InetSocketAddress; import java.nio.ByteBuffer; import java.nio.channels.SelectionKey; import java.nio.channels.Selector; import java.nio.channels.SocketChannel; import java.util.Iterator; public class NioClient {private static final String host 127.0.0.1;private static final Integer port 9999;public static void main(String[] args) {try {//创建一个SocketChannel对象SocketChannel channel SocketChannel.open();//连接服务端channel.connect(new InetSocketAddress(host, port));//设置为非阻塞模式channel.configureBlocking(false);//创建一个Selector对象Selector selector Selector.open();//注册channel可读可写channel.register(selector, SelectionKey.OP_READ, SelectionKey.OP_WRITE);//开启新的线程监听否则的话客户端在控制台输入信息不好操作。new Thread(() - {while (true) {try {//多路复用器开始监听selector.select();IteratorSelectionKey selectionKeys selector.selectedKeys().iterator();while (selectionKeys.hasNext()) {SelectionKey selectionKey selectionKeys.next();if (selectionKey.isValid() selectionKey.isReadable()) {//建立写缓冲区ByteBuffer readBuf ByteBuffer.allocate(1024);//2 获取之前注册的socket通道对象SocketChannel sc (SocketChannel) selectionKey.channel();//3 读取数据int count sc.read(readBuf);if (count -1) {selectionKey.channel().close();selectionKey.cancel();return;}//5 有数据则进行读取 读取之前需要进行复位方法(把position 和limit进行复位)readBuf.flip();//6 根据缓冲区的数据长度创建相应大小的byte数组接收缓冲区的数据byte[] bytes new byte[readBuf.remaining()];//7 接收缓冲区数据readBuf.get(bytes);String body new String(bytes).trim();System.out.println(收到服务端的数据 body);}//移除未处理的keyselectionKeys.remove();}} catch (IOException e) {e.printStackTrace();}}}).start();//设置缓冲区大小ByteBuffer writebuf ByteBuffer.allocate(1024);while (true) {byte[] bytes new byte[1024];System.in.read(bytes);//把数据放到缓冲区中writebuf.put(bytes);//对缓冲区进行复位writebuf.flip();//写出数据到服务端channel.write(writebuf);//清空缓冲区数据writebuf.clear();}} catch (IOException e) {e.printStackTrace();}} } 测试 1.3 AIO AIOAsynchronous I/O是Java中提供的一种异步I/O模型与传统的阻塞式I/OBIO和非阻塞式I/ONIO相比AIO能更高效地处理I/O操作和并发连接。 AIO的关键组件包括通道Channel、缓冲区Buffer和完成通知机制。下面对每个组件进行简要介绍 通道Channel通道是数据源和目标之间的连接可以用于读取和写入数据。在AIO中所有I/O操作都是通过通道进行的。不同类型的通道如文件通道、套接字通道等适用于不同的I/O场景。 缓冲区Buffer缓冲区是一个连续的内存块用于存储数据。它使得读取和写入数据更加高效。在AIO中所有数据的读取和写入都是通过缓冲区进行的。 完成通知机制AIO使用回调和事件驱动的方式来处理I/O操作。当一个I/O操作完成时操作系统会通知应用程序并触发预先注册的回调函数从而进行相应的处理。这种机制可以避免线程阻塞提高系统的并发性能。
AIO的工作原理如下 服务器创建一个通道并注册一个或多个感兴趣的I/O事件和回调函数。当有I/O事件发生时操作系统会通知应用程序并调用相应的回调函数。在回调函数中应用程序可以获取已完成的I/O操作的结果并进行相应的处理如读取数据、写入数据等。 AIO相比于BIO和NIO具有以下优点 异步性AIO通过使用回调和事件驱动的方式实现真正的异步I/O操作。这意味着应用程序无需等待操作完成而是可以继续执行其他任务提高了系统的并发性能。 简化编程模型AIO的异步特性可以简化编程模型避免了繁琐的线程管理和同步操作。开发者只需要关注回调函数的处理即可让操作系统来处理底层的I/O操作。 高性能由于AIO的异步特性可以充分利用系统资源提供更高的并发性能和吞吐量。
需要注意的是AIO在Java中是通过AsynchronousChannel和CompletionHandler来实现的。可以使用java.nio.channels.AsynchronousChannelGroup和java.nio.channels.AsynchronousServerSocketChannel等类来创建和管理异步通道使用java.nio.channels.CompletionHandler来定义回调函数。 总的来说AIO适用于需要处理大量并发连接且对性能要求较高的场景。然而AIO在某些平台上的性能可能不如NIO具体取决于操作系统和硬件的支持程度。在选择使用AIO还是NIO时需要考虑特定的应用需求和目标平台的特性。 服务端 package com.rcg.testtwo;/** author 1452863884qq.com rcg* date Created in 2023/8/24 16:02* description* modified By* version:/ import java.net.InetSocketAddress; import java.nio.ByteBuffer; import java.nio.channels.AsynchronousChannelGroup; import java.nio.channels.AsynchronousServerSocketChannel; import java.nio.channels.AsynchronousSocketChannel; import java.nio.channels.CompletionHandler; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class AioServer {private final int port;public static void main(String[] args) {// 创建一个端口号为9999的AioServer对象int port 9999;// 创建一个AioServer对象并传入端口号new AioServer(port);}public AioServer(int port) {// 将端口号传入AioServer对象this.port port;// 监听listen();// 循环while (true) {try {// 线程休眠1000000毫秒Thread.sleep(1000000);} catch (InterruptedException e) {}}}private void listen() {try {ExecutorService executorService Executors.newCachedThreadPool();AsynchronousChannelGroup threadGroup AsynchronousChannelGroup.withCachedThreadPool(executorService, 1);//创建一个异步的服务端套接字final AsynchronousServerSocketChannel serverSocketChannel AsynchronousServerSocketChannel.open(threadGroup);//绑定端口serverSocketChannel.bind(new InetSocketAddress(port));System.out.println(服务已经启动监听端口 port);//监听serverSocketChannel.accept(null, new CompletionHandlerAsynchronousSocketChannel, Object() {final ByteBuffer byteBuffer ByteBuffer.allocate(1024);Overridepublic void completed(AsynchronousSocketChannel result, Object attachment) {System.out.println(I/O 操作成功开始获取数据);try {//清空缓冲区byteBuffer.clear();//从异步缓冲区中读取数据result.read(byteBuffer).get();//将缓冲区的数据转换为字符串byteBuffer.flip();System.out.println(服务端接收到数据 new String(byteBuffer.array()).trim());//将数据写入异步缓冲区result.write(byteBuffer);//将缓冲区的数据转换为字符串byteBuffer.flip();} catch (Exception e) {e.printStackTrace();} finally {try {//关闭异步套接字result.close();//接收下一个操作serverSocketChannel.accept(null, this);} catch (Exception e) {e.printStackTrace();}}System.out.println(操作完成);}Overridepublic void failed(Throwable exc, Object attachment) {System.out.println(I/O 操作失败: exc);}});Thread.sleep(1000);} catch (Exception e) {e.printStackTrace();}} } 客户端 package com.rcg;/** author 1452863884qq.com rcg* date Created in 2023/8/24 16:02* description* modified By* version:/ import java.net.InetSocketAddress; import java.nio.ByteBuffer; import java.nio.channels.AsynchronousSocketChannel; import java.nio.channels.CompletionHandler; public class AioClient {private AsynchronousSocketChannel clientChannel;// 定义一个AsynchronousSocketChannel类型的变量clientChannelprivate static final String host 127.0.0.1;// 定义一个字符串类型的变量hostprivate static final Integer port 9999;// 定义一个整型类型的变量portpublic AioClient() throws Exception {// 创建一个AsynchronousSocketChannel实例clientChannel AsynchronousSocketChannel.open();}// 定义一个AioClient类的构造函数public void connect(String host, int port) {try {// 调用AsynchronousSocketChannel的open()方法创建一个AsynchronousSocketChannel实例clientChannel.connect(new InetSocketAddress(host, port), null, new CompletionHandlerVoid, Void() {// 定义一个CompletionHandler类型的变量attachment用于存放连接结果Overridepublic void completed(Void result, Void attachment) {try {// 调用AsynchronousSocketChannel的write()方法发送数据clientChannel.write(ByteBuffer.wrap(你好师姐客户端链接成功了.getBytes())).get();System.out.println(数据已经发送成功!);} catch (Exception e) {e.printStackTrace();}}// 定义一个CompletionHandler类型的变量attachment用于存放连接失败的异常Overridepublic void failed(Throwable exc, Void attachment) {}});} catch (Exception e) {e.printStackTrace();}try {// 等待1秒Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}// 定义一个ByteBuffer准备读取数据final ByteBuffer byteBuffer ByteBuffer.allocate(1024);// 调用AsynchronousSocketChannel的read()方法读取数据clientChannel.read(byteBuffer, null, new CompletionHandlerInteger, Object() {// 定义一个CompletionHandler类型的变量attachment用于存放读取结果Overridepublic void completed(Integer result, Object attachment) {System.out.println(I/O操作完成 result);System.out.println(获取返回结果 new String(byteBuffer.array()).trim());}// 定义一个CompletionHandler类型的变量attachment用于存放读取失败的异常Overridepublic void failed(Throwable exc, Object attachment) {exc.printStackTrace();}});}// 定义一个main()方法用于连接服务器public static void main(String[] args) throws Exception {// 创建一个AioClient实例AioClient aioClient new AioClient();// 调用AioClient的connect()方法连接服务器aioClient.connect(host, port);} } 测试 二、WebSocket协议 WebSocket是一种在Web浏览器和服务器之间进行全双工通信的协议。它提供了一种持久连接的机制允许客户端和服务器之间实时地交换数据而不需要频繁地发起HTTP请求。 与传统的HTTP请求相比WebSocket连接通过一个初始的HTTP握手阶段建立并使用一种特殊的数据帧格式来传输数据。一旦建立了WebSocket连接客户端和服务器之间可以随时互相发送消息这样就实现了实时的双向数据交流。 WebSocket具有以下特点 实时性WebSocket连接保持持久性客户端和服务器之间可以实时地发送和接收数据避免了短轮询或长轮询的延迟。双向通信WebSocket连接支持全双工通信即客户端和服务器可以同时发送和接收数据。轻量级WebSocket协议采用了更轻量级的数据帧格式相对于HTTP请求来说数据传输的开销更小。更少的资源消耗由于WebSocket连接的持久性服务器端不需要为每个客户端连接创建一个新的线程或进程从而减少了服务器资源的消耗。跨域支持WebSocket连接支持跨域通信可以在不同域名下的客户端和服务器之间进行通信。 WebSocket广泛用于实时聊天应用、多人游戏、实时数据传输等需要高实时性和双向通信的Web应用场景。在前端开发中可以使用JavaScript提供的WebSocket API来创建和管理WebSocket连接。在后端开发中可以使用各种语言和框架提供的WebSocket库来处理WebSocket连接和消息的收发。 要在Web应用程序中使用WebSocket你需要在客户端和服务器端分别进行相应的代码编写。下面是一个示例展示了如何在JavaScript和Java中使用WebSocket。 客户端 // 创建WebSocket对象并指定服务器的URL var socket new WebSocket(ws://localhost:8080/mywebsocket);// 连接建立时触发事件 socket.onopen function(event) {console.log(WebSocket连接已建立);// 向服务器发送消息socket.send(Hello Server!); };// 收到服务器消息时触发事件 socket.onmessage function(event) {var message event.data;console.log(收到服务器消息 message);// 在此处对收到的消息进行处理 };// 连接关闭时触发事件 socket.onclose function(event) {console.log(WebSocket连接已关闭); };// 发生错误时触发事件 socket.onerror function(event) {console.error(WebSocket出现错误); };服务器端使用Java import javax.websocket.; import javax.websocket.server.ServerEndpoint; import java.io.IOException;ServerEndpoint(/mywebsocket) public class MyWebSocket {OnOpenpublic void onOpen(Session session) {System.out.println(WebSocket连接已建立);// 向客户端发送消息try {session.getBasicRemote().sendText(Hello Client!);} catch (IOException e) {e.printStackTrace();}}OnMessagepublic void onMessage(String message, Session session) {System.out.println(收到客户端消息 message);// 在此处对收到的消息进行处理// 向客户端发送消息try {session.getBasicRemote().sendText(Got your message: message);} catch (IOException e) {e.printStackTrace();}}OnClosepublic void onClose() {System.out.println(WebSocket连接已关闭);}OnErrorpublic void onError(Throwable error) {System.err.println(WebSocket发生错误);error.printStackTrace();} }在示例中客户端使用JavaScript的WebSocket对象创建WebSocket连接并通过相应的事件处理函数来处理连接建立、消息收发、连接关闭和错误等事件。服务器端使用Java的javax.websocket库使用ServerEndpoint注解指定WebSocket的URL并编写相应的方法来处理连接建立、消息收发和连接关闭等事件。 总结