How to subscribe topic with config file ? about cap HOT 7 CLOSED

你这样用代理的方式可能有很多问题。

首先，CAP用来保证分布式事务的前提是首先需要集成本地事务的持久化消息的，这样可以保证消息在业务代码执行期间消息是肯定能够存储成功的。然后CAP通过ICapPublisher接口发送消息，这个消息格式是有一定要求的，要不然在接收到之后反序列化可能会出问题。 订阅这一块也是有和Dashboard功能配合的，如果你不使用[CapSubscriber()]这样方式那么Dashboard这里的订阅列表功能也需要修改。

你的这个需求，我建议你直接封装一下MQ客户端简单实现即可。

from cap.

publisher这块我准备为各个系统提供对应语言的sdk来实现发送的本地事务保护.
subscriber这块因为各个系统涉及各个部门,sdk的开发和维护量有点大,权衡下来就是用同步方法,失败就重发的方式来保证通知的可靠性
dashboard这块可以先不使用
主要是想知道如何在runtime时为consumerclient注册topic,请指教.

from cap.

我这样描述你的需求是否恰当：
有几个不同语言开发的系统，这些系统间需要相互传递消息，消息的类型可能会变化（有未知可能）。消息的传递想通过一个asp.net core 的系统中转。
不明白的地方：消息有实时性要求如何？
感觉不能完全理解你的需求，也许是知识不够

from cap.

@suxi MQ的客户端似乎不能在运行时增加订阅Topic哦？

from cap.

@jjjjj10231023 差不多是这样的需求,不过publish侧我会提供sdk给各个系统,subsribe侧我希望用代理方式进行中转,当然一个业务系统会有一个独立的代理为它服务,没有很强的实时性需求,因为eventbus本来已经是异步了.上面说的用同步方法是指代理->系统api的调用我会使用同步方式,保证代理能及时知道调用是否失败来进行重试处理.

@yuleyule66 可能说运行时不够准确,是在asp.netcore setup的时候,读取配置的topic信息,并绑定到指定的ISubscribeService的某个method(目前简单处理,选第一个)上.目前我已经完成这个功能,现在正在看怎么把topic还有messageid转给这个函数来提供中转必要的参数.

from cap.

功能已实现

from cap.

Function has been implemented

How can I do that? Where is that implementation?

from cap.