主页

2020
scala

在 Scala/Java/Spring 微服务中使用日志

应用开发、运行时，日志作为调试、留痕的重要工具非常重要。对此，Akka Fusion 库为日志处理提供了开箱即用的支持： 预置的日志 encoder 配置 通过 filebeat 输出日志到 Elasticsearch 良好的自定义支持 使用 fusion-log 库，需要添加以下依赖。 12resolvers += Resolver.bintrayRepo("hellos

scalaakka

怎样优雅的关闭 ActorSystem

使用 CoordinatedShutdown 可以优雅的方式关闭 ActorSystem。默认情况下，需要调用 ActorSystem 上的 terminate 方法才会触发 CoordinatedShutdown，但也可以设置为在 JVM 退出时自动运行（比如接收到操作系统的 SIGTERM 信号或Java虚拟机退出）。要使在程序退出时 CoordinatedShutdown 自动调用，需要如下

Ambari编译记录

Download and build Ambari 2.7.5 source12345678wget https://www-eu.apache.org/dist/ambari/ambari-2.7.5/apache-ambari-2.7.5-src.tar.gz (use the suggested mirror from above)

scala

Scala实战：求解 Top K 问题

问题描述服务器上有一个 movies.csv 文件，里面保存了每部电影的评分（为了简化和专注问题，CSV文件每一行只有两个字段：movieId和rating）。文件通过HTTP服务器发布。要求从文件内找出排名最高的10部电影。 解法1：全量排序求Top 10通过 wget、curl 等工具先将文件下载到本地，再读出文件内所有行并解析出 movieId和rating 字段，按 rating 字段排序

scalaakka

OAuth 2 服务的 Akka 实现：access_token 管理

实现一个 OAuth 2 服务有几个核心点： OAuth 2 协议解析 连接的用户可能很多，系统需支持横向扩展 每个连接用户的 access_token 的状态控制：有效期控制 服务要支持容错、可恢复、可扩展、高并发等特性 使用 Akka 来实现 OAuth 2 服务会发现逻辑非常的清晰，且能很好的实现以上几个核心点。 每个连接用户或 access_token 可抽像为一个 Actor，这样多

scalaakka

怎样在 Akka Persistence 中实现分页查询

在 Akka Persistence 中，数据都缓存在服务内存（状态），后端存储的都是一些持久化的事件日志，没法使用类似 SQL 一样的 DSL 来进行分页查询。利用 Akka Streams 和 Actor 我们可以通过编码的方式来实现分页查询的效果，而且这个分页查询还是分步式并行的…… EventSourcedBehaviorAkka Persistence的EventSourcedBehav

2019
scala

2019年12月深圳Scala Meetup预热：《Akka HTTP、gRPC与Typed Actor工程实践》

2019年12月深圳Scala Meetup1. 活动介绍 好久不见，继Tubi TV赞助的两场北京Scala Meetup圆满落幕，深圳的Scala Meetup又要开幕啦！虽然连深圳都变冷了，但是Scalaer的热情丝毫不减，欢迎大家前来一起探讨Scala在生产环境中的实践和应用！ 2. 时间地点 时间：2019年12月21日下午 13:00-18:00 （13:00开始签到）地点：深圳市罗湖

scala

Why gRPC (Akka) ?

原文链接：https://doc.akka.io/docs/akka-grpc/current/whygrpc.html 什么是gRPC？gRPC是一个支持请求/响应和流式处理（非持久化）用例的传输机制。 它是一个模式优先的RPC框架，协议在 Protobuf服务描述符（protobuf service descriptor）中声明，请求和响应将通过 HTTP/2 连接流式的传输。 它有几个优点：