Java WebSocket框架

引言

随着互联网和移动互联网的迅猛发展，实时通信成为了应用程序的一项重要能力。WebSocket作为一种在Web上实现双向通信的协议，极大地丰富了Web应用程序的交互方式。而在Java领域，也有许多优秀的WebSocket框架可供选择，本文将介绍其中几个主流的Java WebSocket框架。

1. Java WebSocket API

Java WebSocket API是Java EE 7规范中引入的原生WebSocket支持。借助Java WebSocket API，开发者可以很方便地创建WebSocket服务器和客户端。

API提供了javax.websocket包，其中包含了服务器端和客户端的接口和类。通过这些接口和类，我们可以实现WebSocket的基本功能，如建立连接、发送和接收消息、关闭连接等。

示例代码如下所示：

@ServerEndpoint("/chat")
public class ChatServer {@OnOpenpublic void onOpen(Session session) {System.out.println("Connected: " + session.getId());}@OnMessagepublic void onMessage(String message, Session session) {System.out.println("Message from " + session.getId() + ": " + message);}@OnClosepublic void onClose(Session session) {System.out.println("Closed: " + session.getId());}
}

上述代码是一个简单的WebSocket服务器示例。通过@ServerEndpoint注解标记类为WebSocket服务器，并且指定了WebSocket的URI路径。通过@OnOpen、@OnMessage和@OnClose注解，我们可以定义连接建立、接收消息和关闭连接时的处理逻辑。

Java WebSocket API是Java EE规范的一部分，因此在Java EE 7或更高版本中，API已经默认可用，无需额外的依赖。

2. Jetty WebSocket

Jetty是一款轻量级的Java Web服务器，同时也提供了功能丰富的WebSocket支持。

Jetty WebSocket提供了易于使用的API和函数式编程模型，使我们可以快速开发可扩展的WebSocket服务器应用程序。

示例代码如下所示：

import org.eclipse.jetty.websocket.api.Session;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketConnect;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketMessage;
import org.eclipse.jetty.websocket.api.annotations.WebSocket;@WebSocket
public class ChatHandler {@OnWebSocketConnectpublic void onConnect(Session session) {System.out.println("Connected: " + session.getRemoteAddress());}@OnWebSocketMessagepublic void onMessage(Session session, String message) {System.out.println("Message: " + message);}
}

上述代码是一个使用Jetty WebSocket的示例。通过@WebSocket注解标记类为WebSocket处理器，并且通过注解来定义连接建立和接收消息时的处理逻辑。

在使用Jetty WebSocket时，我们需要添加Jetty WebSocket依赖。我们可以通过Maven来管理依赖，添加以下依赖配置：

<dependency><groupId>org.eclipse.jetty.websocket</groupId><artifactId>javax-websocket-server-impl</artifactId><version>9.4.35.v20201120</version>
</dependency>
<dependency><groupId>org.eclipse.jetty.websocket</groupId><artifactId>javax-websocket-client-impl</artifactId><version>9.4.35.v20201120</version>
</dependency>

3. Netty WebSocket

Netty是一款高性能的网络应用程序框架，其提供了强大的异步和事件驱动的网络编程能力。Netty也提供了WebSocket支持，使我们可以通过简洁的API来实现WebSocket服务器和客户端。

示例代码如下所示：

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.codec.http.HttpObjectAggregator;
import io.netty.handler.codec.http.HttpServerCodec;
import io.netty.handler.codec.http.websocketx.WebSocketFrameEncoder;
import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler;public class WebSocketServer {public static void main(String[] args) throws Exception {EventLoopGroup bossGroup = new NioEventLoopGroup();EventLoopGroup workerGroup = new NioEventLoopGroup();try {ServerBootstrap server = new ServerBootstrap();server.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class).childHandler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel ch) {ChannelPipeline pipeline = ch.pipeline();pipeline.addLast(new HttpServerCodec());pipeline.addLast(new HttpObjectAggregator(65536));pipeline.addLast(new WebSocketServerProtocolHandler("/websocket"));pipeline.addLast(new WebSocketFrameEncoder());pipeline.addLast(new ChatHandler());}});server.bind(8080).sync().channel().closeFuture().sync();} finally {bossGroup.shutdownGracefully();workerGroup.shutdownGracefully();}}
}

上述代码是使用Netty WebSocket的简单服务器示例。通过构建ServerBootstrap实例，并设置相关的handler和参数，我们可以开启一个WebSocket服务器。

在使用Netty WebSocket时，我们需要添加Netty WebSocket依赖。我们可以通过Maven来管理依赖，添加以下依赖配置：

<dependency><groupId>io.netty</groupId><artifactId>netty-all</artifactId><version>4.1.53.Final</version>
</dependency>

4. Spring WebSocket

Spring WebSocket是Spring框架中的一部分，通过Spring WebSocket，我们可以很方便地集成WebSocket功能到Spring应用程序中。

示例代码如下所示：

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {@Overridepublic void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {registry.addHandler(new ChatHandler(), "/chat").setAllowedOrigins("*");}
}public class ChatHandler extends TextWebSocketHandler {@Overrideprotected void handleTextMessage(WebSocketSession session, TextMessage message) {System.out.println("Message: " + message.getPayload());}
}

上述代码是一个使用Spring WebSocket的示例。通过WebSocketConfigurer和WebSocketHandlerRegistry接口，我们可以轻松地注册并配置WebSocket处理器。

在使用Spring WebSocket时，我们需要添加Spring WebSocket依赖。我们可以通过Maven来管理依赖，添加以下依赖配置：

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-websocket</artifactId><version>2.4.0</version>
</dependency>

5. 基于Java WebSocket API的聊天应用

我们可以使用Java WebSocket API来构建一个简单的聊天室应用程序。下面是一个使用Java WebSocket API的聊天服务器示例：

@ServerEndpoint("/chat")
public class ChatServer {private static Set<Session> sessions = Collections.synchronizedSet(new HashSet<>());@OnOpenpublic void onOpen(Session session) {sessions.add(session);System.out.println("New connection: " + session.getId());}@OnMessagepublic void onMessage(String message, Session session) {sendMessageToAll("Message from " + session.getId() + ": " + message);}@OnClosepublic void onClose(Session session) {sessions.remove(session);System.out.println("Connection closed: " + session.getId());}private void sendMessageToAll(String message) {for (Session session : sessions) {try {session.getBasicRemote().sendText(message);} catch (IOException e) {e.printStackTrace();}}}
}

上述代码定义了一个WebSocket服务器，用于处理聊天室中的消息。当有新的连接建立时，onOpen方法会被调用，将连接添加到会话列表中。当接收到消息时，onMessage方法会将该消息发送给所有连接。当连接关闭时，onClose方法会将该连接从会话列表中删除。

在浏览器中，我们可以使用JavaScript的WebSocket API来连接到该聊天服务器：

var socket = new WebSocket("ws://localhost:8080/chat");socket.onopen = function() {console.log("Connected to server");
};socket.onmessage = function(event) {console.log("Message received: " + event.data);
};socket.onclose = function(event) {console.log("Connection closed");
};function sendMessage() {var message = document.getElementById("message").value;socket.send(message);document.getElementById("message").value = "";
}

上述代码连接到聊天服务器，并在接收到新消息时打印在控制台上。通过sendMessage函数，我们可以将输入框中的消息发送给聊天服务器。

6. 基于Jetty WebSocket的实时股票行情应用

我们可以使用Jetty WebSocket来创建一个实时股票行情应用程序。下面是一个使用Jetty WebSocket的股票服务器示例：

import org.eclipse.jetty.websocket.api.Session;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketConnect;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketMessage;
import org.eclipse.jetty.websocket.api.annotations.WebSocket;import java.util.Random;@WebSocket
public class StockHandler {private Session session;private Random random = new Random();@OnWebSocketConnectpublic void onConnect(Session session) {this.session = session;System.out.println("New connection: " + session.getRemoteAddress());Thread thread = new Thread(() -> {try {while (true) {int price = random.nextInt(100);session.getRemote().sendString(String.valueOf(price));Thread.sleep(1000); // 每一秒发送一次股价}} catch (Exception e) {e.printStackTrace();}});thread.start();}@OnWebSocketMessagepublic void onMessage(String message) {// 不处理客户端发送的消息}
}

在上述代码中，onConnect方法在新连接建立时被调用。我们通过定时线程发送随机生成的股票价格，将其作为实时的股票行情数据。通过session.getRemote().sendString方法，我们将股票价格发送给客户端。

在浏览器中，我们可以使用JavaScript的WebSocket API来连接到股票服务器，并在接收到新的股票价格时进行处理。

var socket = new WebSocket("ws://localhost:8080/stock");socket.onopen = function() {console.log("Connected to server");
};socket.onmessage = function(event) {var price = event.data;console.log("Stock price: " + price);// 在页面上更新股票价格document.getElementById("stockPrice").innerText = price;
};socket.onclose = function(event) {console.log("Connection closed");
};

上述代码将接收到的股票价格打印在控制台上，并将其更新到页面上显示。

7. 基于Spring WebSocket的实时聊天室应用

我们可以使用Spring WebSocket来构建一个实时的聊天室应用程序。下面是一个使用Spring WebSocket的聊天服务器示例：

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {@Overridepublic void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {registry.addHandler(new ChatHandler(), "/chat").setAllowedOrigins("*");}
}public class ChatHandler extends TextWebSocketHandler {private List<WebSocketSession> sessions = new CopyOnWriteArrayList<>();@Overridepublic void afterConnectionEstablished(WebSocketSession session) throws Exception {System.out.println("New connection: " + session.getRemoteAddress());sessions.add(session);}@Overrideprotected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {System.out.println("Message: " + message.getPayloadAsString());for (WebSocketSession s : sessions) {s.sendMessage(message);}}@Overridepublic void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {System.out.println("Connection closed: " + session.getRemoteAddress());sessions.remove(session);}
}

在上述代码中，ChatHandler被定义为WebSocket处理器，用于处理聊天室消息。在连接建立时，afterConnectionEstablished方法会被调用，并将新的会话添加到会话列表中。当接收到消息时，handleTextMessage方法会将该消息发送给所有的会话。当连接关闭时，afterConnectionClosed方法会将该会话从会话列表中删除。

在浏览器中，我们可以使用JavaScript的WebSocket API来连接到聊天服务器，并在接收到新消息时进行处理。

var socket = new WebSocket("ws://localhost:8080/chat");socket.onopen = function() {console.log("Connected to server");
};socket.onmessage = function(event) {var message = event.data;console.log("Message received: " + message);// 在页面上展示消息var div = document.createElement("div");div.innerText = message;document.getElementById("chatMessages").appendChild(div);
};socket.onclose = function(event) {console.log("Connection closed");
};function sendMessage() {var message = document.getElementById("message").value;socket.send(message);document.getElementById("message").value = "";
}

以上案例给出了使用Java WebSocket框架构建简单的聊天应用、实时股票行情应用以及实时聊天室应用的示例。通过这些案例，我们可以更好地理解Java WebSocket框架在不同领域的应用。

结论

本文简要介绍了几个主流的Java WebSocket框架，包括Java WebSocket API、Jetty WebSocket、Netty WebSocket和Spring WebSocket。每个框架都提供了易于使用且功能强大的API，使开发者能够快速开发出高性能、实时通信的WebSocket应用程序。

无论你是在Java EE环境中开发，还是使用独立的Web服务器框架，都可以根据自己的需求选择合适的WebSocket框架。希望本文对初学者理解和使用Java WebSocket框架有所帮助。

参考文献：

  • Java EE 7 WebSocket API：https://javaee.github.io/tutorial/websocket.html
  • Jetty WebSocket：https://www.eclipse.org/jetty/documentation/current/websocket-jetty.html
  • Netty WebSocket：https://netty.io/4.1/api/io/netty/handler/codec/http/websocketx/WebSocketServerProtocolHandler.html
  • Spring WebSocket：https://docs.spring.io/spring-framework/docs/current/reference/html/web.html#websocket

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/156867.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

4D毫米波雷达和3D雷达、激光雷达全面对比

4D毫米波雷达和3D雷达、激光雷达全面对比

众所周知&#xff0c;传统3D毫米波雷达存在如下性能缺陷&#xff1a; 1&#xff09;静止目标和地物杂波混在一起&#xff0c;难以区分&#xff1b; 2) 横穿车辆和行人多普勒为零或很低&#xff0c;难以检测&#xff1b; 3) 高处物体和地面目标不能区分&#xff0c;容易造成误刹…
阅读更多...
从CNN到Transformer：基于PyTorch的遥感影像、无人机影像的地物分类、目标检测、语义分割和点云分类

从CNN到Transformer：基于PyTorch的遥感影像、无人机影像的地物分类、目标检测、语义分割和点云分类

我国高分辨率对地观测系统重大专项已全面启动&#xff0c;高空间、高光谱、高时间分辨率和宽地面覆盖于一体的全球天空地一体化立体对地观测网逐步形成&#xff0c;将成为保障国家安全的基础性和战略性资源。随着小卫星星座的普及&#xff0c;对地观测已具备多次以上的全球覆盖…
阅读更多...
CentOS上搭建SVN并自动同步至web目录

CentOS上搭建SVN并自动同步至web目录

一、搭建svn环境并创建仓库&#xff1a; 1、安装Subversion&#xff1a; yum install svn2、创建版本库&#xff1a; //先建目录 cd /www mkdir wwwsvn cd wwwsvn //创建版本库 svnadmin create xiangmumingcheng二、创建用户组及用户&#xff1a; 1、 进入版本库中的配…
阅读更多...
部署单仓库多目录项目

部署单仓库多目录项目

部署单仓库多目录项目 文章目录 部署单仓库多目录项目1.部署单仓库多目录项目2.Shell脚本进行部署单仓库多目录项目2.1 编写Shell脚本2.2 Demo推送代码及测试 3.小结 1.部署单仓库多目录项目 #部署单仓库多目录项目 在开发过程中,研发团队往往会将一个大型项目拆分成几个子目录…
阅读更多...
MCU 的 TOP 15 图形GUI库：选择最适合你的图形用户界面（一）

MCU 的 TOP 15 图形GUI库：选择最适合你的图形用户界面（一）

在嵌入式系统开发中&#xff0c;选择一个合适的图形用户界面&#xff08;GUI&#xff09;库是至关重要的。在屏幕上显示的时候&#xff0c;使用现成的图形库&#xff0c;这样开发人员就不需要弄清楚底层任务&#xff0c;例如如何绘制像素、线条、形状&#xff0c;如果再高级一点…
阅读更多...
Java LinkedList链表、HashSet、HashMap

Java LinkedList链表、HashSet、HashMap

一、Java LinkedList&#xff1a; 链表&#xff08;LinkedList&#xff09;是一种常见的基础数据结构&#xff0c;是一种线性表&#xff0c;在每一个节点里存储下一个节点的地址。链表分为单向链表和双向链表。单向链表包含两个值&#xff1a;当前节点的值和指向下一个节点的链…
阅读更多...
基于骑手优化算法优化概率神经网络PNN的分类预测 - 附代码

基于骑手优化算法优化概率神经网络PNN的分类预测 - 附代码

基于骑手优化算法优化概率神经网络PNN的分类预测 - 附代码 文章目录 基于骑手优化算法优化概率神经网络PNN的分类预测 - 附代码1.PNN网络概述2.变压器故障诊街系统相关背景2.1 模型建立 3.基于骑手优化优化的PNN网络5.测试结果6.参考文献7.Matlab代码 摘要&#xff1a;针对PNN神…
阅读更多...
2021秋招-总目录

2021秋招-总目录

2021秋招-目录 知识点总结 预训练语言模型: Bert家族 1.1 BERT、attention、transformer理解部分 B站讲解–强烈推荐可视化推倒结合代码理解代码部分常见面试考点以及问题: word2vec 、 fasttext 、elmo;BN 、LN、CN、WNNLP中的loss与评价总结 4.1 loss_function&#xff1…
阅读更多...
基础算法：大数除以除以13

基础算法：大数除以除以13

基础算法&#xff1a;大数除以一个数 信息学奥赛&#xff1a;1175&#xff1a;除以13 时间限制: 1000 ms 内存限制: 65536 KB 【题目描述】 输入一个大于0的大整数N&#xff0c;长度不超过100位&#xff0c;要求输出其除以13得到的商和余数。 【输入】 一个大于0的大整数&…
阅读更多...
基于AVR单片机的移动目标视觉追踪系统设计与实现

基于AVR单片机的移动目标视觉追踪系统设计与实现

基于AVR单片机的移动目标视觉追踪系统是一种常见的应用领域&#xff0c;旨在通过摄像头采集图像数据并使用图像处理和追踪算法实现对移动目标的实时追踪。本文将介绍基于AVR单片机的移动目标视觉追踪系统的设计原理和实现步骤&#xff0c;并提供相应的代码示例。 1. 设计概述 …
阅读更多...
C语言中的大端字节序和小端字节序是什么？如何进行字节序的转换？

C语言中的大端字节序和小端字节序是什么？如何进行字节序的转换？

C语言中的大端字节序和小端字节序以及字节序的转换 引言 在计算机科学中&#xff0c;字节序是指多字节数据在存储或传输过程中字节的排列顺序。在C语言中&#xff0c;特别是在涉及二进制数据的处理、网络通信以及硬件相关的编程中&#xff0c;了解大端字节序和小端字节序的概…
阅读更多...
QJsonObject经过哪些转换才能发送到UDP端口

QJsonObject经过哪些转换才能发送到UDP端口

一、QJsonObject转换为QJsonDocument 二、将 QJsonDocument 转换为 JSON 字符串&#xff0c;以便输出或传输 三、将 QString 转换为 QByteArray 四、发送到UDP端口 // 将 QJsonObject 转换为 QJsonDocument QJsonDocument jsonDocument(jsonobj); // 将 QJsonDocument 转换为 J…
阅读更多...
基于SSM的校内互助交易平台设计

基于SSM的校内互助交易平台设计

末尾获取源码 开发语言&#xff1a;Java Java开发工具&#xff1a;JDK1.8 后端框架&#xff1a;SSM 前端&#xff1a;Vue 数据库&#xff1a;MySQL5.7和Navicat管理工具结合 服务器&#xff1a;Tomcat8.5 开发软件&#xff1a;IDEA / Eclipse 是否Maven项目&#xff1a;是 目录…
阅读更多...
使用 AWS boto3 库从 s3 桶中批量下载数据

使用 AWS boto3 库从 s3 桶中批量下载数据

文章目录 一、Boto3 快速安装二、账户配置三、代码示例3.1 下载单个文件3.2 下载文件夹内全部文件 官方文档 一、Boto3 快速安装 安装 Boto3 之前&#xff0c;先安装 Python 3.8 或更高版本&#xff1b;对 Python 3.6 及更早版本的支持已弃用。 通过 pip 安装最新的 Boto3 版…
阅读更多...
MAX/MSP SDK学习04：Messages selector的使用

MAX/MSP SDK学习04：Messages selector的使用

其实消息选择器在simplemax示例中就接触到了&#xff0c;但这文档非要讲那么抽象。目前为止对消息选择器的理解是&#xff1a;可判断接收过来的消息是否符合本Object的处理要求&#xff0c;比如加法对象只可接收数值型的消息以处理&#xff0c;但不能接收t_symbol型的消息&…
阅读更多...
Laravel/Lumen 任务调度简易入门说明

Laravel/Lumen 任务调度简易入门说明

前提 Laravel 中任务调度简化了服务器系统中 Cron 的操作&#xff0c;使得 计划任务 的实现更为简便。 这里主要以 Laravel 自带的消息队列进行说明&#xff0c;了解其间运行关系可以让我们更清晰的进行代码实现。 下方代码以 Lumen 9.x 框架进行举例&#xff0c;与 Laravel…
阅读更多...
【Spring Boot】如何在Linux系统中快速启动Spring Boot的jar包

【Spring Boot】如何在Linux系统中快速启动Spring Boot的jar包

在Linux系统中先安装java的JDK 然后编写下列service.sh脚本&#xff0c;并根据自己的需求只需要修改export的log_path、exec_cmd参数即可 # 配置运行日志输出的路径 export log_path/usr/local/project/study-pro/logs # 当前服务运行的脚本命令 export exec_cmd"nohup /u…
阅读更多...
算法训练营一刷 总结篇

算法训练营一刷 总结篇

今天就是Day60了&#xff0c;坚持了两个月的算法训练营在今天结束了。这两个月中&#xff0c;学习、练习了许许多多的算法&#xff0c;坚持每天完成博客来打卡&#xff0c;养成了写C的习惯&#xff0c;现在相比于Python我反而更喜欢思路严谨的C。感谢这个平台&#xff0c;感谢C…
阅读更多...
【DevOps】Git 图文详解（七）：标签管理

【DevOps】Git 图文详解（七）：标签管理

Git 图文详解&#xff08;七&#xff09;&#xff1a;标签管理 标签&#xff08;Tags&#xff09;指的是某个分支某个特定时间点的状态&#xff0c;是对某一个提交记录的 固定 “指针” 引用。一经创建&#xff0c;不可移动&#xff0c;存储在工作区根目录下 .git\refs\tags。可…
阅读更多...
Ajax相关知识

Ajax相关知识

目录 一.前后端传输数据的编码格式&#xff08;contentType&#xff09; 1.form表单 2.编码格式 3.Ajax 4.代码演示 后端 前端HTML 二.Ajax发送JSON格式数据 1.引入 后端 前端 2.后端 接收到的数据为空 解决办法 3.request方法判断Ajax 4.总结 前端在通过ajax…
阅读更多...
最新文章

Copyright @ 2022~2023