Mongodb: `com.mongodb.MongoSocketReadException: 吗啡提前到达流的结尾

Question

我有一个简单的数据结构（下面引用的 Transaction）要插入 mongodb:

{"amount":111,"debitAcc":"588188286231743e7d5c923d","type":"CHARGE"}

我得到以下错误堆栈：

com.mongodb.MongoSocketReadException: Prematurely reached end of stream
        at com.mongodb.connection.SocketStream.read(SocketStream.java:88)
        at com.mongodb.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:494)
        at com.mongodb.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:224)
        at com.mongodb.connection.UsageTrackingInternalConnection.receiveMessage(UsageTrackingInternalConnection.java:96)
        at com.mongodb.connection.DefaultConnectionPool$PooledConnection.receiveMessage(DefaultConnectionPool.java:440)
        at com.mongodb.connection.WriteCommandProtocol.receiveMessage(WriteCommandProtocol.java:262)
        at com.mongodb.connection.WriteCommandProtocol.execute(WriteCommandProtocol.java:104)
        at com.mongodb.connection.InsertCommandProtocol.execute(InsertCommandProtocol.java:67)
        at com.mongodb.connection.InsertCommandProtocol.execute(InsertCommandProtocol.java:37)
        at com.mongodb.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:168)
        at com.mongodb.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:289)
        at com.mongodb.connection.DefaultServerConnection.insertCommand(DefaultServerConnection.java:118)
        at com.mongodb.operation.InsertOperation.executeCommandProtocol(InsertOperation.java:76)
        at com.mongodb.operation.BaseWriteOperation.call(BaseWriteOperation.java:139)
        at com.mongodb.operation.BaseWriteOperation.call(BaseWriteOperation.java:133)
        at com.mongodb.operation.OperationHelper.withConnectionSource(OperationHelper.java:422)
        at com.mongodb.operation.OperationHelper.withConnection(OperationHelper.java:413)
        at com.mongodb.operation.BaseWriteOperation.execute(BaseWriteOperation.java:133)
        at com.mongodb.operation.BaseWriteOperation.execute(BaseWriteOperation.java:60)
        at com.mongodb.Mongo.execute(Mongo.java:845)
        at com.mongodb.Mongo.execute(Mongo.java:828)
        at com.mongodb.DBCollection.executeWriteOperation(DBCollection.java:342)
        at com.mongodb.DBCollection.insert(DBCollection.java:337)
        at com.mongodb.DBCollection.insert(DBCollection.java:328)
        at org.mongodb.morphia.DatastoreImpl.saveDocument(DatastoreImpl.java:1297)
        at org.mongodb.morphia.DatastoreImpl.tryVersionedUpdate(DatastoreImpl.java:1340)
        at org.mongodb.morphia.DatastoreImpl.save(DatastoreImpl.java:1286)
        at org.mongodb.morphia.DatastoreImpl.save(DatastoreImpl.java:775)
        at org.mongodb.morphia.DatastoreImpl.save(DatastoreImpl.java:758)

我的 mongodb 版本是 3.4.2。

有趣的是我在我的本地开发环境中没有这个问题 (mint linux 18.1)。但它不能在我的 SIT 环境中工作，这是一个 ubuntu 16.04

有什么想法吗？

更新代码以插入文档

可在以下位置找到 transactionDao.save(...) 实现：

https://github.com/actframework/act-morphia/blob/master/src/main/java/act/db/morphia/MorphiaDaoBase.java#L206

更新 2

系统与其他写入一起工作（即使有更大的记录）

Answer 1

大多数情况下，这是长时间超时的结果 reads\writes。

尝试增加超时或完全删除它们：

    MongoClientOptions.Builder options_builder = new MongoClientOptions.Builder();
    options_builder.maxConnectionIdleTime(<some_long_time>);
    MongoClientOptions options = options_builder.build();
    MongoClient mongo_db = new MongoClient ("your.db.address", options);

Answer 2

我不知道根本原因，但最后我通过将字段类型从 BigDecimal 更改为 double.

解决了问题

问题出现在我们的 SIT 环境和一个开发人员的 windows 环境中，该环境具有 mongodb 集群设置。

Answer 3

最可能的原因是兼容版本设置太低

试试 db.adminCommand( { setFeatureCompatibilityVersion: "3.4" } )

https://docs.mongodb.com/manual/reference/command/setFeatureCompatibilityVersion/

Mongodb: `com.mongodb.MongoSocketReadException: 吗啡提前到达流的结尾

Mongodb: `com.mongodb.MongoSocketReadException: Prematurely reached end of stream` with morphia

mongodb

mongodb-java

morphia