SimpleMQ:SimpleMQ是一个Message Queue系统,可通过几个步骤轻松管理您的实时消息

时间:2024-06-06 11:25:55
【文件属性】:

文件名称:SimpleMQ:SimpleMQ是一个Message Queue系统,可通过几个步骤轻松管理您的实时消息

文件大小:16KB

文件格式:ZIP

更新时间:2024-06-06 11:25:55

pubsub message-queue simplemq Python

简单MQ SimpleMQ是一个将数据保留在内存中的消息队列系统。 这个主意 SimpleMQ的主要目标是提供易于配置和使用的消息队列系统。 您可以通过带有队列信息的JSON文件轻松配置队列。 SimpleMQ基本上是Redis Pub / Sub(所有订阅者都接收到已发布的消息)和RabbitMQ(您可以拥有多个使用方,并且代理将订阅的使用方之间的使用交织在一起)的混合体。 因此,您可以将每个队列配置为不同的行为,可以将其配置为通知所有使用者或交错使用。 其他目标 第二个目标是将消息保存在内存中,因此读/写确实非常快,但可以确保队列的原子性。 背后的技术 我们正在使用Gevent在Python中开发SimpleMQ进行并发处理。 简单的基准测试 我们已经用SimpleMQ做过一些测试。 我们有两个版本,一个是Python版本,另一个是使用从Python编译到C的。 结果是: 版本


【文件预览】:
SimpleMQ-master
----.gitignore(50B)
----queues.json(156B)
----README.md(1KB)
----queues()
--------consumer.py(611B)
--------queue.py(5KB)
--------exceptions.py(363B)
--------producer.py(112B)
--------__init__.py(0B)
--------stack.py(2KB)
--------manager.py(3KB)
----config.json(38B)
----tests()
--------producers.py(629B)
----simplemq.py(688B)
----server()
--------server.py(2KB)
--------__init__.py(0B)
--------client.py(2KB)
----compile.sh(249B)
----events()
--------exceptions.py(254B)
--------types.py(122B)
--------__init__.py(0B)
--------dispatcher.py(2KB)
----__init__.py(0B)
----config()
--------config.py(776B)
--------__init__.py(0B)
----message()
--------message.py(977B)
--------__init__.py(0B)
----commands()
--------base.py(316B)
--------consumer.py(462B)
--------producer.py(314B)
--------__init__.py(461B)
--------manager.py(2KB)

网友评论