V2EX = way to explore
V2EX 是一个关于分享和探索的地方
Sign Up Now
For Existing Member Sign In
This topic created in 3056 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
不应该叫 消息队列，应该叫 消息缓冲队列，
描述有问题，见谅
描述有问题，见谅
 |
1
paragon Dec 13, 2017
这个不叫做消息队列~
|
 |
2
misaka19000 Dec 13, 2017
楼上+1 ...
这个同步块可能在数据量很大的情况下导致处理速度变慢 |
 |
3
xingwing Dec 13, 2017
RabbitMQ
|
 |
5
Starry Dec 13, 2017
用 MQ 或者 REDIS 队列
|
 |
6
holyghost Dec 13, 2017
你这个叫 buffer 更合适吧
|
 |
7
arnoldFu OP @misaka19000 有可以优化的方法吗？加同步是怕在插入数据库时有新的消息需要入队导致入队失败
|
 |
10
jimzhong Dec 13, 2017
这种做法未必会有性能提升。
|
 |
12
bigdogbigpig PRO 用个 redis 就好了
|
 |
13
wizardoz Dec 13, 2017
消息队列是一个特指的词，你这个叫做“把消息缓存到队列”可能更好一些，避免误会。
|
 |
14
moka20477 Dec 13, 2017
有同步代码块在高并发的时候就已经可能有性能问题了，另外不太明白这么做的意义，本身可以分散的流量，反倒让他集中 insert，而且还是遍历 insert
|
 |
15
mooncakejs Dec 13, 2017
这个只是缓存，没有 重试 机制的队列不叫队列。
|
 |
16
toono Dec 13, 2017
用现有的消息队列工具很好实现这个缓冲
|
 |
17
jowuIM Dec 17, 2017
。。。个人作品加个线程池就够了，队列比较复杂
|
 |
18
crossoverJie Jan 12, 2018
synchronized 效率较低，如果是为了做同步可以用 ConcurrentLinkedQueue，我记得是基于 CAS 效率比 synchronized 要高。
|
Select Language