首页   注册   登录
V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
华为云
V2EX  ›  Java

关于消息队列的实现

  •  
  •   arnoldFu · 312 天前 · 2539 次点击
    这是一个创建于 312 天前的主题,其中的信息可能已经有所发展或是发生改变。

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

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

    第 1 条附言  ·  312 天前
    不应该叫 消息队列,应该叫 消息缓冲队列,
    描述有问题,见谅
    18 回复  |  直到 2018-01-12 13:50:20 +08:00
        1
    paragon   312 天前
    这个不叫做消息队列~
        2
    misaka19000   312 天前
    楼上+1 ...

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