Scala

在java中，单例模式需要满足以下要求： 构造方法私有化，使得本类之外的地方不能使用构造方法new出对象 提供私有静态属性，接收单例对象 公共的、静态的getInstance方法，便于外界拿到单例对象 想了解Java单例模式的请转到：Java单例模式-懒汉式、恶汉式、静态内部类、枚举以及线程安全问题 ... »

alpakka-kafka-consumer的功能描述很简单：向kafka订阅某些topic然后把读到的消息传给akka-streams做业务处理。在kafka-consumer的实现细节上，为了达到高可用、高吞吐的目的，topic又可用划分出多个分区partition。分区是分布在kafka集群节 ... »

@ 函数可以作为值进行传递 语法var f = 函数名 _ 如果明确了变量的数据类型，那么下划线可以省略 //函数正常的声明与调用 def foo():Int={ println("foo...") 10 } //将foo函数的执行结果赋值给res变量 //val res: Int = foo() ... »

1.return可以省略，Scala会使用函数体的最后一行代码作为返回值 2.如果函数体只有一行代码，可以省略花括号 3.返回值类型如果能够推断出来，那么可以省略（:和返回值类型一起省略） 4.如果有return，则不能省略返回值类型，必须指定 5.如果函数明确声明unit，那么即使函数体中使用re ... »

alpakka项目是一个基于akka-streams流处理编程工具的scala/java开源项目，通过提供connector连接各种数据源并在akka-streams里进行数据处理。alpakka-kafka就是alpakka项目里的kafka-connector。对于我们来说：可以用alpakka ... »

从概念到使用、从基础到原理、从示例到实战的讲解一个技术，并会结合一些实际中当运用这些技术时遇到的问题 ... »

通过Scala对文件进行读写操作在实际业务中应用也比较多，这里介绍几种常用的方式。相信使用Scala进行应用开发时，ArrayBuffer是经常使用的数组。对ArrayBuffer进行新增元素时，通常使用方法：+= ... »

前面介绍了事件源（EventSource）和集群（cluster），现在到了讨论CQRS的时候了。CQRS即读写分离模式，由独立的写方程序和读方程序组成，具体原理在以前的博客里介绍过了。akka-typed应该自然支持CQRS模式，最起码本身提供了对写方编程的支持，这点从EventSourcedBe ... »

在使用akka-typed的过程中发现有很多地方都简化了不少，变得更方便了，包括：Supervision，只要用Behaviors.supervise()把Behavior包住，很容易就可以实现这个actor的SupervisorStrategy.restartWithBackoff策略了。然后集群 ... »

先谈谈akka-typed的router actor。route 分pool router, group router两类。我们先看看pool-router的使用示范： val pool = Routers.pool(poolSize = 4)( // make sure the workers a ... »

akka-cluster对每个节点的每种状态变化都会在系统消息队列里发布相关的事件。通过订阅有关节点状态变化的消息就可以获取每个节点的状态。这部分已经在之前关于akka-cluster的讨论里介绍过了。由于akka-typed里采用了新的消息交流协议，而系统消息的发布和订阅也算是消息交换，也受交流协 ... »

前面提到过，akka-typed中较重要的改变是加入了EventSourcedBehavior。也就是说增加了一种专门负责EventSource模式的actor, 最终和其它种类的actor一道可以完美实现CQRS。新的actor，我还是把它称为persistentActor，还是一种能维护和维持运 ... »

akka-typed中已经没有PersistentActor了。取而代之的是带有EventSourcedBehavior的actor，也就是一种专门支持EventSource模式的actor。EventSource的原理和作用在之前的博客里已经有了比较详细的介绍，这里就不再重复了。本篇直接从Even ... »

akka系统是一个分布式的消息驱动系统。akka应用由一群负责不同运算工作的actor组成，每个actor都是被动等待外界的某种消息来驱动自己的作业。所以，通俗点描述：akka应用就是一群actor相互之间发送消息的系统，每个actor接收到消息后开始自己负责的工作。对于akka-typed来说，t ... »

akka-typed的actor从创建、启用、状态转换、停用、监视等生命周期管理方式和akka-classic还是有一定的不同之处。这篇我们就介绍一下akka-typed的actor生命周期管理。 每一种actor都是通过定义它的行为属性behavior形成模版，然后由对上一层的父辈actor用sp ... »

akka 2.6.x正式发布以来已经有好一段时间了。核心变化是typed-actor的正式启用，当然persistence,cluster等模块也有较大变化。一开始从名称估摸就是把传统any类型的消息改成强类型消息，所以想拖一段时间看看到底能对我们现有基于akka-classic的应用软件有什么深层 ... »

今天简单记录一下，利用Scala解答的一道LRU题目，原题为LeetCode的第146题，是一道设计LRU的题目。 题目详情 运用你所掌握的数据结构，设计和实现一个 LRU (最近最少使用) 缓存机制。它应该支持以下操作： 获取数据 get 和 写入数据 put 。 获取数据 get(key) 如果 ... »

从SQL领域来的用户，对于ES的文件关系维护方式会感到很不习惯。毕竟，ES是分布式数据库只能高效处理独个扁平类型文件，无法支持关系式数据库那样的文件拼接。但是，任何数据库应用都无法避免树型文件关系，因为这是业务模式需要的表现形式。在ES里，无论nested或join类型的数据，父-子关系的数据文件实 ... »

闭包与内部类 中英文社区中，比较常见的对闭包的定义是 ` 引用了自由变量的一段代码或函数，被引用的自由变量和函数（一段代码）共同存在，即使离开了创造它的环境 ` 内部类 按照我的理解，scala/java中虽然并不存在语法级地支持或是定义，对于闭包而言，一些概念和闭包的概念一致。一般理解scala中 ... »

聚合结果buckets默认以doc_count 排序方式呈现，即： _count asc 表达。其它还有 _term, _key 为排序控制元素。_key适用于histogram,date_histogram，如下： POST /cartxns/_search { "aggs": { "colors ... »