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

[特殊字符] 苍穹外卖项目中的 WebSocket 实战：实现来单与催单提醒功能

news 来源：原创 2025/6/27 1:15:20

🚀 苍穹外卖项目中的 WebSocket 实战：实现来单与催单提醒功能

在这里插入图片描述

在现代 Web 应用中，实时通信成为提升用户体验的关键技术之一。WebSocket 作为一种在单个 TCP 连接上进行全双工通信的协议，被广泛应用于需要实时数据交换的场景，如在线聊天、实时通知等。本文将结合苍穹外卖项目，介绍如何使用 WebSocket 实现来单提醒与催单提醒功能。

📖 WebSocket 简介 WebSocket 是一种网络通信协议，允许在客户端和服务器之间建立持久的连接，双方可以随时发送数据。与传统的 HTTP 请求-响应模式不同，WebSocket 提供了更高效的通信方式，特别适用于需要实时交互的应用场景。

🛠️ 项目中 WebSocket 的应用场景在苍穹外卖项目中，WebSocket 被用于实现以下功能：

来单提醒：当用户下单并支付成功后，系统通过 WebSocket 向商家管理端发送通知，提示有新订单。
- 催单提醒：用户在等待订单过程中，可以点击“催单”按钮，系统通过 WebSocket 向商家管理端发送催单通知。这些功能依赖于客户端与服务器之间的实时通信，确保商家能够及时响应用户的需求。

🧱 实现步骤

引入WebSocket依赖
在pom.xml中添加以下依赖：

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

配置WebSocket
创建配置类WebSocketConfiguration，注册WebSocket组件：

@Configuration  
public class WebSocketConfiguration {  @Bean  public ServerEndpointExporter serverEndpointExporter() {  return new ServerEndpointExporter();  }  
}

创建WebSocket服务端
实现WebSocketServer类，处理连接、消息收发逻辑：

@Component  
@ServerEndpoint("/ws/{sid}")  
public class WebSocketServer {  private static Map<String, Session> sessionMap = new HashMap<>();  @OnOpen  public void onOpen(Session session, @PathParam("sid") String sid) {  sessionMap.put(sid, session);  }  @OnMessage  public void onMessage(String message, @PathParam("sid") String sid) {  // 处理接收到的消息  }  @OnClose  public void onClose(@PathParam("sid") String sid) {  sessionMap.remove(sid);  }  public void sendToAllClient(String message) {  for (Session session : sessionMap.values()) {  try {  session.getBasicRemote().sendText(message);  } catch (Exception e) {  e.printStackTrace();  }  }  }  
}

业务逻辑中集成消息发送

订单支付成功提醒

public void paySuccess(String outTradeNo) {  // 更新订单状态  Orders ordersDB = orderMapper.getByNumber(outTradeNo);  Orders orders = Orders.builder()  .id(ordersDB.getId())  .status(Orders.TO_BE_CONFIRMED)  .payStatus(Orders.PAID)  .checkoutTime(LocalDateTime.now())  .build();  orderMapper.update(orders);  // 构造消息并广播  Map<String, Object> map = new HashMap<>();  map.put("type", 1); // 1=来单提醒  map.put("orderId", ordersDB.getId());  map.put("content", "订单号：" + outTradeNo);  String json = JSON.toJSONString(map);  webSocketServer.sendToAllClient(json);  
}

用户催单提醒

public void reminder(Long id) {  Orders orders = orderMapper.selectByOId(id);  if (orders == null || orders.getStatus() != Orders.TO_BE_CONFIRMED) {  throw new OrderBusinessException("订单状态不允许催单");  }  Map<String, Object> map = new HashMap<>();  map.put("type", 2); // 2=催单提醒  map.put("orderId", id);  map.put("content", "订单号：" + orders.getNumber());  String json = JSON.toJSONString(map);  webSocketServer.sendToAllClient(json);  
}

前端消息处理
建立WebSocket连接并解析通知：

// 初始化连接（clientId为前端用户标识）  
var websocket = new WebSocket("ws://localhost:8080/ws/" + clientId);  // 消息监听  
websocket.onmessage = function(event) {  var data = JSON.parse(event.data);  if (data.type === 1) {  alert("来单提醒：" + data.content);  } else if (data.type === 2) {  alert("催单提醒：" + data.content);  }  
};

🧪 测试与验证

测试流程：

启动后端服务与前端页面，建立WebSocket连接；
模拟用户下单并支付，验证商家端是否弹出“来单提醒”；
触发用户催单操作，验证是否收到“催单提醒”弹窗。

Nginx配置（如需代理）：

location /ws/ {  proxy_pass http://localhost:8080;  proxy_http_version 1.1;  proxy_set_header Upgrade $http_upgrade;  proxy_set_header Connection "Upgrade";  
}

🧠 总结

通过WebSocket技术，苍穹外卖实现了毫秒级实时通知，显著提升了商家订单处理效率与用户体验。WebSocket在实时通信场景（如在线聊天、数据监控）中具有广泛适用性，是现代Web开发的核心技术之一。

[特殊字符] 苍穹外卖项目中的 WebSocket 实战：实现来单与催单提醒功能

🚀 苍穹外卖项目中的 WebSocket 实战：实现来单与催单提醒功能在现代 Web 应用中，实时通信成为提升用户体验的关键技术之一。WebSocket 作为一种在单个 TCP 连接上进行全双工通信的协议，被广泛应用于需要实时数据交换的场景&#…...

编程日记 2025/6/27 1:15:20

【C/C++】深度解析C++ Allocator：优化内存管理的关键

文章目录深度解析C Allocator：优化内存管理的关键1 默认 std::allocator2 自定义 Allocator3 自定义 Allocator 的实现3.1 基本结构3.2 使用自定义 Allocator 4 关键特性详解4.1 rebind 机制4.2 状态化 Allocator 5 应用示例：内存池 Allocator5.1 简单内…...

编程日记 2025/6/27 0:22:50

gitlab+portainer 实现Ruoyi Vue前端CI/CD

1. 场景最近整了一个Ruoyi Vue 项目，需要实现CICD，经过一番坎坷，最终达成，现将技术要点和踩坑呈现。具体操作流程和后端大同小异，后端操作参考连接如下： https://blog.csdn.net/leinminna/article/detai…...

编程日记 2025/6/27 0:21:47

CAPL编程系列_04

1_ 测试模块TestModule：基本使用 1）在Simulation Setup 中创建并配置 Test Module节点 2）编写测试脚本【1】测试用例函数（testcase）:实现具体测试逻辑【2】主测试函数（Main Test）&…...

编程日记 2025/6/27 0:19:59

Weblogic SSRF漏洞复现（CVE-2014-4210）【vulhub靶场】

漏洞概述： Weblogic中存在一个SSRF漏洞，利用该漏洞可以发送任意HTTP请求，进而攻击内网中redis、fastcgi等脆弱组件。漏洞形成原因： WebLogic Server 的 UDDI 组件（uddiexplorer.war）中的 SearchPublicR…...

编程日记 2025/6/27 0:29:21

科技的成就（六十八）

623、杰文斯悖论杰文斯悖论是1865年经济学家威廉斯坦利杰文斯提出的一悖论：当技术进步提高了效率，资源消耗不仅没有减少，反而激增。例如，瓦特改良的蒸汽机让煤炭燃烧更加高效，但结果却是煤炭需求飙升。 624、代码混…...

编程日记 2025/6/23 17:13:53

知从科技闪耀2025上海车展：以创新驱动未来出行新篇章

上海，2025年4月23日——全球汽车科技领域的年度盛会——2025上海国际汽车工业展览会（简称“上海车展”）于5月2日圆满落幕。作为智能汽车软件与系统解决方案的领军企业，知从科技受邀参展，并在活动期间全方位展示了其在智…...

编程日记 2025/6/27 1:13:08

【iOS安全】Dopamine越狱 iPhone X iOS 16.6 (20G75) | 解决Jailbreak failed with error

Dopamine越狱 iPhone X iOS 16.6 (20G75) Dopamine兼容设备参考：https://www.bilibili.com/opus/977469285985157129 A9 - A11（iPhone6s－X）：iOS15.0-16.6.1 A12-A14（iPhoneXR－12PM&#xf…...

编程日记 2025/6/26 20:18:48

医疗数据迁移质量与效率的深度研究：三维六阶框架与实践创新

引言随着医疗信息化建设的深入推进，医疗数据作为医疗机构的核心资产，其价值与日俱增。在医院信息系统升级、迁移或整合过程中，数据迁移的质量与效率直接关系到医疗服务的连续性、患者信息的安全性以及医院运营的稳定性。传统数据迁移方法往往面临时间长、风险高、成本大等…...

编程日记 2025/6/24 16:50:41

[6-8] 编码器接口测速江协科技学习笔记（7个知识点）

1 2 在STM32微控制器的定时器模块中，CNT通常指的是定时器的计数器值。以下是CNT是什么以及它的用途： 是什么： • CNT：代表定时器的当前计数值。在STM32中，定时器从0开始计数，直到达到预设的自动重装载值&am…...

编程日记 2025/6/25 17:20:07

java类加载阶段与双亲委派机制

java执行过程:.java->.class->然后被jvm加载解释执行。一、类加载机制的三个阶段加载（Loading） 任务：通过类的全限定名获取二进制字节流（如从文件系统、网络等），将字节流转换为方…...

编程日记 2025/6/27 0:26:23

医院网络安全托管服务(MSS)深度解读与实践路径

医疗行业网络安全挑战与MSS的应运而生医疗行业在数智化转型的过程中面临着前所未有的网络安全挑战。根据2025年的最新数据，医疗行业将面临大量网络攻击，其中高达91%与勒索软件有关，且45%的数据泄露事件源于第三方供应商。医疗机构的平均数据…...

编程日记 2025/6/27 1:09:25

计算图存储采用矩阵吗，和张量关系

计算图存储采用矩阵吗，和张量关系计算图的存储方式与张量的关系一、计算图的存储方式计算图（Computational Graph）是一种用于描述数学运算的有向无环图（DAG），其节点代表运算（如加减乘除、矩阵乘法、激活函数等），边代表运算的输入和输出（通常是张量）。计算图的…...

编程日记 2025/6/24 21:26:22

RPA 自动化实现自动发布

📕我是廖志伟，一名Java开发工程师、《Java项目实战——深入理解大型互联网企业通用技术》（基础篇）、（进阶篇）、（架构篇）清华大学出版社签约作家、Java领域优质创作者、CSDN博客专家、…...

编程日记 2025/6/27 0:30:24

博途软件直接寻址AMS348i读取位置值详解

一、AMS348i简介 AMS348i是一种高性能绝对值编码器，常用于工业自动化领域的位置检测。它具有以下特点： 高精度位置测量多种通信接口（如SSI、PROFIBUS、PROFINET等） 坚固的工业设计支持多种安装方式二、元器件及配件设备…...

编程日记 2025/6/27 0:40:42

MySQL 学习（十）执行一条查询语句的内部执行过程、MySQL分层

目录一、MySQL 执行流程图二、MySQL的分层2.1 连接阶段2.2 查询缓存阶段（Query Cache，MySQL 8.0已移除）2.3 解析与预处理阶段（词法分析、语法分析、预处理器）2.4 查询优化阶段2.5 执行引擎阶段三、常见面试题3.1 MyS…...

编程日记 2025/6/27 1:04:37

C语言中的指定初始化器

什么是指定初始化器？ C99标准引入了一种更灵活、直观的初始化语法——指定初始化器（designated initializer），可以在初始化列表中直接引用结构体或联合体成员名称的语法。通过这种方式，我们可以跳过某些不需要初始化的成员，并且可以以任意顺序对特定成员进行初始化。这…...

编程日记 2025/6/24 19:23:02

什么是 NB-IoT ？窄带IoT 应用

物联网使各种应用能够与大量无线通信设备进行连接和通信。它有望为智能城市、公用事业、制造设施、农业应用、远程工业机械等提供动力。这些应用均可使用窄带物联网（NB-IoT ）网络协议。例如，智能城市可使用 NB-IoT 监控整个城市的街道照明、…...

编程日记 2025/6/23 1:45:03

CSRF 和 XSS 攻击分析与防范

CSRF 和 XSS 攻击分析与防范 CSRF (跨站请求伪造) 什么是 CSRF？ CSRF (Cross-Site Request Forgery) 是一种攻击方式，攻击者诱使用户在已登录目标网站的情况下，执行非预期的操作。攻击流程： 用户登录可信网站 A在不登出 A 的…...

编程日记 2025/6/26 18:00:17

Window下Jmeter多机压测方法

1.概述 Jmeter多机压测的原理，是通过单个jmeter客户端，控制多个远程的jmeter服务器，使他们同步的对服务器进行压力测试。以此方式收集测试数据的好处在于： 保存测试采样数据到本地机器通过单台机器管理多个jmeter执行引擎测试…...

编程日记 2025/6/23 1:48:31

Apache RocketMQ ACL 2.0 全新升级

📖知识延伸：本文相关知识库已收录至「RocketMQ 中文社区」，同步更新更多进阶内容引言 RocketMQ 作为一款流行的分布式消息中间件，被广泛应用于各种大型分布式系统和微服务中，承担着异步通信、系统解耦、削峰填谷和消…...

编程日记 2025/6/26 7:23:24

第九讲 | 模板进阶

模板进阶一、非类型模板参数1、模板参数的分类2、应用场景3、array4、注意二、模板的特化1、概念2、函数模板特化3、类模板特化（1）、全特化：全部模板参数都特化成具体的类型（2）、偏/半特化：部分模板参数特…...

编程日记 2025/6/23 23:57:54

联合建模组织学和分子标记用于癌症分类|文献速递-深度学习医疗AI最新文献

Title 题目 Joint modeling histology and molecular markers for cancer classification 联合建模组织学和分子标记用于癌症分类 01 文献速递介绍癌症是对人类致命的恶性肿瘤，早期准确诊断对癌症治疗至关重要。目前，病理诊断仍是癌症诊断的金标准…...

编程日记 2025/6/24 18:21:30

会计要素+借贷分录+会计科目+账户,几个银行会计的重要概念

1.借贷分录还是借贷分路正确表述是“借贷分录”。 “分录”即会计分录，它是指预先确定每笔经济业务所涉及的账户名称，以及计入账户的方向和金额的一种记录，简称分录。在借贷记账法下，会计分录通过“借”和“贷”来表示记账方向…...

编程日记 2025/6/26 4:10:40

【C++】set和multiset的常用接口详解

前⾯我们已经接触过STL中的部分容器如：string、vector、list、deque、array、forward_list等，本篇文章将介绍一下map和multiset的使用。 1. 序列式容器和关联式容器在介绍set之前我们先简单介绍一下什么是序列式容器和关联式容器。前⾯我们已经接触过S…...

编程日记 2025/6/26 12:27:23

PostgreSQL 联合索引生效条件

最近面试的时候，总会遇到一个问题在 PostgreSQL 中，联合索引在什么条件下会生效？ 特此记录~ 前置信息数据库版本 PostgreSQL 14.13, compiled by Visual C build 1941, 64-bit 建表语句 CREATE TABLE people (id SERIAL PRIMARY KEY,c…...

编程日记 2025/6/24 15:11:35

聊聊redisson的lockWatchdogTimeout

序本文主要研究一下redisson的lockWatchdogTimeout lockWatchdogTimeout redisson/src/main/java/org/redisson/config/Config.java private long lockWatchdogTimeout 30 * 1000;/*** This parameter is only used if lock has been acquired without leaseTimeout param…...

编程日记 2025/6/25 10:18:24

数据结构第七章（三）-树形查找：红黑树

树形查找（二） 红黑树一、红黑树1.定义2.黑高3.性质二、插入1.插入步骤2.举例总结红黑树红黑树来喽~ 我们在上一篇说了二叉排序树（BST）和平衡二叉树（AVL），那么既然都有这两个了，…...

编程日记 2025/6/27 1:01:43

C++篇——多态

目录引言 1，什么是多态 2. 多态的定义及实现 2_1，多态的构成条件 2_2，虚函数 2_3，虚函数的重写 2_4，虚函数重写的两个例外 2_4_1，协变(基类与派生类虚函数返回值类型不同) 2_4_2. 析构函数的重写(基类…...

编程日记 2025/6/26 6:45:42

AI实时对话的通信基础，WebRTC技术综合指南

在通过您的网络浏览器进行音频和视频通话、屏幕共享或实时数据传输时，您可能并不常思考其背后的技术。推动这些功能的核心力量之一就是WebRTC。2011年由谷歌发布的这个开源项目，如今已发展成为一个高度全面且不断扩展的生态系统。尤其是在AI技术大幅突破…...

编程日记 2025/6/26 23:55:19

【寻找Linux的奥秘】第五章：认识进程

请君浏览前言1. 冯诺依曼体系结构数据流动 2. 操作系统（Operating System）2.1 概念2.2 设计OS的目的2.3 如何理解“管理”2.4 系统调用和库函数概念 3. 进程3.1 基本概念3.1.1 查看进程3.1.2 创建进程 3.2 进程状态3.2.1 简单介绍3.2.2 运行&&阻…...

编程日记 2025/6/27 1:03:00

uniapp微信小程序-长按按钮百度语音识别回显文字

流程图： 话不多说，上代码： <template><view class"content"><view class"speech-chat" longpress"startSpeech" touchend"endSpeech"><view class"animate-block" …...

编程日记 2025/6/27 1:06:10

支付宝创建商家订单收款码（统一收单线下交易预创建）.net开发的软件附带大型XML文件可以删除吗？AlipaySDKNet.OpenAPI.xml

支付宝创建商家订单收款码（统一收单线下交易预创建）一个程序55MB，XML就带了35MB AlipaySDKNet.OpenAPI.xml，BouncyCastle.Crypto.xml 支付宝店铺收款码创建的程序，这些文件可以不用吗在支付宝店铺收款码创建的程序中…...

编程日记 2025/6/25 19:20:16

Profinet转Ethernet/IP网关模块通信协议适配配置

案例背景在某自动化生产车间中，现有控制系统采用了西门子 S7 - 1500 PLC 作为主要控制器，负责生产流程的核心控制。同时，由于部分设备的历史原因，存在使用 AB 的 PLC 进行特定环节控制的情况。为了实现整个生产系统的信息交互与…...

编程日记 2025/6/26 19:31:48

4.6/Q1，GBD数据库最新文章解读

文章题目：Global burden, subtype, risk factors and etiological analysis of enteric infections from 1990-2021: population based study DOI：10.3389/fcimb.2025.1527765 中文标题：1990-2021 年肠道感染的全球负担、亚型、危险因素和病因…...

编程日记 2025/6/27 0:26:22

数字孪生技术：开启未来的“镜像”技术

想象一下，你拥有一个与现实世界一模一样的 “数字分身”，它不仅长得像你，行为举止、思维方式也和你毫无二致，甚至能提前预知你的下一步行动。这听起来像是科幻电影里的情节，但数字孪生技术却让它在现实中成为了可能。数…...

编程日记 2025/6/26 22:22:40

Java 序列化（Serialization）

一、理论说明 1. 序列化的定义 Java 序列化是指将对象转换为字节流的过程，以便将其存储到文件、数据库或通过网络传输。反序列化则是将字节流重新转换为对象的过程。通过实现java.io.Serializable接口，类可以被标记为可序列化的，该接口是一…...

编程日记 2025/6/26 3:39:46

Python解析Excel入库如何做到行的拆分

我们读取解析Excel入库经常会遇到这种场景，那就是行的拆分，如图： 比如我们入库，要以name为主键，可是表格name的值全是以逗号分割的多个，这怎么办呢？这就必须拆成多行了啊。代码如下&#xff…...

编程日记 2025/6/24 8:35:45

信创国产化监控 | 达梦数据库监控全解析

达梦数据库（DM Database）是国产数据库的代表产品之一，在政府、金融、电信、能源等多个关键行业应用广泛，它具有高兼容性、高安全性、高可用性、高性能、自主可控等特点。随着国产化替代进程加速，达梦数据库在关键信息基…...

编程日记 2025/6/21 5:23:07

Parsec解决PnP连接失败的问题

提示：文章写完后，目录可以自动生成，如何生成可参考右边的帮助文档文章目录前言一、准备环境二、DMZ三、端口映射1.Parsec设置固定端口2.路由器设置端口转发3.重启被控端Parsec四、多少一句1.有光猫管理员账号2.没有光猫管理员账号总结前言…...

编程日记 2025/6/25 8:44:48

LLM笔记（二）LLM数据基础

核心目标: 构建 LLM 的数据基础，将原始文本转化为模型可处理的、包含丰富语义和结构信息的数值形式。一、环境与库准备 (Environment & Libraries): 必要库确认: 在开始之前，确保 torch (PyTorch深度学习框架) 和 tiktoken (OpenAI的高效BPE分词…...

编程日记 2025/6/25 15:49:01

让三个线程（t1、t2、t3）按顺序依次打印 A、B、C

public class ThreadWait {private static final Object lock = new Object();private static boolean t1Output=true;private static boolean t2Output=false;private static boolean t3Output=false;public static void main(String[] args) {//线程1new Thread(new Runnable…...

编程日记 2025/6/24 10:25:34