技术总舵
如果我没有在装逼,那么就是在去装逼的路上!

Tagged: Akka

架构师的选择,Pulsar还是Kafka?

介绍 最近,我一直在研究Pulsar及其与Kafka的比较。快速搜索将显示两个最著名的开源消息传递系统之间存在当前的”战争”。 作为Kafka的用户,我确实对Kafka的某些问题感到困惑,并且我对Pulsar感到非常失望。所以最…

美团酒旅起源数据治理平台的建设与实践

背景 作为一家高度数字化和技术驱动的公司,美团非常重视数据价值的挖掘。在公司日常运行中,通过各种数据分析挖掘手段,为公司发展决策和业务开展提供数据支持。经过多年的发展,美团酒旅内部形成了一套完整的解…

Akka HTTP:自定义指令(Directive)

自定义指令 有3种创建自定义指令的基本方法: 将已有指令通过命名配置(比如通过组合的方式)的方式来定义新的指令 转换已存在的指令 从头开始实现一个指令 命名配置 创建自定义指令最简便的方法就是将一个或多个…

Scala Web开发-Akka HTTP中使用JSON

Jackson Jackson 是Java生态圈里最流行的JSON序列化库,它的官方网站是:https://github.com/FasterXML/jackson。 为什么选择 Jackson 为什么选择 Jackson 而不是更Scala范的 play-json、 circe、 json4s 等JSON序……

Akka向设备组添加Actor注册《thirteen》译

我们已经完成了设备级别的注册支持,现在我们必须在组级别实现它。在注册时,小组成员还有更多工作要做,包括: 通过将注册请求转发给现有设备actor或通过创建新actor并转发消息来处理注册请求。 跟踪组中存在哪些…

akka进阶(1) – supervisor strategy

当我们设计并行系统时,常常会在这稳定性、可扩展性、实时性这几个特性上深究。 团队从半年前开始构建一个机遇akka的网络爬虫项目,现在项目已经上线运营。这段时间大家开始做一些细致的工作,或是性能调优,或是重构代码,从这个过程中了解到更多akka强大而简便的功能: – 提高系统级稳定性 -> supervisor strategy – 横…

Akka实战:分散、聚合模式

**分散、聚合**:简单说就是一个任务需要拆分成多个小任务,每个小任务执行完后再把结果聚合在一起返回。 本实例来自一个真实的线上产品,现将其需求简化如下: 1. 传入一个关键词:`key`,根据`key`从网上抓取相关新闻 2. 可选传入一个超时参数:`duration`,设置任务到期时必须反回数据(返回实际已抓取数据) 3. 若超…