kafka是LinkedIn开发并开源的一个分布式MQ系统,现在是Apache的一个孵化项目。在它的主页描述kafka为一个高吞吐量的分布式(能将消息分散到不同的节点上)MQ。在这片博文中,作者简单提到了开发kafka而不选择已有MQ系统的原因。两个原因:性能和扩展性。Kafka仅仅由7000行Scala编写,据了解,Kafka每秒可以生产约25万消息(50
MB),每秒处理55万消息(110...
分类:
其他好文 时间:
2015-03-11 19:45:02
阅读次数:
299
Akka 快速入门
Akka的优点太多,高性能、高可靠、高并发、分布式、可容错、可扩展、事件驱动,不一一叙述。不同版本的API差异很大,本文代码运行在 Scala 2.10.3 和 Akka
2.3.2 之上。
dependency>
groupId>com.typesafe.akkagroupId>
artifactId>akka-actor_2.10artifactId...
分类:
其他好文 时间:
2015-03-11 17:17:27
阅读次数:
192
1. 所有的基本数据类型都是对象,比如数值1的所说的类是 scala.Int2. 所有的运算符都是类成员方法,比如1+2调用1.+(2); 0 to 2调用 0.to(2)3. 数组的访问也是通过函数调用,array(3)4. val,var分别定义const引用和普通的引用,const的是logi...
分类:
编程语言 时间:
2015-03-11 14:42:23
阅读次数:
237
Scala 语言和其它语言比如Java相比,算是一个比较复杂的语言,它是一个面向对象和面向函数的统一体,使用起来非常灵活,因此也不容易掌握,前面的58篇文章 仅仅是Scala的一个入门教程,有了这些基础知识,你就可以开始编写Scala应用,学习一种语言最好的方法是通过实践来学习。为方便起见,下面列出...
分类:
其他好文 时间:
2015-03-11 14:31:46
阅读次数:
131
Gatling是一款基于Scala 开发的高性能服务器性能测试工具,它主要用于对服务器进行负载等测试,并分析和测量服务器的各种性能指标。Gatling主要用于测量基于HTTP的服务器,比如Web应用程序,RESTful服务等,除此之...
分类:
其他好文 时间:
2015-03-11 13:11:02
阅读次数:
200
Scala有很强的类型系统。加上一些隐式规则,我们可以在scala里模拟haskell的monad。 先从haskell的monad type class开始: class Monad M where ret :: a -> M a bind :: M a -> (b -> M b) -> M b
...
分类:
其他好文 时间:
2015-03-11 00:40:15
阅读次数:
151
1、下载spark解压到D盘,现在的版本是1.2.12、下载scala安装到d:\ProgramFiles(x86)\scala\ 安装好scala后需要配置环境变量 修改path这个变量,把Scala的bin目录也放进去D:\ProgramFiles(x86)\scala\bin(现在版本的sca...
1. 在类UNIX系统上作为脚本运行在类Unix系统上,你可以设置一个shell前导词来执行脚本。如下例:Script.scala#!/usr/bin/env scala!#println("Hello" + args(0))先输入chmod +x Script.scala,确保对Script.sc...
分类:
其他好文 时间:
2015-03-09 22:15:31
阅读次数:
333
一天一段scala代码(十)
为了更好的驾驭spark,最近在学习scala语言特性,主要看《快学scala》,顺便把一些自己认为有用的代码记下来。
package examples
//特质的基本使用
trait Logger
{
def log(msg:String) //不定义,抽象方法
}
class Conso...
分类:
其他好文 时间:
2015-03-09 19:08:40
阅读次数:
129