2. 首页 > Tomcat教程 > 正文

Tomcat教程FG028-Tomcat WebSocket应用开发与部署实战

教程整理：风哥教程  |  更新时间：2026-03-23  |  教程分类：Tomcat教程  |  文档学习：34

目录大纲

Part01-基础概念与理论知识

Part02-生产环境规划与建议

Part03-生产环境项目实施方案

Part04-生产案例与实战讲解

Part05-风哥经验总结与分享

Part01-基础概念与理论知识

1.1 WebSocket基本概念

WebSocket是一种在单个TCP连接上进行全双工通信的协议，主要特点包括：

  • 全双工通信：客户端和服务器可以同时发送和接收消息
  • 低延迟：相比HTTP轮询，延迟更低
  • 实时性：支持实时数据传输
  • 节省资源：减少HTTP请求的开销
  • 跨域支持：支持跨域通信

WebSocket的应用场景包括：

  • 实时聊天：在线聊天室、即时通讯
  • 实时数据：股票行情、实时监控
  • 在线游戏：多人在线游戏
  • 协作编辑：在线文档协作
  • 实时通知：系统通知、消息推送

更多视频教程www.fgedu.net.cn

1.2 Tomcat WebSocket支持

Tomcat从7.0版本开始支持WebSocket，支持以下功能：

  • JSR-356规范：支持Java WebSocket API规范
  • 注解支持：使用@ServerEndpoint注解定义WebSocket端点
  • 编程式配置：支持编程式配置WebSocket端点
  • 消息处理：支持文本、二进制和Ping/Pong消息
  • 会话管理：支持WebSocket会话管理

Tomcat WebSocket的特点：

  • 易于使用：使用注解简化开发
  • 高性能：基于NIO，性能优异
  • 可扩展：支持自定义编解码器
  • 安全支持：支持SSL/TLS加密
  • 集群支持：支持WebSocket集群

1.3 WebSocket协议原理

WebSocket协议的工作原理：

  1. 握手阶段：客户端发送HTTP请求，升级到WebSocket协议
  2. 连接建立：服务器响应，建立WebSocket连接
  3. 数据传输：客户端和服务器通过WebSocket连接传输数据
  4. 连接关闭：客户端或服务器关闭连接

WebSocket协议的帧格式：

  • 文本帧：传输文本数据
  • 二进制帧：传输二进制数据
  • Ping帧：心跳检测
  • Pong帧：心跳响应
  • 关闭帧：关闭连接

1.4 WebSocket应用架构

WebSocket应用的架构包括以下组件：

  • WebSocket客户端：浏览器或应用中的WebSocket客户端
  • WebSocket服务器：Tomcat中的WebSocket端点
  • 消息处理器：处理WebSocket消息
  • 会话管理器：管理WebSocket会话
  • 消息存储：存储和转发消息

WebSocket应用的设计原则：

  • 消息格式：定义统一的消息格式
  • 错误处理：完善的错误处理机制
  • 连接管理：管理连接的生命周期
  • 安全验证：验证连接的合法性
  • 性能优化：优化消息处理性能

风哥提示：WebSocket是实时通信的重要技术，合理使用WebSocket可以实现高效的实时应用

Part02-生产环境规划与建议

2.1 WebSocket开发建议

在生产环境中，WebSocket开发的建议：

  • 使用注解：使用@ServerEndpoint注解简化开发
  • 异常处理：完善的异常处理机制
  • 消息验证：验证接收到的消息
  • 连接管理：管理连接的生命周期
  • 日志记录：记录关键操作和错误

2.2 WebSocket部署建议

WebSocket部署的建议：

  • 配置超时：配置合理的超时时间
  • 配置缓冲区：配置合理的缓冲区大小
  • 配置SSL/TLS：配置SSL/TLS保护通信
  • 配置负载均衡：配置负载均衡支持WebSocket
  • 配置监控：监控WebSocket连接和消息

2.3 性能优化建议

WebSocket性能优化的建议：

  • 批量发送：批量发送消息，减少开销
  • 消息压缩：对消息进行压缩
  • 连接池：使用连接池管理连接
  • 异步处理：使用异步处理消息
  • 缓存优化：使用缓存减少重复计算

学习交流加群风哥QQ113257174

Part03-生产环境项目实施方案

3.1 WebSocket应用开发步骤

WebSocket应用开发的步骤如下：

  1. 创建项目：创建Java Web项目
  2. 添加依赖：添加WebSocket依赖
  3. 创建端点：创建WebSocket端点类
  4. 实现处理逻辑：实现消息处理逻辑
  5. 创建客户端：创建WebSocket客户端

3.2 WebSocket应用部署步骤

WebSocket应用部署的步骤：

  1. 打包应用：打包应用为WAR文件
  2. 配置Tomcat：配置Tomcat参数
  3. 部署应用：将WAR文件部署到Tomcat
  4. 配置SSL：配置SSL/TLS
  5. 测试应用：测试WebSocket应用

3.3 部署验证与测试

部署完成后，需要进行以下验证和测试：

  • 连接测试：测试WebSocket连接是否正常
  • 消息测试：测试消息发送和接收
  • 性能测试：测试WebSocket应用的性能
  • 安全测试：测试WebSocket应用的安全性
  • 压力测试：测试WebSocket应用的稳定性

Part04-生产案例与实战讲解

4.1 WebSocket聊天应用开发实战

以下是WebSocket聊天应用开发的实战案例：

# 1. 创建WebSocket端点
cat > /Tomcat/app/webapps/fgedu_chat/WEB-INF/classes/com/fgedu/websocket/ChatEndpoint.java << EOF package com.fgedu.websocket; import javax.websocket.*; import javax.websocket.server.ServerEndpoint; import java.io.IOException; import java.util.Set; import java.util.concurrent.CopyOnWriteArraySet; @ServerEndpoint(value = "/chat") public class ChatEndpoint { private static Set sessions = new CopyOnWriteArraySet<>();

@OnOpen
public void onOpen(Session session) {
sessions.add(session);
System.out.println(“Session opened: ” + session.getId());
}

@OnMessage
public void onMessage(String message, Session session) {
System.out.println(“Message received: ” + message);
broadcast(message, session);
}

@OnClose
public void onClose(Session session) {
sessions.remove(session);
System.out.println(“Session closed: ” + session.getId());
}

@OnError
public void onError(Session session, Throwable error) {
System.err.println(“Error on session ” + session.getId() + “: ” + error.getMessage());
}

private void broadcast(String message, Session excludeSession) {
for (Session session : sessions) {
if (!session.equals(excludeSession) && session.isOpen()) {
try {
session.getBasicRemote().sendText(message);
} catch (IOException e) {
System.err.println(“Error sending message: ” + e.getMessage());
}
}
}
}
}
EOF

# 2. 创建HTML客户端
cat > /Tomcat/app/webapps/fgedu_chat/index.html << EOF

FGEDU Chat


EOF

# 3. 创建web.xml
cat > /Tomcat/app/webapps/fgedu_chat/WEB-INF/web.xml << EOF

FGEDU Chat Application

EOF

# 4. 编译Java类
cd /Tomcat/app/webapps/fgedu_chat/WEB-INF/classes
javac -cp /Tomcat/app/lib/* com/fgedu/websocket/ChatEndpoint.java

# 输出示例：
Note: ChatEndpoint.java uses unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.

# 5. 重启Tomcat服务
/Tomcat/app/bin/shutdown.sh
/Tomcat/app/bin/startup.sh

# 6. 查看Tomcat日志
tail -f /Tomcat/app/logs/catalina.out

# 输出示例：
21-Jul-2024 11:00:00.000 INFO [main] org.apache.catalina.startup.HostConfig.deployDirectory Deploying web application directory [/Tomcat/app/webapps/fgedu_chat]
21-Jul-2024 11:00:00.100 INFO [main] org.apache.catalina.startup.HostConfig.deployDirectory Deployment of web application directory [/Tomcat/app/webapps/fgedu_chat] has finished in [100] ms

# 7. 测试WebSocket应用
curl http://localhost:8080/fgedu_chat/

# 输出示例：

FGEDU Chat


4.2 WebSocket实时数据推送实战

以下是WebSocket实时数据推送的实战案例：

# 1. 创建WebSocket端点
cat > /Tomcat/app/webapps/fgedu_push/WEB-INF/classes/com/fgedu/websocket/DataPushEndpoint.java << EOF package com.fgedu.websocket; import javax.websocket.*; import javax.websocket.server.ServerEndpoint; import java.io.IOException; import java.util.Set; import java.util.concurrent.CopyOnWriteArraySet; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; @ServerEndpoint(value = "/push") public class DataPushEndpoint { private static Set sessions = new CopyOnWriteArraySet<>();
private static ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);

@OnOpen
public void onOpen(Session session) {
sessions.add(session);
System.out.println(“Session opened: ” + session.getId());
}

@OnMessage
public void onMessage(String message, Session session) {
System.out.println(“Message received: ” + message);
if (“start”.equals(message)) {
startPushing();
} else if (“stop”.equals(message)) {
stopPushing();
}
}

@OnClose
public void onClose(Session session) {
sessions.remove(session);
System.out.println(“Session closed: ” + session.getId());
}

@OnError
public void onError(Session session, Throwable error) {
System.err.println(“Error on session ” + session.getId() + “: ” + error.getMessage());
}

private void startPushing() {
scheduler.scheduleAtFixedRate(() -> {
String data = generateData();
broadcast(data);
}, 0, 1, TimeUnit.SECONDS);
}

private void stopPushing() {
scheduler.shutdown();
}

private String generateData() {
long timestamp = System.currentTimeMillis();
double value = Math.random() * 100;
return String.format(“{\”timestamp\”:%d,\”value\”:%.2f}”, timestamp, value);
}

private void broadcast(String message) {
for (Session session : sessions) {
if (session.isOpen()) {
try {
session.getBasicRemote().sendText(message);
} catch (IOException e) {
System.err.println(“Error sending message: ” + e.getMessage());
}
}
}
}
}
EOF

# 2. 创建HTML客户端
cat > /Tomcat/app/webapps/fgedu_push/index.html << EOF

FGEDU Data Push

Waiting for data…


EOF

# 3. 创建web.xml
cat > /Tomcat/app/webapps/fgedu_push/WEB-INF/web.xml << EOF

FGEDU Data Push Application

EOF

# 4. 编译Java类
cd /Tomcat/app/webapps/fgedu_push/WEB-INF/classes
javac -cp /Tomcat/app/lib/* com/fgedu/websocket/DataPushEndpoint.java

# 输出示例：
Note: DataPushEndpoint.java uses unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.

# 5. 重启Tomcat服务
/Tomcat/app/bin/shutdown.sh
/Tomcat/app/bin/startup.sh

# 6. 查看Tomcat日志
tail -f /Tomcat/app/logs/catalina.out

# 输出示例：
21-Jul-2024 11:00:00.000 INFO [main] org.apache.catalina.startup.HostConfig.deployDirectory Deploying web application directory [/Tomcat/app/webapps/fgedu_push]
21-Jul-2024 11:00:00.100 INFO [main] org.apache.catalina.startup.HostConfig.deployDirectory Deployment of web application directory [/Tomcat/app/webapps/fgedu_push] has finished in [100] ms

# 7. 测试WebSocket应用
curl http://localhost:8080/fgedu_push/

# 输出示例：

FGEDU Data Push

Waiting for data…


4.3 WebSocket应用部署实战

以下是WebSocket应用部署的实战案例：

# 1. 打包应用为WAR文件
cd /Tomcat/app/webapps/fgedu_chat
jar cvf /Tomcat/app/webapps/fgedu_chat.war *

# 输出示例：
added manifest
adding: (in = 0) (out= 0)(stored 0)
adding: WEB-INF/
adding: WEB-INF/classes/
adding: WEB-INF/classes/com/
adding: WEB-INF/classes/com/fgedu/
adding: WEB-INF/classes/com/fgedu/websocket/
adding: WEB-INF/classes/com/fgedu/websocket/ChatEndpoint.class
adding: WEB-INF/web.xml
adding: index.html

# 2. 配置Tomcat WebSocket参数
cat > /Tomcat/app/conf/server.xml << EOF









EOF

# 3. 配置SSL/TLS（可选）
# 生成自签名证书
mkdir -p /Tomcat/app/ssl
cd /Tomcat/app/ssl
openssl genrsa -out server.key 2048

# 输出示例：
Generating RSA private key, 2048 bit long modulus
…………………………………………..+++++
……..+++++
e is 65537 (0x10001)

openssl req -new -key server.key -out server.csr

# 输出示例：
You are about to be asked to enter information that will be incorporated
into your certificate request.
What you are about to enter is what is called a Distinguished Name or a DN.
There are quite a few fields but you can leave some blank
For some fields there will be a default value,
If you enter ‘.’, the field will be left blank.
—–
Country Name (2 letter code) [AU]:CN
State or Province Name (full name) [Some-State]:Beijing
Locality Name (eg, city) []:Beijing
Organization Name (eg, company) [Internet Widgits Pty Ltd]:fgedu
Organizational Unit Name (eg, section) []:IT
Common Name (e.g. server FQDN or YOUR name) []:fgedu.net.cn
Email Address []:admin@fgedu.net.cn

openssl x509 -req -days 365 -in server.csr -signkey server.key -out server.crt

# 输出示例：
Signature ok
subject=/C=CN/ST=Beijing/L=Beijing/O=fgedu/OU=IT/CN=fgedu.net.cn/emailAddress=admin@fgedu.net.cn
Getting CA Private Key

# 4. 配置HTTPS连接器
cat > /Tomcat/app/conf/server.xml << EOF














EOF

# 5. 重启Tomcat服务
/Tomcat/app/bin/shutdown.sh
/Tomcat/app/bin/startup.sh

# 6. 查看Tomcat日志
tail -f /Tomcat/app/logs/catalina.out

# 输出示例：
21-Jul-2024 11:00:00.000 INFO [main] org.apache.catalina.startup.VersionLoggerListener.log Server version name: Apache Tomcat/11.0.9
21-Jul-2024 11:00:00.000 INFO [main] org.apache.catalina.startup.VersionLoggerListener.log Server built: Jul 21 2024 10:00:00 UTC
21-Jul-2024 11:00:00.000 INFO [main] org.apache.catalina.startup.VersionLoggerListener.log Server number: 11.0.9.0
21-Jul-2024 11:00:00.000 INFO [main] org.apache.catalina.startup.VersionLoggerListener.log OS Name: Linux
21-Jul-2024 11:00:00.000 INFO [main] org.apache.catalina.startup.VersionLoggerListener.log OS Version: 5.15.0-105-generic
21-Jul-2024 11:00:00.000 INFO [main] org.apache.catalina.startup.VersionLoggerListener.log Architecture: amd64
21-Jul-2024 11:00:00.000 INFO [main] org.apache.catalina.startup.VersionLoggerListener.log JVM Version: 17.0.8+7
21-Jul-2024 11:00:00.000 INFO [main] org.apache.catalina.startup.VersionLoggerListener.log JVM Vendor: Eclipse Adoptium

# 7. 测试WebSocket应用（HTTP）
curl http://localhost:8080/fgedu_chat/

# 输出示例：

FGEDU Chat


# 8. 测试WebSocket应用（HTTPS）
curl -k https://localhost:8443/fgedu_chat/

# 输出示例：

FGEDU Chat


更多学习教程公众号风哥教程itpux_com

Part05-风哥经验总结与分享

5.1 WebSocket开发常见问题与解决方案

在WebSocket开发中，常见的问题及解决方案如下：

  • 连接失败：检查WebSocket端点URL和协议
  • 消息丢失：检查消息处理逻辑和异常处理
  • 性能问题：优化消息处理，使用异步处理
  • 连接断开：检查超时配置和网络连接
  • 跨域问题：配置CORS支持跨域请求

5.2 生产环境WebSocket最佳实践

在生产环境中，WebSocket的最佳实践包括：

  • 使用SSL/TLS：使用SSL/TLS保护WebSocket通信
  • 配置超时：配置合理的超时时间
  • 监控连接：监控WebSocket连接和消息
  • 负载均衡：配置负载均衡支持WebSocket
  • 错误处理：完善的错误处理机制

5.3 WebSocket开发经验分享

以下是一些WebSocket开发的经验分享：

  • 消息格式：使用JSON等标准格式
  • 心跳机制：实现心跳机制检测连接状态
  • 重连机制：实现自动重连机制
  • 消息队列：使用消息队列处理消息
  • 性能优化：批量发送消息，减少开销

风哥提示：WebSocket是实时通信的重要技术，合理使用WebSocket可以实现高效的实时应用

from Tomcat视频:www.itpux.com

本文由风哥教程整理发布,仅用于学习测试使用,转载注明出处:http://www.fgedu.net.cn/10327.html

相关推荐

联系我们

在线咨询：点击这里给我发消息

微信号：itpux-com

工作日：9:30-18:30，节假日休息