q:akka作为跨微服务消息传递工具包?

xuo3flqw  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(287)

我正在寻找一个框架/平台(轻松)支持跨微服务通信。我被引导和Kafka一起调查阿克卡。不幸的是,我无法找到具体的设置和用例,但也没有找到任何具体的消息,可以说它将不起作用。根据这里和其他网站上的文章/消息,我已经整理了一组来自akka+kafka的期望值,其中有几个开放点。
请你复习/纠正以下几点好吗?
微服务“集群”实现平台。微服务“集群”是用一组微服务[应用程序]实现的系统
答。微服务通过akka消息api进行交互(e、 (说,问)
b。可以有多个微服务示例
一。问:邮箱是否在示例之间共享(一个microservice=actor)?
akka可以连接到kafka并将其用作传输(messagebroker),即kafkaapi被封装到akkaapi中
答。问:Kafka的价值观是什么?e、 性能、吞吐量、可靠性。为什么akka远程处理是不够的?
信息
答。首先,需要进行一些初始化:
一。e、 g.创建参与者系统、主管
二。所有微服务(集群中的参与者)之间应该有一些共享的预配置。e、 g.ip/uri、消息类型/案例等。
b。可以在运行时添加/示例化工作角色:i。按姓名/uri ii查找主管。将工作角色添加为子级
c。可以向所有子级广播消息(例如,通过名称和通配符指定),并等待所有子级的响应。然而,它似乎不是akkaapi的“本机”,代码看起来也不够清晰(stackoverlow中的示例:1,2)
d。无法订阅特定类型的事件,即在订阅期间定义筛选条件,以防需要筛选-只能在onreceive方法中的每个参与者内部完成。所以,在广播的情况下,每个演员都会收到消息,然后需要决定它是否适用于他。
e。问:akka提供了哪些消息跟踪/调试工具/功能?
参与者的执行可以是“链式”的:例如a->b->c,在这种情况下,在处理完c和b之后,控制将被传回(在“ask”方法的情况下)
阿克卡星团
答。为应用程序生命周期管理提供API。示例:全部启动/启动一个/停止/缩放等。
问:我如何支持/实现优雅关机?
b。它具有内置的监控功能(检查应用程序可用性、运行状况等)
c。问:基础设施监控怎么样?我需要关心它吗?
d。问:导体是必须的还是只是很好的?
不需要服务发现(例如eureka),因为我们使用React式通信(异步)。通过消息代理发送的消息)
答。问:亲和力/粘性如何?我需要关心它吗?阿克卡在这方面能提供什么?
b。问:如何平衡?
此外,如果阿克卡真的可以在Kafka的基础上工作-有好的例子吗?我只找到了数据流的示例,但我只需要事件/消息处理。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题