讲师中心 微信公众号
AI工具推荐 视频效率加速

在Java里如何实现一个基本的消息提醒系统_Java多线程与文件处理应用

星萱小哥_1799

星萱小哥_1799

发布时间:2026-02-05 12:38:49

|

147人浏览过

|

来源于php中文网

原创

最轻量线程安全消息队列用LinkedList+wait()/notify()实现,需while循环等待、add后notify、消息体预留type/priority/expireAt等字段,文件持久化用Files.write或PrintWriter,启动用CountDownLatch控制顺序。

在java里如何实现一个基本的消息提醒系统_java多线程与文件处理应用

用 wait() + notify() 实现线程安全的消息队列

Java里最轻量、不依赖第三方库的消息提醒系统,核心是让生产者(发消息)和消费者(处理提醒)解耦。直接用 LinkedList 配合 synchronized 块 + wait()/notify() 是最可控的做法——比裸用 BlockingQueue 更利于理解阻塞逻辑,也比自己加 Thread.sleep() 轮询更省资源。

常见错误是忘了在 while (queue.isEmpty()) 里等待,写成 if 导致虚假唤醒后直接 poll() 出 null;还有忘记在 addMessage() 末尾调用 notify(),导致消费者永远卡住。

  • getMessage() 方法必须用 while 判断空队列,不能用 if
  • 每次 addMessage() 后必须 notify(),哪怕队列没满也要唤醒等待中的消费者
  • 不要在 wait() 外层加 try-catch InterruptedException 后吞掉异常——应向上抛或重新设置中断状态

消息体设计要预留扩展字段,别只存 content 和 receiver

实际项目中,“提醒”不是只有“发给谁+说什么”。比如你要支持邮件、短信、站内信混合推送,就得在 Message 类里提前留好 type("email"/"sms")、priority(int)、expireAt(long 时间戳),甚至 retryCount。否则后期加字段要改所有生产者代码,还容易漏初始化。

一个典型坑是把接收者写成 String receiver,结果业务要求支持群发(多个邮箱)、分级通知(先发组长再发总监)。不如一开始定义为 List<String> recipients,哪怕初期只加一个元素。

立即学习“Java免费学习笔记(深入)”;

Wjs Uploading Video
Wjs Uploading Video

将一个或多个视频上传至YouTube。当用户想“上传到YouTube”“发YouTube”“批量上传”“upload to YouTube”“post videos to YouTube”或发布到YouTube时使用此技能。

下载
  • 加 timestamp 字段,方便后续做延迟提醒或去重判断
  • 避免用 public 成员变量,getter/setter 虽啰嗦,但未来加校验逻辑(如邮箱格式检查)不用动调用方
  • 如果消息可能持久化到文件,字段类型优先选 String、long、int,少用 Date 或自定义对象,减少序列化麻烦

文件落盘做兜底时,别用 FileWriter 直接追加

消息提醒系统一旦挂掉,内存里的队列就丢了。加文件持久化是刚需,但很多人用 FileWriter("queue.log", true) 每次写一条,结果高并发下日志错乱、换行丢失、甚至覆盖前一条——因为 FileWriter 不保证原子写入,也没缓冲区控制。

正确做法是:用 Files.write() 配合 StandardOpenOption.APPEND,且每次写入带完整换行符;或者更稳一点,用 PrintWriter 包一层,调用 println() 并显式 flush()。

  • 写入前对 Message 做 JSON 序列化(比如用 Gson.toJson()),别拼字符串,避免内容含换行或引号导致解析失败
  • 文件名建议带日期,如 queue_20260204.log,方便按天归档和排查
  • 启动时先读文件重建队列,但要注意重复加载风险——可加个 processedId 文件记录最后成功消费的 ID

多线程启动顺序错了,系统会“假死”

主函数里如果先 start() 消费者线程,再 start() 生产者,大概率消费者一上来就 wait() 等消息,而生产者还没开始放数据,整个流程卡住。这不是 bug,是线程调度的正常现象。

解决方法很简单:生产者线程启动后,主线程 sleep(100) 再启动消费者;或者更干净的做法——用 CountDownLatch 控制就绪顺序:生产者初始化完 countDown(),消费者 await() 等它就位。

  • 别依赖 Thread.join() 来等生产者“发完”,它根本不知道啥时候算“发完”
  • 消费者线程的 while(true) 循环里,catch(InterruptedException) 后建议直接 break,避免被中断后还傻等
  • 如果后续要支持优雅停机,得给消费者加个 volatile boolean running = true,循环条件改成 while(running)

真正难的从来不是写出让消息“动起来”的代码,而是想清楚:哪条消息绝对不能丢?哪类提醒必须 5 秒内触达?文件写一半进程崩溃了怎么办?这些边界问题不提前想,上线后查日志都找不到断点。

热门AI工具

更多
AionClaw
AionClaw Hot

AionClaw是一款面向办公、创作和编程任务的AI桌面智能体。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

蛙蛙写作

一款AI论文写作工具,主要用于超级AI智能写作助手,适合需要提升相关任务效率的用户。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

Loomy
Loomy Hot

一款AI工具,主要用于科大讯飞发布的桌面级 AI 助理,比 OpenClaw 更易用、更安全!,适合需要提升相关任务效率的用户。

音述AI
音述AI Hot

一款AI音频处理工具,主要用于音述AI是一个以“用声音述说故事”为核心的 AI 音乐创作与声音分享社区,适合需要提升相关任务效率的用户。

LibLibAI
LibLibAI Hot

一款AI视频创作工具,主要用于国内领先的AI创意平台,以海量模型、低门槛操作与“创作-分享-商业化”生态,让小白与专业创作者都能高效实现图文乃至视频创意表达,适合需要提升相关任务效率的用户。

Seko
Seko Hot

一款AI视频创作工具,主要用于商汤科技推出的创编一体的AI短视频创作Agent,适合需要提升相关任务效率的用户。

相关专题

更多
json数据格式
json数据格式

JSON是一种轻量级的数据交换格式。本专题为大家带来json数据格式相关文章,帮助大家解决问题。

2095

2023.08.07

json是什么
json是什么

JSON是一种轻量级的数据交换格式,具有简洁、易读、跨平台和语言的特点,JSON数据是通过键值对的方式进行组织,其中键是字符串,值可以是字符串、数值、布尔值、数组、对象或者null,在Web开发、数据交换和配置文件等方面得到广泛应用。本专题为大家提供json相关的文章、下载、课程内容,供大家免费下载体验。

3142

2023.08.23

jquery怎么操作json
jquery怎么操作json

操作的方法有:1、“$.parseJSON(jsonString)”2、“$.getJSON(url, data, success)”;3、“$.each(obj, callback)”;4、“$.ajax()”。更多jquery怎么操作json的详细内容,可以访问本专题下面的文章。

1056

2023.10.13

go语言处理json数据方法
go语言处理json数据方法

本专题整合了go语言中处理json数据方法,阅读专题下面的文章了解更多详细内容。

3579

2025.09.10

string转int
string转int

在编程中,我们经常会遇到需要将字符串(str)转换为整数(int)的情况。这可能是因为我们需要对字符串进行数值计算,或者需要将用户输入的字符串转换为整数进行处理。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

6119

2023.08.02

java中boolean的用法
java中boolean的用法

在Java中,boolean是一种基本数据类型,它只有两个可能的值:true和false。boolean类型经常用于条件测试,比如进行比较或者检查某个条件是否满足。想了解更多java中boolean的相关内容,可以阅读本专题下面的文章。

2130

2023.11.13

java boolean类型
java boolean类型

本专题整合了java中boolean类型相关教程,阅读专题下面的文章了解更多详细内容。

143

2025.11.30

c语言中null和NULL的区别
c语言中null和NULL的区别

c语言中null和NULL的区别是:null是C语言中的一个宏定义,通常用来表示一个空指针,可以用于初始化指针变量,或者在条件语句中判断指针是否为空;NULL是C语言中的一个预定义常量,通常用来表示一个空值,用于表示一个空的指针、空的指针数组或者空的结构体指针。

549

2023.09.22

Linux 新手先学哪些命令
Linux 新手先学哪些命令

Linux新手命令专题汇集终端基础、文件目录操作、文本查看、软件安装和权限管理等入门文章,帮助按实际任务练习常用命令并建立命令行操作习惯。

0

2026.10.15

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
dev.java 官方:Learn Java
dev.java 官方:Learn Java

共0课时 | 0人学习

Java JDBC数据库连接官方教程
Java JDBC数据库连接官方教程

共0课时 | 0人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn