queueservice
2015-07-23 19:33:38 0 举报
QueueService是一种用于管理和操作队列的服务,它提供了创建、删除、获取和发送消息等功能。通过使用QueueService,用户可以在应用程序中实现异步处理、任务调度和消息传递等需求。QueueService通常与消息队列服务(如RabbitMQ、Kafka等)结合使用,以实现高可用性和可扩展性的消息传递。用户可以通过编写代码或使用图形界面来操作队列,实现对消息的生产和消费。QueueService广泛应用于各种应用场景,如实时通信、日志收集、任务队列等,为用户提供了灵活、可靠和高效的信息传递方式。
作者其他创作
大纲/内容
http interface callback
MqProxy对外提供一致性的消息提交接口如果以后更换队列系统,可以平滑迁移
Message Queue With Pusher
Broker 1Topic APartition 1Replica 1
Broker 4Topic APartition 2Replica 2
Pusher Consumer 3
Pusher Consumer 2
AddressDataService
Broker 2Topic APartition 1Replica 2
callback 下游提供,最好支持幂等。Pusher 保证 at least once
Producer 1
Zookeeper
Broker 4Topic BPartition 2Replica 2
consumer
和Zk交互获取leader后和broker交互
Pusher Consumer 1
Producer 2
BICart Data Receiver Interface (HTTP)
Producer N
interface
other Consumers
CartDataService
Broker 1Topic BPartition 1Replica 1
OrderDataService
Broker 3Topic BPartition 2Replica 1
Broker 2Topic BPartition 1Replica 2
CartMysql Syncer Interface(HTTP)
MqProxy
MonitorCart Action Monitor Interface (HTTP)
Producer 无状态
ConsumerPusher获取信息并推送下游Pusher本身无状态,状态(offset)存ZK
broker
Broker 有状态多分片多副本通过Zk保存Leader
producer
Broker 3Topic APartition 2Replica 1

收藏
0 条评论
下一页