arnoldFu
V2EX  ›  Java

关于消息队列的实现

  •  
  •   arnoldFu · Dec 13, 2017 · 6719 views
    This topic created in 3257 days ago, the information mentioned may be changed or developed.

    现在需要实现一个功能,每当有消息发送过来时,把消息存到队列中(假设队列最大长度为 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();
            }
        }
        
    }
    

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

    Supplement 1  ·  Dec 13, 2017
    不应该叫 消息队列,应该叫 消息缓冲队列,
    描述有问题,见谅
    18 replies  •  2018-01-12 13:50:20 +08:00
    paragon
    paragon
    Dec 13, 2017
    1
    这个不叫做消息队列~
    misaka19000
    misaka19000
    Dec 13, 2017
    2
    楼上+1 ...

    这个同步块可能在数据量很大的情况下导致处理速度变慢
    xingwing
    xingwing
    Dec 13, 2017
    3
    RabbitMQ
    arnoldFu
    arnoldFu
    OP
    Dec 13, 2017
    4
    @paragon 是的,不能算作消息队列,更像是一个类似缓存的东西
    Starry
    Starry
    Dec 13, 2017
    5
    用 MQ 或者 REDIS 队列
    holyghost
    holyghost
    Dec 13, 2017
    6
    你这个叫 buffer 更合适吧
    arnoldFu
    arnoldFu
    OP
    Dec 13, 2017
    7
    @misaka19000 有可以优化的方法吗?加同步是怕在插入数据库时有新的消息需要入队导致入队失败
    arnoldFu
    arnoldFu
    OP
    Dec 13, 2017
    8
    @xingwing 感谢,我去了解一下
    arnoldFu
    arnoldFu
    OP
    Dec 13, 2017
    9
    @Starry 感谢,我去了解一下
    jimzhong
    jimzhong
    Dec 13, 2017
    10
    这种做法未必会有性能提升。
    arnoldFu
    arnoldFu
    OP
    Dec 13, 2017
    11
    @holyghost 是的,叫 buffer 确实更合适
    bigdogbigpig
    bigdogbigpig
    Dec 13, 2017 via iPhone
    12
    用个 redis 就好了
    wizardoz
    wizardoz
    Dec 13, 2017
    13
    消息队列是一个特指的词,你这个叫做“把消息缓存到队列”可能更好一些,避免误会。
    moka20477
    moka20477
    Dec 13, 2017
    14
    有同步代码块在高并发的时候就已经可能有性能问题了,另外不太明白这么做的意义,本身可以分散的流量,反倒让他集中 insert,而且还是遍历 insert
    mooncakejs
    mooncakejs
    Dec 13, 2017
    15
    这个只是缓存,没有 重试 机制的队列不叫队列。
    toono
    toono
    Dec 13, 2017
    16
    用现有的消息队列工具很好实现这个缓冲
    jowuIM
    jowuIM
    Dec 17, 2017
    17
    。。。个人作品加个线程池就够了,队列比较复杂
    crossoverJie
    crossoverJie
    Jan 12, 2018
    18
    synchronized 效率较低,如果是为了做同步可以用 ConcurrentLinkedQueue,我记得是基于 CAS 效率比 synchronized 要高。
    About   ·   Help   ·   Advertise   ·   Blog   ·   API   ·   FAQ   ·   Privacy   ·   Solana   ·   2091 Online   Highest 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 50ms · UTC 01:37 · PVG 09:37 · LAX 17:37 · JFK 20:37
    ♥ Do have faith in what you're doing.