文件名称:simplemq:具有持久订阅者的简单消息队列
文件大小:39KB
文件格式:ZIP
更新时间:2024-07-22 17:37:04
Java
Key Lime Box 的简单 MQ 为什么是另一个消息队列 - 因为我们需要一些简单的东西来按照我们想要的方式发布/订阅消息。 我们查看了所有已建立的消息队列系统。 它们很好,但它们也非常复杂,处理许多消息传递需求等。 我们发现可用的大多数发布/订阅模型都基于连接的订阅者。 无论是否连接,我们都希望向订阅者发送持久消息。 基础架构 我们有一个提供 REST API 的 Web 服务器。 这是一个基于 Spring Boot (Spring 4) 的 Web 应用程序。 队列的配置和消息的持久化以及配置都是通过MongoDB实现的。 操作 当消息发布到队列时,Simple MQ 会查看队列的订阅者,并为每个订阅者创建一个排队的消息并将它们持久化。 如果队列没有订阅者,则不会有消息排队。 坚持 在这个初始实现中,对 MongoDB 的持久化以一种非常简单的方式完成。 有一个名为mes
【文件预览】:
simplemq-master
----WebContent()
--------META-INF()
----LICENSE(1KB)
----.settings()
--------org.eclipse.wst.jsdt.ui.superType.name(6B)
--------org.eclipse.wst.common.project.facet.core.xml(225B)
--------org.eclipse.wst.common.component(16KB)
--------gradle()
--------org.eclipse.wst.jsdt.ui.superType.container(49B)
--------.jsdtscope(503B)
--------org.eclipse.jdt.core.prefs(632B)
----src()
--------main()
----.project(1KB)
----.classpath(558B)
----.gitignore(5KB)
----README.md(6KB)
----build.gradle(2KB)