0

0

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

P粉602998670

P粉602998670

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

|

107人浏览过

|

来源于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 后吞掉异常——应向上抛或重新设置中断状态

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

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

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

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

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

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

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

超能文献
超能文献

超能文献是一款革命性的AI驱动医学文献搜索引擎。

下载

正确做法是:用 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工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

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

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

426

2023.08.07

json是什么
json是什么

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

540

2023.08.23

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

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

313

2023.10.13

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

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

78

2025.09.10

string转int
string转int

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

584

2023.08.02

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

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

354

2023.11.13

java boolean类型
java boolean类型

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

34

2025.11.30

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

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

238

2023.09.22

java return合集
java return合集

本专题整合看java中return关键词的用途,语句的使用等等内容,阅读专题下面的文章了解更多详细内容。

0

2026.02.05

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Kotlin 教程
Kotlin 教程

共23课时 | 3.2万人学习

C# 教程
C# 教程

共94课时 | 8.6万人学习

Java 教程
Java 教程

共578课时 | 57.8万人学习

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

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号