关于消息队列的实现

2017 年 12 月 13 日
 arnoldFu

现在需要实现一个功能,每当有消息发送过来时,把消息存到队列中(假设队列最大长度为 10 ),当队列存满时将队列中的消息存入数据库中,以此来减轻数据库压力。

目前代码实现(java)

private BlockingQueue<Map<String, Object>> queue = new ArrayBlockingQueue<>(10);

public void receiveMessage(Map item) {

	synchronized(queue) {
        //入队
        queue.offer(item);

        //判断队列是否已满
        if (queue.size() == 10) {
            //遍历队列,插入数据库
            insert(queue);

            //清空队列
            queue.clear();
        }
    }
    
}

在高并发的情况下,这样写有没有问题?或者代码有没有可以优化的地方?或者使用第三方框架代替?

6001 次点击
所在节点    Java
18 条回复
paragon
2017 年 12 月 13 日
这个不叫做消息队列~
misaka19000
2017 年 12 月 13 日
楼上+1 ...

这个同步块可能在数据量很大的情况下导致处理速度变慢
xingwing
2017 年 12 月 13 日
RabbitMQ
arnoldFu
2017 年 12 月 13 日
@paragon 是的,不能算作消息队列,更像是一个类似缓存的东西
Starry
2017 年 12 月 13 日
用 MQ 或者 REDIS 队列
holyghost
2017 年 12 月 13 日
你这个叫 buffer 更合适吧
arnoldFu
2017 年 12 月 13 日
@misaka19000 有可以优化的方法吗?加同步是怕在插入数据库时有新的消息需要入队导致入队失败
arnoldFu
2017 年 12 月 13 日
@xingwing 感谢,我去了解一下
arnoldFu
2017 年 12 月 13 日
@Starry 感谢,我去了解一下
jimzhong
2017 年 12 月 13 日
这种做法未必会有性能提升。
arnoldFu
2017 年 12 月 13 日
@holyghost 是的,叫 buffer 确实更合适
bigdogbigpig
2017 年 12 月 13 日
用个 redis 就好了
wizardoz
2017 年 12 月 13 日
消息队列是一个特指的词,你这个叫做“把消息缓存到队列”可能更好一些,避免误会。
moka20477
2017 年 12 月 13 日
有同步代码块在高并发的时候就已经可能有性能问题了,另外不太明白这么做的意义,本身可以分散的流量,反倒让他集中 insert,而且还是遍历 insert
mooncakejs
2017 年 12 月 13 日
这个只是缓存,没有 重试 机制的队列不叫队列。
toono
2017 年 12 月 13 日
用现有的消息队列工具很好实现这个缓冲
jowuIM
2017 年 12 月 17 日
。。。个人作品加个线程池就够了,队列比较复杂
crossoverJie
2018 年 1 月 12 日
synchronized 效率较低,如果是为了做同步可以用 ConcurrentLinkedQueue,我记得是基于 CAS 效率比 synchronized 要高。

这是一个专为移动设备优化的页面(即为了让你能够在 Google 搜索结果里秒开这个页面),如果你希望参与 V2EX 社区的讨论,你可以继续到 V2EX 上打开本讨论主题的完整版本。

https://study.congcong.us/t/414304

V2EX 是创意工作者们的社区,是一个分享自己正在做的有趣事物、交流想法,可以遇见新朋友甚至新机会的地方。

V2EX is a community of developers, designers and creative people.

© 2021 V2EX