关于消息队列的实现

[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();
        }
    }
    
}

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

不应该叫 消息队列，应该叫 消息缓冲队列，
描述有问题，见谅

[paragon]

这个不叫做消息队列~

[misaka19000]

楼上+1 ...

这个同步块可能在数据量很大的情况下导致处理速度变慢

[xingwing]

RabbitMQ

[arnoldFu]

@paragon 是的，不能算作消息队列，更像是一个类似缓存的东西

[Starry]

用 MQ 或者 REDIS 队列

[holyghost]

你这个叫 buffer 更合适吧

[arnoldFu]

@misaka19000 有可以优化的方法吗？加同步是怕在插入数据库时有新的消息需要入队导致入队失败

[arnoldFu]

@xingwing 感谢，我去了解一下

[arnoldFu]

@Starry 感谢，我去了解一下

[jimzhong]

这种做法未必会有性能提升。

[arnoldFu]

@holyghost 是的，叫 buffer 确实更合适

[bigdogbigpig]

用个 redis 就好了

[wizardoz]

消息队列是一个特指的词，你这个叫做“把消息缓存到队列”可能更好一些，避免误会。

[moka20477]

有同步代码块在高并发的时候就已经可能有性能问题了，另外不太明白这么做的意义，本身可以分散的流量，反倒让他集中 insert，而且还是遍历 insert

[mooncakejs]

这个只是缓存，没有 重试 机制的队列不叫队列。

[toono]

用现有的消息队列工具很好实现这个缓冲

[jowuIM]

。。。个人作品加个线程池就够了，队列比较复杂

[crossoverJie]

synchronized 效率较低，如果是为了做同步可以用 ConcurrentLinkedQueue，我记得是基于 CAS 效率比 synchronized 要高。