1.
背景
mongoDB版本1.8.1
collection stats
> db.user.gift.stats()
{
"ns" : "statgame.user.gift",
"count" : 650,
"size" : 162804,
"avgObjSize" : 250.46769230769232,
"storageSize" : 696320,
"numExtents" : 4,
"nindexes" : 3,
"lastExtentSize" : 524288,
"paddingFactor" : 1.0099999999999576,
"flags" : 1,
"totalIndexSize" : 180224,
"indexSizes" : {
"_id_" : 40960,
"day_1_userId_1_fromId_1_sceneId_1" : 81920,
"idx_modified_time_long" : 57344
},
"ok" : 1
}
|
indexes
> db.user.gift.getIndexes()
[
{
"name" :
"_id_",
"ns" :
"statgame.user.gift",
"key" : {
"_id" : 1
}
},
{
"name" :
"day_1_userId_1_fromId_1_sceneId_1",
"ns" :
"statgame.user.gift",
"unique" : true,
"key" : {
"day" : 1,
"userId" :
1,
"fromId" :
1,
"sceneId" :
1
}
},
{
"name" :
"idx_modified_time_long",
"ns" :
"statgame.user.gift",
"key" : {
"modifiedTimeLong" : -1
}
}
]
|
stored data的结构
> db.user.gift.find().limit(1)
{ "_id" :
ObjectId("4dad7840c8b4ebc1064a1f25"), "day" :
ISODate("2011-04-18T16:00:00Z"), "earnMoney" :
NumberLong(18), "earnTimes" : NumberLong(1), "fromId" :
NumberLong(17441), "modifiedTimeLong" :
NumberLong("1303214144458"), "receiveMoney" :
NumberLong(30), "receiveTimes" : NumberLong(1), "sceneId"
: NumberLong("216172782113787850"), "userId" :
NumberLong(4037) }
|
2.在shell查询时不小心将sceneId的值直接输入了,mongoDB认为shell输入的都是double类型,而sceneId是长整型。216172782113787850为58bit。
db.user.gift.find({$query:{day:{$gte:new
Date(2011,03,05),$lte:new Date()}, sceneId:216172782113787850},
$orderby:{day:-1}})
|
这时这个查询会被block住。查看currentOp的执行情况。
> db.currentOp()
{
"inprog" : [
{
"opid" :
756,
"active" :
true,
"lockType"
: "read",
"waitingForLock" : false,
"secs_running" : 597,
"op" :
"query",
"ns" :
"statgame.user.gift",
"query" : {
"$query" : {
"day" : {
"$gte" : ISODate("2011-04-04T16:00:00Z"),
"$lte" : ISODate("2011-04-25T03:22:09.948Z")
},
"sceneId" :
216172782113787840
},
"$orderby" : {
"day" : -1
}
},
"client" :
"127.0.0.1:58166",
"desc" :
"conn"
}
]
}
|
用top看系统资源使用情况:
top - 11:34:04 up 2:57,
6 users, load average: 1.67,
1.13, 0.64
Tasks: 145 total, 3 running, 141 sleeping, 1 stopped, 0 zombie
Cpu(s): 50.2%us, 0.2%sy,
0.0%ni, 49.6%id, 0.0%wa, 0.0%hi,
0.0%si, 0.0%st
Mem:
4048136k total, 2092240k
used, 1955896k free, 213088k buffers
Swap:
3068404k total, 0k
used, 3068404k free, 936064k cached
PID USER PR NI
VIRT RES SHR S %CPU %MEM TIME+
COMMAND
3527 root 15
0 333m 21m
20m R 99.6 0.5
12:58.16 mongod
7050 root 19
0 1604m 655m 8512 S 2.3
16.6 2:53.05 java
|
占CPU接近100%,泪奔。
使用new NumberLong(“sceneId”)来查询,没有问题
>
db.user.gift.find({$query:{day:{$gte:new Date(2011,03,05),$lte:new Date()},
sceneId:new
NumberLong("216172782113787850")},$orderby:{day:-1}})
{ "_id" :
ObjectId("4db00226c8b4ebc1064a8b76"), "day" :
ISODate("2011-04-19T16:00:00Z"), "earnMoney" :
NumberLong(0), "earnTimes" : NumberLong(0), "fromId" : NumberLong(4124),
"modifiedTimeLong" : NumberLong("1303380518261"),
"receiveMoney" : NumberLong(50), "receiveTimes" :
NumberLong(1), "sceneId" :
NumberLong("216172782113787850"), "userId" :
NumberLong(4124) }
{ "_id" :
ObjectId("4db00226c8b4ebc1064a8b75"), "day" :
ISODate("2011-04-19T16:00:00Z"), "earnMoney" :
NumberLong(1005), "earnTimes" : NumberLong(113), "fromId"
: NumberLong(4042), "modifiedTimeLong" :
NumberLong("1303380518320"), "receiveMoney" :
NumberLong(3350), "receiveTimes" : NumberLong(113), "sceneId"
: NumberLong("216172782113787850"), "userId" :
NumberLong(4124) }
………………..
|
将userId的值直接输入查询,userId目前小于4字节。没有问题。4字节整数是可以输入直接查询的。
>
db.user.gift.find({$query:{day:{$gte:new Date(2011,03,05),$lte:new Date()},
userId:4124},$orderby:{day:-1}})
{ "_id" :
ObjectId("4db0021cc8b4ebc1064a86f3"), "day" :
ISODate("2011-04-20T16:00:00Z"), "earnMoney" :
NumberLong(1503), "earnTimes" : NumberLong(167), "fromId"
: NumberLong(4042), "modifiedTimeLong" :
NumberLong("1303380509069"), "receiveMoney" :
NumberLong(5010), "receiveTimes" : NumberLong(167),
"sceneId" : NumberLong("792633972503933553"),
"userId" : NumberLong(4124) }
{ "_id" :
ObjectId("4db00226c8b4ebc1064a8b76"), "day" :
ISODate("2011-04-19T16:00:00Z"), "earnMoney" :
NumberLong(0), "earnTimes" : NumberLong(0), "fromId" :
NumberLong(4124), "modifiedTimeLong" :
NumberLong("1303380518261"), "receiveMoney" :
NumberLong(50), "receiveTimes" : NumberLong(1), "sceneId"
: NumberLong("216172782113787850"), "userId" :
NumberLong(4124) }
{ "_id" :
ObjectId("4db00226c8b4ebc1064a8b75"), "day" :
ISODate("2011-04-19T16:00:00Z"), "earnMoney" :
NumberLong(1005), "earnTimes" : NumberLong(113), "fromId"
: NumberLong(4042), "modifiedTimeLong" :
NumberLong("1303380518320"), "receiveMoney" :
NumberLong(3350), "receiveTimes" : NumberLong(113),
"sceneId" : NumberLong("216172782113787850"),
"userId" : NumberLong(4124) }
………………….
|
浮点数一般用52bit的数表示精度,所以52bit的整型应该都没关系。
3.继续检查查询的哪步操作使得它block住了。
不用索引:dropIndex,或者查询时去掉day,用216172782113787850值可以查到。
> db.user.gift.find({sceneId:216172782113787850})
{ "cursor" :
"BasicCursor", "nscanned" : 650,
"nscannedObjects" : 650, "n" : 0, "millis" : 0,
"nYields" : 0, "nChunkSkips" : 0, "isMultiKey"
: false, "indexOnly" : false, "indexBounds" : { },
"allPlans" : [ { "cursor" : "BasicCursor",
"indexBounds" : { } } ], "oldPlan" : { "cursor"
: "BasicCursor", "indexBounds" : { } } }
>
db.user.gift.find({$query:{sceneId:new NumberLong(216172782113787850)},
$explain:true})
{ "cursor" :
"BasicCursor", "nscanned" : 650, "nscannedObjects"
: 650, "n" : 0, "millis" : 0, "nYields" : 0,
"nChunkSkips" : 0, "isMultiKey" : false,
"indexOnly" : false, "indexBounds" : { },
"allPlans" : [ { "cursor" : "BasicCursor",
"indexBounds" : { } } ], "oldPlan" : { "cursor"
: "BasicCursor", "indexBounds" : { } } }
>
db.user.gift.find({sceneId:216172782113787850}})
Mon Apr 25 13:55:47 SyntaxError: missing
) after argument list (shell):1
> db.user.gift.find({sceneId:216172782113787850})
{ "_id" :
ObjectId("4dad7840c8b4ebc1064a1f26"), "day" :
ISODate("2011-04-18T16:00:00Z"), "earnMoney" :
NumberLong(4218), "earnTimes" : NumberLong(35), "fromId"
: NumberLong(262), "modifiedTimeLong" :
NumberLong("1303214144775"), "receiveMoney" :
NumberLong(10505), "receiveTimes" : NumberLong(35),
"sceneId" : NumberLong("216172782113787850"),
"userId" : NumberLong(4042)
………………….
|
看样子在做全表扫描时,mongoDB将每行NumberLong转成了double和sceneId的值进行了比较。
不用orderby:用216172782113787850值可以查到,
>
db.user.gift.find({$query:{day:{$gte:new Date(2011,03,05),$lte:new Date()},
sceneId:216172782113787850}})
|
用916172782113787850查,不存在也不会死
>
db.user.gift.find({$query:{day:{$gte:new Date(2011,03,05),$lte:new Date()},sceneId:
916172782113787850},$orderby:{day:-1}})
|
4.java端
java端使用时不会出现问题,java
driver会将long型转换成NumberLong查询
5总结
看样子block是由于orderby+索引+NumberLong用double值引起的。为什么呢?查不到应该也不至于block住,应该是mongoDB用索引查询时的问题。
分享到:
相关推荐
在尝试启动MongoDB服务时,用户可能会遇到“Windows无法启动MongoDB服务 错误1067:进程意外终止”的问题。这一错误提示通常意味着MongoDB服务在启动过程中遇到了问题,导致服务无法正常运行。 #### 错误代码解释 ...
开启慢查询日志(`db.setProfilingLevel(1, 100)`)可以捕获执行时间超过100毫秒的查询,帮助我们识别性能问题。进一步,使用 `explain` 命令分析查询计划,理解 MongoDB 如何执行查询,以及是否有效地利用了索引。...
这里讨论了 MongoDB 中的锁定策略,以及如何在高并发环境下有效地管理数据库访问。 #### 三、开发者指南 - **Mongo Developers' Guide**:专为开发者设计,提供了全面的 MongoDB 开发指导。涵盖了从基础概念到高级...
7. **锁定机制**:讲解了MongoDB的锁定原理,帮助理解并避免数据并发访问时的冲突。 8. **概念与术语**:对MongoDB的核心概念进行了定义与解释,如文档、集合、数据库等,为深入学习奠定基础。 9. **更新与结构化...
锁定机制是并发控制的重要组成部分,这部分内容解释了MongoDB中如何使用锁来防止数据冲突和保持数据一致性。 ### **31. MongoDB开发者指南(Mongo Developers' Guide)** MongoDB开发者指南是一份全面的参考手册,...
- **遇到的问题**:当读写操作非常密集时(如4万次/s的写入操作和1万次/s的读取操作),从服务器CPU负载会急剧上升,查询性能显著下降,查询吞吐量大幅降低,且主从复制会出现较大延迟。 - **解决方案**:引入行级...
- **文档级锁定**:通过文档级别的锁定机制来避免并发问题。 - **删除操作**:MongoDB提供了灵活的删除机制,包括按条件删除文档。 #### 七、索引与查询优化 - **索引类型**:除了上述提到的基本索引外,还包括...
首先,`mongostat` 是一个实用工具,允许用户以固定时间间隔检查 MongoDB 实例的运行状态,包括插入、查询、更新、删除操作的数量,内存使用情况,磁盘I/O等。这个命令对于诊断数据库的性能瓶颈和监控整体健康状况...
- 执行`runCommand`命令时,MongoDB服务器会识别查询并执行相应的逻辑,而不是像处理普通集合那样。 2. 常用的`runCommand`命令举例: - `buildInfo`: 返回MongoDB服务器的版本信息以及操作系统详情,这对于识别...
- **加锁**: MongoDB使用文档级别的锁定来提高并发性能。 #### 18. 数据文件过大的原因 - **数据增长**: 随着数据量的增加,文件自然会变大。 - **索引**: 创建索引会占用额外的存储空间。 - **碎片**: 数据库运行...
此外,MongoDB的非结构化数据存储能力,允许快速添加字段,无需锁定整个数据库,非常适合数据模型不断变化的场景。 然而,MongoDB也有一些不适用的场景。例如,由于它不支持事务操作,对事务安全要求较高的应用可能...
15. **锁定机制**(Locking):这部分可能会解释MongoDB中的锁定机制,包括读锁、写锁等不同类型的锁,以及如何在并发环境中正确地使用它们来保证数据的一致性和完整性。 16. **MongoDB开发者指南**(Mongo ...
MongoDB的`runCommand`命令是数据库操作中的一个重要工具,它允许用户执行一系列高级操作,如数据统计、数据库维护、服务器...在使用时,请确保对每个命令的参数和返回值有清晰的理解,以避免潜在的问题和数据损失。
在处理数据库问题时,诊断是关键步骤,尤其是对于性能调优和故障排除。以下是对MongoDB数据库问题诊断的一些关键知识点: 1. **性能相关**: - **WireTiger存储引擎**:MongoDB使用WireTiger作为默认存储引擎,它...
复制集是MongoDB实现高可用性的重要机制,通过在多个节点间复制数据,当主节点故障时,可以从副本中自动切换。 六、分片与水平扩展 1. 分片(Sharding):将大数据集分布在多个物理服务器上,实现水平扩展,处理...
7. MongoDB的journaling确保了数据一致性,不完整的journal条目在恢复时不会被回放,保证了数据的安全性。 8. 分析器在MongoDB中用于评估查询性能,帮助开发者识别慢查询并优化数据库。 9. 名字空间是MongoDB中的...
MongoDB是一款高性能、无模式的文档型数据库系统,被广泛应用于大数据处理、日志存储、实时分析等场景。随着业务的发展,对MongoDB的监控变得至关重要,以确保系统的稳定性和性能优化。本文将详细介绍MongoDB自带的...
此界面提供更直观的图形化展示,包括服务器基本信息、连接状态(如锁类型、等待和查询信息)、各个数据库和集合的访问统计,以及日志信息等。 在监控 MongoDB 性能时,可以使用 `mongodb-stat` 命令的参数来调整...
数据库是存储和管理数据的核心工具,本教程涵盖了多个主流的数据库系统,包括MySQL、Oracle、Redis、Mycat、MongoDB以及Memcached。这些数据库在不同的应用场景下各有优势,理解和掌握它们能帮助我们更好地设计、...
创建索引时,默认情况下,MongoDB 会对相关集合进行锁定,这可能导致在创建过程中对其他操作造成短暂的影响。为了避免这种情况,你可以选择在后台创建索引,这样索引构建过程不会阻塞其他读写操作。使用 `...