weixin_37582106 2017-05-24 02:23 采纳率: 0%
浏览 2698

求问哈java中使用内存实现消息队列

有一个需求，是在servlet的业务方法中。有一些dao操作，因为表建了索引，所以做插入可能比较耗时，就想实现异步。
把dao操作的那一部分放入消息队列里面去，开启一个线程进行到操作。因为不能涉及第三方工具，只能用内存实现消息队列。求大神帮忙。。。

  • 写回答

3条回答 默认 最新

  • RayeWang 2017-05-24 02:33
    关注

    直接使用BlockingQueue 或者ConcurrentLinkedQueue就行了，是Java自带的队列类

    评论

报告相同问题？

  • java websocket通信中多线程问题 java
    2021-05-11 16:13
    回答 1 已采纳 一个连接一个session，链接数量和每个连接发送数据的大小有关系，java线程的创建和销毁是很好资源的，建议使用线程池，基于内存的消息队列是最快的，kafka是面向大数据的可以配置个多消息分区和消费
  • rabbitmq 延时队列，消息被监听到以后，还在队列里面 java
    2020-08-12 10:59
    回答 2 已采纳 开启了手动ack，没有进行手动ack操作，消息自然还是会留在队列里面的，需要进行手动ack操作 参考如下代码 ``` @RabbitListener(queues = RabbitMqConfi
  • Java程序为何运行越来越慢 java spring
    2020-09-23 09:16
    回答 3 已采纳 越来越慢可能是因为算法本身的算法复杂度不是线性的，也就是随着数据量的增加，运算时间不是等比例增加而是平方、指数方式增加 这个需要你优化算法，用算法复杂度低的算法 另一个是内存不足，造成了系
  • Java基于内存的消息队列实现
    2022-03-23 18:26
    鲸歌的博客 Java基于内存的消息队列实现 先看测试情况 需求背景 需求来源于我写的一个单体应用方便使用的动态任务调度框架（详细内容见Gitee地址：https://gitee.com/hyxl-520/autojob.git），该框架需要实现对运行的任务的...
  • Java 生产者消费者与线程池 java
    2018-01-16 15:05
    回答 3 已采纳 线程池起码没有办法解决以下问题： （1）跨进程，跨机器，不能跨机器和进程，只能单机，没有什么实用性。 （2）队列容错和恢复，停机怎么办，程序崩溃怎么办。 （3）比较容易死锁，很难调试，而且隔离性
  • 内存和文件的实时同步有什么好的思路？ java
    2019-10-31 10:04
    回答 1 已采纳 参考增量备份的设计思路： 1. 每次操作有一个全局唯一的、递增的操作id，命名为opid; 2. 文件分两种：快照文件，保存一个时刻的业务数据镜像；操作日志文件，保存一段时间的添加删除日志，以op
  • ThreadPoolTaskExecutor 异步任务 对于长时间大数据的执行，执行一半线程终止。 intellij-idea java spring sqlite
    2019-05-14 18:21
    回答 3 已采纳 问题已解决; sqllite 存入blob字段时 以流的形式将多媒体文件读入流中，并在流中组装prmt,导致堆内存溢出，使线程无限等待。
  • java内存队列的使用_Java知识总结----队列的使用
    2021-03-13 08:45
    Gaven Wang的博客 首先我们要知道使用队列的目的是什么？一般情况下，如果是一些及时消息的处理，并且处理...当我们接受到消息后，先把消息放到队列中，然后再用新的线程进行处理，这个时候就不会有消息的阻塞了。下面就跟大家介绍...
  • vs2022无法打开文件 java
    2022-10-08 15:12
    回答 2 已采纳 source = fopen("ch", "r") 其中的ch不要加引号source = fopen(ch, "r")
  • 怎么样用一个文件来实现队列?
    2010-05-12 13:50
    回答 1 已采纳 这个需求有意思。如果是我来做,我会这么想。 首先这是经典的生产消费者问题,您完全可以找一篇文章来看看应该怎么处理。 假设（1） [b][color=red]A线程[/color][/b]忘
  • 为什么下面的代码会报内存溢出呢
    2012-10-17 16:59
    回答 3 已采纳 溢出后 建议打印堆栈检查（jmap） bufImg.getGraphics() 用完后考虑dispose JDK描述 [quote]dispose()释放此图形的上下文以及它使用的所有系统资
  • Java开发 - 消息队列之RabbitMQ初体验
    2023-03-13 08:30
    CodingFire的博客 RabbitMQ是使用Erlang语言开发的开源消息队列系统，基于AMQP...所以在Java业务中使用很多，目前我所知道的很多都是用的此消息队列，只不过大家评价都是：功能强，性能一般。与其相反的，就是Kafka了：性能强，功能弱。
  • 请教一个JVM内存优化的问题
    2008-12-28 22:46
    回答 2 已采纳 你打个能运行的代码包上来，我帮你看看。
  • java实现队列
    2022-07-10 17:57
    梧桐叶123的博客 java实现队列
  • java实现RabbitMQ消息队列
    2022-04-19 16:46
    笑对人生-的博客 MQ（Message Queue）消息队列，是基础数据结构中“先进先出”的一种数据结构。一般用来解决应用解耦，异步消息，流量削峰等问题，实现高性能，高可用，可伸缩和最终一致性架构。
  • 没有解决我的问题, 去提问

悬赏问题

  • ¥15 c程序不知道为什么得不到结果
  • ¥40 复杂的限制性的商函数处理
  • ¥15 程序不包含适用于入口点的静态Main方法
  • ¥15 素材场景中光线烘焙后灯光失效
  • ¥15 请教一下各位，为什么我这个没有实现模拟点击
  • ¥15 执行 virtuoso 命令后，界面没有，cadence 启动不起来
  • ¥50 comfyui下连接animatediff节点生成视频质量非常差的原因
  • ¥20 有关区间dp的问题求解
  • ¥15 多电路系统共用电源的串扰问题
  • ¥15 slam rangenet++配置