展开

关键词

首页关键词akka

akka

相关内容

  • Akka 指南 之「Akka 简介」

    温馨提示:Akka 中文指南的 GitHub 地址为「akka-guide」,欢迎大家Star、Fork,纠错。Akka 简介欢迎来到 Akka,它是一组用于设计跨越处理器和网络的可扩展、弹性系统的开源库。Akka 允许你专注于满足业务需求,而不是编写初级代码来提供可靠的行为、容错性和高性能。Akka 对 Actor 模型的使用提供了一个抽象级别,使得编写正确的并发、并行和分布式系统更加容易。Actor 模型贯穿了整个 Akka 库,为我们提供了一致的理解和使用它们的方法。这些主题包括:为什么现代系统需要新的编程模型Actor 模型如何满足现代分布式系统的需求Akka 库和模块概述一个基于 Hello World 示例的「更复杂的例子」以说明常见的 Akka 模式。----英文原文链接:Introduction to Akka.
    来自:
    浏览:234
  • Akka 3 Akka actor 与

    经常有人问: Akka的Actor和Scala的Actor有什么不同?这里的回答是,从actor 模型角度讲,没什么不同,它们都实现了actor model.Akka actors and Scala actors are two implementations of thatactor X to actor Y will arrive in the order thay were sentThere is no difference between Scala and Akkaactors on this level.具体实现的不同请参考附件我个人学习Akka的Actor的原因是Spark使用Akka作为消息驱动系统
    来自:
    浏览:190
  • 广告
    关闭

    50+款云产品免费体验

    提供包括云服务器,云数据库在内的50+款云计算产品。打造一站式的云产品试用服务,助力开发者和企业零门槛上云。

  • 您找到你想要的搜索结果了吗?
    是的
    没有找到
  • 聊聊Akka

    分布式、并行计算等,那么,Akka在其中的哪些领域可以一展身手呢?总之,对高并发和密集计算的系统,Akka都是适用的!Akka架构体系Akka采用Scala开发,运行于JVM之上,提供了Scala和Java两种API,目前所属Lightbend公司(原名Typesafe)。本节我将为大家介绍Akka的整个体系结构以及相关概念。在Akka基础上,也诞生了Play、Lagom等应用框架,让开发者更容易打造自己的高可用分布式系统。——本文摘自《Akka实战:快速构建高可用分布式应用》Akka实战:快速构建高可用分布式应用
    来自:
    浏览:656
  • Akka(28): Http:About Akka-Http

    Akka-http正是这么一套能高效解决以上问题的编程工具。Akka-http是一套支持Tcp传输标准及Http标准数据的编程工具。 Akka-http应该正是为了这个人群而设计的。  Akka-http对Http消息的各组成部分进行了建模:用class来代表数据结构。由于Akka-http是基于Akka-stream功能之上的,它支持Http数据的流操作,也就是说它可以把一个Stream-Source放在Http消息的数据里,然后Akka-http的Client-Side-Api下面我们就用Akka-http做个Hello World Rest服务示范: import akka.actor._import akka.stream._import akka.stream.scaladsl._import akka.http.scaladsl.model.
    来自:
    浏览:502
  • Akka 介绍

    欢迎使用 Akka,Akka 是一套被用来在在多处理器核心和网络之间被设计可扩展和具有相关弹性的开源工具集。Akka 允许你更加关注商业需求而不是书写低级别的代码来提供可靠性,容错率和高性能。在给一个典型的例子就是警报系统(Early Warning System).Akka 使用 actor 抽象模型能够让 Akka 更加容易的创建正确的并发,并行的分布式系统。actor 模型贯穿整个 Akka 的库,能够让你更加容易的理解和使用它们,并且能够保证更好的完整性。因此 Akka 提供了一个深度的整合和集成,如果你无法通过选择库来解决个别问题的时候,你可以尝试将这些整合在一起。https:www.cwiki.usdisplayAkkaZHIntroduction+to+Akka
    来自:
    浏览:236
  • Akka 介绍

    欢迎使用 Akka,Akka 是一套被用来在在多处理器核心和网络之间被设计可扩展和具有相关弹性的开源工具集。Akka 允许你更加关注商业需求而不是书写低级别的代码来提供可靠性,容错率和高性能。在给一个典型的例子就是警报系统(Early Warning System).Akka 使用 actor 抽象模型能够让 Akka 更加容易的创建正确的并发,并行的分布式系统。actor 模型贯穿整个 Akka 的库,能够让你更加容易的理解和使用它们,并且能够保证更好的完整性。因此 Akka 提供了一个深度的整合和集成,如果你无法通过选择库来解决个别问题的时候,你可以尝试将这些整合在一起。https:www.cwiki.usdisplayAkkaZHIntroduction+to+Akka
    来自:
    浏览:199
  • Akka 指南 之「Akka 和 Java 内存模型」

    Akka 和 Java 内存模型使用 LightBend 平台(包括 Scala 和 Akka)的一个主要好处是简化了并发软件的编写过程。本文讨论了 LightBend 平台,特别是 Akka 如何在并发应用程序中处理共享内存。Java 内存模型在 Java 5 之前,Java 内存模型(JMM)是定义有问题的。Actors 和共享可变状态由于 Akka 在 JVM 上运行,所以仍然需要遵循一些规则。关闭内部 Actor 状态并将其暴露给其他线程import akka.actor.{ Actor, ActorRef }import akka.pattern.askimport akka.util.Timeoutimport----英文原文链接:Akka and the Java Memory Model.
    来自:
    浏览:351
  • Akka(0):聊聊对Akka的初步了解和想法

    众所周知,Akka应该是目前最著名和通用的分布式软件开发工具了,加上是scala语言的开源项目。花了几天时间研究了一下Akka官方网站上的资料,先在这里把了解的情况在下面做个小结:Akka程序是由多个Actor组成的。Actor是Akka系统中的最小运算单元。每个Actor只容许单一线程,这样来说Actor就是一种更细小单位的线程。Akka的编程模式和其内置的线程管理功能使用户能比较自然地实现多线程并发编程。当然,希望通过各种努力最终实现让那些不精通Akka的朋友们能方便的编写Actor模式的分布式应用程序。这可能会涉及到对Akka功能的再组合,搭建新的更高层次的抽象框架、提供API等。当然,这些还是需要对Akka进行详细的研究学习后才能有所定论。刚好,发现在网上的基于scala的Akka讨论示范并不多,那在下面一段时间的讨论里我们就开始从头学习Akka吧。。。
    来自:
    浏览:411
  • Akka 指南 之「邮箱」

    akka-actor_2.12 2.5.21 dependencies { compile group: com.typesafe.akka, name: akka-actor_2.12, version: 2.5.21} libraryDependencies += com.typesafe.akka %% akka-actor % 2.5.21简介Akka 的邮箱中保存着发给 Actor 的信息。下面是一个例子:import akka.dispatch.BoundedMessageQueueSemantics;import akka.dispatch.RequiresMessageQueue;mailbox-capacity = 1000 } akka.actor.mailbox.requirements { akka.dispatch.BoundedMessageQueueSemantics;import akka.actor.ActorSystem;import akka.dispatch.Envelope;import akka.dispatch.MailboxType;import
    来自:
    浏览:585
  • Akka 指南 之「Akka 应用程序示例简介」

    Akka 应用程序示例简介写散文时,最难的部分往往是写前几句话。在开始构建 Akka 系统时,也有类似的“空白画布(blank canvas)”感觉。你可能会想:哪个应该是第一个 Actor?在本文的其余部分中,我们将研究一个简单的 Akka 应用程序的核心逻辑,以向你介绍 Actors,并向您展示如何使用他们来制定解决方案。该示例演示了帮助你启动 Akka 项目的常见模式。先决条件你应该提前跟着「快速入门 Akka Java 指南」中的指令来下载并运行Hello World示例。你将使用它作为种子项目(seed project),并添加本教程中描述的功能。IoT 示例用例在本教程中,我们将使用 Akka 构建物联网(IoT)系统的一部分,该系统报告安装在客户家中的传感器设备的数据。这个例子着重在温度的读数上。
    来自:
    浏览:355
  • Akka 指南 之「配置」

    Akka 构建的库也是一个不错的选择。如果你正在编写基于 Akka 的库,请将其配置保存在 JAR 文件根目录下的reference.conf中。否则,所有默认值将丢失,Akka 将不起作用。示例如下:akka.actor.deployment { # useractorAactorB is a remote deployed actor actorAactorB { remote = akka.tcp参考配置列表每个 Akka 模块都有一个带有默认值的参考配置文件。
    来自:
    浏览:780
  • Akka 指南 之「Actors」

    akka-actor_2.12 2.5.21 dependencies { compile group: com.typesafe.akka, name: akka-actor_2.12, version: 2.5.21} libraryDependencies += com.typesafe.akka %% akka-actor % 2.5.21简介「Actor Model」为编写并发和分布式系统提供了更高级别的抽象下面是一个例子:import akka.actor.AbstractActor;import akka.event.Logging;import akka.event.LoggingAdapter; publicimport akka.actor.ActorRef;import akka.actor.ActorSystem;使用ActorSystem将创建顶级 Actor,由ActorSystem提供的守护者import akka.actor.Actor;import akka.actor.IndirectActorProducer;class DependencyInjector implements IndirectActorProducer
    来自:
    浏览:868
  • 使用Akka实现并发

    我找到了这样一个框架:Akka。Akka基于Erlang actor模型。如果您阅读上述问题的实现方式,则使用拉策略实现,消费者线程将在完成当前任务后执行新任务。所以我们需要等到生产者准备好了。在Akka之后,我感受到了类似的快乐。Akka基于actors,所以actors是什么?Actorsactors给你带来:简单和高级的并发和并行抽象。异步,非阻塞和高性能的事件驱动编程模型。使用Akka非常容易。它可以作为依赖项添加到我们的project.Simple jar文件中。所以,让我们亲自动手,编写一个Hello World程序。示例来自Akka文档。所以Akka保证一次只调用一次OnReceive方法。就这么简单,你不需要考虑同步。Akka是一个非常可扩展的软件,不仅在性能方面,而且在其有用的应用程序大小方面。Akka的核心,akka-actor,非常小,很容易被放入现有的项目中,你需要异步和无锁并发而不会有麻烦。“向外扩展(Remoting)”确实看起来很有意义,对吧?
    来自:
    浏览:656
  • akka-grpc - 基于akka-http和akka-streams的scala gRPC开发工具

    %% akka-actor-typed % AkkaVersion, com.typesafe.akka %% akka-stream % AkkaVersion, com.typesafe.akka%% akka-discovery % AkkaVersion, com.typesafe.akka %% akka-cluster-sharding-typed % AkkaVersion, com.typesafe.akkacom.typesafe.akka %% akka-serialization-jackson % AkkaVersion, com.typesafe.akka %% akka-persistence-cassandraakka.NotUsedimport akka.actor.typed.ActorSystemimport akka.http.scaladsl.util.FastFutureimport akka.grpc.scaladsl_import scala.util.Try import akka.Doneimport akka.NotUsedimport akka.actor.ActorSystemimport akka.grpc.GrpcClientSettingsimport
    来自:
    浏览:226
  • 快速入门 Akka Java 指南

    温馨提示:Akka 中文指南的 GitHub 地址为「akka-guide」,欢迎大家Star、Fork,纠错。Akka 是一个用于在 JVM 上构建高并发、分布式和容错的事件驱动应用程序的运行时工具包。Akka 既可以用于 Java,也可以用于 Scala。本指南通过描述 Java 版本的Hello World示例来介绍 Akka。如果你喜欢将 Akka 与 Scala 结合使用,请切换到「快速入门 Akka Scala 指南」。package com.lightbend.akka.sample; import akka.actor.AbstractActor;import akka.actor.Props;import akka.event.Logging;import com.lightbend.akka.sample.Greeter.WhoToGreet; import akka.actor.ActorRef;import akka.actor.ActorSystem
    来自:
    浏览:2986
  • Akka 使用系列之四: Future

    这篇文章介绍 Akka 的同步机制,以及 Spark 和 Akka 的恩怨情仇。?1 Akka 中的 Future Akka 中的 Actor 发送和接收消息默认都是异步的。到了 Spark 1.6, Spark 可以配置使用 Akka 或者 Netty 了,这意味着 Netty 可以完全替代 Akka 了。requires the upstream Akka actors to also use the identical version of Akka.Spark 主要用了 Akka 的 RPC 和 单线程 event-loop,因此 Spark 没有必要依赖完全的 Akka。最终 Spark 用 netty 实现下简易版本的 Akka。真爱啊。Akka 系列系列文章Akka 使用系列之一: 快速入门Akka 使用系列之二: 测试Akka 使用系列之三: 层次结构和容错机制Akka 使用系列之四: Future
    来自:
    浏览:384
  • Akka简单的性能测试

    方案二采用比较流行的Akka框架来实现。 **Akka的五大特性 **易于构建并行和分布式应用可靠性(Resilient by Design) 系统具备自愈能力,在本地远程都有监护。弹性,无中心(Elastic — Decentralized) 自适应的负责均衡,路由,分区,配置可扩展(Extensible) 可以使用Akka 扩展包进行扩展。因为之前一直研究Scala,Scala的多线程处理的性能是非常高的,那基于Scala语言而开发出来的Akka框架得到了广泛使用。代码如下:import akka.actor.ActorRef;import akka.actor.ActorSystem;import akka.actor.Props;import akka.actor.UntypedActor
    来自:
    浏览:587
  • Akka 指南 之「持久化」

    温馨提示:Akka 中文指南的 GitHub 地址为「akka-guide」,欢迎大家Star、Fork,纠错。持久化依赖为了使用 Akka 持久化(Persistence)功能,你必须在项目中添加如下依赖: com.typesafe.akka akka-persistence_2.12 2.5.20 dependencies+= com.typesafe.akka %% akka-persistence % 2.5.20Akka 持久性扩展附带了一些内置持久性插件,包括基于内存堆的日志、基于本地文件系统的快照存储和基于import akka.actor.ActorRef;import akka.actor.ActorSystem;import akka.actor.Props;import akka.persistence.AbstractPersistentActor为了做到这一点,你应该首先在akka.extensions键下添加akka.persistence.Persistence。
    来自:
    浏览:467
  • Akka(35): Http:Server side streaming

    Akka-http是基于Akka-stream开发的:不但它的工作流程可以用Akka-stream来表达,它还支持stream化的数据传输。Akka-http的stream类型数据内容是以Source类型表示的。_import akka.actor._import akka.stream._import akka.stream.scaladsl._import akka.http.scaladsl.Httpimport akka.http.scaladsl.server.Directives._import akka.http.scaladsl.common.
    来自:
    浏览:359
  • Akka 指南 之「容错」

    akka-actor_2.12 2.5.21 dependencies { compile group: com.typesafe.akka, name: akka-actor_2.12, version: 2.5.21} libraryDependencies += com.typesafe.akka %% akka-actor % 2.5.21简介正如在「Actor System」中所解释的,每个首先,我们需要一个合适的监督者:import akka.japi.pf.DeciderBuilder;import akka.actor.SupervisorStrategy; static classimport akka.testkit.TestProbe;import akka.testkit.ErrorFilter;import akka.testkit.EventFilter;importakka.testkit.TestEvent;import static java.util.concurrent.TimeUnit.SECONDS;import static akka.japi.Util.immutableSeq
    来自:
    浏览:310

扫码关注云+社区

领取腾讯云代金券