文件名称：turbine.go:go中基于redis的kafkaesque数据管道
文件大小：42KB
文件格式：ZIP
更新时间：2024-07-11 05:17:01
JavaScript
涡轮机 - 消息队列 Turbine 是一个基于 Redis 的类似 Kafka 的消息队列。 目的是消除运行 Apache Zookeeper 集群的麻烦，并允许在 Cloudfoundry 等云环境中进行更轻松的设置。 涡轮机的默认消费者模型无需复制即可工作。 这是因为在 Turbine 内部消费者只是一个指针。 ┏ Current last element of pipeline ┏━┳━┳━┳━┳━┳━┳━┳┻┳━┳━┓ ┃1┃2┃3┃3┃4┃5┃6┃7┃8┃9┃ ┗┳┻━┻━┻━┻┳┻━┻━┻━┻━┻━┛ ┃ ┗ Pointer for consumer 1 ┗ Pointer for consumer 2 通过这种方式，Turbine 可以实现高吞吐量，同时还允许集群消费者至少执行一次行为。 运行 docker run -
【文件预览】：
turbine.go-master
----.gitignore(40B)
----Dockerfile(157B)
----turbine.go(9KB)
----.travis.yml(61B)
----loadtest.jmx(25KB)
----License.md(1KB)
----ui()
--------.gitignore(43B)
--------package.json(1KB)
--------src()
--------.bowerrc(53B)
--------module.prefix(43B)
--------Gruntfile.js(18KB)
--------build.config.js(3KB)
--------module.suffix(30B)
--------karma()
--------bower.json(371B)
----README.md(6KB)
----backend()
--------RedisBackend.go(10KB)
--------Backend.go(1KB)
----docker_build.sh(363B)