search

fanliang11 / surging

Surging is a micro-service engine that provides a lightweight, high-performance, modular RPC request pipeline. support Event-based Asynchronous Pattern and reactive programming ,The service engine supports http, TCP, WS,Grpc, Thrift,Mqtt, UDP, and DNS protocols. It uses ZooKeeper and Consul as a registry, and integrates it. Hash, random, polling, Fair Polling as a load balancing algorithm, built-in service governance to ensure reliable RPC communication, the engine contains Diagnostic, link tracking for protocol and middleware calls, and integration SkyWalking Distributed APM
MIT License
3.25k stars 923 forks source link

事件总线怎么同时分发给多个订阅者 #304

Open tang-butian opened 5 years ago

tang-butian commented 5 years ago

我的需求是，用户服务删除用户广播删除用户事件后，其他服务订阅该事件；目前我只实现了只有一个消费者收到事件，想问下 EventBus 怎么实现这个需求

fanliang11 commented 5 years ago

用的是基于rabbitmq 的EventBus?如果是，Exchange 现在只实现了direct类型，如果需要消息广播到多个消费者，需要扩展实现 Fanout 类型，暂时surging 不支持

tang-butian commented 5 years ago

用的是基于rabbitmq的EventBus？如果是，Exchange现在只实现了直接类型，如果需要消息广播到多个消费者，需要扩展实现Fanout类型，暂时激增不支持

如果不用基于rabbitmq 的EventBus， surging里面有其他方法来实现这个需求吗？

fanliang11 commented 5 years ago

这个需求暂时不支持

tang-butian commented 5 years ago

好的，我想办法自己扩展下，谢谢回复