这是我的答案，因此为所有需要相同东西的人概述了解决方案。它当然有其局限性，例如最大图像大小为 16Mb，但在很多情况下它并不相关。
我的 DAO 的相关部分：
trait DocumentService {
....
def updatePicture(data:Array[Byte], title:String)(implicit ec:ExecutionContext):Future[UpdateResult]
def picture(title:String)(implicit ec:ExecutionContext):Future[Option[Array[Byte]]]
}
这里title是文章的标题，它是唯一的，在文章提取和特定文章的所有相关操作中用作键。
实施：
package services
import javax.inject.Singleton
import com.mongodb.client.result.UpdateResult
import model.Annotation
import org.bson.types.Binary
import org.mongodb.scala.bson.collection.immutable.Document
import org.mongodb.scala.{MongoClient}
import org.mongodb.scala.model.Filters._
import org.mongodb.scala.model.Updates._
import _root_.scala.concurrent.{ExecutionContext, Future}
/**
* Created by Alex on 7/13/2016.
*/
@Singleton
class MongoDocumentService extends DocumentService{
val mongoClient:MongoClient = MongoClient()
val db = mongoClient.getDatabase("test")
.....
override def updatePicture(data: Array[Byte], title:String)(implicit ec: ExecutionContext): Future[UpdateResult] = {
val collection = db.getCollection("items")
val update = set("picture.data", new Binary(data))
collection.updateOne(equal("title", title), update).toFuture().map(sx => sx.head)
}
override def picture(title: String)(implicit ec: ExecutionContext): Future[Option[Array[Byte]]] = {
val collection = db.getCollection("items")
collection.find(equal("title", title)).first()
.toFuture()
.recoverWith{case e:Throwable => {println(e); Future.failed(e)}}
.map{seq => if(seq.isEmpty) None else seq.head.get("picture").map(p => p.asDocument().get("data")).map(r => r.asBinary().getData)}
}
}
updatePicture 方法将图片数据插入到特定的文章文档中。作为输入，它获取字节数组并使用Binary 类型对其进行编码。
picture 方法从文章文档中检索图片原始字节。
现在为<img src="...">标签提供图片文件上传和图片检索的相关控制器方法：
def updatePicture = AdminAction.async(parse.multipartFormData){implicit request =>
request.body.file("contentField").fold(Future.successful(Redirect(routes.MainController.index())))
{filePart =>
val tempFile = new File("./temp.txt");
filePart.ref.moveTo(tempFile, true)
val in = new FileInputStream(environment.getFile("./temp.txt"))
val content = Stream.continually(in.read()).takeWhile(_ != -1).map(_.toByte).toArray
val formOtherFields = request.body.asFormUrlEncoded
val title = formOtherFields("titleField").head
documentService.updatePicture(content, title).map(
r => {
in.close()
tempFile.delete()
Redirect(routes.MainController.index())
}
)
}
}
此控制器操作处理图像文件上传，它使用多部分表单数据解析器访问文件数据并将其提供给上面显示的相关 DAO 方法。
def picture(title:String) = Action.async{implicit request =>
documentService.picture(title).map{
case r => Ok(r.getOrElse(Array.empty[Byte]))
}
}
此方法用于在文章视图上将图像呈现为<img src="..."> 标签，如下所示：
<img src="/picture/@{document.get("title").get.asString().getValue}"/>
routes 文件的相关部分：
POST /updatePicture controllers.MainController.updatePicture
GET /picture/:title controllers.MainController.picture(title:String)