- 综合排序
- 最热优先
- 最新优先
- 来自专栏函数式编程语言及工具
akka-typed(0) - typed-actor, typed messages
核心变化是typed-actor的正式启用，当然persistence,cluster等模块也有较大变化。 特别的是类型参数Behavior[Greeting]，代表这个actor只处理Greeting类型的消息，因而是个typed-actor。 akka-typed已经不支持sender()了，在消息里自带，如Greeting.replyTo。 akka-typed已经不再支持become方法了。 akka-typed需要用户提供这个顶层actor。这个是在ActorSystem的第一个参数指定的。
73630发布于 2020-05-29 - 来自专栏TomatoCool
Typed.js
Github https://github.com/mattboldt/typed.js 快速使用 <! --从CDN导入--> script src="https://unpkg.com/typed.js@2.0.16/dist/typed.umd.js"></script> <script> var typed = new Typed('#element', { strings: ['第一句话', '第二句话'], typeSpeed: 50,
63620编辑于 2023-07-30 - 来自专栏函数式编程语言及工具
akka-typed(2) - typed-actor交流方式和交流协议
对于akka-typed来说，typed-actor只能接收指定类型的消息，所以actor之间的消息交流需要按照消息类型来进行，即需要协议来规范消息交流机制。 典型的单向消息发送fire-and-forget如下： import akka.actor.typed._ import scaladsl._ object Printer { case class 不过，在akka-typed中这种模式最基本的要求就是发送的消息类型必须符合接收方actor的类型。 好了，我们先对这个模式做个示范。所有actor的定义可以先从它的消息类型开始。 如下： import akka.actor.typed._ import scaladsl._ object FrontEnd { sealed trait FrontMessages case (ex) => println(s"error: ${ex.getMessage}") } system.terminate() } 这个ask是在akka.actor.typed.scaladsl.AskPattern
95810发布于 2020-06-02 - 来自专栏函数式编程语言及工具
akka-typed(4) - EventSourcedBehavior in action
前面提到过，akka-typed中较重要的改变是加入了EventSourcedBehavior。 withMaxRestarts(3) .withResetBackoffAfter(10.seconds) ) 下面是本次示范的源码： build.sbt name := "learn-akka-typed AkkaPersistenceCassandraVersion = "1.0.0" libraryDependencies ++= Seq( "com.typesafe.akka" %% "akka-cluster-sharding-typed " % AkkaVersion, "com.typesafe.akka" %% "akka-persistence-typed" % AkkaVersion, "com.typesafe.akka ._ import akka.persistence.typed._ import akka.actor.typed.scaladsl.Behaviors import akka.persistence.typed.scaladsl
66720发布于 2020-06-09 - 来自专栏函数式编程语言及工具
akka-typed(3) - PersistentActor has EventSourcedBehavior
akka-typed中已经没有PersistentActor了。取而代之的是带有EventSourcedBehavior的actor，也就是一种专门支持EventSource模式的actor。 import BehaviorInterceptor._ override def aroundReceive( ctx: typed.TypedActorContext applySideEffects(sideEffects, state)) case _: Unhandled.type => import akka.actor.typed.scaladsl.adapter 为上面的例子设了个运行环境，主要是测试persistence-cassandra-plugin的正确设置，如下： build.sbt name := "learn-akka-typed" version " % AkkaVersion, "com.typesafe.akka" %% "akka-persistence-typed" % AkkaVersion, "com.typesafe.akka
82610发布于 2020-06-03 - 来自专栏函数式编程语言及工具
akka-typed(7) - cluster：sharding, 集群分片
在使用akka-typed的过程中发现有很多地方都简化了不少，变得更方便了，包括：Supervision，只要用Behaviors.supervise()把Behavior包住，很容易就可以实现这个 ._ import akka.actor.typed.scaladsl._ import akka.cluster.sharding.typed.scaladsl.EntityContext import akka.cluster.sharding.typed.scaladsl.Entity import akka.persistence.typed.PersistenceId //#sharding-extension import akka.cluster.sharding.typed.ShardingEnvelope import akka.cluster.sharding.typed.scaladsl.ClusterSharding import akka.cluster.sharding.typed.scaladsl.EntityTypeKey import akka.cluster.sharding.typed.scaladsl.EntityRef
1.2K20发布于 2020-06-16 - 来自专栏函数式编程语言及工具
akka-typed(10) - event-sourcing, CQRS实战
在前面的的讨论里已经介绍了CQRS读写分离模式的一些原理和在akka-typed应用中的实现方式。 通过一段时间akka-typed的具体使用对一些经典akka应用的迁移升级，感觉最深的是EvenSourcedBehavior和akka-cluster-sharding了。 EventSourcedBehaviro是akka-typed为event-sourcing事件源模式提供的开发支持。具体的原理和使用方法在前面的博客里都介绍过了，在这篇就不再重复。
60230发布于 2020-08-17 - 来自专栏有困难要上，没有困难创造困难也要上！
使用 typed-rest-client 进行 REST API 调用
typed-rest-client 是一个用于 Node.js 的库，它提供了一种类型安全的方式来与 RESTful API 进行交互。 其主要功能包括： 安装 typed-rest-client 要使用 typed-rest-client，首先需要安装它，可以通过 npm 来安装： $ npm install typed-rest-client 使用 typed-rest-client 这里假定有个 express 的 server 提供了两个 REST API，一个是获取用户列表，一个是获取用户信息。 running at http://localhost:${port}`); }); 下面是测试程序 test.ts import {RestClient, IRestResponse} from 'typed-rest-client
1.2K10编辑于 2024-09-25 - 来自专栏函数式编程语言及工具
akka-typed(8) - CQRS读写分离模式
akka-typed应该自然支持CQRS模式，最起码本身提供了对写方编程的支持，这点从EventSourcedBehavior 可以知道。 akka-typed提供了新的EventSourcedBehavior-Actor，极大方便了对persistentActor的应用开发，但同时也给编程者造成了一些限制。
58620发布于 2020-06-29 - 来自专栏函数式编程语言及工具
kka-typed(5) - cluster：集群节点状态监视
由于akka-typed里采用了新的消息交流协议，而系统消息的发布和订阅也算是消息交换，也受交流协议约束。 所以想通过重写以前示范的ClusterMemberStatus来了解一下akka-typed环境下节点状态变化消息监听的一些机制。 我们需要一个actor来订阅系统发布的节点状态变化消息。 " % AkkaVersion, "com.typesafe.akka" %% "akka-persistence-typed" % AkkaVersion, "com.typesafe.akka ._ import akka.actor.typed.scaladsl.Behaviors import akka.cluster.ClusterEvent._ import akka.cluster.typed.Subscribe import akka.cluster.typed.Cluster import akka.actor.typed.ActorSystem object MonitorActor { sealed
77130发布于 2020-06-09 - 来自专栏函数式编程语言及工具
akka-typed(1) - actor生命周期管理
akka-typed的actor从创建、启用、状态转换、停用、监视等生命周期管理方式和akka-classic还是有一定的不同之处。这篇我们就介绍一下akka-typed的actor生命周期管理。 akka-typed的守护guardian-actor，即根部root-actor是通过在定义ActorSystem时指定并产生的。 下面这个官方文档上的例子是很好的示范： import akka.actor.typed.Behavior import akka.actor.typed.SpawnProtocol import akka.actor.typed.scaladsl.Behaviors import akka.actor.typed.scaladsl.LoggerOps object HelloWorldMain { def apply(): Behavior[SpawnProtocol.Command import akka.actor.typed.scaladsl.AskPattern._ implicit val ec: ExecutionContext = system.executionContext
1K20发布于 2020-05-29 - 来自专栏函数式编程语言及工具
akka-typed(6) - cluster：group router, cluster-load-balancing
先谈谈akka-typed的router actor。route 分pool router, group router两类。 ._ import akka.persistence.typed._ import akka.persistence.typed.scaladsl._ import scala.concurrent.duration ._ import akka.actor.typed.receptionist._ import akka.actor.typed.scaladsl.Behaviors import akka.actor.typed.scaladsl ._ import akka.cluster.typed.Cluster import akka.cluster.typed.ClusterSingleton import akka.cluster.typed.ClusterSingletonSettings " % AkkaVersion, "com.typesafe.akka" %% "akka-persistence-typed" % AkkaVersion, "com.typesafe.akka
94920发布于 2020-06-15 - 来自专栏前端大合集
前端实现打字机的效果 -- typed库的使用
展示: 1.typed.js的介绍 typed.js是一个类型化库，效果是用打字机的方式显示一段话，可以自定义任何字符串、指定显示速度、指定是否循环等 可以在此网站查看所有演示的Demo: mattboldt.github.io /typed.js/ 其实可以使用原生JS来实现这个效果，但是还是很麻烦的 typed.js是一个轻量级的JavaScript插件, 用于实现页面文字的打字动画效果 这是一款轻量级，使用简单，功能强大的插件 2.typed.js的使用 2.1 安装 使用包管理器进行安装 # With NPM npm install typed.js # With Yarn yarn add typed.js 使用 = new Typed('#typed', options); 输入暂停 var typed = new Typed(".element", { // 键入“first”后等待1000毫秒 // 只退格与前一个字符串不匹配的内容 var typed = new Typed(".element", { strings: ["This is a JavaScript library",
1.3K10编辑于 2024-07-29 - 来自专栏Alone88
Typed.js 实现打字机特效,加入今日诗词~
Typed.js Typed.js is a library that types. Enter in any string, and watch it type at the speed you've set, backspace what it's typed, and begin 简单的就是打字机特效 官网地址：https://mattboldt.com/demos/typed-js/ 使用 1.导入Typed.js <script src="<em>typed</em>.js"></script > //常规本地导入 <script src="https://cdn.bootcss.com/<em>typed</em>.js/2.0.9/<em>typed</em>.js"></script> //cdn导入 导入需要放在网页的head 里面 使用 //html <script> var typed = new Typed('.element', { strings: ["这里是要打的字
2.2K20发布于 2019-10-22 - 来自专栏函数式编程语言及工具
akka-typed(9) - 业务分片、整合，谈谈lagom, 需要吗？
所以，最后还是决定直接用akka-typed来实现这个数据中台。用了一个多月时间做研发，到现在看来效果不错，能够符合项目要求。下面是一些用akka-typed实现业务集成的过程介绍。
1.1K20发布于 2020-08-11 - 来自专栏函数式编程语言及工具
FunDA（12）－ 示范：强类型数据源 - strong typed data sources
String)] val aqmQuery = aqmraw.map {r => (r.year,r.state,r.county,r.value)} // user designed strong typed class TypedRow(year: String, state: String, county: String, value: String) extends FDAROW // strong typed class TypedRow(year: String, state: String, county: String, value: String) extends FDAROW // strong typed row._1,row._2,row._3,row._4) // loader to read from database and convert result collection to strong typed into fs2 stream val aqmStream = fda_staticSource(dataSeq)()() // now access fields in the strong typed
1.2K100发布于 2018-01-05 - 来自专栏DotNet NB && CloudNative
什么是.NET的强类型字符串(Strongly typed string)？
在.NET中，强类型字符串（Strongly typed string）并不是一个官方的概念，是指使用特定的结构来表示某种类型字符串数据的编码实践。 强类型字符串（Strongly typed string）# 强类型字符串要声明成带有字符串构造函数的不可变值类型（struct），即要在该类型上用 readonly 修饰符，并为其实现 IEquatable
27800编辑于 2025-01-07 - 来自专栏Rust语言学习交流
【Rust日报】2021-05-24 typed-sql: Zero-cost ORM
可以非常容易的集成到各种 debug 的场景中. github 地址: https://github.com/daniel5151/gdbstub typed-sql: Zero-cost ORM typed-sql 目前是 beta 版本. github 地址: https://github.com/matthunz/typed-sql -- From 日报小组 BobQin，FBI小白 社区学习交流平台订阅： Rustcc
49630发布于 2021-06-16 - 来自专栏Rust语言学习交流
【Rust日报】2020-01-25 Rust 2020 路线图，typed-builder，format!
Rust 2020 路线图 typed-builder v0.5.0 typed-builder，创建经过编译时验证的构建器，发布了v0.5.0版本。 示例： #[macro_use] extern crate typed_builder; #[derive(TypedBuilder)] struct Foo { // Mandatory Field
37710发布于 2020-02-20 - 来自专栏Michael阿明学习之路
LeetCode 925. 长按键入（双指针）
示例 2： 输入：name = "saeed", typed = "ssaaedd" 输出：false 解释：'e' 一定需要被键入两次，但在 typed 的输出中不是这样。 示例 3： 输入：name = "leelee", typed = "lleeelee" 输出：true 示例 4： 输入：name = "laiden", typed = "laiden" 输出：true 提示： name.length <= 1000 typed.length <= 1000 name 和 typed 的字符都是小写字母。 , j = 0; if(name.size() > typed.size()) return false; while(j < typed.size() if(j > 0 && typed[j-1] == typed[j]) j++; else return false
62540发布于 2020-07-13
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号